建立一個簡單的 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
____()