Как получить доступ к ответу одного SImpleHttpOperator и использовать это значение данных ответа для передачи в качестве параметров для следующей задачи SimpleHttpOperator?

Question

Итак, предположим, у меня есть 2 задачи SimpleHttpOperator в моей DAG Мне нужно получить ответ от 1-й задачи и использовать эти данные для создания параметров для второй задачи. Оба являются GET API.

Как получить данные ответа от simpleHttpOperator, я попробовал XCOM как истину, но как получить данные из XCOM во второй оператор?

Answer 1

Если вы посмотрите на код SimpleHttpOperator на Github , вы увидите, что поля ' конечная точка ', ' data ' и ' заголовки 'являются полями шаблона , так что вы можете использовать шаблоны Jinja.

Здесь приведен пример использования xcoms в шаблонах здесь и описание шаблона Jinja здесь

Я думаю, что на этот вопрос уже был дан ответ в Airflow - Как передать переменную xcom в Python функцию