Я создаю конвейер потоковой обработки Apache Beam для запуска в GCP Dataflow. У меня есть ряд...

Большая мощь Beam проистекает из его расширенных возможностей работы с окнами, но это также немного...

Я создал конвейер для Облачного потока данных Google, используя Apache Beam, но у меня не может...

Я получаю поток сложного и вложенного объекта JSON в качестве входных данных для моего конвейера....

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

У меня есть 3 шага потока данных в конвейере потока данных. Читает из pubsub, сохраняет в таблице и...

Я пытаюсь денормализовать и объединить три таблицы с именами order, order_item и user в Bigquery. У...

Я читаю записи из темы PubSub в конвейере потока данных. Записи PubSub делятся на фиксированные...

Я хотел бы получить 10 лучших результатов, как это: Paul - 38 Michel - 27 Hugo - 27 Bob - 24 Kevin...

Я новичок в потоке данных.У меня есть предопределенная схема, содержащая неповторяющееся поле...

Я новичок в Dataflow / Beam. Я пытаюсь записать некоторые данные в BigQuery. Я хочу, чтобы имя...

При попытке инициализировать Python BigQuery Client () в облачном потоке данных apache beam Google...

Я пытаюсь написать конвейер потока данных для переноса данных из Google Datastore в BigQuery с...

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

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

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

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

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

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

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

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

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

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

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

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