从airflow操作向sql模板传递参数

Question

如果我在SQL模板中使用BigQueryOperator，如何向SQL传递参数？在

文件：.sql/查询.sql在

SELECT * FROM `dataset.{{ task_instance.variable_for_execution }}

文件：日期在

^{pr2}$

Answer 1

您可以在params参数中传递一个参数，该参数可在模板化字段中使用，如下所示：

BigQueryOperator(
    task_id='',
    sql='SELECT * FROM `dataset.{{ params.param1 }}',
    params={
        'param1': 'value1',
        'param2': 'value2'
    },
    use_legacy_sql=False,
    dag=dag
)

也可以在文件中分离SQL：

文件：/sql/查询.sql在

^{pr2}$

params参数的输入应该是字典。一般来说，气流中的任何操作员都可以传递此params参数。在