Я новичок в воздушном потоке. В качестве первого обучающего упражнения я создал минимальную группу DAG, которая каждый час записывает значение в таблицу базы данных postgres. Однако мне не удалось установить соединение с базой данных postgres....

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

TL; DR Как сделать так, чтобы ресурсы (файлы SQL, текстовые файлы) были доступны для задач в моем dag Привет, народ, Я использую установку Airflow с одним узлом (1.10.12). У меня есть даг, который использует операторы SQL. Для удобства чтения я...

Я пытаюсь понять, как работает интервал dag. * * * * * M H D M Y И время в UTC. Пример: 29 21 * * * Это значило бы бегать каждый день в 21:29. Я видел пример, когда год был 4. Что это будет значить? 29 21 * * 4

У меня есть репозиторий git на моем локальном компьютере здесь с некоторым кодом python c: \ repos \ myrepo \ src \ test.py ‹== сценарий python. Я хочу, чтобы Airflow запускался / выполнялся по расписанию Он размещен на гитхабе. У меня...

Я установил Airflow на сервер с Ubuntu и Python 3.8. Я пытаюсь импортировать простой даг в пользовательский интерфейс Airflow, чтобы перечислить файлы в ведре. from airflow import DAG from airflow.providers.amazon.aws.operators.s3_copy_object...

Мне нужно использовать sshoperator в DAG на AWS Airflow (Amazon MWAA), поэтому я импортировал следующую библиотеку в свой файл DAG. from airflow.contrib.operators.ssh_operator import SSHOperator Кажется, sshoperator был определен в библиотеке...

Я пытаюсь вызвать DAG из другой DAG (target_dag из parent_dag). Мой код parent_dag: from datetime import datetime from airflow.models import DAG from airflow.operators.python_operator import PythonOperator from airflow.models import Variable from...