如何在DataFactory中按多环境配置带条件的邮件告警

一、优化环境判断逻辑 #

原单一生产环境判断仅适配单个实例，可扩展为支持多生产实例的集合匹配逻辑，同时兼容开发、测试环境的区分：

1. 生产环境批量判断 #

替换原@equals(pipeline().DataFactory,'AdPrd117')为：

@in(pipeline().DataFactory, createArray('AdPrd117', 'AdPrd118', 'AdPrd119'))

说明：将所有生产环境的Data Factory实例名存入数组，in函数会自动判断当前实例是否属于生产环境集合，后续新增生产实例只需在数组中追加即可。

2. 三环境类型统一标识 #

若需明确区分开发、测试、生产三类环境，可使用switch表达式生成标准化环境标签：

@switch(pipeline().DataFactory,
    'AdDev001', 'development',
    'AdTest001', 'testing',
    'AdPrd117', 'production',
    'AdPrd118', 'production',
    'default', 'unknown'
)

建议将此结果存入管道变量CurrentEnvironment，后续逻辑直接引用该变量即可。

二、按环境配置收件邮箱并纳入判断 #

通过全局参数或管道变量维护环境与收件人的映射关系，结合环境判断动态匹配收件人：

1. 配置环境收件人映射 #

创建全局参数EnvironmentRecipients（类型为对象），示例内容：

{
    "development": "dev-alerts@company.com",
    "testing": "test-alerts@company.com",
    "production": "business-stakeholders@company.com"
}

2. 动态生成收件人地址 #

结合环境判断逻辑，直接输出对应环境的收件人：

@if(
    in(pipeline().DataFactory, createArray('AdPrd117', 'AdPrd118')),
    pipeline().parameters.EnvironmentRecipients.production,
    if(
        equals(pipeline().DataFactory, 'AdTest001'),
        pipeline().parameters.EnvironmentRecipients.testing,
        pipeline().parameters.EnvironmentRecipients.development
    )
)

将此表达式填入邮件活动的收件人字段即可。

3. 控制邮件发送触发规则 #

• 生产环境业务告警：在对应邮件活动的启用条件中填入生产环境判断表达式，仅当环境为生产时触发发送给业务用户。
• 开发/测试环境内部告警：新增独立邮件活动，启用条件设为非生产环境，收件人对应开发/测试团队邮箱，彻底避免业务用户收到冗余告警。

三、Notebook告警适配 #

Notebook生成的告警若通过Data Factory管道触发，可直接复用上述逻辑：

• 确保Notebook所在的Data Factory实例名与环境一一对应（如开发环境用AdDev001实例）。
• 触发邮件活动时，直接使用pipeline().DataFactory获取环境标识，沿用环境判断和收件人映射逻辑即可。

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