Вопросы по теме 'google-cloud-pubsub'
можно ли использовать Kafka с Google Cloud Dataflow
у меня два вопроса
1) Я хочу использовать Kafka с программой Google Cloud Dataflow Pipeline. в моей программе конвейера я хочу читать данные из кафки, возможно ли это?
2) Я создал экземпляр с включенным BigQuery, теперь я хочу включить Pubsub,...
2401 просмотров
schedule
14.05.2022
Есть ли какая-либо форма для уменьшения количества сообщений, прочитанных в секунду из PubSubIO?
У меня есть конвейер потоковой передачи в облаке, который считывается из PubSubIO и для которого «PipelineOptions» установлено значение «WorkerMachineType = n1-standard-1». Эта машина имеет 3,75 ГБ памяти.
Моя проблема в том, что если в подписке...
125 просмотров
schedule
17.01.2023
Ошибка push-уведомлений Gmail (для каждого разработчика разрешен только один клиент push-уведомлений пользователя)
Я попытался выполнить проверку gmail api на двух моих учетных записях gmail, и все работает нормально.
Но когда другой пользователь попытался это сделать, он показывает эту ошибку:
Ошибка HTTP 400: «Для каждого разработчика разрешен только...
1479 просмотров
schedule
20.06.2022
Как я могу убедиться, что все сообщения, отправленные в PubSub, были отправлены правильно?
Я запускаю конвейер потоковой передачи данных, который читает из PubSub и записывает в BigQuery. Когда я пытаюсь убедиться, что все сообщения были записаны в BigQuery, я понимаю, что некоторые сообщения отсутствуют.
Как я могу убедиться, что все...
219 просмотров
schedule
29.05.2023
Push-уведомления Gmail API выдают ошибку 403
Я пытаюсь получать push-уведомления обо всех новых сообщениях, которые я получаю по электронной почте. Я настроил клиент pubsub, как указано в документе pubsub. Ниже приведен код:
import httplib2
from apiclient import discovery
from...
1178 просмотров
schedule
05.01.2023
Как обеспечить идемпотентность с помощью DataFlow и Cloud Pub Sub?
Мне интересно узнать, как лучше всего обеспечить идемпотентность при использовании Cloud DataFlow и PubSub?
В настоящее время у нас есть система, которая обрабатывает и хранит записи в базе данных MySQL. Мне любопытно использовать DataFlow для...
1256 просмотров
schedule
12.12.2022
Невозможно создать конвейер с PubsubIO.Read, не удалось настроить ресурс
Мой тестовый конвейер действительно прост. Он пытается читать из темы, созданной через консоль.
public static void main(String[] args) throws IOException {
Options options = PipelineOptionsFactory.fromArgs(args)....
474 просмотров
schedule
17.04.2022
Google Pub / Sub: push to compute engine
Можно ли в Google Pub / Sub использовать сервер HTTPS, работающий на экземпляре виртуальной машины Compute Engine, в качестве конечной точки для принудительной подписки? Я немного озадачен, так как в документации говорится, что сервер должен быть...
916 просмотров
schedule
10.04.2023
Может кто-нибудь объяснить разницу между GCM и Google Pub/Sub?
Гугл ответил на вопрос здесь
https://cloud.google.com/pubsub/faq
Но мне все еще неясно, для каких сценариев каждый из них будет использоваться?
Есть ли что-то, что может сделать pub sub, чего не может GCM?
3234 просмотров
schedule
24.06.2023
Google PubSub - получение последнего сообщения
Я начинаю работать с движком приложений Google и услугами, которые он предлагает. Одна из услуг, которая меня особенно интересует, - это облачный pubsub.
Мой план состоит в том, чтобы иметь сервер nodejs socket.io, который подписывается на...
432 просмотров
schedule
17.04.2022
Google Cloud DataFlow PubSubIO не читает из полной темы
Я пытаюсь запустить конвейер в Google Cloud DataFlow в "потоковом" режиме. Конвейер должен читать из темы PubSub, однако на самом деле он не читает из темы, пока я не удалю ее, не создаю заново и не опубликую все сообщения в теме ПОСЛЕ запуска...
1123 просмотров
schedule
15.05.2022
Стратегия тестирования Google Pub / Sub для локального сервера Java-разработчика GAE
мы с моей командой очень хотим включить Google Pub / Sub в наше приложение, поскольку это решит некоторые проблемы со связью. Проблема, с которой мы сталкиваемся, заключается в том, как выполнять тесты локальной интеграции в сочетании с сервером...
672 просмотров
schedule
30.12.2022
Доступ к метрике subscription / num_oustanding_messages в Google PubSub из Python
Можно ли получить доступ к метрике subscription/num_outstanding_messages из списка https://cloud.google.com/monitoring/api/metrics#gcp-pubsub из google-cloud-python? Я использовал аналогичный код для успешного доступа к метрике...
1061 просмотров
schedule
13.07.2023
Google Cloud Pub / Sub: невозможно получить запрос PUSH от URL-адреса конечной точки GAE
Я развернул свое приложение в Google App Engine с настройкой
runtime: nodejs
env: flex
Мой домен приложения
https://myapp.appspot.com
но он автоматически перенаправляется на
https://myapp.appspot-preview.com
Я...
433 просмотров
schedule
28.08.2022
API Gmail: просмотр только ярлыка папки "Входящие"
У меня есть код ниже, чтобы посмотреть почтовый ящик. Как видно, в lableIds у меня есть только одна метка INBOX, потому что я хочу слушать только новые сообщения. Однако, когда я запускаю это, он получает уведомления каждые 30 секунд или около того...
994 просмотров
schedule
03.09.2022
Kafka PubSub Connector: Jetty ALPN/NPN настроен неправильно
Я использую kafka_2.11-0.10.2.1 и коннектор pubsub, предоставленный Google здесь . Все, что мне нужно сделать, это передать данные из темы Kafka в тему PubSub с помощью автономного коннектора. Я выполнил все шаги, как и должен был:...
512 просмотров
schedule
03.04.2022
Как загрузить тестовый эмулятор pubsub с Python для автоматического тестирования
Я работаю над API фляги, одна из конечных точек которого должна получить сообщение и опубликовать его в PubSub. В настоящее время, чтобы протестировать эту конечную точку, мне придется вручную запускать эмулятор PubSub из командной строки и...
604 просмотров
schedule
09.05.2022
Google Cloud Platform Java SDK и OSGI
Я пытаюсь заставить свое приложение на основе OSGI взаимодействовать с очередью публикации/подписки через Java SDK платформы Google Cloud. Однако я не могу заставить его позвонить. Это ошибка с трассировкой стека в нижней части сообщения. Я...
606 просмотров
schedule
06.02.2023
Firebase: могу ли я не подтвердить сообщение PubSub внутри облачной функции Firebase?
У меня есть облачная функция Firebase, которая запускается сообщением PubSub. Функция должна либо принять сообщение, либо подождать, чтобы использовать его позже.
Есть ли способ вернуться из этой функции без подтверждения сообщения , чтобы оно...
395 просмотров
schedule
13.11.2022
Обеспечение безопасности конечных точек push-уведомлений PubSub в движке узловых приложений?
Я использую pubsub для отправки сообщений в приложение App Engine, написанное на узле в гибкой среде. Есть ли способ ограничить мои конечные точки трафиком только из pubsub?
В стандартной среде App Engine имеет обработчики, которые могут...
514 просмотров
schedule
27.09.2022
