BlobCheckpointStore Classe

Definição

Namespace:

Azure.Messaging.EventHubs.Primitives

Assembly:

Azure.Messaging.EventHubs.Processor.dll

Pacote:

Azure.Messaging.EventHubs.Processor v5.10.0

Permite a interação com os dados de ponto de verificação e propriedade necessários para a operação do processador de eventos, usando blobs de Armazenamento do Azure para persistência.

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

type BlobCheckpointStore = class
    inherit CheckpointStore

Public Class BlobCheckpointStore
Inherits CheckpointStore

Herança

Object

CheckpointStore

BlobCheckpointStore

Construtores

BlobCheckpointStore(BlobContainerClient)

Inicializa uma nova instância da classe BlobCheckpointStore.

Métodos

ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken)	Tenta reivindicar a propriedade das partições especificadas para processamento. Essa operação é usada pelo balanceamento de carga para habilitar a distribuição da responsabilidade pelo processamento de partições para um Hub de Eventos e emparelhamento de grupo de consumidores entre os processadores de eventos ativos.
GetCheckpointAsync(String, String, String, String, CancellationToken)	Solicita informações de ponto de verificação para uma partição específica, permitindo que um processador de eventos retome a leitura do próximo evento no fluxo.
ListOwnershipAsync(String, String, String, CancellationToken)	Solicita uma lista das atribuições de propriedade para partições entre cada uma das instâncias de processador de eventos de cooperação para um determinado Hub de Eventos e emparelhamento de grupo de consumidores. Essa operação é usada durante o balanceamento de carga para permitir que o processador descubra outros colaboradores ativos e tome decisões sobre como equilibrar melhor o trabalho entre eles.
UpdateCheckpointAsync(String, String, String, String, Int64, Nullable<Int64>, CancellationToken)	Cria ou atualiza um ponto de verificação para uma partição específica, identificando uma posição no fluxo de eventos da partição da qual um processador de eventos deve começar a ler.