PartitionContext Classe

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.

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[str, Any], None