Я создаю изображение воздушного потока и запускаю воздушный поток в док-контейнере.Я перенаправил...
Я хочу создать kubernetes для развертывания вместо модуля. Есть ли способ сделать это в Apache...
У меня есть среда google cloud composer на GCP, и я случайно удалил таблицу dag_runs, из-за которой...
Я получаю сообщение об ошибке при попытке запустить DAG из облачного композитора с помощью...
Попробовал следующий код: import airflow Я получил следующую ошибку на python 2.7 в Jupyter...
Я устанавливаю airflow с помощью команды: python3 setup.py install.Он принимает в файле требований...
Я пытаюсь найти способ заставить VSCode Python intellisense работать с Плагинами воздушного потока
Кажется, что если я запускаю более одного запуска DAG каждую секунду, некоторые из них просто...
Apache airflow установлен и настроен с помощью MySQL без каких-либо ошибок.Проблема в том, что...
Я пытаюсь подключить Airflow к БД Postgresql. Когда в airflow.cfg я изменяю sql_alchemy_conn =...
Я не могу опубликовать, используя PubSubHook в Airflow с Python 3. Все отлично работает с Python 2,...
Мой даг определяется как ниже.Хотя flag1 и flag2 оба y, их как-то пропустили. from datetime import...
Какой оператор лучше всего скопировать файл с одного s3 на другой s3 в потоке воздуха?Я уже...
Я пытаюсь запустить улей в потоке воздуха.Я сделал обычное соединение JDBC, которое вы можете...
Я использую локального исполнителя airlfow с базой данных postgres и получаю: (psycopg2
Есть ли в Cloud Composer / Airflow параметр, который может по умолчанию отключать новые группы...
Я установил воздушный поток, следуя официальной документации. Я проверял это. Теперь я хочу...
У меня есть файл dag, в котором я определил группу DAG и ее задачи. Я хочу отключить ведение...
Я выполнил шаг, указанный в документе: https://airflow.apache.org/security
Преамбула Еще один поток задач, не получая выполненный вопрос ... В моем опыте с воздушным потоком...
Вопрос: Могу ли я использовать строковый синтаксис jinja2 в task_id строке или мы ограничены...
Вкл. on_failure_callback Я вызываю sns метод для отправки уведомления, который работает нормально....
Я пытаюсь опросить конечную точку HTML API для новых данных и выполнять DAG только при наличии...
airflow_version = 1.10.2;python_version = 3.6.8 У меня возникают проблемы с пониманием того, как...
Допустим, у меня есть фиктивный оператор с настраиваемым полем.Вот шаблон {% set my_variable = 1 %}...