根據 Fabric 事件串流中內容的路由資料流 (預覽版)
本文章顯示如何根據 Microsoft Fabric 事件串流中的內容路由事件。
您現在可以在 Fabric 事件串流主要創作區中使用無程式碼編輯器,來建立複雜的串流處理邏輯,而不需要撰寫任何程式碼。 這項功能可讓您更輕鬆地量身打造、轉換及管理資料流。 設定串流處理作業之後,您可以根據特定的架構和串流資料,順暢地將資料流傳送至不同的目的地。
重要
Fabric 事件串流的增強功能目前為預覽版。
支援的作業
以下是支援即時資料處理的作業清單:
匯總:支援對值資料行執行計算的總和、AVG、MIN 和 MAX 函式,並傳回單一結果。
展開:展開陣列值並在陣列中為每個值建立新的資料列。
篩選:根據條件,從資料流中選取或篩選特定資料列。
分組依據:匯總特定時間範圍內的所有事件資料,以及將一或多個資料行分組的選項。
管理欄位:新增、移除或變更資料流欄位或資料行的資料類型。
聯集:將兩個或多個具有相同名稱和資料類型之共用字段的資料流連接到一個資料流。 不相符的欄位會遭到捨棄。
聯結:根據兩個串流之間的比對條件來合併資料。
支援的目的地
支援的目的地為:
Lakehouse:此目的地可讓您在擷取到 Lakehouse 之前轉換即時事件。 即時事件轉換為 Delta Lake 格式,然後儲存在指定的 Lakehouse 資料表中。 此目的地可協助處理資料倉儲案例。
KQL 資料庫:此目的地可讓您將即時事件資料內嵌至 KQL Database,您可以在其中使用功能強大的 Kusto 查詢語言 (KQL) 來查詢和分析資料。 透過 KQL 資料庫中的資料,您可以深入瞭解事件資料,並建立豐富的報表和儀表板。
Reflex:此目的地可讓您將即時事件資料直接連線到 Reflex。 Reflex 是一種智慧型手機的代理程式,其中包含連線到資料、監視條件和行動所需的所有資訊。當資料達到特定閾值或符合其他模式時,Reflex 會自動採取適當的動作,例如警示使用者或啟動 Power Automate 工作流程。
自訂端點(前自訂應用程式): 使用此目的地,您可以輕鬆地將即時事件路由傳送至自訂應用程式。 此目的地可讓您將自己的應用程式連線到 Eventstream,並即時取用事件資料。 當您想要將即時資料輸出至 Microsoft Fabric 之外的外部系統時,這會很有用。
資料流:此目的地代表由一系列作業轉換的預設原始Eventstream,也稱為衍生資料流。 建立之後,您可以從即時中樞檢視資料流。
下列範例顯示三個不同的 Fabric Eventstream 目的地可以如何為單一資料流來源提供個別的函式。 系統會指定一個 KQL 資料庫來儲存原始資料,第二個 KQL 資料庫用於保留篩選的資料流,而 Lakehouse 則用於儲存匯總值。
若要根據內容轉換和路由處理資料流,請遵循編輯和發佈 Eventstream中的步驟,並開始設計資料流的串流處理邏輯。