Я пытаюсь прочитать данные из корзины GS и вывести их в другую корзину GS (разделенную...

Требуется раскрутить задание потока данных из другого потока данных. Первый поток данных будет...

Я хочу запустить один из моих скриптов на Python, используя GCP. Я довольно новичок в GCP, поэтому...

У меня есть облачная функция, которая запускается облачным Pub / Sub. Я хочу, чтобы та же функция...

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

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

Я пытался запустить конвейер apache-beam на облачной платформе Google, используя Cloud Dataflow....

java.lang.NullPointerException at java.util.regex.Matcher.getTextLength(Matcher.java:1283) at java

Вариант использования: PubSub в реальном времени сохраняет мои сообщения JSON в текстовом файле в...

Apache Beam 2.9.0 с использованием Google Cloud DataFlow. При попытке вставить в BigQuery...

Поскольку задания потока данных нельзя удалить, а только удалить / отменить, на моей консоли...

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

Ошибка в вопросе: AttributeError: 'function' object has no attribute 'tableId'...

Я новичок в потоке данных GCP. Я пытаюсь прочитать текстовые файлы (однострочная строка JSON) в...

У меня есть две таблицы в таблицах BigQuery, которые агрегируются и обрабатываются, которые могут...

У меня есть небольшая ежедневная вычислительная работа, которая импортирует данные из BigQuery,...

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

Я пытаюсь прочитать тему Кафки, используя Apache Beam, Google Dataflow. Вот код: public class...

Я получаю сообщение «TypeError: Ожидаемый вызываемый объект вместо: None» при выполнении задания...

Я пытаюсь запустить некоторую предварительную обработку, используя apache-beam (v2.15.0) и...

Я хотел бы получить доступ к файлам, присутствующим в виртуальной машине Compute Engine. Я должен...

Для моего потокового конвейера я вижу непредвиденное поведение при использовании параметра...

Я хочу использовать Spring с Apache Beam, который будет работать в Google Cloud Data Runner....

С точки зрения деталей реализации в DataflowRunner, многие люди могут не заботиться о том,...

снимок экрана кода 1 снимок экрана кода 2 Я хочу прочитать таблицу набора данных в большом запросе...