次の方法で共有

Eventstream にカスタム エンドポイントまたはカスタム アプリのソースを追加する

独自のアプリケーションを Eventstream に接続する場合は、カスタム エンドポイントまたはカスタム アプリをソースとして追加できます。 そうすれば、カスタム エンドポイントまたはカスタム アプリで公開されている接続エンドポイントを使って、独自のアプリケーションから Eventstream にリアルタイム イベントを送信できます。 また、Apache Kafka プロトコルがカスタム エンドポイントまたはカスタム アプリのオプションとして利用できるため、Apache Kafka プロトコルを使ってリアルタイム イベントを送信できます。

この記事では、カスタム エンドポイント ソースまたはカスタム アプリ ソースを Microsoft Fabric の Eventstream に追加する方法について説明します。

前提条件

開始する前に、eventstream が配置されているワークスペースにアクセスできることを確認します。 ワークスペースは 、ファブリック容量 または 試用版 モードである必要があります。

  • イベントストリームを編集してカスタム エンドポイント ソースを追加するには、共同作成者以上のアクセス許可が必要です。
  • Entra ID 認証を使用してアプリケーションを接続する場合は、メンバー以上のアクセス許可が必要です。

Entra ID 認証を使用している場合は、カスタム エンドポイントのマネージド ID に必要なアクセス許可があることを確認する必要もあります。 これを行うには、 管理ポータルで必要な設定を構成します。

  1. 右上隅にある [設定] (歯車アイコン) を選択します。

  2. [ガバナンスと分析情報] セクションで管理ポータルを選択します。

    [ガバナンスと分析情報] セクションの [管理ポータル] リンクの選択を示すスクリーンショット。

  3. 次のテナント設定をアクティブ化して、ワークスペース、接続、またはデプロイ パイプラインを作成するための Fabric API へのアクセス権をサービス プリンシパルに付与します。

    • [ テナント設定 ] ページの [ 開発者設定 ] セクションで、[ Fabric API を使用できるサービス プリンシパル ] オプションを展開します。
    • [有効] に切り替えます。
    • 組織全体に適用します。
    • を選択してを適用します。

    開発者設定を示すスクリーンショット。

  4. 他のすべての API にアクセスするには、このオプションを有効にします (新しいテナントでは既定で有効)。

    • 引き続き [ テナント設定 ] ページで、[ サービス プリンシパルによるプロファイルの作成と使用を許可する ] オプションを展開します。
    • [有効] に切り替えます。
    • 組織全体に適用します。
    • を選択してを適用します。

注

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

  • ソース: カスタム エンドポイント。
  • 宛先: カスタムエンドポイントとEventhouseでのダイレクトインジェスト。

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

ソースとしてカスタム アプリケーションを追加します

  1. カスタム エンドポイント ソースを追加するには、開始ページで [カスタム エンドポイントを使用する] を選びます。 または、既に発行済みの Eventstream があり、カスタム エンドポイント データをソースとして追加する場合は、編集モードに切り替えます。 リボンで、[ソースの追加]>[カスタム エンドポイント] を選びます。

    カスタム エンドポイントを使うオプションのスクリーンショット。

  2. [カスタム エンドポイント] ダイアログで、[ソース名] にカスタム ソースの名前を入力して、[追加] を選びます。

    カスタム エンドポイントを追加するダイアログのスクリーンショット。

  3. カスタム エンドポイント ソースを作成すると、編集モードのキャンバスで Eventstream にそれが追加されます。 カスタム アプリ ソースから新しく追加されたデータを実装するには、[発行] を選びます。

    [発行] ボタンが強調されている、編集モードの Eventstream を示すスクリーンショット。

注

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

  • ソース: カスタム エンドポイント。
  • 宛先: カスタムエンドポイントとEventhouseでのダイレクトインジェスト。

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

