airflow - 如何将 xcom 作为 PostgresOperator 参数获取？

Question

我创建了一个 xcom，我想将结果作为 PostgresOperator 参数获取。我试过了

my_task = PostgresOperator(
    task_id=‘my_task',
    postgres_conn_id=config.get(env, 'redshift_conn'),
    sql="my_task.sql",
    params={
            ‘my_parameter': {{ int(ti.xcom_pull(task_ids=‘previous_task')) }}
    },
    dag=dag
) 

Answer 1

在操作符中访问 xcom 时需要使用模板。

my_task = PostgresOperator(
    task_id='my_task',
    postgres_conn_id=config.get(env, 'redshift_conn'),
    sql="my_task.sql",
    params={
            'my_parameter': "{{ti.xcom_pull(task_ids='previous_task')}}"
    },
    dag=dag
)