У меня есть Airflow DAG, которая как одна upstream задача и около 40 downstream задач из этой...

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

Я использую Kubernetes исполнитель потока воздуха и для data management (обмен данными через...

Traceback (последний вызов был последним): файл "/ anaconda2 / bin / airflow", строка 25, из файла...

Воздушный поток DAG запускается дважды в понедельник для следующих конфигураций. Когда я использую...

Я использую пакет airflow в python. Я пытаюсь создать целевую таблицу набора данных с кластером и...

Я хочу знать статус dag, работает ли он, произошел сбой или произошел успех. Я запускаю dag с...

Google Только что запустил новый API. Ссылка здесь https://cloud.google

Я пытаюсь запустить загрузочный контейнер с воздушными потоками с помощью файла LocalExecutor.yml,...

Я использую образ https://github.com/puckel/docker-airflow для запуска Airflow. Мне пришлось...

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

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

Можно ли использовать оператор включения Jinja: {% include 'some-template' %} в шаблонах...

Я очень плохо знаком с воздушным потоком, и мне нужно создать переменные среды start_date и...

Я начинающий с tenorflow и сейчас в проекте, где мне нужно развернуть распределенную...

Нам нужно выполнить 3000 прогонов Дага в определенный час дня. почти вся работа внутри Дага ждет,...

Я работаю на Mac Catalina с Pyenv с целью установить apache-airflow [все]. У меня не получается, и...

У меня работает Airflow с CeleryExecutor и 2 работниками. Когда мой DAG запускается, задачи...

Я сделал ETL из MySql в bigQuery с python, но, поскольку у меня нет разрешения на подключение...

У меня есть докеризованная служба воздушных потоков с FERNET_KEY в качестве переменной среды,...

Я успешно создал и запустил этот контейнер: https://github.com/puckel/docker-airflow , запустив:...

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

""" functions to invoke the aws lambda """ def lambda1(ds,**kwargs):...

Я использую Воздушный поток в EC2 CentOS с systemd для управления демонами для запуска процессов...

имеют DAG Airflow, определенные в файле python. Хотелось бы выполнить запрос к общедоступным данным...