PartitionContext Classe

Contém informações de contexto relacionadas à partição.

Uma instância PartitionContext será passada para o evento, erros e retornos de chamada de inicialização definidos ao chamar EventHubConsumerClient.receive(). Os usuários podem chamar update_checkpoint() dessa classe para persistir os dados de ponto de verificação.

Herança

builtins.object

PartitionContext

Construtor

PartitionContext(fully_qualified_namespace: str, eventhub_name: str, consumer_group: str, partition_id: str, checkpoint_store: CheckpointStore | None = None)

Parâmetros

Nome	Description
fully_qualified_namespace Obrigatório
eventhub_name Obrigatório
consumer_group Obrigatório
partition_id Obrigatório
checkpoint_store	valor padrão: None

Métodos

update_checkpoint

Atualizações o ponto de verificação de recebimento para o deslocamento de eventos fornecidos.

update_checkpoint

Atualizações o ponto de verificação de recebimento para o deslocamento de eventos fornecidos.

update_checkpoint(event: EventData | None = None, **kwargs: Any) -> None

Parâmetros

Nome	Description
event	EventData A instância EventData que contém as informações de deslocamento e número de sequência usadas para o ponto de verificação. valor padrão: None

Retornos

Tipo	Description
None

Atributos

last_enqueued_event_properties

As informações mais recentes do evento enfileirado.

Essa propriedade será atualizada sempre que um evento for recebido se o receptor for criado com track_last_enqueued_event_properties definido como True. O ditado de propriedades inclui as seguintes informações do último evento enfileirado:

• sequence_number (int)

• offset (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Retornos

Tipo	Description
Dict[str, Any], None