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

前提条件

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

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

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

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

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

   

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

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

   

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

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

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

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

   

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

   

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

   

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

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

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

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

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

イベント ハブ

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

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

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

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

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

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

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

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

カフカ

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

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

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

• サンプル コードのビューを終了するには、[サンプル コードを非表示にする] を選択します。

関連するコンテンツ

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

前提条件

• 共同作成者以上のアクセス許可を使用した Fabric 容量ライセンス モード (または試用版ライセンス モード) でのワークスペースへのアクセス。
• イベントストリームがない場合は、イベントストリームを作成します。

ソースとしてカスタム アプリを追加する

独自のアプリケーションを イベントストリーム に接続する場合は、カスタム アプリ ソースを追加することができます。 次に、カスタム アプリで公開されている接続エンドポイントを使って、独自のアプリから Eventstream にデータを送信します。

カスタム アプリ ソースを追加するには:

1. リボン上の [新しいソース] またはメイン エディター キャンバス内のプラス記号 (+) を選択して、[カスタム アプリ] を選択します。

2. [カスタム アプリ] ペインで、カスタム アプリのソース名を入力して、[追加] を選びます。

   

イベントを送信するために [詳細] ペインでエンドポイントの詳細を取得する

カスタム アプリケーションをソースとして正しく作成した後は、[詳細] ペインでその情報を見ることができます。

[詳細] ペインには、[イベント ハブ]、[AMQP]、[Kafka] という 3 つのプロトコル タブがあります。 各プロトコル タブには、 基本、 SAS キー認証、 Entra ID 認証の 3 つのページがあります。 これらのページでは、選択したプロトコルに固有のエンドポイント情報が提供されます。

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

• SAS キー認証 と Entra ID 認証 は、アプリケーションに接続するためにサポートされる 2 つの認証方法です。
  • SAS キー認証 は、Shared Access Signature (SAS) キーを使用して Eventstream データを生成および使用するために必要な情報を提供します。
  • Entra ID 認証 を使用すると、セキュリティ プリンシパル (ユーザーやサービス プリンシパルなど) が Microsoft Entra ID 認証を使用して Eventstream データを使用できるようになります。

Entra ID 認証を使用する手順については、「Eventstream でアプリケーションの Entra ID 認証を有効にする」を参照してください。
次のセクションでは、 SAS キー認証を使用してカスタム エンドポイントの宛先に接続する方法について説明します。

イベント ハブ

[Event Hub] タブの [キー] ページには、イベント ハブの接続文字列に関連する情報が含まれています。 この情報には、[イベント ハブ名]、[共有アクセス キー名]、[プライマリ キー]、[接続文字列—プライマリキー] が含まれます。

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

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

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

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

カフカ

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

Kafka 形式で必要な接続キーを含む既製のコードを取得するには、Kafka ページの [サンプル コードの表示] ボタンを選択します。 それをコピーするだけで使用できます。

AMQP（高度メッセージキューイングプロトコル）

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

AMQP ページの [サンプル コードの表示] ボタンを選択して、接続キー情報を含むすぐに使用できるコードを AMQP 形式で取得します。

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

関連するコンテンツ

Eventstream に他のソースを追加する方法については、次の記事を参照してください:

• Azure Event Hubs
• Azure IoT Hub
• サンプル データ