Microsoft.Azure.EventHubs.Processor 名前空間

クラス

Checkpoint

ストリーム内の状態を保持するために使用されるコンテキスト オブジェクト。

EventProcessorConfigurationException

構成が正しく指定されていない EventProcessorHost 例外。

EventProcessorHost

Event Hubs イベント データを処理するためのホストを表します。

EventProcessorOptions

EventHubConsumerGroup にインターフェイスを IEventProcessor 登録するときのランタイム オプションを定義します。 これは、オブジェクトによって EventProcessorHost 使用される IEventProcessor インスタンスから例外をキャッチするためのメカニズムでもあります。

EventProcessorRuntimeException

イベント処理中にスローされた例外。

ExceptionReceivedEventArgs

Microsoft.Azure.EventHubs.Processor.EventProcessorOptions.NotifyOfException(System.String,System.String,System.Exception,System.String) イベントのデータを提供します。

Lease

パーティションの所有権情報が含まれています。

LeaseLostException

サービス リースが失われたときに発生する例外を表します。

PartitionContext

によって IEventProcessor使用される Event Hubs パーティションに関連する情報をカプセル化します。

PartitionManagerOptions

インスタンス内 EventProcessorHost で発生するパーティション分散のさまざまな側面を制御するためのオプション。

インターフェイス

ICheckpointManager

EventProcessorHost に Azure Storage 以外の場所にチェックポイントを格納する場合は、このインターフェイスを使用して独自のチェックポイント マネージャーを作成できます。

Azure Storage マネージャーは、リースとチェックポイントの両方に同じストレージを使用するため、両方のインターフェイスが同じクラスによって実装されます。 両方の種類のデータに対して統合ストアがある場合は、同じことを自由に行うことができます。

このインターフェイスでは初期化メソッドは指定されません。実装に必要な情報を把握する方法がないためです。

IEventProcessor

イベント プロセッサ クラスによって実装される必要があるインターフェイス。

イベント プロセッサ クラスの特定のインスタンスは、1 つのイベント ハブの 1 つのパーティションからのイベントのみを処理します。 一部のパラメーターは変更される可能性があるため、PartitionContext はイベント プロセッサの呼び出しごとに提供されますが、常に同じパーティションになります。

EventProcessorHost はマルチスレッドですが、OnError() を除き、イベント プロセッサ クラスの特定のインスタンスへの呼び出しはシリアル化されます。 OnOpen() は最初に呼び出され、OnEvents() は 0 回以上呼び出されます。 イベント プロセッサをシャットダウンする必要がある場合、障害が発生したか、パーティションのリースが失われたか、プロセッサ ホスト全体がシャットダウンされているかに関係なく、OnClose() は最後の OnEvents() 呼び出しが返された後に呼び出されます。

OnEvents() または OnClose() の実行中に OnError() を呼び出す可能性があります。 デッドロックの可能性を回避するために、同期は試行されません。

IEventProcessorFactory

イベント プロセッサ ファクトリ クラスによって実装される必要があるインターフェイス。

イベント プロセッサ オブジェクトを作成する場合は、パラメーターなしのコンストラクターを持つ新しいファクトリよりも多くの作業が必要な場合は、ユーザー指定のファクトリが必要です。

ILeaseManager

Azure Storage 以外の場所に EventProcessorHost ストア リースを設定する場合は、このインターフェイスを使用して独自のリース マネージャーを作成できます。

Azure Storage マネージャーは、リースとチェックポイントの両方に同じストレージを使用するため、両方のインターフェイスが同じクラスによって実装されます。 両方の種類のデータに対して統合ストアがある場合は、同じことを自由に行うことができます。

このインターフェイスでは初期化メソッドは指定されません。実装に必要な情報を把握する方法がないためです。

列挙型

CloseReason

EventProcessorHost閉じる理由。