イベントストリームにカスタムエンドポイントの転送先を追加する

[アーティクル]
05/21/2024

この記事では、カスタムエンドポイントを 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 に他の転送先を追加する方法については、次の記事を参照してください。

次の方法で共有

イベントストリームにカスタムエンドポイントの転送先を追加する

前提条件

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

[詳細] ペイン

基本