AirFlowのDAGの基本的な作成方法
AirFlow は DAG の中に複数の Task を定義して処理を組み込むことができる。タスクを定義するには AirFlow のオペレータを 使用することで簡単に定義することができる。ここではBashOperatorとDummyOperatorを利用して DAG を作成する手順を解説していく。 尚、本記述は AirFlow は AWS にある MWAA で実装されている Ver.2.0.2 を想定する。 DAG の各種Operatorは AirFlow のバージョンによって若干異なるので詳細は公式ページの確認をおすすめします。 公式ページ...
AirFlowのDAG 定義パラメータ解説編
AirFlow での DAG の作成時に定義するパラメータについて解説していこうと思う。 DAG は Python で AirFlow ライブラリーを使用することで簡単に DAG を記述することができる。 以下のサンプルコードでは AirFlow の’DAG’クラスを import して使用し、DAG クラスのインスタンス生成時にパラメーターを定義して DAG を生成する。 尚、本記述は AirFlow は AWS にある...