分享方式


執行、排程或使用事件來觸發管線

當管線啟動並執行活動時,就會發生管線運行。

您可以透過三種方式啟動管線執行:

  • 隨選執行:在管線編輯器中選取 [執行] 以觸發立即執行。 您必須在管線開始之前儲存任何變更。

    顯示如何在 [首頁] 索引標籤上選取 [執行] 的螢幕擷圖。

  • 排程執行:根據時間和頻率設定自動執行。 建立排程時,您可以指定開始和結束日期、頻率和時區。

    螢幕擷取畫面顯示在「首頁」標籤上選取「排程」的位置。

  • 事件為基礎的執行:使用事件觸發程序在發生特定事件時啟動管線,例如到達資料湖中的新檔案或資料庫中的變更。

    螢幕擷取畫面顯示如何在首頁索引標籤上選取觸發條件,以新增事件性的執行觸發器。

隨選管線執行

若要手動觸發管線執行,請選取 [執行] 位於 [首頁] 索引標籤的頂部橫幅。

顯示如何在 [首頁] 索引標籤上選取 [執行] 的螢幕擷圖。

您也可以在首頁索引標籤的頂端橫幅中選取排程,然後選取立即執行以觸發立即執行。

螢幕擷取畫面顯示在「首頁」索引標籤上選取「排程」的位置,然後在排程器中選取「立即執行」按鈕。

在觸發管線執行之前,系統會提示您先儲存變更。 選取儲存並執行以繼續。

顯示儲存和執行提示的螢幕擷取畫面。

當您的變更儲存後,管線就會開始執行。 您可以在畫布底部的 [輸出] 索引標籤中查看運行的進度。

顯示 [輸出] 索引標籤上執行狀態顯示位置的螢幕快照。

一旦一項活動在執行過程中完成,其角落會出現綠色複選標記。

顯示綠色核取號位置的螢幕快照。

當整個管線執行並且輸出狀態更新為 成功時,您就已成功執行管線!

顯示 [輸出] 索引標籤中 [成功狀態] 顯示位置的螢幕快照。

排程的流程執行

當您排程管線執行時,您可以為每個管線設定多個特定排程,以便在需要時準備好資料並可供使用。

選取 [首頁] 索引標籤頂端橫幅中的 [排程],然後選取 [新增排程] 以檢視您的選項。 根據預設,您的管線不會按照排程運行。

螢幕擷取畫面顯示在「首頁」標籤上選取「排程」的位置。

在 [排程組態] 頁面上,您可以指定排程頻率、開始和結束日期和時間,以及時區。

提示

排程管線時,您必須同時設定開始和結束日期。 沒有開放式時間表的選項。 若要讓管線長期執行,請將結束日期設定為遙遠的未來 (例如, 01/01/2099 12:00 AM)。 您可以隨時更新或停止排程。

「排程」組態畫面的螢幕擷取畫面。

設定完成後,選取 儲存 以 設定您的排程。

您可以在儲存第一個排程之後,再次選取 [新增排程] ,為單一管線新增最多20個排程。 每個排程可以有不同的頻率以及開始和結束時間。

管理排程執行

您可以選取 排程 在首頁索引標籤的頂端橫幅中選取 排程。從那裡,您可以編輯現有的排程,或使用切換開關啟用或停用排程。

螢幕擷取畫面顯示您可以在排程功能表中切換或編輯排程執行的位置。

若要刪除排程,請選取您要刪除的排程旁邊的 [編輯] 圖示 (鉛筆)。 在 [編輯排程] 窗格中,選取窗格底部的 [刪除排程 ]。

顯示刪除按鈕的屏幕截圖可以在編輯窗口中找到。

以事件為基礎的流程執行

事件觸發器可讓您在發生特定事件時啟動管線,例如當檔案進入或從儲存體刪除時。 您可以從檔案事件、作業事件和工作區事件觸發管線。 如果您要從 Azure Data Factory 遷移,您會發現儲存事件很熟悉。

觸發程式會使用 Fabric 平臺功能,包括事件資料流程和資料啟動器警示。 您可以從管線畫布或直接在 Data Activator 經驗中建立觸發事件。

