Я хотел бы построить процесс API REST Airflow, используя HTTP-оператор, который выглядит следующим образом:
1) GET запрашивает получение идентификаторов (выполнено с HTTPOperator) 2) Обрабатывает ответ для получения номера Идентификаторы и выходные идентификаторы в список. (Выполнено с / Python Op) 3) Создайте n задач на основе номера и отправьте POST каждому ID.
Однако я не смог создать решение для части 3. Я попытался создать подзадачи безуспешно и попробовал несколько других решений из других вопросов.
Я ценю, что Airflow не предназначен быть динамичным c, но должно быть решение, которое работает для этого сценария.
Спасибо