注意
Apache Airflow 作業是由 Apache Airflow 提供電源。
Apache Airflow 是開放原始碼平臺,可用來以程序設計方式建立、排程及監視複雜的作業。 它可讓您定義一組稱為運算子的工作,這些運算子可以合併成有向非循環圖 (DAG) 代表資料管道。
Apache Airflow 作業提供簡單且有效率的方式來建立和管理 Apache Airflow 環境,讓您輕鬆大規模執行協調流程作業。 在本快速入門中,讓我們建立簡單的 Apache Airflow 作業,讓自己熟悉 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 中監視] 按鈕以監視這些檔案。