Python で DAG をスケジュールする
DAG の作成についてひととおり学びました。次は、特定の DAG を特定の曜日・時刻に実行するようスケジュールを設定しましょう。同僚が別のサーバーに DAG を再インストールする場合に備えて、スケジュール情報をコードに含めておくことが重要です。
Airflow の dag オブジェクトと必要な datetime メソッドはあらかじめインポートされています。
この演習はコースの一部です
Python で学ぶ Apache Airflow 入門
演習の手順
- DAG の開始日を 2025年11月1日に設定してください。
- cron 構文を使って、毎週水曜日の12:30にスケジュールを設定してください。
実践的なインタラクティブ演習
このサンプルコードを完成させて、この演習に挑戦してみましょう。
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()