設置儲存事件觸發器

  1. 選取管線畫布頂端 首頁 功能區上的 觸發 按鈕。

    螢幕擷取畫面顯示管線畫布編輯器視窗的 [首頁] 功能區上的 [觸發器] 按鈕。

  2. 「設定警示」面板隨即開啟。 您可以在此處使用 Data Activator 警示服務定義觸發器的來源事件。 如有需要,您可以將值新增至參數。

    顯示 [設定警示] 面板的螢幕擷取畫面。

  3. 選取您要監聽的事件類型。 選擇 OneLake OneLake 檔案事件、Azure Blob 事件等。

    顯示 [選取資料來源] 對話方塊的螢幕擷取畫面。

  4. 選取 [ 來源 ],然後選取 [ 選取事件 ] 以挑選您要監視的儲存體事件。

    螢幕擷取畫面顯示 Azure Blob 儲存體帳戶中的 Blob 儲存體事件連線位置。

  5. 選擇您的 Azure 訂用帳戶和 Blob 儲存體帳戶。

  6. 系統會在 Fabric 工作區中建立新的事件資料流程物件。 在 [串流詳細資料] 底下選取正確的工作區。

  7. 選取 下一步

  8. 選擇事件類型。 除了建立檔案和刪除檔案之外,您還會看到許多事件選項。

    螢幕擷取畫面顯示觸發程式設定對話方塊的 [設定事件類型和來源] 頁面。

  9. 使用 [主旨] 欄位指定資料夾名稱、檔案名稱、檔案類型和容器,以篩選事件以符合特定檔案和資料夾。

    顯示篩選器設定頁面的螢幕擷取畫面。

    備註

    檔案名稱和資料夾名稱是 主旨 欄位的一部分。

    事件具有以下頂層資料:

    房產 類型 Description Example
    來源 字串 事件來源的完整資源路徑。 此欄位無法寫入。 事件方格會提供此值。 /subscriptions/{subscription-id}/resourceGroups/Storage/providers/Microsoft.Storage/storageAccounts/my-storage-account
    主題 字串 發行者定義的事件主旨路徑。 /blobServices/default/containers/my-file-system/blobs/new-file.txt
    型別 字串 此事件來源的其中一個已註冊事件類型。 Microsoft.Storage.Blob已建立
    time 字串 根據提供者的 UTC 時間產生事件的時間。 2017-06-26T18:41:00.9584103Z
    識別碼 字串 事件的唯一識別碼。 00000000-0000-0000-0000-000000000000
    資料 物件 Blob 儲存體事件資料。 {{資料物件}}
    spec版本 字串 CloudEvents 結構描述規格版本。 1.0
  10. 在觸發程式組態面板上,選擇要儲存觸發程式項目、管線名稱、管線動作的工作區,並將觸發程式命名為 Reflex 項目。

  11. 選取 [建立] 以建立觸發程式。 觸發器會在您的管線上啟動,並回應您所定義的儲存事件。

    顯示 [警示已建立] 通知的螢幕擷取畫面。

檢視和管理觸發程序

  1. 若要檢視觸發程序,請移至您的工作區清單,並在 Fabric 瀏覽器中依名稱尋找 Reflex 物件。

  2. 物件類型是 Reflex。 選取觸發程式以開啟 Reflex 物件以供檢視和編輯。

    顯示 Reflex 對象詳細信息的屏幕截圖。

  3. 若要查看屬於管線的一部分的觸發條件,請在管線功能表中選擇觸發器 檢視觸發條件

    顯示管理觸發規則窗格的螢幕擷取畫面。

在運算式中使用觸發檔案和資料夾名稱

您可以使用內建觸發參數,從管線中的儲存事件中獲取檔案名稱和資料夾路徑。 Data Factory 會在收到儲存體事件時設定這些參數。

在您的管線中選取運算式建構器上的觸發器參數索引標籤,Data Factory 會自動剖析檔案名稱和資料夾名稱,讓您動態地將它們新增至管線運算式。

顯示 新增動態內容 對話方塊的螢幕擷取畫面。

這些內建參數來自檔案事件的 [主旨 ] 和 [主題] 欄位,並為您的管線邏輯自動建立。

@pipeline()?.TriggerEvent?.FileName

請注意?物件參考之後的pipeline()。 這可以處理管道表達式語言中的 NULL 值。 測試使用觸發參數的管線時,您需要此語法,因為在手動測試期間,不會設定檔案和資料夾名稱參數,並傳回 Null 值。 當您從檔案事件觸發流程時,您會看到這些欄位中已填寫的檔案名稱和資料夾名稱。