У меня есть шаблон потока данных, сгенерированный Dataprep, и я выполняю его с помощью Composer (т....

Я разработчик MEAN STACK. У меня есть новая задача, например, я должен отслеживать папку, если в...

Я получаю эту ошибку при использовании ECSOperator для запуска задач через ECS Fargate в Airflow 1

Мне нужно запустить следующую метку - dag = DAG('dummy_for_testing',...

В чем разница между двумя?Насколько я понимаю, оба они основаны на концепции направленного...

В настоящее время я использую CeleryExecutor для отправки групп доступности баз данных и запускаю...

Использование Airflow для запуска KubernetesPodOperator на AWS EKS с получением kubernetes.client

Я пытаюсь вызвать SPARK_SUBMIT с помощью SPARK_SUBMIT_OPERATOR, мне нужно установить...

Как указать каталог по умолчанию в FTP-соединении в Airflow? Следующие поля доступны для Тип...

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

Я исследовал это и в настоящее время придумываю стратегию с использованием Apache Airflow.Я все еще...

Я пытаюсь запустить задание DataFlow из DAG Airflow с использованием DataflowTemplateOperator. В...

В более ранней версии Airflow 1.8 наша команда могла запускать группы DAG вручную, даже если для...

Поэтому, прежде чем спросить об этом, я просмотрел документы и посмотрел на Разница между...

Я играю с Gcloud Composer, пытаюсь создать группу обеспечения доступности баз данных, которая...

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

Я использую DataFlowJavaOperator () в потоке воздуха (Cloud Composer).Есть ли способ получить...

airflowdockercompose_webserver_run_1 застрял в состоянии перезапуска Я уже пытался перезапустить...

Я работаю над отправкой задания Spark с использованием метода POST пакетов Apache Livy. Этот...

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

Я пишу даг, который требует много ресурсов процессора и памяти, но я запускаю его на своем ноутбуке...

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

У меня есть среда Airflow, работающая на Cloud Composer (3 n1-standard-1 узлы; версия образа:...

Я настроил DAG с кучей задач (от Bash Operators), каждая из которых запускает какой-нибудь jar-файл

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