快速入門:建立 Apache Airflow 作業
注意
Apache Airflow 作業是由 Apache Airflow 提供電源。
Apache Airflow 是開放原始碼平臺,可用來以程序設計方式建立、排程及監視複雜的作業。 它可讓您定義一組稱為運算子的工作,這些運算子可以合併成有向非循環圖 (DAG) 代表資料管道。
Apache Airflow 作業提供簡單且有效率的方式來建立和管理 Apache Airflow 環境,讓您輕鬆大規模執行協調流程作業。 在本快速入門中,讓我們建立簡單的 Apache Airflow 作業,讓自己熟悉 Apache Airflow 作業的環境和功能。
必要條件
- 在您的租用戶中啟用 Apache Airflow 作業。
注意
由於 Apache Airflow 作業處於預覽狀態,因此您必須透過租使用者管理員加以啟用。如果您已經看到 Apache Airflow 作業,您的租用戶系統管理員可能已經啟用它。
- 移至 [系統管理入口網站 -> 租用戶設定 -> Microsoft網狀架構下 -> 展開 [使用者可以建立和使用 Apache Airflow 作業 (預覽)] 區段。
- 選取套用。
建立 Apache Airflow 作業
您可以建立現有工作區,或建立新的工作區。
展開
+ New
下拉式清單 -> 按兩下 [其他選項 -> 在區段下Data Factory
-> 選取 Apache Airflow 作業 (預覽)為專案提供適當名稱,然後按下 [建立] 按鈕。
建立 DAG 檔案
執行 DAG
按下 [執行 DAG] 按鈕即可開始。
起始之後,便會顯示通知,指出 DAG 正在執行。
若要監視 DAG 執行的進度,只要按下通知中心中的 [檢視詳細資料] 即可。 此動作會將您重新導向至 Apache Airflow UI,您可以在其中輕鬆地追蹤 DAG 執行的狀態及詳細資料。
在 Apache Airflow UI 中監視 Apache Airflow DAG
已儲存的 DAG 檔案會載入 Apache Airflow UI 中。 您可以按下 [在 Apache Airflow 中監視] 按鈕以監視這些檔案。