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

Наш конвейер потока данных имеет DoFn, который читает из bigtable с помощью клиентского API hbase...

Я реализовал DataflowPythonOperator в моей Airflow DAG, и во время выполнения я получаю сообщение...

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

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

Как записать данные, доступные в файле GCS, т.е. "gs://***/sampleBigtable.csv" в СУБД...

Задача : нам нужно настроить периодическую синхронизацию записей из Spanner в Big Query. Наша база...

Поскольку мне не разрешено задавать мой вопрос в той же теме, где у другого человека есть такая же...

Я просматриваю учебное пособие Google Firestore to BigQuery и перешел к шагу 10, где мне нужно...

Я пишу скрипт проверки данных в Apache Beam. Всякий раз, когда новый файл загружается в Google...

Когда я пытаюсь повторно запустить рецепт с другим набором данных (CSV), возникает ошибка...

Я использую Google dataflow + Scio, чтобы выполнить перекрестное соединение набора данных с самим...

Я настраиваю простое Испытание концепции, чтобы изучить некоторые концепции в Google Cloud, в...

У меня конвейер Beam хорошо работает локально с DirectRunner.Однако при переключении на...

После успешной недели обучения и игры с Google Data Flow я не могу больше запускать выполнение...

У меня возникла проблема при попытке запустить конвейер GCP Cloud-Dataflow. Конвейер работает при...

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

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

У меня есть задание Dataflow, которое считывает данные из pubsub и на основе времени и имени файла...

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

Я пытаюсь внедрить решение BI с использованием GCP, в котором у меня есть данные в виде плоских...

Я пытаюсь построить следующий пример потоковой передачи Pub / Sub на BigQuery: https://github

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

Мы пытаемся вставить данные в большие запросы (потоковые) с использованием потока данных.Есть ли...

В следующем коде во время выполнения мы выполняем ((Object)o).getClass() и передаем экземпляр...