时间戳

首页 > 解决方案 > Airflow Jinja 模板 - 如何将 query_params 传递到我的 SQL 文件中？

jinja2 - Airflow Jinja 模板 - 如何将 query_params 传递到我的 SQL 文件中？

问题描述

我正在尝试使用BigQueryOperator模板化的 SQL 文件。

在 SQL 文件查询中，我有 (eg) {{ param_1 }}, {{ param_2 }}。

我的query_params论点如下：

query_params=[
     {'name': 'param_1',
      'parameterType': {'type': 'STRING'},
      'parameterValue': {'value': 'value_1'}
     },
     {'name': 'param_2',
      'parameterType': {'type': 'STRING'},
      'parameterValue': {'value': 'value_2'}
     }
],

但无论我做什么，参数都不会通过。生成的 SQL 只是将这些参数设置为"".

我试过封闭{{in '，试过写作{{ query_params.param_1 }}，试过params，但我无法让它工作。

我究竟做错了什么？

标签： jinja2airflow

解决方案

解决了。而不是query_params在运算符构造函数中，我需要使用params如下所示：

params={'param_1': 'value_1', 'param_2': 'value_2'}

然后在 SQL 文件中，将这些引用为{{ params.param_1 }}

推荐阅读