栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

气流:将{{ds}}作为参数传递给PostgresOperator

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

气流:将{{ds}}作为参数传递给PostgresOperator

dt = '{{ ds }}'

不起作用,因为Jinja(气流中使用的模板引擎)无法处理整个Dag定义文件。

对于每个

Operator
字段,Jinja将处理的字段都是操作员本身定义的一部分。

在这种情况下,如果您进行如下扩展

params
,则可以使字段(实际上称为
parameters
,请确保更改此字段)为模板
PostgresOperator

class MyPostgresOperator(PostgresOperator):    template_fields = ('sql','parameters')

现在您应该可以执行以下操作:

s3_to_redshift = MyPostgresOperator(    task_id='s3_to_redshift',    postgres_conn_id='redshift',    sql='s3_to_redshift.sql',    parameters={'file': '{{ ds }}'},    dag=dag)


转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/668183.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号