共用方式為

根據 Fabric 事件串流中的內容路由資料流 （預覽）

  • 發行項

本文說明如何根據 Microsoft Fabric 事件數據流中的內容路由事件。

您現在可以在 Fabric 事件串流主要畫布中使用無程式代碼編輯器來建立複雜的串流處理邏輯，而不需要撰寫任何程式代碼。 這項功能可讓您更輕鬆地量身打造、轉換及管理數據流。 設定串流處理作業之後，您可以根據特定的架構和串流數據，順暢地將數據流傳送至不同的目的地。

重要

Fabric 事件數據流的增強功能目前為預覽狀態。

支援的作業

以下是支援即時資料處理的作業清單：

  • 匯總：支援對值數據行執行計算的總和、AVG、MIN 和 MAX 函式，並傳回單一結果。

  • 展開：展開陣列值，併為數位中的每個值建立新的數據列。

  • 篩選：根據條件，從數據流中選取或篩選特定數據列。

  • 分組依據：匯總特定時間範圍內的所有事件數據，以及將一或多個數據行分組的選項。

  • 管理欄位：新增、移除或變更數據流欄位或數據行的數據類型。

  • 聯集：連線 兩個或多個具有相同名稱和數據類型共用字段的數據流成一個數據流。 不相符的欄位會遭到捨棄。

  • 聯結：根據兩個數據流之間的相符條件結合數據。

支援的目的地

支援的目的地如下：

  • Lakehouse：此目的地可讓您在擷取到 Lakehouse 之前轉換即時事件。 即時事件會轉換成 Delta Lake 格式，然後儲存在指定的 Lakehouse 數據表中。 此目的地可協助處理數據倉儲案例。

  • KQL 資料庫：此目的地可讓您將即時事件數據內嵌至 KQL Database，您可以在其中使用功能強大的 Kusto 查詢語言 （KQL） 來查詢和分析數據。 透過 KQL 資料庫中的數據，您可以深入瞭解事件數據，並建立豐富的報表和儀錶板。

  • 反射：此目的地可讓您將即時事件數據直接連線到 Reflex。 Reflex 是一種智慧型手機的代理程式，其中包含連線到數據、監視條件和行動所需的所有資訊。當數據達到特定閾值或符合其他模式時，Reflex 會自動採取適當的動作，例如警示使用者或啟動 Power Automate 工作流程。

  • 自訂端點（前自定義應用程式）： 使用此目的地，您可以輕鬆地將即時事件路由傳送至自定義應用程式。 此目的地可讓您將自己的應用程式連線到事件串流，並即時取用事件數據。 當您想要將即時數據輸出至 Microsoft Fabric 外部的外部系統時，會很有用。

  • 數據流：此目的地代表由一系列作業轉換的預設原始事件串流，也稱為衍生數據流。 建立之後，您可以從即時中樞檢視數據流。

下列範例示範三個不同的 Fabric 事件數據流目的地如何為單一數據流來源提供個別的函式。 系統會指定一個 KQL 資料庫來儲存原始數據，第二個 KQL 資料庫用於保留篩選的數據流，而 Lakehouse 則用於儲存匯總值。

根據內容路由事件的螢幕快照。

若要根據內容轉換和路由處理數據流，請遵循編輯和發佈事件串流中的步驟，並開始設計數據流的串流處理邏輯。

相關內容