Я пытаюсь передать функцию Python в Airflow.Я не уверен, что ключ и значения должны быть для...

С помощью этого поста Stackoverflow Я только что создал программу (ту, которая показана в посте), в...

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

У меня есть скрипт airflow ниже, который запускает все скрипты Python как одну функцию.Мне бы...

Я пытаюсь выполнить скрипт Airflow и получить ошибку при проверке журналов Task_id в представлении...

Я новичок в воздушном потоке, и я пытаюсь понять, что означает execution_date в контексте...

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

У меня есть набор групп доступности баз данных, которые запускаются с 2011-01-01 до 2018-04-01 по...

Я могу запустить Spark задание, используя BashOperator, но я хочу использовать SparkSubmitOperator...

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

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

Я пытаюсь получить простой Airflow (v1.9.0) user_defined_filters, работающий на основе Документов

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

Что, по мнению людей, является наилучшим способом распространения кода (dags) среди веб-серверов /...

У меня DAG с воздушным потоком, выполняющий несколько задач BashOperator.Эти задачи в свою очередь...

Развертывание докера Airflow v1.9.0 на основе puckel просто прервалось для меня с этой ошибкой:...

В Airflow я создаю ветки с различными операторами с циклом for, мой код выглядит так: for table in...

Хорошо, я прошу прощения, если это глупый вопрос, потому что кажется настолько очевидным, что он...

Я написал очень простой знак потока воздуха следующим образом: import airflow from airflow import...

Как мне настроить или отправить журналы задач из airflow 1.9 в Elastic search? Я нашел шаблоны...

Я создал соединение типа 'S3' в Airflow (1.7) через административный интерфейс и подтвердил, что...

Мы работаем с Airflow v1.9.0 и у нас проблемы с одним DAG. Этот единственный оператор DHO...

Я хочу изменить расписание задачи, которую я создал в папке dags / через интерфейс воздушного...

Если у меня есть задачи 1, 2, 3, 4 и 5, и я хочу иметь 1 -> 2, затем 2-> 3, 2-> 4, 2-> 5, что лучше...

При использовании переменной с именем xxxx_apiKey в потоке воздуха она маскирует значение...