Я использую Apache Airflow, и я хотел бы, чтобы он отправлял уведомления по электронной почте по...
и я хотел бы понять, выполним ли мой сценарий использования в Airflow. В целом, меня больше...
Настройка catchup_by_default = False в airflow.cfg, похоже, не работает. Кроме того, добавление...
Я запускал учебник по воздушному потоку. Содержимое в tutorial.py выглядит следующим образом:...
В настоящее время нет оператора S3ToBigQuery . Мой выбор: Используйте...
Мы отошли от Celery Executor в Airflow 1.10.0 из-за некоторых ограничений исполнения и сейчас...
В интерфейсе DAG воздушного потока я хотел бы добавить тег для подмножества DAG. Допустим, есть тег...
Моя цель - легко экспортировать события из Airflow в другие системы. Один из вариантов - создать...
Я только что установил Airflow 1.10 на один сервер , используя sudo -E pip-3.6 install...
We are running airflow version 1.9 in celery executor mode. Our task instances are stuck in retry...
Кто-нибудь сообщил, сколько они смогли увеличить Airflow в своей компании? Я смотрю на реализацию...
Мы экспериментируем с Apache Airflow (версия 1.10rc2, с python 2.7) и разворачиваем его на...
У меня есть DAG Airflow, которая запускается один раз в день в определенное время. Группа...
Я понимаю, что это потенциально плохой вопрос, но мне все еще не удается найти нужную информацию....
У меня есть пара групп доступности баз данных, которые создают временные кластеры EMS AWS, а затем...
Я использую PythonOperator в моей группе Airflow DAG, и мне нужно что-то напечатать внутри функции...
Я новичок в Airflow и не могу понять, как перезагрузить оператор / плагин, когда я изменяю его код....
Я запускаю поток воздуха в контейнере внутри codebuild, в настоящее время он выполняет все, кроме...
Сначала работая с dag callback (on_failure_callback и on_success_callback), я думал, что это...
У меня есть DAG, и затем, когда он успешен или неуспешен, я хочу, чтобы он вызывал метод, который...
Я использую Воздушный поток 1.8.0 и у меня есть DAG, как этот: default_args = { 'owner':...
У меня есть следующий Dag: Первый Даг с 0 1 * * * работал без проблем. Конец DAG 0 10 1 * * Не...
Можно ли создать DAG Airflow, которая запускается каждый день, кроме субботы и воскресенья? Кажется...
DAG A имеет расписание '0 6 * * *'. DAG B имеет расписание '* / 5 * * * *'. Однако группа...
Я использую Airflow 1.8.0 с LocalExecutor, и у меня есть ежедневная группа доступности баз данных,...