すべてのプロダクト
Search

このプロダクト

    Data Management:Airflow のアラート通知の設定

    ドキュメントセンター

    Data Management:Airflow のアラート通知の設定

    最終更新日:Aug 06, 2026

    DMS Airflow は、DAG が成功または失敗した際にアラートで通知する機能をサポートしています。組み込みの DMS メッセージ通知を使用するか、カスタム SMTP メールサービスを設定してアラートメールを送信できます。

    前提条件

    Airflow 環境をセットアップ済みであること。

    DMS メッセージ通知の使用

    1. 対象のコードリポジトリに移動します。

    2. 依存関係を設定します。

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

    3. アラート通知を設定します。

      デフォルトでは、アラート通知はワークスペース管理者に送信されます。受信者は通知管理で変更できます。

      • 失敗アラート：DAG に on_failure_callback パラメータを追加し、値を lambda context: DmsNotifier(success=False).notify(context) に設定します。

      • 成功アラート：DAG に on_success_callback パラメータを追加し、値を lambda context: DmsNotifier(success=True).notify(context) に設定します。

      コード例：

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

      上記の設定は DAG レベルでアラートを設定するため、DAG の実行ごとに通知は 1 件のみ送信されます。各タスクごとに個別の通知を送信するには、on_failure_callback と on_success_callback を DAG の default_args に配置してください。

    カスタムメールサービスの使用

    SMTP サービスパラメータと Airflow 接続を設定することで、カスタムメールサービスを使用して Airflow のアラート通知メールを送信できます。設定は、次の 2 つの手順で構成されています。

    1. Airflow インスタンスの設定オプションで SMTP サービスパラメータを設定します。

    2. メールの認証情報を保存するために、Airflow で smtp_default 接続を作成します。

    Airflow は、両方の手順が完了した後にのみアラートメールを送信できます。

    手順 1：SMTP サービスパラメータの設定

    1. DMSコンソールV5.0 にログインします。

    2. コンソールの左上の 2023-01-28_15-57-17.png アイコンをクリックし、[All Features] > [Data+AI] > [Workspace] を選択します。

      説明

      非コンパクトなコンソールモードを使用している場合は、上部メニューから [Data+AI] > [Workspace] を選択します。

    3. Airflow インスタンスを含むワークスペース名をクリックし、左側メニューで image > [Airflow Instance] を選択します。

    4. 対象の Airflow インスタンスの [Operation] 列で、[Configuration Options] をクリックします。

    5. 表示されるダイアログボックスで [Add Configuration Option] をクリックし、次の SMTP 設定オプションを追加します。

      重要

      smtp.smtp_ssl と smtp.smtp_starttls は相互排他的な暗号化方式であり、同時に True に設定できません。

      設定オプション

      値の例

      説明

      smtp.smtp_host

      smtp.qiye.aliyun.com

      メールサービスプロバイダーが提供する SMTP サーバーアドレス

      smtp.smtp_port

      465

      SMTP サービスのポート。通常、SSL では 465、STARTTLS では 587 です。

      smtp.smtp_ssl

      True

      SSL 暗号化を有効にするかどうか。有効にする場合は、smtp.smtp_starttls を False に設定します。

      smtp.smtp_starttls

      False

      STARTTLS 暗号化を有効にするかどうか。有効にする場合は、smtp.smtp_ssl を False に設定します。

      smtp.smtp_mail_from

      sender@example.com

      アラートメールの送信元メールアドレス

      smtp.smtp_user

      sender@example.com

      SMTP サーバー認証用のログインアカウント。通常は送信元アドレスと同じです。

    6. [Confirm] をクリックします。

      設定が有効になるまで待ちます。Airflow インスタンスのステータスが [Deploying] に変わり、その後 [Running] に戻ると、設定が有効になったことを示します。

    手順 2：Airflow 接続の設定

    SMTP サービスパラメータを設定した後、メールの認証情報を保存するために Airflow 接続を設定します。

    1. 対象の Airflow インスタンスの [Operation] 列で、[Open] をクリックして Airflow Web UI にアクセスします。

    2. 左側メニューで [Admin] > [Connections] を選択します。

    3. 右上の [Add Connection] をクリックし、次のパラメータを設定します。

      パラメータ

      値

      説明

      [接続 ID]

      smtp_default

      固定値です。この値は変更しないでください。Airflow はデフォルトでこの ID を使用して SMTP の認証情報を取得します。

      [接続タイプ]

      SMTP

      SMTP を選択します。

      [Login]

      メールアドレス

      smtp.smtp_user の設定値と同じにする必要があります。

      [Password]

      メールパスワード

      メールアカウントのログインパスワード、またはアプリ固有のパスワード (認証コード)

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

    設定完了後、DAG で EmailOperator を使用するか、email_on_failure = True を設定してアラートメールをトリガーし、SMTP 設定が動作することを確認できます。