共用方式為


快速入門:建立 Apache Airflow 作業

注意

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

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

必要條件

  • 在您的租用戶中啟用 Apache Airflow 作業。

注意

由於 Apache Airflow 作業處於預覽狀態,因此您必須透過租使用者管理員加以啟用。如果您已經看到 Apache Airflow 作業,您的租用戶系統管理員可能已經啟用它。

  1. 移至 [系統管理入口網站 -> 租用戶設定 -> Microsoft網狀架構下 -> 展開 [使用者可以建立和使用 Apache Airflow 作業 (預覽)] 區段。
  2. 選取套用

螢幕擷取畫面,其中顯示在租用戶中啟用 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。