使用 Azure Blob 儲存體 匯入 DAG

注意

此功能處於公開預覽狀態。 工作流程協調流程管理員由 Apache Airflow 提供。

本文說明如何使用 Azure Blob 儲存體 將導向非循環圖表 （DAG） 匯入工作流程協調流程管理員的逐步指示。

必要條件

• Azure 訂用帳戶：如果您沒有 Azure 訂用帳戶，請在開始前先建立免費 Azure 帳戶。
• Azure Data Factory：在支援工作流程協調流程管理員預覽的區域中，建立或選取現有的 Data Factory 實例。
• Azure 儲存體 帳戶：如果您沒有記憶體帳戶，請參閱建立 Azure 儲存體 帳戶以取得建立帳戶的步驟。 確定記憶體帳戶只允許從選取的網路存取。

預覽期間不支援虛擬網路後置的 Blob 儲存體。 不支援 在中storageLinkedServices匯入 DAG 金鑰保存庫 設定。

匯入 DAG

1. 根據您設定的 Airflow 環境，複製範例 Apache Airflow v2.x DAG 或範例 Apache Airflow v1.10 DAG。 將內容貼到名為 tutorial.py 的新檔案中。

   將 tutorial.py 檔案上傳至 Blob 儲存體。 如需詳細資訊，請參閱 將檔案上傳至 Blob。

   注意

   您必須從 Blob 儲存體 帳戶中選取目錄路徑，其中包含名為 dags 的資料夾和外掛程式，以將它們匯入 Airflow 環境。 外掛程式並非必要專案。 您也可以有名為 dags 的 容器，並上傳其中的所有 Airflow 檔案。

2. 在 [管理中 樞] 底下，選取 [Apache Airflow]。 然後將滑鼠停留在先前建立 的 Airflow 環境上，然後選取 [ 匯入檔案 ] 以將所有 DAG 和相依性匯入 Airflow 環境。

   

3. 將新的連結服務建立至「必要條件」一節中所述的可存取記憶體帳戶。 如果您已經有自己的 DAG，您也可以使用現有的 DAG。

   

4. 使用您上傳 DAG 的記憶體帳戶。 （請參閱一節。測試連線，然後選取 [ 建立]。

   

5. 如果您使用範例 SAS URL，請瀏覽並選取 [空氣流 ]。 您也可以選取包含 DAG 檔案之 dags 資料夾的資料夾。

   注意

   您可以透過這個介面匯入 DAG 及其相依性。 您必須從 Blob 儲存體 帳戶中選取目錄路徑，其中包含名為 dags 和外掛程式的資料夾，以將這些資料夾匯入 Airflow 環境。 外掛程式並非必要專案。

   

   

6. 選取 [ 匯 入] 以匯入檔案。

   

   

在預覽期間，匯入 DAG 可能需要幾分鐘的時間。 您可以使用通知中心（Data Factory UI 中的鈴鐺圖示）來追蹤匯入狀態更新。