當管線啟動並執行活動時,就會發生管線運行。
您可以透過三種方式啟動管線執行:
隨選執行:在管線編輯器中選取 [執行] 以觸發立即執行。 您必須在管線開始之前儲存任何變更。
排程執行:根據時間和頻率設定自動執行。 建立排程時,您可以指定開始和結束日期、頻率和時區。
以事件為基礎的執行:使用事件觸發程序在發生特定事件時啟動管線,例如到達資料湖中的新檔案或資料庫中的變更。
隨選管線執行
若要手動觸發管線執行,請選取 [執行] 位於 [首頁] 索引標籤的頂部橫幅。
您也可以在首頁索引標籤的頂端橫幅中選取排程,然後選取立即執行以觸發立即執行。
在觸發管線執行之前,系統會提示您先儲存變更。 選取儲存並執行以繼續。
當您的變更儲存後,管線就會開始執行。 您可以在畫布底部的 [輸出] 索引標籤中查看運行的進度。
一旦一項活動在執行過程中完成,其角落會出現綠色複選標記。
當整個管線執行並且輸出狀態更新為 成功時,您就已成功執行管線!
排程的流程執行
當您排程管線執行時,您可以為每個管線設定多個特定排程,以便在需要時準備好資料並可供使用。
選取 [首頁] 索引標籤頂端橫幅中的 [排程],然後選取 [新增排程] 以檢視您的選項。 根據預設,您的管線不會按照排程運行。
在 [排程組態] 頁面上,您可以指定排程頻率、開始和結束日期和時間,以及時區。
提示
排程管線時,您必須同時設定開始和結束日期。 沒有開放式時間表的選項。 若要讓管線長期執行,請將結束日期設定為遙遠的未來 (例如, 01/01/2099 12:00 AM)。 您可以隨時更新或停止排程。
設定完成後,選取 儲存 以 設定您的排程。
您可以在儲存第一個排程之後,再次選取 [新增排程] ,為單一管線新增最多20個排程。 每個排程可以有不同的頻率以及開始和結束時間。
管理排程執行
您可以選取 排程 在首頁索引標籤的頂端橫幅中選取 排程。從那裡,您可以編輯現有的排程,或使用切換開關啟用或停用排程。
若要刪除排程,請選取您要刪除的排程旁邊的 [編輯] 圖示 (鉛筆)。 在 [編輯排程] 窗格中,選取窗格底部的 [刪除排程 ]。
以事件為基礎的流程執行
事件觸發器可讓您在發生特定事件時啟動管線,例如當檔案進入或從儲存體刪除時。 您可以從檔案事件、作業事件和工作區事件觸發管線。 如果您要從 Azure Data Factory 遷移,您會發現儲存事件很熟悉。
觸發程式會使用 Fabric 平臺功能,包括事件資料流程和資料啟動器警示。 您可以從管線畫布或直接在 Data Activator 經驗中建立觸發事件。
設置儲存事件觸發器
選取管線畫布頂端 首頁 功能區上的 觸發 按鈕。
「設定警示」面板隨即開啟。 您可以在此處使用 Data Activator 警示服務定義觸發器的來源事件。 如有需要,您可以將值新增至參數。
選取您要監聽的事件類型。 選擇
OneLakeOneLake 檔案事件、Azure Blob 事件等。
選取 [ 來源 ],然後選取 [ 選取事件 ] 以挑選您要監視的儲存體事件。
選擇您的 Azure 訂用帳戶和 Blob 儲存體帳戶。
系統會在 Fabric 工作區中建立新的事件資料流程物件。 在 [串流詳細資料] 底下選取正確的工作區。
選取 下一步。
選擇事件類型。 除了建立檔案和刪除檔案之外,您還會看到許多事件選項。
使用 [主旨] 欄位指定資料夾名稱、檔案名稱、檔案類型和容器,以篩選事件以符合特定檔案和資料夾。
備註
檔案名稱和資料夾名稱是 主旨 欄位的一部分。
事件具有以下頂層資料:
房產 類型 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 在觸發程式組態面板上,選擇要儲存觸發程式項目、管線名稱、管線動作的工作區,並將觸發程式命名為 Reflex 項目。
選取 [建立] 以建立觸發程式。 觸發器會在您的管線上啟動,並回應您所定義的儲存事件。
檢視和管理觸發程序
若要檢視觸發程序,請移至您的工作區清單,並在 Fabric 瀏覽器中依名稱尋找 Reflex 物件。
物件類型是 Reflex。 選取觸發程式以開啟 Reflex 物件以供檢視和編輯。
若要查看屬於管線的一部分的觸發條件,請在管線功能表中選擇
觸發器 檢視觸發條件 。
在運算式中使用觸發檔案和資料夾名稱
您可以使用內建觸發參數,從管線中的儲存事件中獲取檔案名稱和資料夾路徑。 Data Factory 會在收到儲存體事件時設定這些參數。
在您的管線中選取運算式建構器上的觸發器參數索引標籤,Data Factory 會自動剖析檔案名稱和資料夾名稱,讓您動態地將它們新增至管線運算式。
這些內建參數來自檔案事件的 [主旨 ] 和 [主題] 欄位,並為您的管線邏輯自動建立。
@pipeline()?.TriggerEvent?.FileName
請注意?物件參考之後的pipeline()。 這可以處理管道表達式語言中的 NULL 值。 測試使用觸發參數的管線時,您需要此語法,因為在手動測試期間,不會設定檔案和資料夾名稱參數,並傳回 Null 值。 當您從檔案事件觸發流程時,您會看到這些欄位中已填寫的檔案名稱和資料夾名稱。