将一项任务的输出发送到气流中的另一项任务

Question

我正在使用气流，我想将任务 1 的函数的输出传递给任务 2。

def create_dag(dag_id,
               schedule,
               default_args):
    def getData(**kwargs):
        res = requests.post('https://dummyURL')
        return res.json())  
    def sendAlert(**kwargs):
        requests.post('https://dummyURL', params = "here i want to send res.json() from task 1")

    dag = DAG(dag_id,
                  schedule_interval=schedule,
                  default_args=default_args)

    with dag:
        t1 = PythonOperator(task_id='task1',python_callable=getData,provide_context=True,dag=dag)
        t2 = PythonOperator(task_id='task2',python_callable=sendAlert,provide_context=True,dag=dag)
    return dag

Answer 1

查看xcom's，只要你要传递的数据比较小就是最好的选择。