PluggableCheckpointStoreEventProcessor<TPartition> Konstruktoren
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.
Überlädt
PluggableCheckpointStoreEventProcessor<TPartition>()
Initialisiert eine neue Instanz der PluggableCheckpointStoreEventProcessor<TPartition>-Klasse.
protected PluggableCheckpointStoreEventProcessor ();Protected Sub New ()Gilt für:
PluggableCheckpointStoreEventProcessor<TPartition>(CheckpointStore, Int32, String, String, EventProcessorOptions)
Initialisiert eine neue Instanz der PluggableCheckpointStoreEventProcessor<TPartition>-Klasse.
protected PluggableCheckpointStoreEventProcessor (Azure.Messaging.EventHubs.Primitives.CheckpointStore checkpointStore, int eventBatchMaximumCount, string consumerGroup, string connectionString, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);new Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : Azure.Messaging.EventHubs.Primitives.CheckpointStore * int * string * string * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>Protected Sub New (checkpointStore As CheckpointStore, eventBatchMaximumCount As Integer, consumerGroup As String, connectionString As String, Optional options As EventProcessorOptions = Nothing)Parameter
- checkpointStore
- CheckpointStore
Verantwortlich für die Erstellung von Prüfpunkten und für den Besitzanspruch. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben.
- eventBatchMaximumCount
- Int32
Die gewünschte Anzahl von Ereignissen, die in einen zu verarbeitenden Batch eingeschlossen werden sollen. Diese Größe ist die maximale Anzahl in einem Batch. die tatsächliche Anzahl kann kleiner sein, je nachdem, ob Ereignisse im Event Hub verfügbar sind.
- consumerGroup
- String
Der Name der Consumergruppe, der dieser Prozessor zugeordnet ist. Der Prozessor bestätigt exklusiven Lesezugriff auf Partitionen für diese Gruppe.
- connectionString
- String
Die Verbindungszeichenfolge, die zum Herstellen einer Verbindung mit dem Event Hubs-Namespace verwendet werden soll. Es wird erwartet, dass der Event Hub-Name und die Freigegebenen Schlüsseleigenschaften in dieser Verbindungszeichenfolge enthalten sind.
- options
- EventProcessorOptions
Der Satz von Optionen, die für den Prozessor verwendet werden sollen.
Ausnahmen
Tritt auf, wenn die angeforderte eventBatchMaximumCount kleiner als 1 ist.
Hinweise
Wenn die Verbindungszeichenfolge aus dem Event Hubs-Namespace kopiert wird, enthält sie wahrscheinlich nicht den Namen des gewünschten Event Hubs, der benötigt wird. In diesem Fall kann der Name manuell hinzugefügt werden, indem "; EntityPath=[[ EVENT HUB NAME ]]" bis zum Ende der Verbindungszeichenfolge. Beispiel: "; EntityPath=telemetry-hub".
Wenn Sie eine SAS-Richtlinie direkt im Event Hub selbst definiert haben, führt das Kopieren der Verbindungszeichenfolge aus diesem Event Hub zu einer Verbindungszeichenfolge, die den Namen enthält.
Gilt für:
PluggableCheckpointStoreEventProcessor<TPartition>(CheckpointStore, Int32, String, String, String, EventProcessorOptions)
Initialisiert eine neue Instanz der PluggableCheckpointStoreEventProcessor<TPartition>-Klasse.
protected PluggableCheckpointStoreEventProcessor (Azure.Messaging.EventHubs.Primitives.CheckpointStore checkpointStore, int eventBatchMaximumCount, string consumerGroup, string connectionString, string eventHubName, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);new Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : Azure.Messaging.EventHubs.Primitives.CheckpointStore * int * string * string * string * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>Protected Sub New (checkpointStore As CheckpointStore, eventBatchMaximumCount As Integer, consumerGroup As String, connectionString As String, eventHubName As String, Optional options As EventProcessorOptions = Nothing)Parameter
- checkpointStore
- CheckpointStore
Der Anbieter von Prüfpunkt- und Besitzdaten für den Prozessor. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben.
- eventBatchMaximumCount
- Int32
Die gewünschte Anzahl von Ereignissen, die in einen zu verarbeitenden Batch eingeschlossen werden sollen. Diese Größe ist die maximale Anzahl in einem Batch. die tatsächliche Anzahl kann kleiner sein, je nachdem, ob Ereignisse im Event Hub verfügbar sind.
- consumerGroup
- String
Der Name der Consumergruppe, der dieser Prozessor zugeordnet ist. Der Prozessor bestätigt exklusiven Lesezugriff auf Partitionen für diese Gruppe.
- connectionString
- String
Die Verbindungszeichenfolge, die zum Herstellen einer Verbindung mit dem Event Hubs-Namespace verwendet werden soll. Es wird erwartet, dass die Eigenschaften mit gemeinsam genutzten Schlüsseln in dieser Verbindungszeichenfolge enthalten sind, aber nicht der Event Hub-Name.
- eventHubName
- String
Der Name des spezifischen Event Hubs, dem der Prozessor zugeordnet werden soll.
- options
- EventProcessorOptions
Der Satz von Optionen, die für den Prozessor verwendet werden sollen.
Ausnahmen
Tritt auf, wenn die angeforderte eventBatchMaximumCount kleiner als 1 ist.
Hinweise
Wenn die Verbindungszeichenfolge aus dem Event Hub selbst kopiert wird, enthält sie den Namen des gewünschten Event Hubs und kann direkt verwendet werden, ohne das eventHubNamezu übergeben. Der Name des Event Hubs sollte nur einmal übergeben werden, entweder als Teil der Verbindungszeichenfolge oder separat.
Gilt für:
PluggableCheckpointStoreEventProcessor<TPartition>(CheckpointStore, Int32, String, String, String, AzureNamedKeyCredential, EventProcessorOptions)
Initialisiert eine neue Instanz der PluggableCheckpointStoreEventProcessor<TPartition>-Klasse.
protected PluggableCheckpointStoreEventProcessor (Azure.Messaging.EventHubs.Primitives.CheckpointStore checkpointStore, int eventBatchMaximumCount, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, Azure.AzureNamedKeyCredential credential, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);new Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : Azure.Messaging.EventHubs.Primitives.CheckpointStore * int * string * string * string * Azure.AzureNamedKeyCredential * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>Protected Sub New (checkpointStore As CheckpointStore, eventBatchMaximumCount As Integer, consumerGroup As String, fullyQualifiedNamespace As String, eventHubName As String, credential As AzureNamedKeyCredential, Optional options As EventProcessorOptions = Nothing)Parameter
- checkpointStore
- CheckpointStore
Der Anbieter von Prüfpunkt- und Besitzdaten für den Prozessor. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben.
- eventBatchMaximumCount
- Int32
Die gewünschte Anzahl von Ereignissen, die in einen zu verarbeitenden Batch eingeschlossen werden sollen. Diese Größe ist die maximale Anzahl in einem Batch. die tatsächliche Anzahl kann kleiner sein, je nachdem, ob Ereignisse im Event Hub verfügbar sind.
- consumerGroup
- String
Der Name der Consumergruppe, der dieser Prozessor zugeordnet ist. Der Prozessor bestätigt exklusiven Lesezugriff auf Partitionen für diese Gruppe.
- fullyQualifiedNamespace
- String
Der vollqualifizierte Event Hubs-Namespace, mit dem eine Verbindung hergestellt werden soll. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net
- eventHubName
- String
Der Name des spezifischen Event Hubs, dem der Prozessor zugeordnet werden soll.
- credential
- AzureNamedKeyCredential
Die Anmeldeinformationen für den freigegebenen Zugriffsschlüssel, die für die Autorisierung verwendet werden sollen. Zugriffssteuerungen können je nach Azure-Konfiguration vom Event Hubs-Namespace oder vom angeforderten Event Hub angegeben werden.
- options
- EventProcessorOptions
Der Satz von Optionen, die für den Prozessor verwendet werden sollen.
Ausnahmen
Tritt auf, wenn die angeforderte eventBatchMaximumCount kleiner als 1 ist.
Gilt für:
PluggableCheckpointStoreEventProcessor<TPartition>(CheckpointStore, Int32, String, String, String, AzureSasCredential, EventProcessorOptions)
Initialisiert eine neue Instanz der PluggableCheckpointStoreEventProcessor<TPartition>-Klasse.
protected PluggableCheckpointStoreEventProcessor (Azure.Messaging.EventHubs.Primitives.CheckpointStore checkpointStore, int eventBatchMaximumCount, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, Azure.AzureSasCredential credential, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);new Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : Azure.Messaging.EventHubs.Primitives.CheckpointStore * int * string * string * string * Azure.AzureSasCredential * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>Protected Sub New (checkpointStore As CheckpointStore, eventBatchMaximumCount As Integer, consumerGroup As String, fullyQualifiedNamespace As String, eventHubName As String, credential As AzureSasCredential, Optional options As EventProcessorOptions = Nothing)Parameter
- checkpointStore
- CheckpointStore
Der Anbieter von Prüfpunkt- und Besitzdaten für den Prozessor. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben.
- eventBatchMaximumCount
- Int32
Die gewünschte Anzahl von Ereignissen, die in einen zu verarbeitenden Batch eingeschlossen werden sollen. Diese Größe ist die maximale Anzahl in einem Batch. die tatsächliche Anzahl kann kleiner sein, je nachdem, ob Ereignisse im Event Hub verfügbar sind.
- consumerGroup
- String
Der Name der Consumergruppe, der dieser Prozessor zugeordnet ist. Der Prozessor bestätigt exklusiven Lesezugriff auf Partitionen für diese Gruppe.
- fullyQualifiedNamespace
- String
Der vollqualifizierte Event Hubs-Namespace, mit dem eine Verbindung hergestellt werden soll. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net
- eventHubName
- String
Der Name des spezifischen Event Hubs, dem der Prozessor zugeordnet werden soll.
- credential
- AzureSasCredential
Die Anmeldeinformationen für freigegebene Signaturen, die für die Autorisierung verwendet werden sollen. Zugriffssteuerungen können je nach Azure-Konfiguration vom Event Hubs-Namespace oder vom angeforderten Event Hub angegeben werden.
- options
- EventProcessorOptions
Der Satz von Optionen, die für den Prozessor verwendet werden sollen.
Ausnahmen
Tritt auf, wenn die angeforderte eventBatchMaximumCount kleiner als 1 ist.
Gilt für:
PluggableCheckpointStoreEventProcessor<TPartition>(CheckpointStore, Int32, String, String, String, TokenCredential, EventProcessorOptions)
Initialisiert eine neue Instanz der PluggableCheckpointStoreEventProcessor<TPartition>-Klasse.
protected PluggableCheckpointStoreEventProcessor (Azure.Messaging.EventHubs.Primitives.CheckpointStore checkpointStore, int eventBatchMaximumCount, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, Azure.Core.TokenCredential credential, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);new Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : Azure.Messaging.EventHubs.Primitives.CheckpointStore * int * string * string * string * Azure.Core.TokenCredential * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>Protected Sub New (checkpointStore As CheckpointStore, eventBatchMaximumCount As Integer, consumerGroup As String, fullyQualifiedNamespace As String, eventHubName As String, credential As TokenCredential, Optional options As EventProcessorOptions = Nothing)Parameter
- checkpointStore
- CheckpointStore
Der Anbieter von Prüfpunkt- und Besitzdaten für den Prozessor. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben.
- eventBatchMaximumCount
- Int32
Die gewünschte Anzahl von Ereignissen, die in einen zu verarbeitenden Batch eingeschlossen werden sollen. Diese Größe ist die maximale Anzahl in einem Batch. die tatsächliche Anzahl kann kleiner sein, je nachdem, ob Ereignisse im Event Hub verfügbar sind.
- consumerGroup
- String
Der Name der Consumergruppe, der dieser Prozessor zugeordnet ist. Der Prozessor bestätigt exklusiven Lesezugriff auf Partitionen für diese Gruppe.
- fullyQualifiedNamespace
- String
Der vollqualifizierte Event Hubs-Namespace, mit dem eine Verbindung hergestellt werden soll. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net
- eventHubName
- String
Der Name des spezifischen Event Hubs, dem der Prozessor zugeordnet werden soll.
- credential
- TokenCredential
Die Anmeldeinformationen für verwaltete Azure-Identitäten, die für die Autorisierung verwendet werden sollen. Zugriffssteuerungen können je nach Azure-Konfiguration vom Event Hubs-Namespace oder vom angeforderten Event Hub angegeben werden.
- options
- EventProcessorOptions
Der Satz von Optionen, die für den Prozessor verwendet werden sollen.
Ausnahmen
Tritt auf, wenn die angeforderte eventBatchMaximumCount kleiner als 1 ist.
Gilt für:
Azure SDK for .NET