共用方式為


快速入門:建立 Apache Airflow 作業

注意

Apache Airflow 作業是由 Apache Airflow 提供電源。
Apache Airflow 是開放原始碼平臺,可用來以程序設計方式建立、排程及監視複雜的作業。 它可讓您定義一組稱為運算子的工作,這些運算子可以合併成有向非循環圖 (DAG) 代表資料管道。

Apache Airflow 作業提供簡單且有效率的方式來建立和管理 Apache Airflow 環境,讓您輕鬆大規模執行協調流程作業。 在本快速入門中,讓我們建立簡單的 Apache Airflow 作業,讓自己熟悉 Apache Airflow 作業的環境和功能。

建立 Apache Airflow 作業

  1. 您可以建立現有工作區,或建立新的工作區

  2. 展開+ New下拉式清單 -> 按兩下 [更多選項 ] - 下Data Factory一節 ->> 選取 [Apache Airflow 作業]

    螢幕擷取畫面,其中顯示按下更多選項。

    選取 Apache Airflow 作業的螢幕快照。

  3. 為專案提供適當名稱,然後按下 [建立] 按鈕。

建立 DAG 檔案

  1. 按下 [新增 DAG 檔案] 卡片 -> 提供檔案的名稱,然後按下「建立」按鈕。

    螢幕擷取畫面,其中顯示為 DAG 檔案命名。

  2. 會顯示樣板 DAG 程式代碼。 您可以根據需求編輯檔案。

    螢幕擷取畫面,其中顯示 Microsoft Fabric 中的樣板 DAG 檔案。

  3. 按下「儲存圖示」。

    螢幕擷取畫面,其中顯示如何在 Microsoft Fabric 中儲存 DAG 檔案。

執行 DAG

  1. 按下 [執行 DAG] 按鈕即可開始。

    螢幕擷取畫面,其中顯示從資料工作流程 UI 執行 DAG。

  2. 起始之後,便會顯示通知,指出 DAG 正在執行。

  3. 若要監視 DAG 執行的進度,只要按下通知中心中的 [檢視詳細資料] 即可。 此動作會將您重新導向至 Apache Airflow UI,您可以在其中輕鬆地追蹤 DAG 執行的狀態及詳細資料。

    螢幕擷取畫面,其中顯示從通知中心前往 Apache Airflow UI。

在 Apache Airflow UI 中監視 Apache Airflow DAG

已儲存的 DAG 檔案會載入 Apache Airflow UI 中。 您可以按下 [在 Apache Airflow 中監視] 按鈕以監視這些檔案。

螢幕擷取畫面,其中顯示監視 Airflow DAG。

螢幕擷取畫面,其中顯示已載入的 Airflow DAG。