Я пытался создать соединение облачной платформы Google в командной строке Airflow, используя gcloud...
Я получаю следующее AirflowException при очистке экземпляра Dag из пользовательского интерфейса, но...
Я использую Airflow, Databricks и PySpark. Я хотел бы знать, возможно ли добавить дополнительные...
Я хочу интегрировать предупреждающие сообщения Slack при сбое задачи в Airflow с...
Я пытаюсь использовать шаблонное значение в заголовках моего http-запроса, используя мой...
Я попытался установить библиотеку Pyodbc, чтобы использовать ее в воздушном потоке через файл needs
Я создал процесс в потоке воздуха, где мне нужно каждые 10 минут экспортировать новый файл из базы...
Я знаю, что уже есть функция воздушного потока, которая передает файл из облачного хранилища в Big...
Я пытался включить HTTPS через SSL на моем веб-интерфейсе Apache Airflow, но документация довольно...
Моя программа не может создать туннель SSH, пока внутри моего док-контейнера запущен поток Apache....
Я нахожусь в расположении BigQuery southamerica-east1, и когда я пытаюсь запустить функцию...
Я пытаюсь запустить несколько тестов на созданном пользовательском хуке apache airflow. Тесты...
Интересно, можно ли как-нибудь запустить несколько команд ssh как несколько заданий (с...
Есть ли способ зашифровать строку файла конфигурации воздушного потока sql_alchemy_conn, в примере...
Я уже установил Airflow на экземпляр EC2. Мой вариант использования - перенести некоторые данные из...
Я хочу получить идентификатор работы Bigquery в BigQueryOperator. В файле bigquery_operator.py я...
Я пытаюсь динамически установить зависимости и получить task_0 уже зарегистрированным. Ниже...
Я пытаюсь добавить dag для воздушного потока, динамически циклически перебирая ключи словаря и...
Как энтузиаст типизированных языков, я ненавижу писать простые SQL-запросы. К сожалению,...
У меня есть DAG с воздушным потоком, задачи которого я пытаюсь запустить в кластере AWS EKS. Задачи...
Я пытаюсь сохранить запрос BigQuery в кадре данных в пользовательском операторе Airflow. Я пытался...
У меня есть простой DAG, который выглядит так: Начало -> Загрузка -> Готово В моей локальной среде...
Я новичок в Google Cloud Composer.У меня есть некоторый код в Google Cloud Compute Engine -...
Я пытаюсь вызвать файл SQL с несколькими операторами, разделенными; через OracleOperator в airflow,...
Мне нужно добавить жестко закодированные элементы в журнал для задач воздушного потока, таких как...