活動是可協助您在 Microsoft Fabric 中建立端對端數據工作流程的建置組塊。 你可以將這些任務視為處理和轉換數據以滿足您的業務需求的工作。 您可以使用複製活動將資料從 SQL Server 移至 Azure Blob 記憶體。 然後,您可以新增數據流活動或 Notebook 活動,以在將數據載入 Azure Synapse Analytics 以進行報告之前處理和轉換該數據。
活動被分組在管道中,以達成特定的目標。 例如,您可以建立管線,以便:
- 從不同來源提取記錄數據
- 清理及組織該數據
- 執行分析以尋找洞察
將您的活動分組到管線,可讓您將所有這些步驟當作一個單位來管理,而不是個別處理每個活動。 您可以一次部署和排程整個管線,以在需要時執行。
Microsoft Fabric 提供三種類型的活動:
資料移動活動
這些活動可協助您將資料從管線中的一個位置移至另一個位置。
| 運動活動 | Description |
|---|---|
| 複製資料 | 您可以將資料從任何支援的來源複製到任何支援的目的地。 請參閱 連接器概觀 ,以查看可用的內容。 |
| 複製作業 | 複製工作是快速移動資料的簡化方法。 |
如果您需要在不同的資料移動選項之間進行選擇,請參閱 資料移動決策指南 一文。
資料轉換活動
這些活動可協助您處理和轉換數據。 您可以個別使用它們,或將它們與其他活動鏈結在一起。
如需詳細資訊,請參閱資料轉換活動一文。
| 資料轉換活動 | 運算環境 |
|---|---|
| 複製資料 | Fabric 的計算管理器 |
| 資料流程 Gen2 | Fabric 的計算管理器 |
| 刪除資料 | Fabric 的計算管理器 |
| Fabric筆記本 | 由 Fabric 管理的 Apache Spark 叢集 |
| HDInsight 活動 | 由 Fabric 管理的 Apache Spark 叢集 |
| Spark 作業定義 | 由 Fabric 管理的 Apache Spark 叢集 |
| 預存程序 | Azure SQL、Azure Synapse Analytics 或 SQL Server |
| SQL 指令碼 | Azure SQL、Azure Synapse Analytics 或 SQL Server |
控制流程活動
這些活動可協助您控制管線的執行方式:
| 控制活動 | Description |
|---|---|
| 附加變數 | 將值新增至現有的陣列變數。 |
| 審批活動 | 暫停管線執行,並向指定審查者請求批准或拒絕決定。 |
| Azure Batch 活動 | 執行 Azure Batch 指令碼。 |
| Azure Databricks 活動 | 執行 Azure Databricks 作業 (Notebook、Jar、Python)。 |
| Azure Machine Learning 活動 | 執行 Azure Machine Learning 作業。 |
| 停用活動 | 停用另一個活動。 |
| Fail | 導致管線執行失敗,並出現自訂錯誤訊息和錯誤碼。 |
| Filter | 將篩選條件運算式套用至輸入陣列。 |
| ForEach | ForEach 活動會定義管線中重複的控制流程。 此活動用於逐一查看整個集合,然後以迴圈執行指定的活動。 此活動的迴圈實作與程式設計語言中的 Foreach 迴圈結構相似。 |
| 功能活動 | 執行 Azure 函數。 |
| 取得中繼資料 | GetMetadata 活動可用於擷取 Data Factory 或 Azure Synapse 管線中任何資料的元資料。 |
| 如果條件 | 「If 條件」可用於根據評估結果為 true 或 false 的情況進行分支。 If 條件活動所提供的功能,與 If 陳述式在程式設計語言中提供的功能相同。 它能在條件評估為 true 時執行一系列的活動,並在條件評估為 false 時執行另一系列的活動。 |
| 啟動管線 | 執行管線活動允許資料工廠或 Azure Synapse 管線呼叫另一條管線。 |
| KQL 活動 | 在 Kusto 執行個體上執行 KQL 指令碼。 |
| 湖畔屋維護活動 | 在 Fabric 管線中對 Lakehouse 執行例行資料表維護。 |
| 查找活動 | 「查閱活動」可用於讀取或查閱任何外部來源的記錄/資料表名稱/值。 此輸出可供後續活動進一步參考。 |
| 刷新實體化湖景活動 | 刷新湖畔別墅中具體化的湖景,以反映最新數據。 |
| 刷新 SQL 分析端點活動 | 刷新 lakehouse SQL 分析端點以反映最新資料。 |
| 設定變數 | 設定現有變數的值。 |
| 切換活動 | 實作 switch 運算式,允許針對運算式的每個潛在結果執行多個後續活動。 |
| Teams 活動 | 在 Teams 頻道或群組聊天中張貼訊息。 |
| 直到活動 | 實作類似於程式語言中 do-until 迴圈結構的 do-until 迴圈。 它會以迴圈的方式執行一系列活動,直到與該活動相關聯的條件評估為 True 為止。 您可以為「Until」活動指定逾時值。 |
| 等待活動 | 當你在管線中使用等待活動時,該管線會等待指定時間後才繼續執行後續的活動。 |
| 網路活動 | 網頁活動可以用來從管線呼叫自訂的 REST 端點。 |
| Webhook 活動 | 使用 Webhook 活動,呼叫端點並傳遞回呼 URL。 管線執行會等候回呼被調用,再繼續至下一個活動。 |
使用 Microsoft Fabric UI 將活動新增到管線中
以下是如何在管線中新增和設定活動:
- 在工作區中建立新的管線。
- 前往 活動 標籤,瀏覽可用的活動。 向右卷動以查看所有選項,然後選取活動以將它新增至管線編輯器。
- 當您新增活動並在畫布上選取它時,您會在下方的屬性窗格中看到其 [一般 ] 設定。
- 每個活動在屬性窗格中的其他索引標籤上有其他組態選項。
螢幕擷取畫面顯示管線編輯器,突出[活動]索引標籤、工具列、複製活動,以及其屬性的[一般]索引標籤。
一般設定
當您將新活動新增至管線並加以選取時,您會在畫面底部看到其屬性。 這些包括一般、設定,有時還有其他索引標籤。
每個活動都包含一般設定中的 [名稱 ] 和 [ 描述] 欄位。 某些活動也有下列選項:
| Setting | Description |
|---|---|
| Timeout | 活動可以在逾時之前執行多久。默認值為 12 小時,最大值為 7 天。 使用 D.HH:MM:SS 格式。 |
| 啟用重試 | 選擇後,活動失敗時會自動重試。 |
| Retry | 如果活動失敗,重試次數。 預設值為 1。 |
| 重試條件(預覽) | 設定觸發重試的特定錯誤條件。 |
| 重試間隔(秒) | 重試嘗試之間要等候的秒數。 預設值為 30 秒。 |
| (進階屬性) 安全輸出 | 選取時,活動輸出不會出現在記錄中。 |
| (進階屬性) 安全輸入 | 選取時,活動輸入不會出現在記錄中。 |
Note
根據預設,每個管線最多可以有120個活動。 這包括容器的內部活動。
重試一個活動
當某項活動在管線執行時失敗,你可以設定它自動重試,再標記執行為失敗。 此功能對於處理網路逾時、暫時性服務無法使用或間歇性連線問題等暫時性錯誤非常有用。
在此處進一步了解重試設定以及如何設定重試。
停用活動
在驗證和管線執行期間,你可以停用管線中的一個或多個活動,以便跳過它們。 此功能提升了管線開發者的效率,讓你能註解部分管線內容,而不必從畫布中刪除。 你可以在之後重新啟動活動。
停用活動
停用活動有兩種方式:從其「一般」標籤中停用單一活動,或用右鍵關閉多個活動。
在下一次排程管線執行時,保存變更以停用這些活動。
停用單一活動
- 選擇你想停用的活動
- 在一般標籤中,將活動狀態選為停用
- 選擇一個狀態來將活動標記為。 可選擇 成功、 失敗 或 跳過
停用多項活動
- 按下 Ctrl 鍵可多選。 用滑鼠,左鍵點擊所有想停用的活動
- 按下滑鼠右鍵以顯示下拉選單
- 選擇 停用 以停用所有
- 若要微調 [將活動標示為] 的設定,請移至活動的 [一般] 索引標籤,並進行適當的變更
重新啟動活動
要重新啟用活動,選擇活動狀態為「啟用」,活動就會回復到先前的行為,如預期。
非活躍的活動行為
非作用中的活動在管線中的行為會不同。
在畫布上,非作用中活動呈現灰色,而活動類型旁邊則會有 非作用中符號
在畫布上,方塊上會有狀態符號 ([成功]、[失敗] 或 [略過]),以視覺化 [將活動標示為] 設定
從管線驗證中排除了該活動。 因此,您不需要提供非作用中活動的所有必要欄位。
在偵錯運行和管線運行期間,活動不會實際執行。 相反地,它會執行一個佔位符行項目,其保留狀態為[非作用中]
分支選項由 [將活動標示為] 選項所控制。 換句話說:
- 如果您將活動標示為成功,則會執行UponSuccess或UponCompletion分支。
- 如果您將活動標記為失敗,則將執行UponFailure或UponCompletion分支
- 如果您將活動標示為 Skipped,則會執行 UponSkip 分支
停用的最佳實務
取消功能是管線開發者的重要工具。 它可讓開發人員「註解化」部分程式碼,而不會永久刪除活動。 在下列案例中,它大放異彩:
- 開發管線時,開發人員可以在填入所有必要的欄位之前,新增佔位符非活躍活動。 例如,我需要一個從 SQL Server 複製到資料倉儲的複製活動,但我還沒有完成所有連線設定。 因此,我會使用 [不啟用] 複製活動作為反覆開發流程的佔位符。
- 部署之後,開發人員可以註解化某些持續造成麻煩的活動,以避免成本高昂的重試。 例如,我的內部部署 SQL Server 發生網路連線問題,而我知道我的複製活動在某些情況下會失敗。 我可能想要停用複製活動,以避免重複的請求淹沒脆弱的系統。
Note
非作用中活動永遠不會實際執行。 這表示活動不會有錯誤欄位或其一般輸出欄位。 遺漏欄位的任何引用可能會在後續流程中引發錯誤。