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.