次の方法で共有

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

  • [アーティクル]

独自のアプリケーションを eventstream に接続する場合は、カスタム エンドポイントまたはカスタム アプリを転送先として追加することができます。 そうすれば、カスタム エンドポイントまたはカスタム アプリで公開されている接続エンドポイントを使用して、独自のアプリケーションへの eventstream からリアルタイム イベントを使用できます。 また、Apache Kafka プロトコルがカスタム エンドポイントまたはカスタム アプリのオプションとして利用できるため、Apache Kafka プロトコルを使用してリアルタイム イベントを使用することができます。

この記事では、カスタム エンドポイントの転送先またはカスタム アプリの転送先を Microsoft Fabric イベント ストリーム内の eventstream に追加する方法について説明します。

Note

プレビュー段階の拡張機能を使用する場合は、上部にある [拡張機能] を選択します。 それ以外の場合は、[Standard 機能] を選択します。 プレビュー段階の拡張機能の詳細については、「Fabric イベント ストリームの概要」を参照してください。

前提条件

開始する前に、共同作成者以上のアクセス許可を使用して eventstream が配置されている Premium ワークスペースにアクセスする必要があります。

Note

1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。

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

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

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

    編集モードに切り替えるための [編集] ボタンを示すスクリーンショット。

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

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

      リボンで転送先としてカスタム エンドポイントが選択されているところを示すスクリーンショット。

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

      エディターでカスタム エンドポイントが選択されているところを示すスクリーンショット。

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

    カスタム エンドポイントの名前を入力するためのペインを示すスクリーンショット。

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

    カスタム エンドポイント タイルへの接続を示すスクリーンショット。

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

    [公開] ボタンを示すスクリーンショット。

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

ライブ ビューで、カスタム エンドポイント タイルを選択します。 表示される [詳細] ペインには、[Event Hub]、[AMQP]、[Kafka] という 3 つのプロトコル タブがあります。

カスタム エンドポイントの [詳細] ペインを示すスクリーンショット。

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

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

eventstream ライブ ビューのカスタム エンドポイントの基本的な詳細を示すスクリーンショット。

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

イベント ハブ

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

eventstream ライブ ビューの [詳細] ペイン上のイベント ハブ キーを示すスクリーンショット。

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

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

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

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

eventstream ライブ ビューの [詳細] ペイン上のイベント ハブのサンプル コードを示すスクリーンショット。

Kafka

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

eventstream ライブ ビューの [詳細] ペイン上の Kafka キーを示すスクリーンショット。

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

eventstream ライブ ビューの [詳細] ペイン上の Kafka サンプル コードを示すスクリーンショット。

AMQP

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

eventstream ライブ ビューの [詳細] ペイン上の AMQP キーを示すスクリーンショット。

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

eventstream ライブ ビューの [詳細] ペイン上の AMQP サンプル コードを示すスクリーンショット。

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

関連するコンテンツ

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

前提条件

開始する前に、共同作成者以上のアクセス許可を使用して eventstream が配置されている Premium ワークスペースにアクセスする必要があります。

Note

1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。

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

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

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

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

    カスタム アプリを転送先として構成するためのペインのスクリーンショット。

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

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

カスタム アプリの転送先の [詳細] ペインを示すスクリーンショット。

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

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

eventstream の [詳細] ペイン上のカスタム アプリの基本的な詳細を示すスクリーンショット。

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

イベント ハブ

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

eventstream の [詳細] ペイン上のイベント ハブ キーを示すスクリーンショット。

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

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

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

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

eventstream の [詳細] ペイン上のイベント ハブのサンプル コードを示すスクリーンショット。

Kafka

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

eventstream の [詳細] ペイン上の Kafka キーを示すスクリーンショット。

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

eventstream の [詳細] ペイン上の Kafka サンプル コードを示すスクリーンショット。

AMQP

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

eventstream の [詳細] ペイン上の AMQP キーを示すスクリーンショット。

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

eventstream の [詳細] ペイン上の AMQP サンプル コードを示すスクリーンショット。

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

宛先を管理する

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

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

転送先の変更オプションと削除オプションを選択するキャンバス上の場所を示すスクリーンショット。

関連するコンテンツ

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