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 を設定します。

   説明

   [設定オプションの追加] をクリックし、「メール設定」を参照して、[設定オプション] と [値] のテキストボックスにパラメーターを設定できます。

4. [確認] をクリックします。