How to access response of one SImpleHttpOperator and use that response data value to pass as params for the next SimpleHttpOperator task?

Question

So assume I have 2 SimpleHttpOperator tasks in my DAG. I need to get a response from the 1st task and use that response data to create params for the second task. Both are GET APIs.

How to get response data from simpleHttpOperator, I tried XCOM as true, but how to get data from XCOM into the second operator?

score 0 · Answer 1 · answered Apr 03 '20 at 06:41

If you take a look at the code for the SimpleHttpOperator on Github, you can see that the fields 'endpoint', 'data' and 'headers' are template_fields, so you can use Jinja templating.

There is an example of how to use xcoms in templating here and a description of Jinja templating here

I think this question has already been answered in Airflow - How to pass xcom variable into Python function

How to access response of one SImpleHttpOperator and use that response data value to pass as params for the next SimpleHttpOperator task?

1 Answers1