ファブリック イベント ストリームのコンテンツに基づいてデータ ストリームをルーティングする (プレビュー)
この記事では,Microsoft Fabricのイベントストリームのコンテンツに基づいてイベントをルーティングする方法を示します。
Fabricのイベントストリームメインキャンバス内でコードを書かずに複雑なストリーム処理ロジックを作成するためのノーコードエディターを使用できます。 この機能を使用すると、データ ストリームをより簡単に調整、変換、管理できます。 ストリーム処理操作を設定したら、特定のスキーマとストリームデータに従って、さまざまな宛先にデータストリームをスムーズに送信できます。
重要
Fabric イベント ストリームの拡張機能は現在プレビュー段階です。
対応している操作
以下は、リアルタイムデータ処理でサポートされている操作のリストです。
集約： 単一の結果を返す値の列で計算を実行するSUM、AVG、MIN、MAX関数をサポートします。
展開： 配列値を展開し、配列内の値ごとに新しい行を作成します。
フィルター： 条件に基づいて、データストリームから特定の行を選択またはフィルタリングします。
グループ化： 一定の時間枠内のすべてのイベントデータを集約し、 1 つまたは複数の列をグループ化することができます。
フィールドの管理： フィールドや列のデータ型を追加、削除、または変更します。
結合： 同じ名前とデータ型の共有フィールドを持つ 2 つ以上のデータストリームを 1 つのデータストリームに接続します。 該当しないフィールドは削除されます。
結合: 2 つのストリーム間の一致条件に基づいて、2 つのストリームからのデータを結合します。
サポートされる転送先
サポートされる接続先は次のとおりです。
レイクハウス： この宛先では、レイクハウスに取り込む前にリアルタイムイベントを変換できます。 リアルタイム イベントは、Delta Lake 形式に変換してから、指定されたレイクハウス テーブルに保存します。 この宛先は、データ ウェアハウスのシナリオに役立ちます。
KQL データベース： Tこの宛先を使用すると、リアルタイム イベント データを KQL データベースに取り込み、強力な Kusto 照会言語 (KQL) を使用してデータのクエリと分析を行うことができます。 KQL Database のデータを使用すると、イベント データに関するより深い分析情報を取得し、豊富なレポートとダッシュボードを作成できます。
Reflex： この宛先を使用すると、リアルタイムのイベントデータを Reflex に直接接続できます。 Reflex は、データに接続し、条件を監視し、行動するために必要なすべての情報を含むインテリジェント エージェントの種類です。データが特定のしきい値に達したり、他のパターンに一致した場合、Reflex は自動的にユーザーへの警告や Power Automate ワークフローのキックオフなど、適切なアクションを実行します。
カスタムエンドポイント： この宛先を使用すると、リアルタイムイベントをカスタムアプリケーションに簡単にルーティングできます。 この宛先を使用すると、独自のアプリケーションをイベントストリームに接続し、イベントデータをリアルタイムで使用できます。 これは、Microsoft Fabric の外にある外部システムにリアルタイム データのエグレスを行いたい場合に便利です。
ストリーム： この宛先は、一連の操作 (派生ストリームとも呼ばれます) によって変換された既定の生のイベントストリームを表します。 作成したら、リアルタイム ハブからストリームを表示できます。
次の例は、3 つの異なる Fabric イベントストリーム変換先が、1 つのデータ ストリーム ソースに対して個別の関数を提供する方法を示しています。 1 つの KQL データベースは生データの保存用に指定され、2 つ目の KQL データベースはフィルター処理されたデータ ストリームの保持用として指定され、レイクハウスは集計値を保存するために使用されます。
コンテンツに基づいてデータ ストリームを変換およびルーティングするには「イベントストリームの編集と発行」の手順 に従って、データ ストリーム のストリーム処理ロジックの設計を開始します。