次の方法で共有


クイックスタート: Azure Event Hubs を使って大きいメッセージを送受信する (プレビュー)

このクイックスタートでは、Azure Event Hubs を使って大きいメッセージ (最大 20 MB) を送受信する方法について説明します。 Azure Event Hubs を初めて使用する場合は、このクイックスタートを実行する前に Event Hubs の概要を参照してください。

前提条件

このクイック スタートを完了するには、次の前提条件を用意しておく必要があります。

  • Azure サブスクリプション。 Event Hubs を含む Azure サービスを使用するには、サブスクリプションが必要です。 既存の Microsoft Azure アカウントをお持ちでない場合は、アカウントを作成する際に、無料試用版にサインアップするか、MSDN サブスクライバー特典を利用できます。
  • セルフサービスのスケーラブルな専用クラスター、イベント ハブ名前空間、イベント ハブ。 この前提条件を満たすための最初の手順として、Azure portal を使用して、クラスター内に専用クラスターと名前空間を作成します。 イベント ハブを作成するには、「クイックスタート: Azure portal を使用したイベント ハブの作成」を参照してください。 セルフサービスのスケーラブルな専用クラスターが既にある場合は、この手順をスキップできます。

Note

現在パブリック プレビュー段階にある大きいメッセージのサポートは、特定の Event Hubs セルフサービス専用クラスターでのみ利用できます。 これらのクラスターで大きなメッセージをストリーミングする場合、追加料金は発生しません。

Event Hubs 専用クラスターを構成する

大きいメッセージをストリーミングするには、セルフサービスのスケーラブルな専用クラスターを構成する必要があります。

Azure portal で、専用クラスターの [設定] セクションに移動します。 [設定]で、[クォータ] タブを選択します。

専用クラスターの [クォータ] ウィンドウを示すスクリーンショット。

  • 読み取り専用キー supportslargemessages の値が True に設定されていることを確認します。
  • キー eventhubmaxmessagesizeinbytes を適切な値 (バイト単位) に更新できます。 この値の許容範囲は 1048576 バイトから 20971520 バイトです。

構成が保存されると、イベント ハブを使用して大きいメッセージをストリーミングする準備は完了です。

重要

大規模なメッセージ ストリーミングは、最新のインフラストラクチャから構築されたセルフサービスのスケーラブルな専用クラスターでのみサポートされます。 この機能はキー Supportslargemessages によって反映されます。

クラスター値が false の場合、大きなメッセージ ストリーミングはサポートされません。 この機能を有効にするには、クラスターを再作成する必要があります。

Event Hubs を使用して大きなメッセージをストリーミングする

Event Hubs では、バッチおよび個々のパブリケーションの両方で大きいメッセージ (最大 20 MB ) をストリーミングできます。 大きいメッセージやイベントをストリーミングできるようにするために、メッセージまたはイベント自体の変更は別として、クライアント コードの変更は必要ありません。 既存のイベント ハブ SDK または Kafka API を使用してメッセージの送受信を続行し、大きいメッセージをイベント ハブにストリーミングすることができます。 これにより、サイズが 1 MB 未満のメッセージの場合と同じ方法で、大きなメッセージを Event Hubs にストリーミングできます。

詳細については、「.NETを使用して Event Hubs との間でイベントを送受信する」を参照してください。

ヒント

Event Hubs にストリーミングするメッセージの最大サイズを制限する可能性がある Event Hubs Advanced Message Queuing Protocol (AMQP) クライアントまたは Kafka クライアント構成を確認してください。 大きなメッセージをストリーミングするには、クライアント タイムアウトを大きな値に更新する必要があります。

既定では、AMQP クライアント プリフェッチ数は 300 です。 大きいメッセージを処理するとき、クライアント側でメモリの問題が発生しないようにするには、この値を小さくします。

完全な .NET ライブラリ リファレンスについては、SDK のドキュメントを参照してください。