BlobCheckpointStore.UpdateCheckpointAsync Methode

Definition

Namespace:

Azure.Messaging.EventHubs.Primitives

Assembly:

Azure.Messaging.EventHubs.Processor.dll

Paket:

Azure.Messaging.EventHubs.Processor v5.10.0

Erstellt oder aktualisiert einen Prüfpunkt für eine bestimmte Partition, um eine Position im Ereignisstream der Partition zu identifizieren, von der ein Ereignisprozessor mit dem Lesen beginnen soll.

public override System.Threading.Tasks.Task UpdateCheckpointAsync (string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId, long offset, long? sequenceNumber, System.Threading.CancellationToken cancellationToken);

override this.UpdateCheckpointAsync : string * string * string * string * int64 * Nullable<int64> * System.Threading.CancellationToken -> System.Threading.Tasks.Task

Public Overrides Function UpdateCheckpointAsync (fullyQualifiedNamespace As String, eventHubName As String, consumerGroup As String, partitionId As String, offset As Long, sequenceNumber As Nullable(Of Long), cancellationToken As CancellationToken) As Task

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 Prüfpunkt zugeordnet ist.

partitionId

String

Der Bezeichner der Partition, für die der Prüfpunkt verwendet wird.

offset

Int64

Der Offset, der dem Prüfpunkt zugeordnet werden soll, der angibt, dass ein Prozessor mit dem Lesen des nächsten Ereignisses im Stream beginnen soll.

sequenceNumber

Nullable<Int64>

Eine optionale Sequenznummer, die dem Prüfpunkt zugeordnet werden soll und als Informationsmetadaten vorgesehen ist. Wird offset für die Positionierung verwendet, wenn Ereignisse gelesen werden.

cancellationToken

CancellationToken

Ein CancellationToken instance, um eine Anforderung zum Abbrechen des Vorgangs zu signalisieren.

Gibt zurück

Task