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