Airflow中如何在BashOperator的嵌套Jinja模板内读取动态变量值

问题核心原因 #

• 第一种写法错误是因为Jinja模板语法不允许嵌套 {{ }} 标签，模板会把内层的 {{ 识别为语法错误。
• 第二种写法错误是因为params参数是在DAG解析阶段就完成求值的，此时还没有运行时的dag_run实例，你写在params里的模板字符串不会被二次渲染，只会被当成普通字符串处理，自然拿不到对应值。

正确实现方式 #

直接使用Jinja支持的字典方括号访问语法，从var.json.env_variables字典里取动态key对应的值即可，代码示例如下：

task = BashOperator(
    task_id="自定义任务ID",
    bash_command="export KUBECONFIG=$KUBECONFIG:{{ var.json.env_variables[dag_run.conf['param']] }}"
)

容错补充 #

如果要避免传入的key不存在时触发报错，可以搭配Jinja的default过滤器处理异常场景：

bash_command="export KUBECONFIG=$KUBECONFIG:{{ var.json.env_variables[dag_run.conf['param']] | default('') }}"

内容的提问来源于stack exchange，提问作者Vinit Bodhwani