ソースとしてカスタム アプリケーションを追加します

  1. カスタム エンドポイント ソースを追加するには、開始ページで [カスタム エンドポイントを使用する] を選びます。 または、既に発行済みの Eventstream があり、カスタム エンドポイント データをソースとして追加する場合は、編集モードに切り替えます。 リボンで、[ソースの追加]>[カスタム エンドポイント] を選びます。

    カスタム エンドポイントを使うオプションのスクリーンショット。

  2. [ソースの追加] ページで、[スキーマの関連付けのアクティブ化] を選択し、[追加] を選択します。

    スキーマを関連付けるオプションを含むカスタム エンドポイント ソースのスクリーンショット。

  3. エディターで、スキーマ レジストリから新しいスキーマまたは既存のスキーマに関連付けるには、リボンの [ イベント スキーマの関連付け ] を選択します。

    リボンの [イベント スキーマの関連付け] ボタンが選択されている eventstream エディターのスクリーンショット。

  4. 既存のスキーマを使用するには、[ Choose from event schema registry]\(イベント スキーマ レジストリから選択\) を選択し、次の手順に従います。

    1. [ イベント スキーマの関連付け ] ウィンドウで、スキーマ レジストリからスキーマを選択します。 右側のウィンドウにイベント データ スキーマが表示されます。

    2. [ 選択] を選択 して、イベント スキーマをカスタム エンドポイントに関連付けます。

      スキーマ レジストリから選択されたスキーマを持つ [イベント スキーマの関連付け] ウィンドウのスクリーンショット。

    3. Eventstream エディターで、 eventstream タイルを選択します。 下部のウィンドウで、[ スキーマの関連付け ] タブに切り替えます。eventstream に関連付けられているスキーマが表示されることを確認します。

      Eventstream エディターのスクリーンショット。eventstream が選択され、[関連付けられたスキーマ] タブが強調表示されています。

  5. スキーマを作成するには、次のいずれかのオプションを使用します。

    • スキーマ JSON ファイルがある場合は、[ アップロード ] を選択してファイルをアップロードします。 サンプル ファイルについては、「 サンプル スキーマ ファイル 」セクションを参照してください。

      スキーマを作成するためのアップロード オプションを示すスクリーンショット。

    • [ 行の追加] を選択して、スキーマの作成を手動で開始します。 各行に対して、 フィールドの種類、 フィールド名を選択し、必要に応じて説明を入力 します。

      スキーマを手動で構築する方法を示すスクリーンショット。

    • JSON コードを入力してスキーマを作成するには、次の図に示すように [コード エディター] オプションを選択します。 メッセージが表示された場合: コード エディターを使用してスキーマを作成する場合は、UI ビルダーに切り替えることができないことに注意してください。 [編集] を選択します。

      スキーマをビルドするコード エディターを示すスクリーンショット。

      エディターに JSON コードを入力します。

      スキーマを構築するためのコード エディターの JSON コードを示すスクリーンショット。

[詳細] ペインでエンドポイントの詳細を取得する

カスタム エンドポイント ソースを作成した後は、そのデータをライブ ビューの視覚化に利用できます。

ライブ ビューの Eventstream を示すスクリーンショット。

[詳細] ペインには、[イベント ハブ]、[AMQP]、[Kafka] という 3 つのプロトコル タブがあります。 各プロトコル タブには、[基本] および [SAS キー認証] という 3 つのページがあります。 これらのページには、接続用の対応するプロトコルとともにエンドポイントの詳細が表示されます。

[基本] には、カスタム エンドポイントの名前、種類、状態が表示されます。

Eventstream ライブ ビューの [詳細] ペインの基本情報を示すスクリーンショット。

[SAS キー認証] ページには、接続キーに関する情報と、対応するキーが埋め込まれたサンプル コードへのリンクが表示されます。これを使って、イベントをイベントストリームにストリーミングできます。 [キー] ページに表示される情報はプロトコルによって異なります。

イベント ハブ

[イベント ハブ] タブの [SAS キー認証] ページには、イベント ハブの接続文字列に関連する情報が含まれています。 たとえば、[イベント ハブ名]、[共有アクセス キー名]、[主キー]、[セカンダリ キー]、[接続文字列 - 主キー]、[接続文字列 - セカンダリ キー] などの情報です。

Eventstream の [詳細] ペインのキー情報を示すスクリーンショット。

イベント ハブ形式は接続文字列の既定値であり、Azure Event Hubs SDK で動作します。 この形式を使用すると、Event Hubs プロトコルを使用して eventstream に接続できます。

イベント ハブ形式での接続文字列は、次の例のようになります。

Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

[サンプル コードの表示] ボタンを選択すると、イベント ハブの接続キーに関する必要な情報が含まれている、すぐに使用できる Java コードが表示されます。 それをコピーしてアプリケーションに貼り付けることで使用できます。

Eventstream ライブ ビューの [詳細] ペインのサンプル コードを示すスクリーンショット。

Advanced Message Queuing Protocol (AMQP) (アドバンスト メッセージ キュー プロトコル (AMQP))

AMQP 形式は、AMQP 1.0 プロトコルと互換性があります。これは、さまざまなプラットフォームおよび言語間の相互運用性をサポートする標準メッセージング プロトコルです。 この形式を使用すると、AMQP プロトコルを使用して eventstream に接続できます。

