При выполнении следующего скрипта Python с использованием cloud-composer, я получаю *** Task...
Мы хотим использовать воздушный поток apache там, где наши рабочие журналы должны идти в корзину S3
Изначально я установил Apache Airflow, а python 2.7 задан как путь по умолчанию. Теперь я пытаюсь...
Сертифицирован ли airflow для работы с бэкэндом Microsoft SQL Server? Настройка потока воздуха для...
У нас есть требование для планирования заданий на запуск, так как мы знакомы с apache-airflow, и мы...
Я создаю скрипт на python для генерации групп DAG (сгенерировать новый файл python со...
Мы запустили кластер Cloud Composer и хотим использовать его для перемещения данных из Cloud SQL...
Мне нужно импортировать модули библиотеки воздушного потока в оболочке Pyspark. Я включаю путь...
После некоторых исследований и испытаний мы решили начать использовать Google Cloud Composer....
Некоторый контекст: Я использую composer-1.3.0-airflow-1.10.0 Установленный пакет PyPi docker===2.7
Я пытаюсь запустить команду bash в этом шаблоне ssh user@host "my bash command",...
Среда: Python 2.7.5 и Centos 7 Я успешно установил поток воздуха, используя: pip install...
Недавно я добавил несколько новых групп доступности базы данных в производственный поток и в...
Я использую PostgresHook в операторе Airflow. pg_hook =...
Я пытаюсь запустить тестовое задание на Airflow, но получаю следующую ошибку: FAILED:...
Я разрабатываю решение на Java, которое взаимодействует с набором устройств через API REST,...
Недавно мы встретили известную проблему с потоком воздуха: Воздушный поток "Этот DAG недоступен в...
Мы используем соединение JDBC в потоке воздуха для получения данных с общедоступного сервера MySQL....
Airflow версия 1.8 Python версия 3.6 я получаю Нет модуля с именем MySQLdb ошибка, когда я...
У меня постоянно возникает ошибка ImportError: cannot import name 'flash' при попытке...
Я использую группу обеспечения доступности баз данных, которая динамически создает задачу: каждый...
У меня проблема с загрузкой всех переменных Airflow из кода. Существует возможность экспорта из...
Я новичок в Nginx, и у меня возникли некоторые проблемы при его настройке. Я всегда работал с очень...
Я использую Airflow 1.10 и пытаюсь получить доступ к SFTP с помощью оператора и датчика SFTP. Это...
Я запускаю блокнот jupyter из компаузера, используя PythonOperator, который выполняет следующий код...