Мы создали конвейер Apache Beam, который успешно работает при работе по прямому конвейеру.См....

У меня есть конвейер apache-beam == 2.3.0, написанный с использованием Python SDK, который работает...

Я работаю с набором данных Chicago Traffic Tracker , где новые данные публикуются каждые 15 минут

Я запускаю конвейер луча apache в облаке Google (через поток данных Google).В моем коде python я...

Заранее спасибо! [+] Проблема: У меня много файлов в облаке Google, для каждого файла мне нужно:...

Возможно ли выполнить запись во 2-ю таблицу BigQuery после того, как запись в 1-ю завершена в...

Мой поток данных постоянно завершается с ошибкой в ​​моей функции объединения, и в журналах не...

Я получаю некоторые странные ошибки, которые трудно отладить.Я использую простой UDF JavaScript...

Один из первых шагов в моем конвейере Dataflow включает чтение данных из таблицы, хранящейся в...

У меня сжатый файл в облачном хранилище Google. Этот файл содержит большой CSV-файл и небольшой...

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

У меня есть конвейер чтения данных из событий PubSub. При получении сообщения я делаю шаг...

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

Я уже давно использую Apache Beam Python SDK, используя облачный сервис передачи данных Google. Я...

Я заранее прошу прощения, задавая этот вопрос. Это должно быть что-то очень глупое, что я пропускаю

Таким образом, при использовании DataflowRunner мы размещаем файлы в GCS с помощью метода...

Я хочу прочитать входящие данные по теме Google PubSub, обработать данные и преобразовать их в...

Java-пакет Apache Beam имеет класс DynamicDestination , который позволяет выполнять запись в...

Я пытаюсь запустить задание потока данных облака Google, созданное с использованием шаблона "pubsub...

Я пытаюсь выполнить запросы для выбора данных из одной таблицы в BigQuery и записи данных в другую...

У меня есть задание потока данных, которое кажется сбойным из-за слишком большого тела http_request...

У меня возникли проблемы с определенным потоком данных Apache Beam Python SDK. Если я перебираю...

Имеет ли Python SDK для Apache Beam поддержку IntraBundleParallelization , как Java SDK?Я понимаю,...