Мой конвейер имеет следующий простой ввод JSON {"mac": "KC:FC:48:AE:F6:94",...

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

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

В основном я читаю данные из pubsub и записываю данные в хранилище Google.Фрагмент кода, как...

Я пытаюсь прочитать и записать его в BigQuery с облачным потоком данных (Beam Python SDK).На чтение...

Я пытаюсь прочитать таблицу SQL облака в Java-луче, используя JdbcIO.Read.Я хочу преобразовать...

У меня есть требование, чтобы иметь возможность проследить происхождение до отдельного файла...

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

Когда я выполняю задание шаблона потока данных с использованием API-интерфейса клиента потока...

Я написал задание Python Dataflow для обработки некоторых данных: pipeline | "read"...

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

после добавления additionalUserLabels в среду выполнения задания потока данных, созданного dataflow

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

Мы создаем конвейер потока данных, мы будем читать данные из postgres и записывать их в файл...

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

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

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

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

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

Я использую панель мониторинга Stackdriver для мониторинга «element_count» «pcollection» в...

Мы используем довольно простой поток, когда сообщения извлекаются из PubSub, их содержимое JSON...

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

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

Когда я пытаюсь развернуть задание потока данных с учетной записью службы, происходит сбой со...

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