如何解决如何获取xcom作为PostgresOperator参数?
我创建了一个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
)
解决方法
在操作员内部访问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
)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。