草庐IT

PostgresOperator

全部标签

python - 将 Airflow 的 PostgresOperator 与 Jinja 模板和 SQL 一起使用时出现 TemplateNotFound

当尝试将Airflow的模板功能(通过Jinja2)与PostgresOperator结合使用时,我一直无法渲染。很可能我做错了什么,但我对问题可能是什么一无所知。下面是重现我遇到的TemplateNotFound错误的示例:airflow.cfgairflow_home=/home/gregreda/airflowdags_folder=/home/gregreda/airflow/dags相关DAG和变量default_args={'owner':'gregreda','start_date':datetime(2016,6,1),'schedule_interval':None,

python - Airflow :将 {{ ds }} 作为参数传递给 PostgresOperator

我想使用执行日期作为我的sql文件的参数:我试过了dt='{{ds}}'s3_to_redshift=PostgresOperator(task_id='s3_to_redshift',postgres_conn_id='redshift',sql='s3_to_redshift.sql',params={'file':dt},dag=dag)但它不起作用。 最佳答案 dt='{{ds}}'不起作用,因为Jinja(Airflow中使用的模板引擎)不处理整个Dag定义文件。对于每个Operator都有Jinja将处理的字段,它们是运