次の方法で共有

Eventstream にイベントハウスを宛先として追加する

この記事では、Microsoft Fabric イベント ストリームの Eventstream に宛先としてイベントハウスを追加する方法について説明します。

前提条件

  • 共同作成者以上のアクセス許可を使用して Fabric 容量ライセンス モード (または試用版ライセンス モード) でワークスペースにアクセスします。
  • 共同作成者以上のアクセス許可を持つ Fabric ワークスペース内で作成されたイベントハウスにアクセスします。

注記

eventstream では、次の種類を使用する場合、最大 11 個 の結合されたソースと宛先をサポートできます。

  • ソース: Azure Event Hubs、IoT Hub、およびカスタム エンドポイント。
  • 宛先: ダイレクト インジェストを使用したカスタム エンドポイントと Eventhouse。

上記の一覧に含まれていないソースまたは宛先、および既定のストリームに追加されていない宛先は、この制限にはカウントされません。

既定のストリームに Eventhouse の宛先を追加する

イベントハウスを宛先として追加するには、[直接インジェスト] と [インジェスト前のイベント処理] の 2 つのインジェスト モードから選択できます。

直接インジェスト モード

直接インジェスト モードでは、イベント データが処理されずにイベントハウスに直接取り込まれます。 ダイレクト インジェスト モードを使用して、Eventhouse の宛先を既定のストリームまたは派生ストリームに追加できます。

  1. Eventstream の [編集モード] で、リボンの [宛先の追加] を選択するか、キャンバスで [イベントの変換] または [宛先の追加] カードを選択してから、[イベントハウス] を選択します。

    [追加先] ドロップダウン リストで [Eventhouse] を選択したスクリーンショット。

  2. [イベントハウス] 画面で、[直接インジェスト] を選択します。

  3. 宛先名、ワークスペース、および選択したワークスペースから Eventhouse を入力します。

  4. [保存] を選択します。

    [イベントハウス] 構成画面のスクリーンショット。

  5. まだ接続していない場合は、新しいイベントハウスの宛先カードを Eventstream の出力に接続し、[発行] を選択します。

    [発行] ボタンが強調表示されたイベントストリームのスクリーンショット。

  6. [ライブ ビュー] で、Eventhouse 宛先ノードで [構成] を選択します。

    KQL データベースの転送先の [構成] ボタンが強調表示されている、発行済みのイベントストリームのスクリーンショット。

  7. Eventhouse が [データの取得] 画面に開きます。 KQL データベースの既存のテーブルを選択するか、[新しいテーブル] を選択 して、データをルーティングおよび取り込むための新しいテーブルを作成します。

  8. データ接続名を指定するか、入力した名前をそのまま使用して、[次へ] を選択します。 イベントストリームからデータをプルするには数分かかる場合があります。

    [次へ] ボタンが強調表示されている、KQL データベース変換先の [データの取得] 画面のスクリーンショット。

  9. [データの検査] 画面では、次のことができます。

    • 形式 を選択して、Eventhouse へのデータの送信方法をプレビューします。
    • [列の編集] を選択して、データの列を構成します。
    • [詳細設定] を選択して、含めるイベントを選択するか、マッピング オプションを選択します。

    [データの検査] 画面のデータ形式と詳細設定オプションを示すスクリーンショット。

  10. [列の編集] を選択すると、[列の編集] 画面で次のことができます。

    • 列を追加するには、[列の追加] を選択します。
    • マッピングするソース列を選択します。
    • 列にマッピング変換を適用します。
    • サンプル データ値を変更します。

    次に、[適用] を選択します。

    編集列画面のスクリーンショット。

  11. データの構成が完了したら、[データの検査] 画面で [完了] を選択します。

  12. [概要 画面で、定義したスキーマを含むテーブルや、eventstream と Eventhouse 間の接続など、データ インジェストの詳細と状態を確認します。 「選択 閉じるを押して、Eventhouse のセットアップを完了してください。」

    [閉じる] ボタンが強調表示されている [概要] 画面のスクリーンショット。

これで、ライブ ビューで、キャンバスに Eventhouse の宛先を表示できるようになりました。

ライブ ビューに表示された構成後の KQL データベース転送先を示すスクリーンショット。

インジェスト前イベント処理

インジェスト モードの前のイベント処理は、イベント データを Eventhouse に取り込む前に処理します。 このモードは、フィルター処理や集計などの演算子を適用して、インジェストの前または派生ストリームの後にデータを処理する場合に使用します。

  1. イベント ストリーム 編集モード で、演算子または派生ストリームにカーソルを合わせ、を選択して、Eventhouse選択します。

    演算子出力の +記号の選択と、KQL データベースの選択を示すスクリーンショット。

  2. [Eventhouse] 画面で、[インジェスト前イベント処理] が既に選択されています。 Eventhouse に関する残りの情報を入力し、[保存] を選択します。

    インジェストの前にイベントを処理のための KQL データベース構成画面のスクリーンショット。

  3. 新たに追加された Eventhouse 宛先を実装するには、[発行] を選択します。

    KQL データベースの転送先が追加された、編集モードのイベントストリームのスクリーンショット。

これらの手順を完了すると、Eventhouse を宛先とするイベントストリームを ライブビューで表示できます。

構成された KQL データベース イベント処理フローのライブ ビューのスクリーンショット。

派生ストリームに Eventhouse の送信先を追加する

派生ストリームに宛先として Eventhouse をシームレスに追加できるようになりました。この機能強化により、リアルタイムの分析とストレージのために、データをそのままルーティングしたり、Eventhouse に変換したりする際の柔軟性が向上します。

派生ストリームは、データの論理ストリームを参照します。 このストリームは、変換またはフィルターを既定のストリームに適用することによって作成されます。 派生ストリームは、特定のニーズに合わせて調整されたデータの精選されたサブセットを提供することで、データ管理と分析を強化します。 この更新プログラムを使用すると、次のことができます。

  • 高度なクエリと視覚化のために、派生ストリーム データを Eventhouse にルーティングします。
  • インジェストの前に 、優先インジェスト モード (直接インジェスト または イベント処理) を選択します。
  • 一貫性のあるセットアップ エクスペリエンスを維持する: 構成プロセスは、既定のストリームについて既に理解しているものを反映しているため、学習曲線はありません。
  1. eventstream の編集モードで、次の手順に従って Eventhouse 変換先を派生ストリームに追加します。

  • 派生ストリームから Eventhouse 宛先を選択します。

    派生ストリームから Eventhouse 変換先を追加する方法を示すスクリーンショット。

  • 優先インジェスト モードの構成を完了します。 セットアップ プロセスは、既定のストリームについて上記で説明したものと同じです。

    Eventhouse 目的地の構成を示すスクリーンショット。

注記

Eventstream を構成するときは、通常、ソース、変換ロジック、および変換先が一緒に追加されます。 既定では、Eventstream を発行すると、データ インジェストとデータ ルーティングの両方のバックエンド サービスがそれぞれ Now から開始されます。 ただし、データ インジェストはデータ ルーティングよりも高速に開始され、ルーティングが完全に初期化される前に一部のデータが Eventstream に取り込まれる可能性があります。 その結果、このデータは宛先にルーティングされない可能性があります。

一般的な例として、データベース変更データ キャプチャ (CDC) ソースがあります。初期スナップショット データの一部は、送信先にルーティングされずに Eventstream に残る可能性があります。

これを軽減するには、次の手順に従います。

  1. Eventhouse (インジェスト前のイベント処理) または Lakehouse 変換先を構成する場合は、データ ソースの追加後に [インジェストのアクティブ化] をオフにします。

    データ ソースの追加後に [取り込みのアクティブ化] を選択しない KQL データベースのスクリーンショット。

  2. Eventstream が発行された後、インジェストを手動でアクティブ化します。

  3. [カスタム時刻] オプションを使用して、以前のタイムスタンプを選択し、初期データが適切に処理およびルーティングされるようにします。

    KQL データベースの再開のスクリーンショット。 詳細については、「データ ストリームの一時停止と再開」を参照してください。

関連するコンテンツ

イベントストリームに他の宛先を追加する方法については、次の記事を参照してください。 イベントを宛先にルーティングする