Airflow中如何打印变量值？BashOperator echo输出为空问题排查

这是Airflow BashOperator最常见的作用域误区：
你在Python代码块里定义的test="test"是DAG解析阶段的Python局部变量，只在Python进程里生效；而bash_command里写的$test是Bash解释器的变量语法，只会读取Bash运行环境内的变量，和你前面写的Python同名变量没有任何关联。Bash执行时根本找不到test这个变量，读到的值是空串，echo就只会输出一个换行，和你贴的空日志完全对应。

根据你要打印的变量是DAG加载时就固定的静态值，还是任务运行时才生成的动态值，选对应方案就行：

• 静态固定值直接用f-string把值拼进bash命令就好，记得给变量加引号避免特殊字符导致命令报错：

with DAG(
    dag_id="tmp",
) as dag:
    test="test"
    test_dag = BashOperator(
        task_id="test_dag",
        bash_command=f'echo "{test}"',
    )

• 预定义变量或者需要区分参数和命令逻辑的场景，用params配合Airflow自带的Jinja模板传值，不需要手动拼字符串：

test_dag = BashOperator(
    task_id="test_dag",
    bash_command='echo "{{ params.target_val }}"',
    params={"target_val": test}
)

• 如果是上游任务运行时动态算出来的值，走XCom拉取即可：

# 假设值是task_id为calc_val的上游任务返回的
test_dag = BashOperator(
    task_id="test_dag",
    bash_command='echo "{{ ti.xcom_pull(task_ids=\"calc_val\") }}"'
)

• 非要用Bash原生$变量名写法的话，得先在bash命令里把变量定义了再调用：

test_dag = BashOperator(
    task_id="test_dag",
    bash_command=f'export test="{test}"; echo $test'
)

提醒：如果变量是密码、密钥这类敏感信息，别直接拼到命令里，存Airflow Variable或者连接配置里再通过模板拉取，避免明文泄露到日志和DAG文件里。

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