Event Hubs データ エクスプローラーを使用して Event Hubs 上でデータ操作を実行する

Azure Event Hubs は、大量のイベントやデータを取り込んで処理するスケーラブルなイベント処理サービスで、短い待機時間と高い信頼性を実現します。 サービスの概要については、「Event Hubs とは」を参照してください。

開発者とオペレーターは、多くの場合、サンプル データをイベント ハブに送信してエンドツーエンドのフローをテストしたり、特定のオフセット (または時点) でイベントを表示して、その後の簡易デバッグを行ったりするための簡単なツールを探しています。 Event Hubs データ エクスプローラーを使用すると、イベント ハブ上のデータをテストおよび検査するために特注のクライアント アプリケーションを記述する必要がなくなり、これらの一般的なワークフローがシンプルになります。

この記事では、Azure portal で使用できる Azure Event Hubs データ エクスプローラーの機能を説明します。

重要

Event Hubs 名前空間にプライベート エンドポイント経由でのみアクセスできる場合は、そのプライベート エンドポイントと同じ仮想ネットワーク内の仮想マシンから Event Hubs データ エクスプローラーにアクセスします。これにより、Web ブラウザーにプライベート エンドポイントへの必要なアクセス許可があることが保証されます。

Azure Event Hubs 名前空間に対して実行される操作は 2 種類あります。

• 管理操作 - Event Hubs 名前空間、およびイベント ハブの作成、更新、削除。
• データ操作 - イベント ハブからのイベントの送信と表示。

重要

• Event Hubs データ エクスプローラーでは、管理操作はサポートされていません。 データ エクスプローラーがそのイベント ハブからイベントを送信または表示するには、イベント ハブを作成する必要があります。
• Kafka プロトコルを使用して送信されたイベント ペイロード (Kafka では値と呼ばれる) はデータ エクスプローラー経由で表示されますが、特定のイベントのキーは表示されません。
• メッセージ サイズや、クライアントと Service Bus サービス間のネットワーク待機時間などによってはタイムアウトになる可能性があるため、Event Hubs データ エクスプローラーを使用して大きなメッセージを送信しないことをお勧めします。代わりに、独自のタイムアウト値を指定できる独自のクライアントを使用して、より大きなメッセージを操作することをお勧めします。
• ユーザーが Event Hubs データ エクスプローラーを使用して実行できる操作は、ユーザーが割り当てられているロールベースのアクセス制御 (RBAC) の役割によって決まります。

前提条件

Event Hubs データ エクスプローラー ツールを使用するには、Azure Event Hubs の名前空間とイベント ハブを作成します。

Event Hubs データ エクスプローラーを使用する

Event Hubs データ エクスプローラーを使用するには、データ操作を実行する Event Hubs 名前空間に移動します。

イベント ハブを選択できる Data Explorer に直接移動するか、entities からイベント ハブを選択し、ナビゲーション メニューから Data Explorer を選択します。

イベントを送信する

Send events エクスペリエンスを使用して、選択したイベント ハブにカスタム ペイロードまたは事前に準備されたデータセットを送信できます。

これを行うには、send events ボタンを選択して、右側のウィンドウを有効にします。

カスタム ペイロードを送信する

カスタム ペイロードを送信するには -

1. [データセットの選択] - Custom payload を選択します。 次のセクションに示すように、イエロー タクシー データ、気象データなど、事前に準備されたデータセットを選択することもできます。
2. Text/Plain、JSON、または XML から Content-Type を選択します。
3. JSON ファイルをアップロードするか、[ペイロードを入力] ボックスにペイロードを入力します。
4. [省略可能] システム プロパティを指定します。
5. [省略可能] カスタム プロパティを指定します。キーと値のペアとして使用できます。
6. [省略可能] 複数のペイロードを送信する場合は、[送信を繰り返す] チェック ボックスをオンにして、[送信の繰り返し回数] (つまり、送信するペイロードの数) と、[送信の繰り返し間隔 (ミリ秒)] を指定します。

ペイロードの詳細を定義したら [送信] を選択して、定義に従ってイベント ペイロードを送信します。

事前に準備されたデータセットの送信

事前に準備されたデータセットからイベント ペイロードを送信するには -

1. [データセットの選択] - 黄色のタクシー、気象データなど事前に準備されたデータセットからオプションを選択します。
2. [省略可能] システム プロパティを指定します。
3. [省略可能] カスタム プロパティを指定します。キーと値のペアとして使用できます。
4. [省略可能] 複数のペイロードを送信する場合は、[送信を繰り返す] チェック ボックスをオンにして、[送信の繰り返し回数] (つまり、送信するペイロードの数) と、[送信の繰り返し間隔 (ミリ秒)] を指定します。

ペイロードの詳細を定義したら [送信] を選択して、定義に従ってイベント ペイロードを送信します。

イベントの表示

Event Hubs データ エクスプローラーを使用すると、イベントを表示して、条件に合ったデータを検査できます。

イベントを表示するには、以下のプロパティを定義するか、既定値を使用します。

1. [パーティション ID] - 特定のパーティションを選択するか、[すべてのパーティション ID] を選択します。
2. [コンシューマー グループ] - [$Default] または別のコンシューマー グループを選択するか、オンザフライで作成します。
3. [イベントの位置] - [最も古い位置] (つまり、イベント ハブの開始)、[最も新しい位置] (つまり、最新)、[カスタムの位置] (特定のオフセット、シーケンス番号、またはタイムスタンプ) を選択します。
   1. 最も古い位置: 保持ポリシーのために期限切れになっていないパーティション内の最初のイベントからのイベントの受信を開始します。
   2. カスタムの位置: イベントの受信を開始するパーティション内の位置を指定するフィルターを追加します。
   3. 最新の位置: ビュー呼び出しの直後にエンキューされたイベントからのイベントの受信を開始します。 イベントの最後の表示後に送信されたイベントのみが受信されます。
4. 詳細プロパティ - "最大バッチ サイズ" を指定し、"最大待機時間を秒単位で"指定します。

上記のオプションが設定されたら、[イベントの表示] を選択してイベントをプルし、データ エクスプローラーにレンダリングします。

イベントが読み込まれたら、[次のイベントを表示] を選択して同じクエリを再度使用してイベントをプルするか、[すべてクリア] を選択してグリッドを更新できます。

イベント ペイロードのダウンロード

特定のイベント ハブでイベントを表示する場合は、イベント ペイロードをダウンロードしてさらに確認できます。

イベント ペイロードをダウンロードするには、特定のイベントを選択し、イベント ペイロード本文の上に表示される [ダウンロード] ボタンを選択します。

関連するコンテンツ

• Event Hubs についてさらに学習する。
• Event Hubs の機能と用語を確認する