クイックスタート: 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 のドキュメントを参照してください。