イベント ストリームにカスタムエンドポイントの転送先を追加する
この記事では、カスタム エンドポイント (すなわち、標準機能のカスタム アプリなど) 転送先を Microsoft Fabric のイベント ストリームに追加する方法について説明します。
Note
プレビュー段階の拡張機能を使用する場合は、上部にある [拡張機能] を選択します。 それ以外の場合は、[Standard機能] を選択します。 プレビュー段階の拡張機能の詳細については、「Fabric イベント ストリームの概要」を参照してください。
前提条件
開始する前に、次の前提条件を満たしている必要があります。
- イベントストリーム が配置されている Premium ワークスペースに、寄稿者以上のアクセス許可を使用してアクセスします。
Note
1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。
カスタム アプリケーションを転送先として追加する
イベント データをアプリケーションにルーティングする場合は、イベントストリームにおける宛先としてカスタム アプリを追加できます。 宛先となるカスタム アプリを追加するには、次の手順に従います。
ライブ ビューの場合は、リボンの [編集] を選択して編集モードに切り替えます。
編集モードで、次のいずれかの方法でカスタム エンドポイントの宛先を追加します。
カスタム エンドポイントの宛先名を入力し、[保存] を選択します。
接続がまだない場合は、既定のストリーム タイルをカスタム エンドポイント タイルに接続します。
カスタム エンドポイントの詳細情報を表示するには、[発行] を選択します。
ライブ ビューで、カスタム エンドポイント タイルを選択します。 ページの下部で [ポリシー詳細] ウィンドウが開きます。 詳細については、次のセクションを参照してください。
[詳細] ペイン
[詳細] ウィンドウには、Eventhub、AMQP、Kafka の 3 つのプロトコル タブがあります。 各プロトコル タブには、基本、キー、サンプル コードの 3 つのページがあります。
基本
テーブル情報ページに次の情報が表示されます。
- 名前: エンドポイントの名前。
- 型を設定するには、次を実行します
CustomApp
。 - コンシューマー グループ - コンシューマーの グループのグローバル一意識別子 (GUID)。
- カスタム状態エンドポイントの URL
キー
[キー] ページには、共有アクセス キー名、主キー、セカンダリ キー、主キーを使用した接続文字列、セカンダリ キーを使用した接続文字列の 3 つのプロトコルの共通フィールドがあります。
[Event Hubs] タブに、イベント ハブの名前が表示されます。 [AMQP] タブにエンティティ名が表示されます。 [Kafka] タブには、ブートストラップ サーバー、セキュリティ プロトコル、SASL メカニズム、SASL JASS 構成、トピック名の情報が表示されます。
サンプル コード
アプリケーションからカスタム エンドポイントの宛先からイベントを受信するために使用できるサンプル コードを示します。
イベント ハブ
接続文字列はイベント ハブ互換の接続文字列であり、これをアプリケーションで使用すると、イベントストリーム からイベントを受信できます。 接続文字列は、次の例のようになりますEndpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxxx
。
Event Hubs 形式は接続文字列のデフォルト形式であり、Azure Event Hubs SDK と互換性があります。 この形式を使用して、Event Hubs プロトコルによってイベントストリームに接続できます。
AMQP
AMQP 形式は、AMQP 1.0 プロトコルと互換性があります。これは、さまざまなプラットフォームおよび言語間で相互運用性をサポートする標準メッセージング プロトコルです。 この形式を使用して、AMQP プロトコルによってイベントストリームに接続できます。
Kafka
Kafka 形式は、Apache Kafka プロトコルと互換性があります。Apache Kafka は、高スループットで待機時間の短いデータ処理をサポートする、よく使用されている分散ストリーミング プラットフォームです。 この形式を使用して、Kafka プロトコルによってイベントストリームに接続できます。
アプリケーションのニーズと設定に適したプロトコル形式を選択し、接続文字列をコピーしてアプリケーションに貼り付けることができます。 [サンプル コード] タブに表示されるサンプル コードを参照したりコピーしたりすることもできます。ここには、さまざまなプロトコルを使用してイベントを送受信する方法が示されます。
関連するコンテンツ
Eventstream に他の転送先を追加する方法については、次の記事を参照してください。
前提条件
開始する前に、次の前提条件を満たしている必要があります。
- イベントストリーム が配置されている Premium ワークスペースに、寄稿者以上のアクセス許可を使用してアクセスします。
Note
1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。
カスタム アプリケーションを転送先として追加する
イベント データをアプリケーションにルーティングする場合は、イベントストリームにおける宛先としてカスタム アプリを追加できます。 宛先となるカスタム アプリを追加するには、次の手順に従います。
リボン上の [新しい転送先] またはメイン エディターのキャンバス内の [+] を選択し、[カスタム アプリ] を選択します。 宛先となるカスタム アプリを構成する画面が表示されます。
カスタム アプリの転送先名を入力し、[追加] を選択します。
カスタム アプリケーションの変換先が正常に作成された後は、下側ペインの [詳細] タブで以下の情報を切り替えて表示できます。
- [基本]: カスタム アプリの名前、説明、種類、状態が表示されます。
- [キー]: カスタム アプリの接続文字列が表示されます。これをコピーしてアプリケーションに貼り付けることができます。
- [サンプル コード]: サンプル コードが表示されます。イベント データをこのイベントストリームにプッシュしたり、このイベントストリームからイベント データをプルしたりするために、これを参照またはコピーできます。
各タブ ([基本] / [キー] / [サンプル コード]) では、[Eventhub]、**[AMQP]、[Kafka] の 3 つのプロトコル タブを切り替えて、異なるプロトコル形式の情報にアクセスすることもできます。
接続文字列はイベント ハブ互換の接続文字列であり、これをアプリケーションで使用すると、イベントストリーム からイベントを受信できます。 接続文字列には複数のプロトコル形式があり、[キー] タブで切り替えて選択できます。イベント ハブ形式での接続文字列は、次の例のようになります。
Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxxx
Event Hubs 形式は接続文字列のデフォルト形式であり、Azure Event Hubs SDK と互換性があります。 この形式を使用して、Event Hubs プロトコルによってイベントストリームに接続できます。
他の 2 つのプロトコル形式は、AMQP と Kafka です。これらは、[キー] タブの対応するタブをクリックして選択できます。
AMQP 形式は、AMQP 1.0 プロトコルと互換性があります。これは、さまざまなプラットフォームおよび言語間で相互運用性をサポートする標準メッセージング プロトコルです。 この形式を使用して、AMQP プロトコルによってイベントストリームに接続できます。
Kafka 形式は、Apache Kafka プロトコルと互換性があります。Apache Kafka は、高スループットで待機時間の短いデータ処理をサポートする、よく使用されている分散ストリーミング プラットフォームです。 この形式を使用して、Kafka プロトコルによってイベントストリームに接続できます。
アプリケーションのニーズと設定に適したプロトコル形式を選択し、接続文字列をコピーしてアプリケーションに貼り付けることができます。 [サンプル コード] タブに表示されるサンプル コードを参照したりコピーしたりすることもできます。ここには、さまざまなプロトコルを使用してイベントを送受信する方法が示されます。
宛先を管理する
[編集]/[削除]: ナビゲーション ウィンドウまたはキャンバスで イベントストリーム の転送先を編集または削除することができます。
[編集] を選択すると、メイン エディターの右側に編集ペインが開きます。 イベント変換ロジックを含み、必要に応じて、イベント プロセッサ エディターを使用して構成を変更できます。
関連するコンテンツ
Eventstream に他の転送先を追加する方法については、次の記事を参照してください。