BlobCheckpointStore Klasse

Definition

Namespace:

Azure.Messaging.EventHubs.Primitives

Assembly:

Azure.Messaging.EventHubs.Processor.dll

Paket:

Azure.Messaging.EventHubs.Processor v5.10.0

Ermöglicht die Interaktion mit Prüfpunkt- und Besitzdaten, die für den Ereignisprozessorbetrieb erforderlich sind, wobei Azure Storage-Blobs für die Persistenz verwendet werden.

public class BlobCheckpointStore : Azure.Messaging.EventHubs.Primitives.CheckpointStore

type BlobCheckpointStore = class
    inherit CheckpointStore

Public Class BlobCheckpointStore
Inherits CheckpointStore

Vererbung

Object

CheckpointStore

BlobCheckpointStore

Konstruktoren

BlobCheckpointStore(BlobContainerClient)

Initialisiert eine neue Instanz der BlobCheckpointStore-Klasse.

Methoden

ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken)	Versucht, den Besitz der angegebenen Partitionen für die Verarbeitung in Anspruch zu nehmen. Dieser Vorgang wird vom Lastenausgleich verwendet, um die Verteilung der Verantwortung für die Verarbeitung von Partitionen für einen Event Hub und eine Consumergruppe zwischen den aktiven Ereignisprozessoren zu ermöglichen.
GetCheckpointAsync(String, String, String, String, CancellationToken)	Fordert Prüfpunktinformationen für eine bestimmte Partition an, sodass ein Ereignisprozessor das Lesen des nächsten Ereignisses im Stream fortsetzen kann.
ListOwnershipAsync(String, String, String, CancellationToken)	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.
UpdateCheckpointAsync(String, String, String, String, Int64, Nullable<Int64>, CancellationToken)	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.