Когда я создаю двоичный файл и пакет в альпийское изображение для экспортера воздушного потока с...

У меня есть шаблон jinja, который я планирую использовать для динамической генерации SQL в Hive.Мой...

Я пытаюсь использовать DataflowJavaOperator в нашей тестовой среде composer, но у меня ошибка 403...

Я пытаюсь использовать LocalExecutor вместо SequentialExecutor по умолчанию, который заставляет...

Я пытаюсь установить поток пакетов Python в virtualenv, который был создан с помощью pipenv, внутри...

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

У меня есть Apache Airflow, работающий на Kubernetes (через Google Composer).Я хочу получить одно...

У меня есть ряд задач Airflow, которые требуют некоторого разветвления и сбора результатов для...

Я создал новый плагин в Airflow, выполнив следующие шаги. создал папку шаблонов в пути / usr /...

Мы используем Google Composer для оркестровки рабочего процесса, случайно мы получаем сообщение An...

Я пытаюсь создать DAG в потоке воздуха, который будет отслеживать диск Google, когда новый файл...

У меня, похоже, проблема с BashOperator.Я использую Airflow 1.10, установленный на CentOS в среде...

Я пытаюсь настроить поток воздуха на сервере Ubuntu.Я написал несколько пакетов, которые, кажется,...

При динамическом создании задач мне нужно, чтобы Задача 2 зависела от Задачи 1, Задачи 1 >> Задачи...

Чем AirFlow отличается от инструмента FBP (Flow-Programming), такого как, например, Node-Red?...

У меня есть знак, который устанавливает зависимость_он_паст = Истина.Так что для большинства задач...

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

Airflow имеет представление о создании соединения, которое можно использовать хуками?Мы хотели...

Ребята, есть ли какие-либо рекомендуемые для структуры папок / каталогов Composer?То, как он должен...

Со следующим кодом: import pandas as pd filename = r"/path/to/my/file.csv" with...

Я загружаю данные из Google Storage в bigQuery, используя GoogleCloudStorageToBigQueryOperator...

Я пытаюсь передать значение динамической даты в макрос-функцию ds_format. DEFAULT_DATE= '{{ ds...

Я использую google composer. Как мы можем установить hadoopy в google composer environment. Эта...

У меня есть два скрипта Python, запускаемых один раз в день в моей локальной среде.Один - это...

Я настраиваю airflow на сервере.В настоящее время веб-сервер airflow работает как демон, и я...