Airflow 从 UI 手动 运行 传递配置

Question

有什么方法可以将 JSON 配置从手动 DAG 运行 传递（从 dag_run.conf['attribute'] 到 KubernetesPodOperator 的配置？

尝试在 YAML 中的模板化字段上使用 Jinja 模板，但出现错误，dag_run is not defined。

task_parse_raw_data = KubernetesPodOperator(
        namespace=NAMESPACE, 
        image='artifactory/image:tag',
        service_account_name='airflow',
        cmds=["sh", "/current.sh"],
        arguments=[ {{ dag_run.conf['date']}} ],
        ...)

Answer 1

您需要用引号将 Jinja 表达式括起来，如下所示：

arguments=[ "{{ dag_run.conf['date'] }}" ]