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

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

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

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

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

Преобразуйте это значение веса / результата из входного файла .csv в список имен столбцов,...

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

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

Я анализирую XML и пишу в Bigquery, используя конвейер потока данных. Как можно обработать ошибки,...

Недавно я начал работать с Apache Beam и облачным потоком данных Google для разработки больших...

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

У меня есть PCollection KV, где ключ - это имя файла, а значение - некоторая дополнительная...

У меня есть PCollection KV, где ключом является gcs file_patterns, а значением является некоторая...

Я использую JDBCIO.write() функцию Apache Beam для записи потоковых данных в CloudSQL.Согласно...

Я читаю bigtable в своей коллекции Pcollection, а затем пытаюсь преобразовать прочитанные записи в...

Я использую Apache Beam для настройки конвейера, состоящего из 2 основных шагов: преобразование...

Я получаю PCollection, подписавшись на паб / саб Google в Apache Beam следующим образом:...

Это присутствует PCollection<BeamRecord> rec = rec_out.apply(BeamSql.query( "SELECT...

Привет! Я написал лучевой конвейер для чтения каталога и анализа загруженных опубликованных...

Внутри преобразования Apache Beam я могу успешно преобразовать значения pub / sub (в формате...

Можете ли вы изменить метаданные файла в облачной базе данных с помощью Apache Beam?Насколько я...

Я пытаюсь создать некоторые облачные метрики из scala, используя scio и apache beam для задачи...

Я пытаюсь записать CSV из корзины облачной платформы Google в хранилище данных, содержащее...

Мне нужно прочитать двоичный файл в потоке данных Google, мне просто нужно прочитать файл и...

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