Я установил Airflow 1.10.3 в Ubuntu 18.10 и могу добавить свои группы обеспечения доступности баз...

Я использую Airflow для динамического создания дагов. Конструктор dag использует «переменную» для...

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

У меня есть оператор с именем MsSqlToS3Operator, который делает то, что вы думаете. Он регистрирует...

На сайте администратора Airflow При обновлении подключения http_default датчик http выдает...

Я выполняю почасовой процесс, который собирает данные из одного местоположения («источник») и...

Мое требование состоит в том, чтобы планировать выполнение задачи dag с каждого воскресенья с 21:00...

Я пытаюсь использовать apache airflow.Мне удалось все установить. Я добавил новый DAG в папку dag,...

У My Airflow есть задача, которая использует BashOperator для запуска скрипта pySpark на нашем...

Я пытаюсь манипулировать состоянием задачи (PythonOperator) на основе выходных данных.Файл dag...

Используя TriggerDagRunOperator, я могу запустить прогон DAG. После непродолжительного «запуска»...

Когда задача в успешном запуске обратной засыпки очищается, DagRun с состоянием выполнения...

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

Я пытаюсь добавить в SLA для DAG / отдельных задач, которые имеют частоту расписания один раз. По...

У меня есть DAG с воздушным потоком, который я хочу запускать каждые 15 минут. Эта метка всегда...

У меня есть скрипт, который просматривает разделы s3, чтобы увидеть, существует ли файл.Если файл...

Воздушный поток позволяет легко выполнять задания с фиксированными интервалами. В этом посте...

Я пытаюсь создать шаблон поля params в операторе Bigquery, как показано ниже. t3 =...

Я пытаюсь создать метку программно, используя следующие инструкции: http://airflow.apache.org/faq

Мы хотели бы использовать Apache Airflow для составления расписания Scrapy Python Spiders и...

Мне нужно запустить следующую метку - dag = DAG('dummy_for_testing',...

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

Отсутствует представление «Профилирование данных» при использовании FAB-Security с RBAC. Я создал...

Я выполняю задачи (T1 и T2) параллельно. Как установить последующую задачу T3, которая зависит от...

Я пытаюсь перенести все существующие соединения с воздушным потоком на новый воздушный поток. Я...