Eventstream にカスタムエンドポイントまたはカスタムアプリのソースを追加する

[アーティクル]
11/19/2024

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

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

Note

現在、イベントストリームを作成すると、拡張機能が既定で有効になります。標準機能を使用して作成されたイベントストリームがある場合、それらのイベントストリームは引き続き機能します。通常どおりに編集や使用を続けられます。新しいイベントストリームを作成して標準のイベントストリームを置き換えることをお勧めします。そうすることで、強化されたイベントストリームの追加機能と利点を利用できます。

前提条件

共同作成者以上のアクセス許可を使用した Fabric 容量ライセンスモード (または試用版ライセンスモード) でのワークスペースへのアクセス。
イベントストリームがない場合は、イベントストリームを作成します。

ソースとしてカスタムアプリケーションを追加します

カスタムエンドポイントソースを追加するには、開始ページで [カスタムエンドポイントを使用する] を選びます。または、既に発行済みの Eventstream があり、カスタムエンドポイントデータをソースとして追加する場合は、編集モードに切り替えます。リボンで、[ソースの追加]>[カスタムエンドポイント] を選びます。
[カスタムエンドポイント] ダイアログで、[ソース名] にカスタムソースの名前を入力して、[追加] を選びます。
カスタムエンドポイントソースを作成すると、編集モードのキャンバスで Eventstream にそれが追加されます。カスタムアプリソースから新しく追加されたデータを実装するには、[発行] を選びます。

Note

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

[詳細] ペインでエンドポイントの詳細を取得する

カスタムエンドポイントソースを作成した後は、そのデータをライブビューの視覚化に利用できます。

ライブビューの Eventstream を示すスクリーンショット。

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

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

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

イベントハブ

[イベントハブ] タブの [SAS キー認証] ページには、イベントハブの接続文字列に関連する情報が含まれています。たとえば、[イベントハブ名]、[共有アクセスキー名]、[主キー]、[セカンダリキー]、[接続文字列 - 主キー]、[接続文字列 - セカンダリキー] などの情報です。

Eventstream の [詳細] ペインのキー情報を示すスクリーンショット。

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

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

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

[サンプルコードの表示] ボタンを選択すると、イベントハブの接続キーに関する必要な情報が含まれている、すぐに使用できる Java コードが表示されます。それをコピーしてアプリケーションに貼り付けることで使用できます。

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

Advanced Message Queuing Protocol (AMQP)

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

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

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

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

Kafka

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

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

[サンプルコードの表示] ボタンを選択すると、Kafka 形式で必要な接続キーが含まれている、すぐに使用できる Java コードが表示されます。それをコピーして使用できます。

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

Note

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

サンプルコードのビューを終了するには、[サンプルコードを非表示にする] を選択します。

サポートされているソースの一覧については、「イベントソースをイベントストリームに追加する」を参照してください

前提条件

開始する前に、イベントストリームが配置されているワークスペースに対し、共同作成者以上のアクセス許可によるアクセスを取得する必要があります。

Note

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

ソースとしてカスタムアプリを追加する

独自のアプリケーションをイベントストリームに接続する場合は、カスタムアプリソースを追加することができます。次に、カスタムアプリで公開されている接続エンドポイントを使って、独自のアプリから Eventstream にデータを送信します。

カスタムアプリソースを追加するには:

リボン上の [新しいソース] またはメインエディターキャンバス内のプラス記号 (+) を選択して、[カスタムアプリ] を選択します。
[カスタムアプリ] ペインで、カスタムアプリのソース名を入力して、[追加] を選びます。

イベントを送信するために [詳細] ペインでエンドポイントの詳細を取得する

カスタムアプリケーションをソースとして正しく作成した後は、[詳細] ペインでその情報を見ることができます。

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

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

Eventstream の [詳細] ペインのカスタムアプリに関する基本情報を示すスクリーンショット。

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