Поиск способа выполнения фрагмента кода после завершения определенной группы обеспечения...
Мы используем Apache Airflow для запуска DML в таких базах данных, как Postgres и Redshift. Прямо...
Я запускаю конвейер потока данных от Composer-> airflow.Когда я запускаю следующий код:...
Мы планируем обновить Airflow и перейти с одного сервера Airflow на Airflow кластер (AWS). Мы...
В моем скрипте Ariflow есть несколько задач с использованием оператора python для запуска...
Мне нужно получить данные из базы данных Google Cloud SQL в одном из моих Dags. Я пытался...
Я хочу запустить команду papermill в модуле и получить ошибки (если есть).Это должно быть сделано...
Я использую планировщик заданий Slurm для запуска своих заданий в кластере. Каков наиболее...
У меня есть несколько дагов, использующих Celery Executor, но я хочу, чтобы один конкретный даг...
Я пытаюсь создать соединение с воздушным потоком в Cloud Composer с помощью CLI gcloud. Я следую за...
Я создал Composer Environment в среде разработки GCP с учетной записью службы, которая имеет...
Я установил Python, Docker на свою машину и пытаюсь импортировать from airflow.contrib.operators
Я хотел бы знать, является ли то, что я сделал для достижения цели динамических операторов в DAG...
Мне нужен доступ к параметру, переданному BigqueryOperator в файл sql, но я получаю сообщение об...
Я пытаюсь проверить, существует ли файл на удаленном сервере, если это так, проверьте, равно ли...
Согласно https://anaconda.org/conda-forge/airflow-with-docker, я установил следующий пакет: conda...
Можно ли добавить подпапки в корзину GCS, которую Cloud Composer / Airflow использует для создания...
Я уже реализовал модель конвейера sagemaker. В частности, для сквозного ноутбука, который обучает...
Я пытаюсь использовать оператор BigQueryCreateEmptyTableOperator, но он выдает ошибку импорта.
Я хотел бы распределить работу среди моих работников в Apache Airflow, основываясь на состоянии и...
Я использую AirFlow для планирования заданий, однако это становится медленнее, чем раньше, особенно...
компания, для которой я сейчас стажируюсь, хочет, чтобы я запланировал уже существующий веб-скребок...
Я пытаюсь прочитать файл с удаленного сервера с помощью клиента smb pysmb с помощью Airflow DAG
Я использую образ докера воздушного потока puckel для запуска приложения воздушного потока, которое...
Подобный вопрос задавался ранее, но, насколько я могу судить, этот ответ не может быть объяснен,...