Airflow DAGs

在 Airflow 中，管線（pipeline）以有向無環圖（Directed Acyclic Graph，簡稱 DAG）來表示。圖中的節點代表要執行的工作（task），節點之間的有向連線代表工作之間的相依關係。

把資料管線表示成 DAG 很合理，因為有些工作需要先完成，後續的工作才能開始。你可以把它想成汽車工廠的生產線。工作一步步累積，每個工作都可能相依於前一個或多個已完成的工作。一個虛構的 DAG 可能長這樣：

Example DAG

先組裝車架，接著是車身與輪胎，最後再進行烤漆。我們來用程式碼重現上面的範例。

本練習屬於課程

Data Engineering 入門

檢視課程

動手互動練習

試著完成這個範例程式碼，體驗一下這個練習。

# Create the DAG
@dag(dag_id="car_factory_simulation",
     start_date=datetime(2024, 1, 1),
     schedule="____")
def car_factory_simulation():
    pass

# Run the DAG
car_factory_simulation()

編輯並執行程式碼