N8N Каталог воркфлоу

Запустите DAG Apache Airflow и получите значение XCom

С легкостью запускайте DAG’и Apache Airflow и получайте результаты выполнения через автоматизацию n8n Настройте свой API-эндпоинт Airflow и безопасно конфигурируйте аутентификацию с помощью комплексных инструкций по правам доступа Предоставьте динамические параметры — ID DAG, ID задачи, пользовательский ввод и условия ожидания — для гибкой оркестрации Мониторьте статус выполнения DAG’ов Airflow с настраиваемыми таймаутами, обеспечивая надежное выполнение Моментально извлекайте и возвращайте значения XCom для бесшовной обработки на более поздних этапах, с результатами, хранящимися для немедленного доступа

Category: n8n

Описание
Отзывы (0)

Описание

Этот рабочий процесс позволяет n8n программно инициировать запуск DAG (Directed Acyclic Graph) в Apache Airflow, отслеживать его состояние выполнения и получать результат значения XCom для конкретной задачи. Он предназначен для случаев, когда Airflow управляет рабочими процессами, а n8n выступает в роли внешнего контроллера и потребителя результатов задач Airflow.

Рабочий процесс логически разделен на следующие блоки:

1.1 Прием входных данных: Принимает входные параметры, включая ID DAG, ID задачи, настройки запуска DAG и управляющие параметры времени.
1.2 Настройка API Airflow: Устанавливает базовый URL API Airflow для последующих HTTP-запросов.
1.3 Запуск DAG: Отправляет POST-запрос в API Airflow для запуска DAG с указанной конфигурацией.
1.4 Мониторинг состояния DAG: Периодически проверяет статус выполнения DAG, пока он не достигнет конечного состояния (успех или сбой) или не истечет время ожидания.
1.5 Получение результата XCom: После успешного завершения получает значение возврата XCom для указанной задачи.
1.6 Обработка ошибок и управление временем: Управляет попытками повторного выполнения, интервалами ожидания и ошибками, такими как сбой выполнения DAG или истечение времени ожидания.