Data Management：配置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. 單擊確認。