カスタム アプリケーション ソースを Eventstream に追加すします
独自のアプリケーションをイベントストリームに接続したい場合は、カスタムエンドポイント（旧カスタムアプリ）ソースを追加できます。 その後、カスタムエンドポイント（旧カスタムアプリ）として表示される接続エンドポイントを使用して、独自のアプリケーションからイベントストリームにデータを送信できます。 この記事では、カスタムエンドポイント（旧カスタムアプリ）のソースをイベントストリームに追加する方法について説明します。
Note
プレビュー段階の拡張機能を使用する場合は、上部にある [拡張機能] を選択します。 それ以外の場合は、[Standard機能] を選択します。 プレビュー段階の拡張機能の詳細については、「Fabric イベント ストリームの概要」を参照してください。
前提条件
- 寄稿者以上のアクセス許可を持つ Fabric Premium ワークスペース へのアクセス権
重要
Fabric イベント ストリームの拡張機能は現在プレビュー段階です。
Note
1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。
ソースとしてカスタム アプリケーションを追加します
カスタム エンドポイントソースを追加するには、次の手順に従います。
新しいイベントストリームを作成するには、[ホーム] 画面から [Eventstream] を選択します。 [拡張機能 (プレビュー)] オプションが有効になっていることを確認します。
カスタム アプリ ソースを追加するには、開始ページで [カスタム エンドポイントの使用] を選択 します。
![[カスタム エンドポイントの使用] を選択したスクリーンショット。](media/external-sources/use-custom-endpoint.png)
または、既に発行済みのイベントストリームがあり、カスタムエンドポイント データをソースとして追加する場合は、編集モードに切り替えます。 次に、リボンで [ソースの追加] を選択し、[カスタム エンドポイント] を選択します。
[カスタム エンドポイント] 画面で、[ソース名] にカスタム ソースの名前を入力し、[追加] を選択します。
![[追加] ボタンが強調表示された [カスタム エンドポイント] 画面を示すスクリーンショット。](media/add-source-custom-app-enhanced/add.png)
カスタム アプリ ソースを作成すると、編集モードでキャンバス上の eventstream に追加されていることがわかります。 この新しく追加されたカスタム アプリ ソース データを実装するには、[発行] を選択します。
![[発行] ボタンが強調表示されている、編集モードのイベントストリームを示すスクリーンショット。](media/add-source-custom-app-enhanced/edit-mode.png)
これらの手順を完了すると、カスタム アプリ データをライブ ビューで視覚化できるようになります。
接続文字列とサンプル コードを取得する
[ライブ ビューの詳細] ウィンドウには、基本、キー、サンプル コードの 3 つのカテゴリが表示されます。 イベント ハブ、AMQP、Kafka の 3 つのプロトコル タブから選択することもできます。 キーとサンプル コードの情報はプロトコルによって異なります。
[基本]: カスタム アプリの名前、説明、種類、状態が表示されます。
![eventstream ライブ ビューの [詳細] ウィンドウの [基本情報] を示すスクリーンショット。](media/add-source-custom-app-enhanced/details-event-basic.png)
[キー]: カスタム アプリの接続文字列が表示されます。これをコピーしてアプリケーションに貼り付けることができます。
![eventstream ライブ ビューの [詳細] ウィンドウの [キー] 情報を示すスクリーンショット。](media/add-source-custom-app-enhanced/details-event-keys.png)
接続文字列は、アプリケーションでこのイベントストリームからイベントを受信するために使用できるイベント ハブ互換の文字列です。 Event Hubs 形式は接続文字列のデフォルト形式であり、Azure Event Hubs SDK と互換性があります。 この形式を使用して、Event Hubs プロトコルによってイベントストリームに接続できます。
次の例は、接続文字列がイベント ハブ形式でどのように見えるかを示しています。
Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxxx
サンプル コード は、このイベントストリームとの間でイベント データをプッシュまたはプルするために、アプリケーションを参照またはコピーして貼り付けることができるサンプル コードを示しています。
![eventstream ライブ ビューの [詳細] ウィンドウのサンプル コードを示すスクリーンショット。](media/add-source-custom-app-enhanced/details-event-sample.png)
イベント ハブ以外に、[詳細] ウィンドウで選択できる他の 2 つのプロトコル形式タブは AMQP と Kafka です。
AMQP 形式は、AMQP 1.0 プロトコルと互換性があります。これは、さまざまなプラットフォームおよび言語間で相互運用性をサポートする標準メッセージング プロトコルです。 この形式を使用して、AMQP プロトコルによってイベントストリームに接続できます。
Kafka 形式は、Apache Kafka プロトコルと互換性があります。Apache Kafka は、高スループットで待機時間の短いデータ処理をサポートする、よく使用されている分散ストリーミング プラットフォームです。 この形式を使用して、Kafka プロトコルによってイベントストリームに接続できます。
アプリケーションのニーズと設定に合ったプロトコル形式を選択できます。 [詳細] ウィンドウでこれらのタブを選択して、カスタマイズされたキーとサンプル コードを取得します。 [キー] セクションから接続文字列をコピーして、アプリケーションに貼り付けます。 提供されたサンプル コードを参照またはコピーして貼り付け、さまざまなプロトコルを使用してイベントを送受信します。
関連するコンテンツ
Eventstream に他のソースを追加する方法については、次の記事を参照してください:
前提条件
開始する前に、次の前提条件を満たしている必要があります。
- イベントストリーム が配置されている Premium ワークスペースに、寄稿者以上のアクセス許可を使用してアクセスします。
Note
1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。
ソースとしてカスタム アプリを追加する
独自のアプリケーションを イベントストリーム に接続する場合は、カスタム アプリ ソースを追加することができます。 次に、カスタム アプリで公開されている接続エンドポイントを使用して、独自のアプリで イベントストリーム にデータを送信します。 カスタム アプリ ソースを追加するには、次の手順に従います。
リボン上の [新しいソース] またはメイン エディター キャンバス内の「+」、次に [カスタム アプリ] を選択します。
カスタム アプリのソース名を入力し、[追加] を選択します。
カスタム アプリケーション ソースが正常に作成された後は、下側ペインの [詳細] タブで以下の情報を切り替えて表示できます。
- [基本]: カスタム アプリの名前、説明、種類、状態が表示されます。
- [キー]: カスタム アプリの接続文字列が表示されます。これをコピーしてアプリケーションに貼り付けることができます。
- [サンプル コード]: サンプル コードが表示されます。イベント データをこのイベントストリームにプッシュしたり、このイベントストリームからイベント データをプルしたりするために、これを参照またはコピーできます。
各タブ ([基本] / [キー] / [サンプル コード]) では、[Eventhub]、[AMQP]、[Kafka] の 3 つのプロトコル タブを切り替えて、異なるプロトコル形式の情報にアクセスすることもできます。
接続文字列はイベント ハブ互換の接続文字列であり、これをアプリケーションで使用すると、イベントストリーム からイベントを受信できます。 接続文字列には複数のプロトコル形式があり、[キー] タブで切り替えて選択できます。次の例は、接続文字列が Event Hubs 形式でどのように見えるかを示しています。
Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxxxEvent Hubs 形式は接続文字列の既定の形式であり、Azure Event Hubs SDK と互換性があります。 この形式を使用して、Event Hubs プロトコルによってイベントストリームに接続できます。
他の 2 つのプロトコル形式は、AMQP と Kafka です。これらは、[キー] タブの対応するタブをクリックして選択できます。
AMQP 形式は、AMQP 1.0 プロトコルと互換性があります。これは、さまざまなプラットフォームおよび言語間で相互運用性をサポートする標準メッセージング プロトコルです。 この形式を使用して、AMQP プロトコルによってイベントストリームに接続できます。
Kafka 形式は、Apache Kafka プロトコルと互換性があります。Apache Kafka は、高スループットで待機時間の短いデータ処理をサポートする、よく使用されている分散ストリーミング プラットフォームです。 この形式を使用して、Kafka プロトコルによってイベントストリームに接続できます。
アプリケーションのニーズと設定に適したプロトコル形式を選択し、接続文字列をコピーしてアプリケーションに貼り付けることができます。 [サンプル コード] タブに表示されるサンプル コードを参照したりコピーしたりすることもできます。ここには、さまざまなプロトコルを使用してイベントを送受信する方法が示されます。
関連するコンテンツ
Eventstream に他のソースを追加する方法については、次の記事を参照してください:
フィードバック
以下は間もなく提供いたします。2024 年を通じて、コンテンツのフィードバック メカニズムとして GitHub の issue を段階的に廃止し、新しいフィードバック システムに置き換えます。 詳細については、「https://aka.ms/ContentUserFeedback」を参照してください。
フィードバックの送信と表示