How to pull xCom in HttpSensor operator

Question

I want to call an API, which needs data of the previous task which I saved in xCom.How to access that xCom.

I am using HttpOperater as well as HttpSensor for calling API.

Answer 1

you need to use the xcom_pull method on the context:

http_task = SimpleHttpOperator(
    task_id='http_call',
    endpoint='nodes/url',
    data="name=Joe",
    headers={"Content-Type": "application/x-www-form-urlencoded"},
    dag=dag,
)

def get_http_payload(**context):
    http_payload = ['ti'].xcom_pull(task_ids='http_call')
    print(http_payload)

process_output = PythonOperator(
    task_id='process_stuff',
    python_callable=get_http_payload,
    provide_context=True,
    dag=dag,
)

http_task >> process_output