シンプルな DAG を作成する
Airflow のコンポーネントを一通り確認し、実際に自分のワークフローを試してみることにしました。まずは、デフォルトのパラメーターを定義し、ワークフロー用の DAG オブジェクトを作成しましょう。
datetime オブジェクトはあらかじめインポートされています。
この演習はコースの一部です
Python で学ぶ Apache Airflow 入門
演習の手順
- Airflow の DAG オブジェクトをインポートしましょう。大文字と小文字が区別されることに注意してください。
- DAG デコレーターを定義し、DAG の名前を
example_etlにしましょう。 - コードファイルの末尾で DAG 関数を呼び出しましょう。
実践的なインタラクティブ演習
このサンプルコードを完成させて、この演習に挑戦してみましょう。
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()