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

Я настроил шаблон в потоке данных Google, и он работал нормально.После некоторой модификации...

У меня есть модель Apache Beam для обработки нескольких временных рядов в реальном времени....

В основном я запускаю конвейер в облачном потоке данных Google, используя apache beam python SDK

Я написал поток (pub / sub) на python, который я тестировал локально с DirectRunner. Я хотел...

Согласно руководству по программированию BEAM и многим потоков join может быть достигнуто с помощью...

Попытка записать данные в таблицу BigQuery с помощью BeamSQL.Для записи данных нам нужна схема этих...

Я пытаюсь запустить потоковое задание потока данных, содержащее n конвейеров. На основе настроенной...

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

Я хочу прочитать CSV-файл из облачного хранилища и записать его в таблицу больших запросов со...

Я использую Beam-SDK версии 2.9 в моем потоке данных. и вызвать службу в потоке данных. регион...

Я обучил модель научного обучения (~ 70 МБ), которую я хочу использовать для прогнозирования с...

У меня есть файл .txt, который имеет формат JSON.Я хочу читать, манипулировать и реструктурировать...

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

У меня есть потоковый конвейер, который использует потоковый источник (Kafka) и записывает данные в...

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

Я использую apache-beam python 2.12.0 SDK. У меня проблемы при использовании какого-то специального...

Мне нужно загрузить JSON из API, а затем подготовить CSV для использования на машинном обучении....

У меня есть конвейер Apache Beam, построенный на python.Я читаю строки из CSV-файла. Затем...

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

После чтения данных из неограниченного источника, такого как pub / sub, я применяю управление...

Я выполняю задание потока данных, используя Python, который использует библиотеку pandas. Он...

Создание задания Dataflow из шаблона Dataflow, который был создан при запуске задания Dataprep. При...

В настоящее время у меня есть некоторый код, который запрашивает MySQL.Я хотел бы запустить этот...

У меня есть скрипт python 2.7, который я запускаю локально для запуска задания Apache Beam / Google...