透過 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()