活動概觀
本文將協助了解 Microsoft Fabric 中的和活動,並使用這些項目來為資料移動和資料處理案例建構端對端的資料導向工作流程。
概觀
Microsoft Fabric 工作區可以有一或多個管線。 管線是共同執行一項工作的多個活動邏輯群組。 例如,管線可能包含內嵌和清理記錄資料的一組活動,然後啟動對應資料流程來分析記錄資料。 管線可供以集合而不是個別的方式來管理活動。 您可部署和排程管線,而不是個別的活動。
管線中活動會定義要對資料執行的動作。 例如,您可以使用複製活動將資料從 SQL Server 複製到 Azure Blob 儲存體。 然後,使用 Dataflow 活動或筆記本活動來處理 Blob 儲存體中的資料,並將其轉換成 Azure Synapse Analytics 集區,來作為建置商業智慧報表解決方案的基礎。
Microsoft Fabric 有三種類型的活動︰資料移動活動、資料轉換活動,以及控制活動。
資料移動活動
Microsoft Fabric 中的複製活動會將資料從來源資料存放區複製到接收器資料存放區。 <連接器概觀>一文中提供了支援的資料存放區清單。 可將來自任何來源的資料寫入任何接收器。
如需詳細資訊,請參閱<如何使用複製活動複製資料>。
資料轉換活動
Microsoft Fabric 支援下列轉換活動,這些活動可個別新增或與其他活動鏈結新增。
如需詳細資訊,請參閱資料轉換活動一文。
資料轉換活動 | 計算環境 |
---|---|
複製資料 | Microsoft Fabric 的計算管理員 |
Dataflow Gen2 | Microsoft Fabric 的計算管理員 |
刪除資料 | Microsoft Fabric 的計算管理員 |
Fabric 筆記本 | 由 Microsoft Fabric 管理的 Apache Spark 叢集 |
HDInsight 活動 | 由 Microsoft Fabric 管理的 Apache Spark 叢集 |
Spark 工作定義 | 由 Microsoft Fabric 管理的 Apache Spark 叢集 |
預存程序 | Azure SQL、Azure Synapse Analytics 或 SQL Server |
SQL 指令碼 | Azure SQL、Azure Synapse Analytics 或 SQL Server |
控制流程活動
支援下列的控制流程活動:
控制活動 | 描述 |
---|---|
附加變數 | 將值新增至現有的陣列變數。 |
Azure Batch 活動 | 執行 Azure Batch 指令碼。 |
Azure Databricks 活動 | 執行 Azure Databricks 作業 (Notebook、Jar、Python)。 |
Azure Machine Learning 活動 | 執行 Azure Machine Learning 作業。 |
停用活動 | 停用另一個活動。 |
失敗 | 導致管線執行失敗,並出現自訂錯誤訊息和錯誤碼。 |
Filter | 將篩選條件運算式套用至輸入陣列。 |
ForEach | ForEach 活動會定義管線中重複的控制流程。 此活動用於逐一查看整個集合,然後以迴圈執行指定的活動。 此活動的迴圈實作與程式設計語言中的 Foreach 迴圈結構相似。 |
函數活動 | 執行 Azure 函數。 |
取得中繼資料 | GetMetadata 活動可以用來擷取 Data Factory 或 Synapse 管線中任何資料的中繼資料。 |
If 條件 | 「If 條件」可用於根據評估為 True 或 False 的條件進行分支。 If 條件活動所提供的功能,與 If 陳述式在程式設計語言中提供的功能相同。 它能在條件評估為 true 時執行一系列的活動,並在條件評估為 false 時執行另一系列的活動。 |
叫用管線 | 執行管線活動允許 Data Factory 或 Synapse 管線叫用另一個管線。 |
KQL 活動 | 針對 Kusto 執行個體執行 KQL 指令碼。 |
查閱活動 | 「查閱活動」可用於讀取或查閱任何外部來源的記錄/資料表名稱/值。 此輸出可供後續活動進一步參考。 |
設定變數 | 設定現有變數的值。 |
Switch 活動 | 實作 switch 運算式,允許針對運算式的每個潛在結果執行多個後續活動。 |
Teams 活動 | 在 Teams 頻道或群組聊天中張貼訊息。 |
Until 活動 | 實作 Do-Until 迴圈,類似於程式設計語言中的 Do-Until 迴圈結構。 它會以迴圈的方式執行一系列活動,直到與該活動相關聯的條件評估為 True 為止。 您可以指定 Until 活動的逾時值。 |
Wait 活動 | 在管線中使用 Wait (等待) 活動時,管線便會等待指定的時間,然後再繼續執行後續的活動。 |
網路活動 | 使用網路活動可以從管線呼叫自訂的 REST 端點。 |
Webhook 活動 | 使用 Webhook 活動,呼叫端點並傳遞回呼 URL。 管線執行會等候要叫用的回呼,然後再繼續進行下一個活動。 |
使用 Microsoft Fabric UI 將活動新增至管線
使用這些步驟在 Microsoft Fabric 管線中新增和設定活動:
- 在工作區中建立新的管線。
- 在管線的 [活動] 索引標籤,瀏覽顯示的活動,視需要捲動至右側查看所有活動。 選取活動將其新增至管線編輯器。
- 在管線編輯器畫布中新增活動並加以選取時,其 [一般] 設定會出現在畫布下方的屬性窗格中。
- 每個活動還包含屬性窗格中其它索引標籤上特定於其組態的自訂屬性。
一般設定
將新活動新增至管線並加以選取時,會在畫面的底部區域中看到其屬性窗格。 這些屬性窗格也包括 [一般]、 [設定] 和其他窗格。
[一般] 設定一律會包含 每個活動的 [名稱] 和 [描述] 欄位。 有時活動可以包括以下各項:
設定 | 描述 |
---|---|
Timeout | 活動可以執行的最長時間。 預設時間為 12 小時,而允許的時間上限為 7 天。 逾時的格式為 D.HH:MM:SS。 |
重試 | 重新嘗試次數的上限。 |
(進階屬性) 重試間隔 (秒) | 每次重新嘗試間隔的秒數。 |
(進階屬性) 安全輸出 | 核取時,活動輸出不會擷取至記錄。 |
(進階屬性) 安全輸入 | 核取時,活動輸入不會擷取至記錄。 |
注意
每個管道的預設軟性限制活動數目上限為 80 個,包含容器的內部活動。