Хочу установить дату выполнения в триггере DAG.Я использую оператор TriggerDagRunOperator, у этого...
Мне нужно ежедневно копировать таблицы из MySQL в BigQuery.Мой рабочий процесс:...
Чтобы получить dag_state, я запускаю следующую команду LCI: airflow dag_state example_bash_operator...
Я настраивал кластер воздушного потока в нашей системе, и ранее он работал.Я не уверен, что я мог...
В последнее время я играю с Airflow и PySpark.Я видел, что Airflow имеет ряд переменных.Моя цель -...
Я запустил aird initdb во второй раз и получил следующую ошибку: alembic.util.exc.CommandError:...
У меня есть задача, которая читает список файлов из Azure и отправляет результаты в XCOM.Оператор...
Я следую таким образом .и работает хорошо без аутентификации. curl -X POST \...
Мне просто интересно, возможно ли это? Если нет, то есть ли рекомендуемое решение, позволяющее...
Apache Airflow имеет таблицы MYSQL, такие как dag, dag_run, задание, которое поддерживает поля...
У меня есть задание, которое запускается каждое воскресенье и генерирует отчет за последние X дней...
Я использую Airflow для управления выполнением и расписанием задач ETL.DAG был создан, и он отлично...
def perPracticeFileToCDRJob(**context): #t1 = BashOperator(task_id='task',xcom_push=True...
Когда экземпляры задачи отмечены состоянием State.REMOVED в Airflow?Когда я динамически генерирую...
Я пытаюсь создать пользовательский интерфейс, основанный на выполнении задач воздушного потока.Одна...
Документация по воздушному потоку https://airflow.readthedocs.io/en/1.9.0/configuration.html...
У меня есть задача, с помощью которой я пишу в БД, какие задачи были успешно обработаны.Я пытаюсь...
Ошибка ниже при запуске веб-сервера Airflow balajee@Balajees-MacBook-Air.local: ~ $ airflow...
Мой пример использования - управление большим количеством запланированных заданий на микро-сервисах...
У меня есть конвейер, который я хочу запускать каждый день, но я бы хотел, чтобы дата выполнения...
У меня есть следующий DAG с несколькими простыми задачами: hour_list = [“0:00”, “1:00",...
Я хочу сделать предупреждение о слабом состоянии (статус ошибки и статус успеха) Теперь Dag...
Я ищу ресурсы для изменения путей журналов для служб Airflow, таких как веб-сервер и планировщик
Привет! Я попытался очистить свою группу обеспечения доступности баз данных, однако позже моя...
Я пытаюсь вызвать сценарий оболочки в моей группе DAG с потоком воздуха и передаю несколько...