У меня есть простой DAG с воздушным потоком, скажем, с 2 заданиями. как то так: newDirToLoad =...

Возникают проблемы с использованием кредитов OAuth для подключения к API-интерфейсу JIRA Server...

После установки sql_alchemy_conn в sybase строку подключения, команда initdb не выполняется с...

Я пытаюсь выполнить следующую задачу в Airflow: time_zone = "America/New_York" t1=...

У меня есть функция, которую мы в основном используем для добавления в конец каждого DAG. Давайте...

Я хочу соединить свой Airflow и Microsoft SQL Server. Я настроил свое соединение в строке...

Мы создаем решение для хранилища данных в Google BigQuery, используя Apache Airflow для переноса...

Ниже приведен код DAG воздушного потока.Он отлично работает как при локальном размещении воздушного...

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

Я указал 3 узла при создании среды композитора в облаке. Я пытался подключиться к рабочим узлам...

У меня есть группа доступности базы данных, которая импортирует данные из источника на сервер

Я использую Windows 10, python 3.6.4 и apache-airflow 1.10.2 Я пытаюсь использовать Apache-Airflow...

Вызов S3KeySensor помечает себя и последующие задачи как пропущенные, когда для soft_fail...

Мне нужно создать метку, которая выглядит следующим образом: print_date задача должна запускаться...

У меня есть код ниже, но он не работает, поскольку в модуле "line" есть переменная. Пожалуйста,...

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

Сначала я получаю все данные, используя запрос MySQL, из производственной базы данных, затем...

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

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

Я настраиваю среду Airflow в Google Cloud Composer для тестирования.Я добавил некоторые секреты в...

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

Я использую Airflow для запуска заданий Spark в Google Cloud Composer.Мне нужно Создать кластер...

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

Мой проект Python примерно структурирован следующим образом: ./code ./code/pipeline_xyz.py

Я новичок в Google Cloud Composer и следую инструкции QuickStart: Создать среду, Загрузить нагрузку...