ERROR - Scheduler heartbeat got an exception: (psycopg2.OperationalError) could not translate host...
Я успешно установил airflow с помощью Ubuntu на Windows 10. Однако при попытке запустить airflow я...
Точно так же, как можно установить соединения через переменную среды после имени...
У меня есть требование, когда я хочу, чтобы мое задание воздушного потока считывало файл с S3 и...
Я установил Airflow на докер.Я хочу знать, как изменить домашний путь Airflow с докера на мою...
Я столкнулся с трудностью запуска Dag в Airflow, сегодня я написал свой первый день, но он не...
Я пытаюсь настроить процесс AWS EMR в Airflow, и мне нужно, чтобы job_flow_overrides в...
Последние пару месяцев я изучал, как использовать Apache-Airflow, и хотел узнать, есть ли у...
Я реализовал S3DeleteObjectsOperator, но хотя задача показывает, что ключ успешно удален, в...
У меня есть переменная, которую я должен генерировать значение каждый раз, когда выполняю...
Я пытаюсь установить поток воздуха на экземпляре AWS EC2.Кажется, этот процесс довольно хорошо...
Airflow 1.10.5 Celery executor Сбой планировщика воздушного потока с ошибкой соединения postgres...
Я боролся с ошибкой шаблонизации Jinja в composer-1.5.2-airflow-1.10.0. Мне нужен был оператор K8SO...
Не удается запустить воздушный поток после развертывания, отчеты об ошибках не могут разрешить...
Я пытаюсь проверить одного из моих операторов.Для этого я вдохновляю свой код из: https://github
когда я инициализирую поток, используя mysql в качестве бэкэнда, я вижу ниже ошибку File...
Я создал процесс в потоке воздуха с главной целью копирования таблиц BigQuery между проектами в...
У меня есть кластер AWS EMR с 1 главным узлом, 30 базовыми узлами и некоторыми автоматически...
У меня есть файл с именем properties.json, который выглядит как { "FOO": {...
Мне действительно нужно знать, как использовать Airflow, чтобы несколько групп DAG вызывали друг...
У меня следующий рабочий процесс, за исключением задач ветвления, все остальные задачи реализуются...
У меня следующая структура проекта, | ├── database │ ├── db_adapter.py │ ├── db_layer │ │ ├──...
Я создал группу обеспечения доступности баз данных, которая подключается к Cloud SQL (MySQL) через...
Я установил Airflow на моей машине, которая работает хорошо, и у меня также есть локальная искра...
Выполнение следующей задачи DAG. dag = DAG( 'TEST', default_args=default_args,...