У нас есть система издательских и абонентских систем на базе GCP PubSub.Абонент обрабатывает одно...
Я пытаюсь перенести IngestionTime (_PARTITIONTIME) в многораздельные таблицы TIMESTAMP в BQ.При...
Я следую этому руководству: РУКОВОДСТВО , и я продолжаю получать "PartialFailureError: Во время...
Я потратил почти день на под-документацию Google Pub, чтобы создать небольшое приложение.Я думаю о...
У меня есть весенняя служба подписки на сообщения из темы в облачном пабе google (тянет).В целом...
Я пытаюсь изучать продукты Google. В настоящее время я хочу выполнить очень простую задачу.Сценарий...
Я пытаюсь записать данные с моего Node-сервера в раздел pubsub, который запускает облачную функцию...
Я пишу весеннее загрузочное приложение для подписки на Google Cloud Pub / Sub topic. Я использую...
Я пытаюсь встроить webhook в свое приложение.Точнее говоря, я хочу, чтобы пользователь мог...
В Google Console я создаю тему и публикую ее, и она работает нормально.Теперь я хочу сделать это из...
У меня есть подписчик в пабе, который вызывает асинхронную функцию для обновления некоторых...
Я пытаюсь выполнить простой подсчет количества прогонов в Apache Beam (Dataflowrunner), но мне...
Я создал watch () на 2 разных ярлыках, таких как INBOX и SENT для одного и того же почтового ящика....
Я установил уведомление Pubsub для GCS.(https://cloud.google.com/storage/docs/pubsub-notifications)...
Я пытаюсь создать учетную запись службы, которая имеет разрешение только для определенной темы...
Я читаю сообщение JSON, опубликованное в теме PubSub, и загружаю таблицы CloudSQL, используя метод...
Я подключаюсь к Google PubSub (Google.Cloud.PubSub.V1 1.0.0) в проекте библиотеки классов .Net...
Я установил pipenv, а затем пытался установить модуль grpc-googlep-pubsub-v1 через pipenv. Но я...
Привет. Я пытаюсь получить сообщения из pubsub с помощью луча apache. PubsubIO
Разработка из предыдущей темы обнаружила, что предположения при задании вопроса были не по теме...
Я новичок в GCP и в настоящее время имею микросервисную архитектуру, использующую GKE и gRPC....
Я создал экземпляр Cloud Compute Engine в Debian и успешно создал подписку PUSH на тему с from...
Мне нужно получать опубликованные сообщения от системы Google Pub / Sub с помощью подписчика на...
Я пытаюсь спроектировать конвейер, который будет считывать данные из PubSubIO и объединять их в...
Я пытаюсь подготовить setup.py, который установит все необходимые зависимости, включая...