Возобновление того, что я ищу для работы с Apache Beam в Google Dataflow, выглядит примерно так:...

У меня есть требование изменить ~ / .ssh / authorized_keys для добавления пользовательских открытых...

Обработка не распределяется DataFlow, но обрабатывается одним узлом. Я создал следующую программу и...

При отправке задания потока данных в GCP я получаю эту ошибку: Traceback (most recent call last):...

Я запускаю этот пример кода из Google, тестирующего входные данные Spanner в Dataflow.Когда я...

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

Я пытаюсь прочитать файл JSON (многострочный) в конвейере, но beam.io.ReadFromText(somefile.json...

Я использую поток данных Python (луч 2.5), и мне было интересно, почему метрики шага не...

После того, как конвейер Apache Beam был спроектирован и протестирован в облачном потоке данных...

Я очень новичок с GCP и потоком данных.Однако я хотел бы начать тестировать и развертывать...

Я провел несколько тестов с использованием Apache-Beam, используя как автоматических работников,...

Есть ли пакет, который в настоящее время установлен в Python SDK , который позволил бы мне...

Я планирую использовать поток данных с постоянным MapState С https://beam.apache

Привет. Я пытаюсь получить сообщения из pubsub с помощью луча apache. PubsubIO

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

У меня проблемы с запуском задания Dataflow из Datalab. То, что я мог сделать, - это минимально...

Я пытаюсь написать конвейер потока данных, который читает из pubsub и записывает в GCS. Но когда я...

Я копирую данные Spanner в BigQuery через задание Dataflow.Задание планируется запускать каждые 15...

У меня есть задание потока данных (пакет), которое отлично работает, когда не используется шаблон,...

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

Я запускаю следующий успешный Тестовый конвейер Apache Beam в Google Dataflow.Он использует...

В конвейере потока данных я читаю из авторизованного представления BigQuery: beam.io.Read (beam.io

Я совершенно новичок в Apache Beam и Java. Я работаю над PHP около 5 лет, но я не работал в Java...

Видя что-то странное, когда я обрабатываю большой файл (5 миллионов + строк).В коде мое количество...

Я пытаюсь прочитать значения из паба Google и хранилища Google и поместить эти значения в большой...