Обычно мы определяем Операторы в том же файле python, где определена наша группа DAG (см. этот...

Как извлечь yarn_application_id из SparkSubmitHook? Я пытался использовать пользовательский...

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

Я пытаюсь создать SimpleHttpOperator. Я впервые попробовал task1 = SimpleHttpOperator(...

Я хочу выполнить запрос улья, используя HiveOperator, и вывод этого запроса должен быть перенесен в...

Я использую док-станцию ​​Jenkins вместе с потоком воздуха на моей локальной машине. Задание...

Я запускаю поток воздуха в Kubernetes и использую «Оператор Kubernetes» . Когда я запускаю...

Работа с потоком воздуха. Я пробую простую работу с DAG. Я написал пользовательские операторы и...