Я работаю над задачей, которая должна принять некоторые таблицы в Salesforce и обработать их в...

Я пытаюсь перенести IngestionTime (_PARTITIONTIME) в многораздельные таблицы TIMESTAMP в BQ.При...

У меня есть шаблон потока данных, созданный с помощью приведенной ниже команды python scrap.py...

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

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

Скажем, в программе Dataflow / Apache Beam я пытаюсь прочитать таблицу с экспоненциально растущими...

Метод сохранения модели XGBoost, упомянутый в в этом ответе , решил проблему совместимости с...

После обработки данных у меня есть партия строк в формате (u'378491520468_sale',...

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

Мне нужно использовать облачный API Google для написания моих заданий Dataflow. Насколько я понимаю...

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

В демоверсии источника используется хранилище Google. Но как заменить его на SFTP?

Это Apache Beam Python проект, развернутый в потоке данных. он работает с directrunner, но не с...

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

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

Я выполняю задание Apache Beam, которое читает данные из корзины, выполняет некоторые...

GDAL зависит от заголовочных файлов , которые устанавливаются через apt-get. Простое выполнение pip...

Я пытаюсь запустить очередь RabbitMQ из луча / потока данных в потоковом режиме (чтобы он продолжал...

Я изучаю концепции Window & Triggering в Apache с целью: чтения для неограниченных источников...

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

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

Context Я читаю файл из Google Storage в Beam, используя процесс, который выглядит примерно так:...

Я пытаюсь построить конвейер, используя Apache Beam, который принимает CSV-файл, содержащий 10 тыс....

SDK: Apache Beam SDK для Go 0.5.0 Мы выполняем задания Apache Beam Go SDK в облачном потоке данных...

Я пытаюсь научиться проходить через Cloud Dataflow.В целях обучения я разбил их базовый пример Word...