Partilhar via

PartitionContext Classe

  • Referência

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

Uma instância PartitionContext será transmitida para as chamadas de evento, erro e inicialização definidas ao chamar EventHubConsumerClient.receive(). Os utilizadores podem chamar update_checkpoint desta classe para persistir em dados 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

Name Description
fully_qualified_namespace
Necessário
eventhub_name
Necessário
consumer_group
Necessário
partition_id
Necessário
checkpoint_store
valor predefinido: None

Métodos

update_checkpoint

Atualizações o posto de controlo de receção para a compensação dos eventos.

update_checkpoint

Atualizações o posto de controlo de receção para a compensação dos eventos.

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

Parâmetros

Name Description
event
EventData

A instância EventData que contém as informações de número de offset e sequência utilizadas para o checkpoint.

valor predefinido: None

Devoluções

Tipo Description
None

Atributos

last_enqueued_event_properties

As últimas informações sobre eventos.

Esta propriedade será atualizada cada vez que um evento for recebido se o recetor for criado com track_last_enqueued_event_properties definido para True. O dict propriedades inclui as seguintes informações do último evento enqueso:

  • sequence_number (int)

  • offset (str)

  • enqueued_time (hora de data da UTC.datetime)

  • retrieval_time (hora de data da UTC.datetime)

Devoluções

Tipo Description
dict,
None