Airflow KubernetesPodOperator环境变量访问问题：容器运行时如何获取env_vars传递的环境变量

你遇到的问题根源在于KubernetesPodOperator默认不会通过shell来执行你指定的命令，导致环境变量无法被解析展开。

当你直接设置cmds=["echo $POSTGRES_URL"]时，容器会把整个字符串当作一个独立命令去执行，而不是先通过shell解析$POSTGRES_URL这个环境变量引用。这时候echo会把$POSTGRES_URL当作字面量输出，而不是读取你传入的dummy值。

解决方法：通过shell执行命令 #

要让环境变量被正确解析，你需要让命令通过shell来运行。修改cmds参数，用sh -c包裹你的命令：

task_fetch = KubernetesPodOperator(
    task_id=FETCH,
    name=FETCH,
    image=K8S_PRODUCTION_IMAGE,
    in_cluster=K8S_IN_CLUSTER,
    namespace=K8S_NAMESPACE,
    get_logs=True,
    do_xcom_push=False,
    config_file="/app/.kube/config",
    affinity=K8S_AFFINITY,
    cmds=["sh", "-c", "echo $POSTGRES_URL"],  # 用shell包裹命令触发环境变量解析
    env_vars={"POSTGRES_URL": "dummy"},
)

这样shell会先解析$POSTGRES_URL为对应的环境变量值dummy，再传给echo命令执行，就能得到你预期的输出了。

额外验证方法 #

如果你想确认环境变量是否真的被注入到容器中，可以执行env命令查看所有环境变量：

cmds=["sh", "-c", "env | grep POSTGRES_URL"]

这会输出POSTGRES_URL=dummy，证明环境变量已经正确设置。

补充说明 #

KubernetesPodOperator的cmds参数对应Kubernetes Pod定义中的command字段，默认是直接执行二进制程序，不会经过shell。只有当你明确调用shell并传入命令字符串时，shell才会处理环境变量、通配符等语法。

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