Мне нужно читать данные таблицы из Bigquery, используя поток данных, но вместо того, чтобы...

Я пытаюсь прочитать большой набор данных в потоке данных. Не удается найти указанный мной набор...

Я пытаюсь создать ParDo с сохранением состояния в Apache Beam, который хранит данные о значениях и...

Моя подписка pubsub pull отправляет сообщение и значение None для каждого сообщения. Мне нужно...

Я запустил задание Dataflow, содержащее конвейер потоковой передачи, запускаемый сообщениями PubSub...

В настоящее время хочу распространять обнаружение текста в потоке данных Google на огромный набор...

Я написал небольшой конвейер Beam на Python для подсчета сообщений, отправленных в чате.Сообщения...

Я разрабатываю задание GCP Cloud Dataflow, в котором используется брокер Kafka и реестр схем.Наш...

Я написал код для извлечения данных из Google Datastore в моей программе Google Cloud Dataflow.Я...

В Google Cloud у меня есть основной реестр IoT с несколькими устройствами (подключенными через...

Луч Apache, похоже, отказывается распознавать Iterable Котлина.Вот пример кода: @ProcessElement fun...

Я пишу простой конвейер Python через Apache-Beam для сбора голосов пользователей. На входе у меня...

Как поддерживать не-ascii символы в конвейерах DataFlow, передаваемых в Google Cloud BigQuery в...

у меня ниже json {attribute_values=[{key=PO, values=[234234, 21]}, {key=POReceipt, values=[ABC]}]}...

В настоящее время я новичок в использовании Apache Beam в Python с бегуном Dataflow.Я заинтересован...

У меня есть корзина GCS, из которой я пытаюсь прочитать около 200k файлов и затем записать их в...

Я спроектировал луч / конвейер потока данных, используя библиотеку луча Python.Конвейер примерно...

Можно ли прочитать несколько файлов и записать их в соответствующие несколько файлов (до 100)? Я...

Я создал конвейер потока данных Beam, который анализирует один JSON из темы PubSub: {...

Мое задание Google Dataflow выполняется локально с локальным исполнителем, но не может создать...

Я использовал шаблон Pub / Sub to BigQuery для потоковой передачи данных JSON, отправляемых в тему...

Я не могу создать собственный шаблон потока данных Google Cloud, используя пример wordcount, следуя...

У меня есть конвейер потоков данных Google Cloud, который обрабатывает большое количество вставок в...

Мне нужно сохранить эскизы HLL в BigQuery из ApacheBeam. Я нашел расширение библиотека для...

Я пытаюсь составить простое резюме клиента на основе данных транзакций.Например, учитывая целевой...