Airflow 1.10.10如何全局设置任务失败告警默认邮箱 支持按需覆盖

首先明确：你用到的Airflow 1.10.10版本本身没有内置全局任务告警邮箱的配置入口，不需要反复在airflow.cfg中查找对应设置。以下方案完全满足「全局默认告警邮箱统一维护、特殊场景可自定义覆盖」的核心需求，无需修改核心源码即可落地。

方案1：抽离公共默认参数模块（最稳妥、低侵入） #

这是生产环境最常用的实现方式，维护成本最低：

• 把通用的default_args配置单独抽成可导入的公共Python文件，放在DAG目录的可访问路径下（比如dags/common/路径），所有新建DAG直接引用该公共模块的配置，不需要重复编写邮箱列表。

公共模块示例代码（dags/common/global_defaults.py）：

# 全局统一维护的通用默认参数
GLOBAL_DEFAULT_ARGS = {
    # 全局默认告警接收人，仅需在此处统一调整
    "email": ["dev1@test.com", "dev2@test.com", "dev3@test.com"],
    # 其他通用配置（重试次数、重试间隔、默认归属人等）可一并放入
    "retries": 2,
    "retry_delay": 300,
    "owner": "data_platform_team"
}

DAG侧使用示例：
普通DAG直接导入公共模块即可复用全局配置，不需要重复写邮箱参数。有特殊告警需求的DAG，直接复制公共配置后重写对应字段即可实现覆盖，不会影响其他全局配置的复用。

from common.global_defaults import GLOBAL_DEFAULT_ARGS

# 普通DAG直接复用全局配置
# with DAG(
#     "ordinary_business_dag",
#     default_args=GLOBAL_DEFAULT_ARGS
# ) as dag:
#     ...

# 有特殊告警需求的DAG，在公共配置基础上自定义覆盖
custom_args = GLOBAL_DEFAULT_ARGS.copy()
# 比如独立业务线的告警需要单独发给对应负责人，直接覆盖email字段即可
custom_args["email"] = ["project_x_owner@test.com"]
custom_args["owner"] = "project_x_team"

with DAG(
    "custom_business_dag",
    default_args=custom_args
) as dag:
    # 具体任务逻辑

方案2：通过插件全局注入默认参数（零手动导入） #

如果你的环境内DAG数量非常多，不想每个DAG都手动导入公共模块，可以利用Airflow插件机制，在DAG加载阶段自动为所有DAG注入全局默认邮箱，同时保留自定义覆盖能力：

• 在Airflow的plugins目录下新建插件文件（比如plugins/global_dag_config.py），通过重写DAG类的初始化逻辑，为未手动配置email的DAG自动补上全局告警邮箱列表。

插件示例代码：

from airflow.models.dag import DAG
from airflow.plugins_manager import AirflowPlugin

# 保存DAG类的原始初始化方法
original_dag_init = DAG.__init__

def patched_dag_init(self, *args, **kwargs):
    # 全局默认告警邮箱列表
    global_email_list = ["dev1@test.com", "dev2@test.com", "dev3@test.com"]
    # 取出用户在DAG中传入的自定义default_args
    user_args = kwargs.get("default_args", {})
    # 仅当用户未手动配置email字段时，自动注入全局默认值，不覆盖用户自定义配置
    if "email" not in user_args:
        user_args["email"] = global_email_list
    kwargs["default_args"] = user_args
    # 执行原始初始化逻辑
    original_dag_init(self, *args, **kwargs)

# 挂载重写后的DAG初始化方法
DAG.__init__ = patched_dag_init

class GlobalDagConfigPlugin(AirflowPlugin):
    name = "global_default_dag_config"

该方案生效后：

• 所有新建DAG不需要手动编写email配置，默认自动使用全局告警列表
• 如果某个DAG有特殊告警需求，只要在自身的default_args中写上自定义的email列表，就会自动跳过全局注入，完全不影响自定义逻辑

注意：如果在单任务层面需要单独配置告警人，两种方案的兼容性都符合Airflow原生参数优先级：任务级别的配置优先级高于DAG级别的全局默认配置，不会出现配置冲突。

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