У меня около миллиона задач Airflow, использующих одну и ту же функцию Python.Каждый из них должен...

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

Справочная информация Я пытаюсь запустить DAG в 22:00 America/New_York один раз в день с...

Есть ли какая-либо документация или сценарии для развертывания Airflow в кластерной или...

Я пытаюсь настроить удаленное ведение журнала с помощью BLOB-объекта Azure. Airflow version: 1.10.2...

Я новичок в Airflow и работаю над тем, чтобы сделать мой конвейер ETL более пригодным для...

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

Я прочитал ссылку на API и не смог найти на ней ничего, это возможно?

При попытке просмотра журналов Airflow выдает страницу с сообщением: File "/Users/user/

Airflow version: 1.10.2 Ubuntu: 18.04 (bionic) Python: 3.6.5 Проблема: Я не уверен, как, но...

Учитывая, что у меня есть файл easteregg.py: from airflow import DAG from dateutil import parser...

создал изображение, содержащее /airflow/xcom/return.json с chmod + x на всех вложенных каталогах....

Использование работника Airflow и веб-сервера / планировщика в качестве образов Docker, работающих...

У меня есть почасовой сценарий, который принимает в качестве входных параметров дату и час.Дата и...

Я пытаюсь использовать airflow trigger_dag dag_id, чтобы вызвать мой даг, но он просто показывает...

Я знаю, что priority_weight можно установить для DAG в default_args согласно примеру в официальной...

У нас есть оператор модуля kubernetes, который выдаст словарь python, который определит, какие...

Я недавно обновил поток воздуха до 1.10.2. Некоторые задачи в пакете работают нормально, а...

Как отключить поддержку SSLv3 в веб-сервере Apache Airflow.В настоящее время я не могу выбрать...

Мой DAG планируется запускать каждый час. Я каждый час беру данные из источника s3 и обрабатываю их

Большую часть времени без проблем работает одна из моих групп DAG Airflow.Однако время от времени...

Проект Apache Airflow, по-видимому, заставил TriggerDagRunOperator conf разрешить только JSON. Это...

Как предложено в документах для проверки другой авторизации для веб-потока воздуха ниже, необходимо...

Мы перешли на AirFlow 1.10.2 , чтобы разрешить использование процессора. Хорошо, что проблема, с...

У меня есть конвейер задачи воздушного потока, как на диаграмме.task1_error_handler &...