BlobCheckpointStore.ListOwnershipAsync Methode

  • Referenz

Definition

Namespace:
Azure.Messaging.EventHubs.Primitives
Assembly:
Azure.Messaging.EventHubs.Processor.dll
Paket:
Azure.Messaging.EventHubs.Processor v5.11.3
Paket:
Azure.Messaging.EventHubs.Processor v5.12.0-beta.1
Quelle:
BlobCheckpointStore.cs
Quelle:
BlobCheckpointStore.cs

Fordert eine Liste der Besitzzuweisungen für Partitionen zwischen den einzelnen kooperierenden Ereignisprozessorinstanzen für eine bestimmte Event Hub- und Consumergruppenpaarung an. Dieser Vorgang wird während des Lastenausgleichs verwendet, um es dem Prozessor zu ermöglichen, andere aktive Mitarbeiter zu ermitteln und Entscheidungen darüber zu treffen, wie die Arbeit zwischen ihnen optimal ausbalanciert werden kann.

public override System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>> ListOwnershipAsync (string fullyQualifiedNamespace, string eventHubName, string consumerGroup, System.Threading.CancellationToken cancellationToken);
override this.ListOwnershipAsync : string * string * string * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>>
Public Overrides Function ListOwnershipAsync (fullyQualifiedNamespace As String, eventHubName As String, consumerGroup As String, cancellationToken As CancellationToken) As Task(Of IEnumerable(Of EventProcessorPartitionOwnership))

Parameter

fullyQualifiedNamespace
String

Der vollqualifizierte Event Hubs-Namespace, dem der Besitz zugeordnet ist. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net

eventHubName
String

Der Name des spezifischen Event Hubs, dem der Besitz zugeordnet ist, relativ zum Event Hubs-Namespace, der ihn enthält.

consumerGroup
String

Der Name der Consumergruppe, der der Besitz zugeordnet ist.

cancellationToken
CancellationToken

Ein CancellationToken instance, um die Anforderung zum Abbrechen der Verarbeitung zu signalisieren. Dies tritt am wahrscheinlichsten auf, wenn der Prozessor heruntergefahren wird.

Gibt zurück

Task<IEnumerable<EventProcessorPartitionOwnership>>

Der Satz von Besitzdaten, die bei Lastenausgleichsentscheidungen berücksichtigt werden sollen.

Gilt für: