У меня есть требование в composer опрашивать задачу до тех пор, пока он не найдет zip-файл в...

Я новичок в Google Cloud Composer.У меня есть некоторый код в Google Cloud Compute Engine -...

Хотя datastore_export_operator доступен с Airflow (работает в Cloud Composer), можно использовать...

код на моем компьютере работает нормально, но когда я помещаю его в DAG для запуска через Airflow,...

Что я хочу сделать: - сравнить отсутствующий идентификатор из MySQL и BigQuery - получить все...

У меня есть шаблон потока данных, сгенерированный Dataprep, и я выполняю его с помощью Composer (т....

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

Я пытаюсь запустить BigQueryOperator в GCC. Мне уже удалось запустить для...

Я пытаюсь запустить задание DataFlow из DAG Airflow с использованием DataflowTemplateOperator. В...

Я пишу плагин Cloud Composer, и мне нужно создать DAG во время выполнения.Как я могу создать файл...

Я играю с Gcloud Composer, пытаюсь создать группу обеспечения доступности баз данных, которая...

Я использую DataFlowJavaOperator () в потоке воздуха (Cloud Composer).Есть ли способ получить...

Я пытаюсь выполнить Spark jar на Dataproc, используя DataProcSparkOperator от Airflow .JAR...

Я не могу использовать google-cloud-storage в моем Airflow. Я использую облачный композитор для...

Я пытаюсь настроить конвейеры данных, которые перемещают данные из GCS в BigQuery, выполняют...

Мы запустили кластер Cloud Composer и хотим использовать его для перемещения данных из Cloud SQL...

Я пытаюсь запустить команду bash в этом шаблоне ssh user@host "my bash command",...

Я использую google composer-1.0.0-airflow-1.9.0.Я использовал dask в одном из моих DAG и хотел...

Я работаю над развертыванием конвейера CI gitlab для запуска DAG-компилятора облака Google. Ниже...

Проблема : У меня есть управляемая среда Cloud Composer, под мастером кластера Kubernetes 1.9.7-gke

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

Я знаю, как назначить статический внешний IP-адрес для Compute Engine, но можно ли это сделать с...

Я создаю почасовую задачу в Airflow, которая планирует задание потока данных, однако ловушка,...

Airflow позволяет вам помещать зависимости (внешний код Python в код DAG), на которые полагаются...