2025 Airflow 峰会将于 10 月 07-09 日举行。立即注册以获取早鸟票!

导出可供 Operator 使用的动态环境变量

airflow_local_settings.py 中定义的 get_airflow_context_vars 返回的键值对会被注入到默认的 Airflow 上下文环境变量中,这些变量在运行任务时可作为环境变量使用。请注意,键和值都必须是字符串。

dag_idtask_idexecution_datedag_run_iddag_ownerdag_email 是保留键。

例如,在您的 airflow_local_settings.py 文件中

def get_airflow_context_vars(context) -> dict[str, str]:
    """
    :param context: The context for the task_instance of interest.
    """
    # more env vars
    return {"airflow_cluster": "main"}

有关如何配置本地设置的详细信息,请参阅配置本地设置

此条目是否有帮助?