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

Я пытаюсь запустить .jar DAG через Airlfow. У меня есть файл .sh, который вызывает все библиотеки,...

У меня есть конфигурация для развертывания 4 модулей (следовательно, 4 рабочих) для Airflow в...

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

У меня есть Airflow DAG, которая создает кластер EMR, а затем запускает задачи SSHOperator на этом...

У меня есть dag A, который ждет, пока некоторые другие операторы в других dag B и C загрузят данные...

Я использую свой собственный SqlSensor со времени выпуска Apache Airflow 1.9, так как я не смог...

У меня есть скрипт, хранящийся на диске, сопоставленном с W: на удаленном сервере Windows. Я...

Привет, люди Земли!Я использую Airflow для планирования и запуска .jar Задание, созданное с помощью...

Мы бы хотели установить время ожидания сельдерея на 2 часа с опцией visibility_timeout.наш dag...

Я пытаюсь создать DAG в Cloud Composer.При импорте я получаю следующую ошибку: Broken DAG:...

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

Я выполняю несколько длительных задач в выделенной очереди. Так что нет коротких временных задач. В...

Я хотел запустить зависимость google.cloud.storage для моего проекта, поэтому я попытался...

Мне нужен доступ к веб-журналу доступа Airflow Webserver, но я не могу его найти. Я также посмотрел...

Я включил веб-аутентификацию для воздушного потока, следуя инструкциям на http://airflow.apache

Я извлек последнюю версию изображения воздушного потока из док-станции. apache/airflow. И я...

В платформе Apache airflow существует задача, которая переносит данные через фрейм данных pandas с...

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

Я использую airflow.operators.sensors.ExternalTaskSensor, чтобы заставить одного Дага ждать другого

У меня есть задача, созданная из PostgresOperator следующим образом: sql = "select * from {{...

Я новичок в Airflow.У меня есть несколько заданий .jar, сгенерированных с помощью T alend Open...

В настоящее время я использую Docker с puckel / Airflow для запуска Airflow Я успешно установил...

У меня есть конвейер ETL, который состоит из следующих задач: сканирование веб-сайта для сбора...

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