Partager via

BlobCheckpointStore Classe

  • Référence

Définition

Espace de noms:
Azure.Messaging.EventHubs.Primitives
Assembly:
Azure.Messaging.EventHubs.Processor.dll
Paquet:
Azure.Messaging.EventHubs.Processor v5.10.0

Permet l’interaction avec les données de contrôle et de propriété nécessaires pour le fonctionnement du processeur d’événements, à l’aide d’objets blob stockage Azure pour la persistance.

public class BlobCheckpointStore : Azure.Messaging.EventHubs.Primitives.CheckpointStore
type BlobCheckpointStore = class
    inherit CheckpointStore
Public Class BlobCheckpointStore
Inherits CheckpointStore
Héritage
Object
CheckpointStore
BlobCheckpointStore

Constructeurs

BlobCheckpointStore(BlobContainerClient)

Initialise une nouvelle instance de la classe BlobCheckpointStore.

Méthodes

ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken)

Tente de revendiquer la propriété des partitions spécifiées pour le traitement. Cette opération est utilisée par l’équilibrage de charge pour permettre la répartition de la responsabilité du traitement des partitions pour un hub d’événements et un regroupement de consommateurs entre les processeurs d’événements actifs.
GetCheckpointAsync(String, String, String, String, CancellationToken)

Demande des informations de point de contrôle pour une partition spécifique, ce qui permet à un processeur d’événements de reprendre la lecture de l’événement suivant dans le flux.
ListOwnershipAsync(String, String, String, CancellationToken)

Demande une liste des attributions de propriété pour les partitions entre chacune des instances de processeur d’événements qui coopèrent pour un appairage Event Hub et un groupe de consommateurs donné. Cette opération est utilisée lors de l’équilibrage de charge pour permettre au processeur de découvrir d’autres collaborateurs actifs et de prendre des décisions sur la meilleure façon d’équilibrer le travail entre eux.
UpdateCheckpointAsync(String, String, String, String, Int64, Nullable<Int64>, CancellationToken)

Crée ou met à jour un point de contrôle pour une partition spécifique, identifiant une position dans le flux d’événements de la partition à partir de laquelle un processeur d’événements doit commencer à lire.

S’applique à