Freigeben über


Microsoft.Azure.EventHubs.Processor Namespace

Klassen

Checkpoint

Das Kontextobjekt, das verwendet wird, um den Zustand im Stream beizubehalten.

EventProcessorConfigurationException

Eine Ausnahme, die angibt, dass die EventProcessorHost Konfiguration falsch ist.

EventProcessorHost

Stellt einen Host zum Verarbeiten von Event Hubs-Ereignisdaten dar.

EventProcessorOptions

Definiert die Laufzeitoptionen beim Registrieren einer IEventProcessor Schnittstelle bei einer EventHubConsumerGroup. Dies ist auch der Mechanismus zum Abfangen von Ausnahmen aus einer IEventProcessor-instance, die von einem EventProcessorHost -Objekt verwendet wird.

EventProcessorRuntimeException

Eine Ausnahme, die während der Ereignisverarbeitung ausgelöst wird.

ExceptionReceivedEventArgs

Stellt Daten für das Microsoft.Azure.EventHubs.Processor.EventProcessorOptions.NotifyOfException(System.String,System.String,System.Exception,System.String)-Ereignis bereit.

Lease

Enthält Informationen zum Partitionsbesitz.

LeaseLostException

Stellt eine Ausnahme dar, die auftritt, wenn die Dienstleasase verloren gegangen ist.

PartitionContext

Kapselt Informationen im Zusammenhang mit einer Event Hubs-Partition, die von verwendet wird IEventProcessor.

PartitionManagerOptions

Optionen zum Steuern verschiedener Aspekte der Partitionsverteilung innerhalb EventProcessorHost instance.

Schnittstellen

ICheckpointManager

Wenn Sie EventProcessorHost-Speicherprüfpunkte an einer anderen Stelle als Azure Storage haben möchten, können Sie über diese Schnittstelle Einen eigenen Prüfpunkt-Manager schreiben.

Die Azure Storage-Manager verwenden denselben Speicher sowohl für Lease als auch für Prüfpunkte, sodass beide Schnittstellen von derselben Klasse implementiert werden. Sie können dasselbe tun, wenn Sie über einen einheitlichen Speicher für beide Datentypen verfügen.

Diese Schnittstelle gibt keine Initialisierungsmethoden an, da wir nicht wissen können, welche Informationen Ihre Implementierung benötigt.

IEventProcessor

Schnittstelle, die von Ereignisprozessorklassen implementiert werden muss.

Jede angegebene instance einer Ereignisprozessorklasse verarbeitet nur Ereignisse aus einer Partition eines Event Hubs. Bei jedem Aufruf des Ereignisprozessors wird ein PartitionContext bereitgestellt, da sich einige Parameter ändern können, aber es ist immer dieselbe Partition.

Obwohl EventProcessorHost multithreaded ist, werden Aufrufe einer bestimmten instance einer Ereignisprozessorklasse serialisiert, mit Ausnahme von OnError(). OnOpen() wird zuerst aufgerufen, dann wird OnEvents() 0 oder öfter aufgerufen. Wenn der Ereignisprozessor heruntergefahren werden muss, sei es, weil irgendwo ein Fehler aufgetreten ist oder die Lease für die Partition verloren gegangen ist oder weil der gesamte Prozessorhost heruntergefahren wird, wird OnClose() aufgerufen, nachdem der letzte OnEvents()-Aufruf zurückgegeben wurde.

OnError() kann aufgerufen werden, während OnEvents() oder OnClose() ausgeführt wird. Es wird keine Synchronisierung versucht, um mögliche Deadlocks zu vermeiden.

IEventProcessorFactory

Schnittstelle, die von einer Ereignisprozessorfactoryklasse implementiert werden muss.

Vom Benutzer bereitgestellte Fabriken sind erforderlich, wenn das Erstellen eines Ereignisprozessorobjekts mehr Arbeit erfordert als nur ein neues mit einem parameterlosen Konstruktor.

ILeaseManager

Wenn Sie EventProcessorHost-Speicherleases an einer anderen Stelle als Azure Storage verwenden möchten, können Sie über diese Schnittstelle Einen eigenen Lease-Manager schreiben.

Die Azure Storage-Manager verwenden denselben Speicher sowohl für Lease als auch für Prüfpunkte, sodass beide Schnittstellen von derselben Klasse implementiert werden. Sie können dasselbe tun, wenn Sie über einen einheitlichen Speicher für beide Datentypen verfügen.

Diese Schnittstelle gibt keine Initialisierungsmethoden an, da wir nicht wissen können, welche Informationen Ihre Implementierung benötigt.

Enumerationen

CloseReason

Grund für das Schließen von EventProcessorHost.