注
Apache Airflow ジョブは Apache Airflow を活用しています。
Apache エアフロー は、プログラムによって複雑なジョブを作成、スケジュール、監視するために使用されるオープンソースプラットフォームです。 これにより、パイプラインを表すために有向非環式グラフ (DAG) に組み合わせることができる、演算子と呼ばれる一連のタスクを定義できます。
Apache Airflow ジョブは、Apache Airflow 環境を簡単かつ効率的に作成および管理する方法を提供します。これにより、オーケストレーション ジョブを簡単に大規模に実行できます。 このクイック スタートでは、Apache Airflow ジョブの環境と機能を理解するための単純な Apache Airflow ジョブを作成しましょう。
Apache Airflow ジョブを作成する
既存のワークスペースを使用するか、新しいワークスペースを作成することができます。
[+ 新しい項目] ドロップダウンを展開し、[Data Factory] セクションで [Apache エアフロー ジョブ] を選択します
プロジェクトに適切な名前を付け、[ 作成 ] ボタンを選択します。
DAG ファイルを作成する
[新しい DAG ファイル] カードを選択し、ファイルに名前を付けて、[作成] を選択します。
定型 DAG コードが表示されます。 ファイルは、実際の要件に応じて編集することができます。
保存 を選択します。
DAG を実行する
まず、[ DAG の実行 ] ボタンを選択します。
開始されると、DAG が実行されていることを示す通知が表示されます。
DAG 実行の進行状況を監視するには、通知センター内の [詳細の表示 ] を選択します。 このアクションにより Apache Airflow UI にリダイレクトされます。この UI を使用すると、DAG 実行の状態と詳細を簡単に追跡できます。
Apache Airflow UI で Apache Airflow DAG を監視する
保存された dag ファイルは、Apache Airflow UI に読み込まれます。 Apache エアフローのモニター ボタンをクリックすると 、それらを監視 できます。
