翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Amazon MWAA での Apache Airflow 構成オプションの使用

Apache Airflow 構成オプションは、Amazon Managed Workflows for Apache Airflow 環境に環境変数としてアタッチできます。推奨されるドロップダウンリストから選択するか、Amazon MWAA コンソールで Apache Airflow バージョンのカスタム設定オプションを指定できます。このトピックでは、使用可能な Apache Airflow 設定オプションと、これらのオプションを使用して環境の Apache Airflow 設定を上書きする方法について説明します。

前提条件

このページのステップを完了するには、以下のものが必要です。

仕組み

環境を作成すると、Amazon MWAA は Airflow 設定オプションの Amazon MWAA コンソールで指定した設定を環境変数として環境の AWS Fargate コンテナにアタッチします。airflow.cfg で同じ名前の設定を使用している場合は、Amazon MWAA コンソールで指定するオプションのほうが、airflow.cfg の値よりも優先されます。

デフォルトでは、Amazon MWAA 環境の Apache Airflow UI で airflow.cfg を公開しませんが設定を公開するための webserver.expose_config の設定など、Amazon MWAA コンソールで直接 Apache Airflow 構成オプションを変更できます。

設定オプションを使用したプラグインのロード

Apache Airflow v2 以降では、デフォルトで core.lazy_load_plugins : True設定を使用してプラグインが「遅延」ロードされるように設定されています。カスタムプラグインを使用している場合は、デフォルト設定を上書きするために、各 Airflow プロセスの開始時にプラグインをロードする Apache Airflow 設定オプションcore.lazy_load_plugins : Falseとして を追加する必要があります。

設定オプションの概要

Amazon MWAA コンソールで設定を追加すると、Amazon MWAA はその設定を環境変数として書き込みます。

Apache Airflow 構成オプション

次の図は、Amazon MWAA コンソールで Apache Airflow 設定オプションをカスタマイズできる場所を示しています。

Apache エアフローリファレンス

Apache Airflow でサポートされている設定オプションのリストについては、Apache Airflow リファレンスガイドの「設定リファレンス」を参照してください。Amazon MWAA で実行している Apache Airflow のバージョンのオプションにアクセスするには、ドロップダウンリストからバージョンを選択します。

Amazon MWAA コンソールの使用

以下の手順では、Airflow 構成オプションを環境に追加するステップを説明します。

設定リファレンス

以下のセクションでは、Amazon MWAA コンソールのドロップダウンリストに利用可能な Apache Airflow 設定のリストが表示されます。

電子メールの設定

次のリストは、Amazon MWAA for Apache Airflow v2 および v3 で使用できる Airflow E メール通知設定オプションを示しています。

SMTP トラフィックにはポート 587 を使用することをお勧めします。デフォルトでは、 はすべての Amazon EC2 インスタンスのポート 25 でアウトバウンド SMTP トラフィックを AWS ブロックします。ポート 25 でアウトバウンド・トラフィックを送信したい場合は、「この制限を解除するようリクエストする」ことができます。

タスクの設定

次のリストは、Amazon MWAA for Apache Airflow v2 および v3 の Airflow タスクのドロップダウンリストで使用可能な設定を示しています。

スケジューラーの設定

次のリストは、Amazon MWAA for Apache Airflow v2 および v3 のドロップダウンリストで使用できる Apache Airflow スケジューラ設定を示しています。

ワーカーの設定

次のリストは、Amazon MWAA for Apache Airflow v2 および v3 のドロップダウンリストで使用可能な Airflow ワーカー設定を示しています。

Webserver の設定

次のリストは、Amazon MWAA for Apache Airflow v2 および v3 のドロップダウンリストで使用できる Apache Airflow ウェブサーバー設定を示しています。

トリガー設定

次のリストは、Amazon MWAA for Apache Airflow v2 および v3 で使用できる Apache Airflow トリガーの設定を示しています。

例とサンプルコード

DAG の例

次の DAG を使用して email_backend Apache Airflow 構成オプションを印刷できます。Amazon MWAA イベントに応答して実行するには、Amazon S3 ストレージバケットにある環境の DAG フォルダにコードをコピーします。

from airflow.decorators import dag
				from datetime import datetime
				
				def print_var(**kwargs):
				email_backend = kwargs['conf'].get(section='email', key='email_backend')
				print("email_backend")
				return email_backend
				
				@dag(
				dag_id="print_env_variable_example",
				schedule_interval=None,     
				start_date=datetime(yyyy, m, d),
				catchup=False,
				)
				def print_variable_dag():
				email_backend_test = PythonOperator(
				task_id="email_backend_test",
				python_callable=print_var,
				provide_context=True
				)
				
				print_variable_test = print_variable_dag()

電子メール通知の設定例

アプリパスワードを使用する Gmail.com メールアカウントには、次の Apache Airflow 構成オプションを使用できます。詳細については、Gmail ヘルプリファレンスガイドの「アプリパスワードを使用してサインインする」を参照してください。

次のステップ