配置Airflow告警消息通知

前提条件

已搭建Airflow环境。

使用DMS消息通知

1. 进入目标代码仓库。

2. 配置依赖包。

   from airflow.providers.alibaba_dms.cloud.notifications.dms_notification import DmsNotifier

3. 配置告警消息通知。

   重要

   告警消息默认通知工作空间的管理员，您可以在消息通知管理中修改接收消息的对象。

   • 失败告警：在DAG的default_args中，添加on_failure_callback参数，取值为lambda context: DmsNotifier(success=False).notify(context)。

   • 成功告警：在DAG的default_args中，添加on_success_callback参数，取值为lambda context: DmsNotifier(success=True).notify(context)。

   示例代码：

   dag = DAG(
   	dag_id='iac_ove_test',
   	default_args={
   		'on_failure_callback':lambda context: DmsNotifier(success=False).notify(context),
   		'on_success_callback':lambda context: DmsNotifier(success=True).notify(context)
   	}
   }

使用自定义邮件服务

1. 进入Airflow实例页面。

   

2. 在目标Airflow实例的操作列，单击配置选项。

3. 在弹出的对话框，配置airflow.cfg。

   说明

   您可以单击添加配置选项，参考Email Configuration在配置选项和值文本框中配置。

4. 单击确认。