eventstream ライブ ビューの [詳細] ペイン上の AMQP キーを示すスクリーンショット。

[サンプル コードの表示] ボタンを選択すると、AMQP 形式で接続キー情報が含まれている、すぐに使用できる Java コードが表示されます。

eventstream ライブ ビューの [詳細] ペイン上の AMQP サンプル コードを示すスクリーンショット。

Kafka

Kafka 形式は、Apache Kafka プロトコルと互換性があります。Apache Kafka は、高スループットで待機時間の短いデータ処理をサポートする、よく使用されている分散ストリーミング プラットフォームです。 Kafka プロトコル形式の [SAS キー認証] の情報を使ってイベントストリームに接続し、イベントをストリーミングできます。

Eventstream ライブ ビューの [詳細] ペインの Kafka キーを示すスクリーンショット。

[サンプル コードの表示] ボタンを選択すると、Kafka 形式で必要な接続キーが含まれている、すぐに使用できる Java コードが表示されます。 それをコピーして使用できます。

eventstream ライブ ビューの [詳細] ペイン上の Kafka サンプル コードを示すスクリーンショット。

Kafka プロトコルでのカスタム エンドポイントの使用に関する明確なガイドについては、 このチュートリアルを参照してください。 カスタム エンドポイントと Kafka プロトコルを使用してイベントをストリーミングおよび使用するための詳細な手順について説明します。

注

  • アプリケーションのニーズと設定に適したプロトコル形式を選択し、接続文字列をコピーしてアプリケーションに貼り付けることができます。 サンプル コードを参照したり、コピーしたりすることもできます。そこでは、さまざまなプロトコルを使ってイベントを送受信する方法が示されています。
  • サンプル コードのビューを終了するには、[サンプル コードを非表示にする] を選択します。

スキーマを使用するように eventstream 宛先を設定する

現時点では、拡張機能 (スキーマのサポートなど) が有効になっているイベントストリームでは、Eventhouse、カスタム エンドポイント、および派生ストリーム変換先のみがサポートされています。 このセクションでは、イベントストリームに対して拡張機能 (スキーマ サポートなど) が有効になっている場合に Eventhouse 変換先を追加および構成する方法について説明します。

カスタムエンドポイント送信先のスキーマを構成する

  1. [ イベントの変換] または [宛先の追加] を選択し、[ カスタム エンドポイント] を選択します。

  2. [ カスタム エンドポイント ] ウィンドウで、通常どおり宛先の名前を指定します。

  3. [入力スキーマ] で、イベントのスキーマを選択します。 このフィールドは、イベントストリームのスキーマ サポートを有効にするときに入力する追加のフィールドです。

    [カスタム エンドポイント構成] ページを示すスクリーンショット。

    カスタム エンドポイントの送信先を構成する詳細な手順については、「 カスタム エンドポイントまたはカスタム アプリの宛先をイベントストリームに追加する」を参照してください。

イベントハウスの宛先に対するスキーマを設定する

  1. [ イベントの変換] または [宛先の追加] を選択し、[ Eventhouse] を選択します。
  2. [Eventhouse] ページで、次のスキーマ関連の設定を構成します。

    1. [入力スキーマ] で、ドロップダウン リストから 1 つ以上のスキーマを選択します。

      入力スキーマが選択された [Eventhouse 構成] ページを示すスクリーンショット。

      注

      Event Hubs ソースを構成するときに [ヘッダーによる動的スキーマ ] オプションを選択した場合は、ソースに対して複数のスキーマを構成し、それらを異なるプロパティとその値にマップしている可能性があります。

    2. [テーブルの作成方法] では、要件に応じてオプションのいずれかを選択します。すべてのスキーマを結合した 1 つのテーブル、またはスキーマごとに個別のテーブルを選択します。

      テーブルの作成方法を含む Eventhouse 構成ページを示すスクリーンショット。

    3. [ データの書き込み方法] で、次のいずれかのオプションを選択します。

      • ペイロードのみ: 抽出されたペイロード データをテーブルに書き込みます。 複数の入力スキーマがある場合、データは複数のテーブルに送信されます。

      • メタデータとペイロード: メタデータとペイロード データを 1 つのテーブルに書き込みます。 列の例: source 、 subject、 type、 dataなど。

        Eventhouse 構成ページと書き込みデータ オプションを示すスクリーンショット。

      Eventhouse 変換先を構成する詳細な手順については、「 Eventstream に Eventhouse 変換先を追加する」を参照してください。

関連するコンテンツ

サポートされているソースの一覧については、「イベント ソースをイベントストリームに追加する」を参照してください

  • Last updated on