eventstream に転送先のカスタム エンドポイントまたはカスタム アプリを追加する

前提条件

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

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

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

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

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

   

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

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

   

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

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

カスタム エンドポイントを転送先として追加する

イベント データをアプリにルートする場合は、カスタム エンドポイントを eventstream の転送先として追加できます。

1. ライブ ビューの場合は、リボンの [編集] を選択して編集モードに切り替えます。

   

2. 編集モードで、次のいずれかの方法で転送先のカスタム エンドポイントを追加します。

   • リボンの [転送先の追加] を選択し、[カスタム エンドポイント] を選択して、エンドポイントを既定のストリームまたは派生ストリームに接続します。

     

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

     

3. [転送先名] に、カスタム エンドポイントの名前を入力します。 その後、 [保存] を選びます。

   

4. 既存の接続がない場合は、既定のストリーム タイルをカスタム エンドポイント タイルに接続します。

   

5. カスタム エンドポイントの詳細情報を表示するには、[発行] を選択します。

   

[詳細] ペインでエンドポイントの詳細を取得してイベントを使用する

ライブ ビューで、カスタム エンドポイント タイルを選択します。 表示される [詳細 ] ウィンドウには、 イベント ハブ、 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 ページの [サンプル コードの表示] ボタンを選択します。 それをコピーするだけで使用できます。

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

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

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

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

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

関連するコンテンツ

Eventstream に他の転送先を追加する方法については、次の記事を参照してください。

• 派生ストリーム
• KQL データベース
• レイクハウス
• Fabric アクティベーター

前提条件

開始する前に、Fabric 容量ライセンス モード (または) 試用版ライセンス モードで、共同作成者以上のアクセス許可を使用して Eventstream のワークスペースにアクセスする必要があります。

カスタム アプリケーションを転送先として追加する

イベント データをアプリケーションにルートする場合は、eventstream の転送先としてカスタム アプリを追加できます。

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

2. [カスタム アプリ] ペインで、そのカスタム アプリに対応する転送先名を入力し、[追加] を選択します。

   

[詳細] ペインでエンドポイントの詳細を取得してイベントを使用する

カスタム アプリケーションを転送先として正常に作成すると、[詳細] ペインで情報を表示できます。

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

[基本] には、カスタム アプリの名前、種類、状態が表示されます。

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

イベント ハブ

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

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

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

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

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

カフカ

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

[Kafka] タブの [サンプル コード] ページには、必要な接続キーを含む、すぐに使用できるコードが Kafka 形式で用意されています。 それをコピーするだけで使用できます。

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

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

[AMQP] タブの [サンプル コード] ページには、接続キー情報を含む、すぐに使用できるコードが AMQP 形式で用意されています。

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

宛先を管理する

[データ] ペインまたはキャンバスのいずれかから、eventstream の転送先を ([編集] コマンドで) 編集または ([削除] コマンドで) 削除することができます。

[編集] を選択すると、メイン エディターの右側に編集ペインが開きます。 イベント プロセッサ エディターを使用して、イベント変換ロジックを含む構成を必要に応じて変更することができます。

関連するコンテンツ

Eventstream に他の転送先を追加する方法については、次の記事を参照してください。

• Eventhouse
• レイクハウス
• Fabric アクティベーター