У меня есть облачная функция, которая выполняет синхронное извлечение подписки на pubsub. запрос...
У меня есть очень простое задание Python Dataflow, которое считывает некоторые данные из Pub / Sub,...
Во время from google.cloud import pubsub_v1 библиотека Google добавляет StreamHandler к корневому...
Я оцениваю использование использования pubsub для длительных задач, таких как транскодирование...
Я использовал pubsub для небольшой асинхронной работы, и мне было интересно, почему кто-то может...
Мы используем Firebase для нашего приложения, которое должно обработать некоторые данные и затем...
От клиента у меня есть следующий код: publisher = pubsub_v1.PublisherClient() topic_path =...
У меня есть полнофункциональная конечная точка, которая будет получать запрос POST от подписки...
У меня есть скрипт, который вытаскивает из города, если Чикаго захватывает файл json и затем...
Мы создаем микросервисную систему, новые данные которой могут поступать из трех (или более) разных...
Я использую Google Pub Sub, чтобы публиковать вывод JSON веб-API для определенной темы. Затем я...
Мы храним некоторые из наших дампов SQL из AWS RDS в облачное хранилище GCP в качестве долгосрочной...
Я видел в каком-то примере код, который, кажется, читает непосредственно из темы? PubsubIO
Насколько я знаю, мы можем определять схемы AVRO на Kafka, и тема, определенная с помощью этой...
Мы собираемся выбрать Google Cloud Pub / Sub в качестве нашего MQ.Некоторые сообщения должны...
Я не могу заставить асинхронный клиент Java pubsub Google корректно завершить работу. После вызова...
У меня проблема с подтверждением сообщения GCP Pub / Sub Subscriber. Я написал три класса:...
Все мы знаем, что подписчики Pub / Sub, находящиеся на одной подписке, будут делиться сообщениями...
В настоящее время я использую Python 2.7.11 с google-cloud-pubsub 0.33.1. google-cloud-pubsub...
Я разрабатываю систему тикетов, в которой клиент может задавать свои вопросы или вопросы об услугах
Я смотрел / подписался на тему, используя следующий код. request = { 'labelIds':...
Я пытаюсь разработать алгоритм для поддержки списка новых сообщений INBOX, используя комбинацию...
Я нашел в документах для автоматического масштабирования на основе количества недоставленных...
Мой конвейер лучей apache (использующий Python SDK + DirecrRunner для целей тестирования…) читает...