Freigeben über


EventProcessorHost Klasse

Definition

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: