Я пишу скрипт на python, который вычисляет что-то. Именно поэтому скрипт отделен от папки dags. В...

Я знаю, что Airflow называется менеджером потока операций, менеджером потока данных nifi, но что...

Я создал задачу с PythonOperator в качестве оператора.Он вызывает функцию в другой папке с...

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

Когда я запускаю вручную, иногда DAG не запускается.Показывает статус заданий только как «без...

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

Допустим, у меня есть таблица базы данных со списком URL, мне нужно сделать HTTP-вызов для каждого...

Я пытаюсь понять, подходит ли мне поток воздуха для этого сценария. В настоящее время у меня есть...

У меня есть работа с 3 задачами 1) Получить токен, используя запрос POST 2) Получить значение...

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

Я новичок в Airflow.Я написал код для отправки HTTP Post с помощью SimpleHttpOperator.В этом случае...

Я хочу использовать поток воздуха для обработки изображений. У меня есть 4 задачи: предварительная...

После изучения и изучения основ Airflow, я все еще не могу понять, как я буду выполнять...

Я хотел бы создать свой собственный пользовательский базовый оператор с дополнительной функцией...

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

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

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

Есть ли способ приостановить определенный DagRun в Airflow? Я хочу иметь возможность выполнять...

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

Веб-сервер воздушного потока не отображает график подпада, когда он увеличен. Отображается...

Я новичок в Воздушный поток . У меня возникли проблемы с удалением Airflow v1.10.3, я использую...

Во время работы SQL-конвейеров pySpark через Airflow я заинтересован в получении некоторой...

Я столкнулся с ошибкой "task_log_reader" после обновления потока воздуха с версии 1.9 до версии 1

Я новичок в Airflow и GCP. Я использую GCP composer с воздушным потоком.У меня есть кластер...

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