Мы часто используем Beam Java SDK (и Google Cloud Dataflow для запуска пакетных заданий), и мы...
При работе графика Apache Beam Python я вижу периодически возникающие ошибки 503 в облачном потоке...
Учитывая набор данных, как показано ниже {"slot":"reward","result":1...
Моя структура папок выглядит следующим образом: Project/ --Pipeline.py --setup.py --dist/...
Я хочу отделить событие от группы событий, заданных данными {"type": "A",...
Я использую облачный поток данных Google для запуска задания Apache Beam с большим количеством...
Мой код прилагается. Есть два CSV, которые мне нужно прочитать. Я читаю в первом CSV, а затем хочу...
ОК, так что я бьюсь головой об Apache Beam уже несколько недель. Я учусь, но продолжаю застрять на...
Итак, я только начинаю работать с Apache Beam. Я планирую запускать задания DataFlow в GCP, я...
Я пытаюсь использовать запись в pubsbub после чтения из csv и записи нескольких преобразований,...
Я попытался осушить трубопровод программно. Первая часть кода запускает конвейер, который...
Контекст: Потоковый конвейер с использованием потока данных 2.6.0, использующий окна и этапы...
Пытаюсь сделать что-то концептуально простое, но биться головой о стену. Я пытаюсь создать...
Я хочу знать о GAE, когда задание потока данных будет завершено. пытаюсь сделать следующий оба...
Согласно документации BigQuery, вы можете обеспечить согласованность данных, предоставив insertId...
Я пытаюсь сделать диктат из данных CSV в Python, я не хочу использовать традиционное разбиение ('...
Я хочу использовать одну и ту же функцию для анализа событий в двух разных технологиях: Goolge...
Я использовал Python SDK Apache Beam для создания программы командной строки для запуска заданий...
Не могу найти документацию по этому поводу.У меня есть конвейер apache-beam, который принимает...
Я определил несколько разных заданий облачного потока данных для Python в среде Google AppEngine...
В настоящее время я работаю над заданием потока данных ETL (используя Apache Beam Python SDK),...
Гуру - я новичок в Apache Beam и пытаюсь реализовать то, что кажется довольно простым вариантом...
Привет, я пытаюсь создать источник данных для Apache Beam в Python.Я знаю, что с Java вы можете...
Apache-beam расстраивает управление правильными библиотеками Google-облака, которые я могу...
При чтении данных из таблицы BQ NUMERIC тип данных Все еще не поддерживается в Apache Beam, но с...