EventProcessorHost Klasse
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
Stellt einen Host zum Verarbeiten von Event Hubs-Ereignisdaten dar.
public sealed class EventProcessorHost
type EventProcessorHost = class
Public NotInheritable Class EventProcessorHost
- Vererbung
-
EventProcessorHost
Konstruktoren
EventProcessorHost(String, String, String, String, ICheckpointManager, ILeaseManager) |
Erstellen Sie einen neuen Host, um Ereignisse über einen Event Hub zu verarbeiten. Diese Überladung des Konstruktors ermöglicht maximale Flexibilität. Dadurch kann der Aufrufer auch den Namen des Prozessorhosts angeben. Die Überladung ermöglicht es dem Aufrufer auch, eigene Lease- und Prüfpunkt-Manager bereitzustellen, um die integrierten Manager basierend auf Azure Storage zu ersetzen. |
EventProcessorHost(String, String, String, String, String) |
Erstellen Sie einen neuen Host, um Ereignisse über einen Event Hub zu verarbeiten. Da Event Hubs häufig für Hochskalierungsszenarien mit hohem Datenverkehr verwendet werden, gibt es in der Regel nur einen Host pro Prozess, und die Prozesse werden auf separaten Computern ausgeführt. Es wird jedoch unterstützt, mehrere Hosts auf einem Computer oder sogar innerhalb eines Prozesses auszuführen, wenn der Durchsatz kein Problem darstellt. Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager. Das durch den parameter storageConnectionString angegebene Azure Storage-Konto wird von den integrierten Managern verwendet, um Leases und Prüfpunkte aufzuzeichnen. |
EventProcessorHost(String, String, String, String, String, String, String) |
Erstellen Sie einen neuen Host, um Ereignisse über einen Event Hub zu verarbeiten. Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager. |
EventProcessorHost(String, Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType) |
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellten TokenProvider |
EventProcessorHost(String, Uri, String, String, ITokenProvider, ICheckpointManager, ILeaseManager, Nullable<TimeSpan>, TransportType) |
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellten TokenProvider |
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String) |
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellten TokenProvider |
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType) |
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellten TokenProvider |
Eigenschaften
ConsumerGroupName |
Ruft den Namen der Consumergruppe ab. |
EndpointAddress |
Ruft den Ereignisendpunkt-URI ab. |
EventHubPath |
Ruft den Event Hub-Pfad ab. |
HostName |
Gibt den Prozessorhostnamen zurück. Wenn der Prozessorhostname automatisch generiert wurde, ist dies die einzige Möglichkeit, ihn abzurufen. |
OperationTimeout |
Ruft das Vorgangstimeout ab. |
PartitionManagerOptions |
Ruft die PartitionManagerOptions vom -Objekt verwendete instance ab oder legt diese EventProcessorHost fest. |
TransportType |
Ruft den Transporttyp ab. |
Methoden
RegisterEventProcessorAsync<T>() |
Dadurch wird die IEventProcessor Implementierung mit dem Host registriert Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1. Dies startet auch den Host und bewirkt, dass er am Partitionsverteilungsprozess teilnimmt. |
RegisterEventProcessorAsync<T>(EventProcessorOptions) |
Dadurch wird die IEventProcessor Implementierung mit dem Host registriert Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1. Dies startet auch den Host und bewirkt, dass er am Partitionsverteilungsprozess teilnimmt. |
RegisterEventProcessorFactoryAsync(IEventProcessorFactory) |
Dadurch wird die Implementierung beim Host registriertIEventProcessorFactory, der verwendet wird, um eine instance von IEventProcessor zu erstellen, wenn er den Besitz einer Partition übernimmt. Dies startet auch den Host und bewirkt, dass er am Partitionsverteilungsprozess teilnimmt. |
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions) |
Dadurch wird die Implementierung beim Host registriertIEventProcessorFactory, der verwendet wird, um eine instance von IEventProcessor zu erstellen, wenn er den Besitz einer Partition übernimmt. Dies startet auch den Host und bewirkt, dass er am Partitionsverteilungsprozess teilnimmt. |
UnregisterEventProcessorAsync() |
Beenden Sie die Verarbeitung von Ereignissen. Wird erst zurückgegeben, wenn das Herunterfahren abgeschlossen ist. |
Gilt für:
Azure SDK for .NET