from airflow.operators.http_operator import SimpleHttpOperator
task = SimpleHttpOperator( task_id='my_task', method='GET', endpoint='my-endpoint', xcom_push=True, dag=my_dag )
from airflow.operators.python_operator import PythonOperator
def my_task_func(**context): my_output = context['ti'].xcom_pull(task_ids='my_task') # 继续处理 my_output
task = PythonOperator( task_id='my_task_func', python_callable=my_task_func, provide_context=True, dag=my_dag )
注意:在 xcom_pull 方法中,指定 task_ids 参数来指定要从哪个任务获取 xcom 输出,其中 my_task 是 SimpleHttpOperator 的任务 ID,my_output 是变量名,你可以根据实际情况自定义。