PartitionContext Clase

Contiene información de contexto relacionada con particiones.

Se pasará una instancia de PartitionContext al evento, las devoluciones de llamada de error e inicialización definidas al llamar a EventHubConsumerClient.receive(). Los usuarios pueden llamar a update_checkpoint() de esta clase para conservar los datos del punto de control.

Herencia

builtins.object

PartitionContext

Constructor

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

Parámetros

Nombre	Description
fully_qualified_namespace Requerido
eventhub_name Requerido
consumer_group Requerido
partition_id Requerido
checkpoint_store	valor predeterminado: None

Métodos

update_checkpoint

Novedades el punto de control de recepción al desplazamiento de eventos especificado.

update_checkpoint

Novedades el punto de control de recepción al desplazamiento de eventos especificado.

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

Parámetros

Nombre	Description
event	EventData Instancia de EventData que contiene la información de desplazamiento y número de secuencia utilizada para el punto de control. valor predeterminado: None

Devoluciones

Tipo	Description
None

Atributos

last_enqueued_event_properties

La información de eventos en cola más reciente.

Esta propiedad se actualizará cada vez que se reciba un evento si el receptor se crea con track_last_enqueued_event_properties establecido enTrue. La diferencia de propiedades incluye la siguiente información del último evento en cola:

• sequence_number (int)

• offset (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Devoluciones

Tipo	Description
dict, None