PartitionContext Classe

Contiene informazioni sul contesto correlate alla partizione.

Un'istanza PartitionContext verrà passata all'evento, all'errore e ai callback di inizializzazione definiti quando si chiama EventHubConsumerClient.receive(). Gli utenti possono chiamare update_checkpoint() di questa classe per rendere persistenti i dati del checkpoint.

Ereditarietà

builtins.object

PartitionContext

Costruttore

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

Parametri

Nome	Descrizione
fully_qualified_namespace Necessario
eventhub_name Necessario
consumer_group Necessario
partition_id Necessario
checkpoint_store	valore predefinito: None

Metodi

update_checkpoint

Aggiornamenti il checkpoint di ricezione all'offset degli eventi specificato.

update_checkpoint

Aggiornamenti il checkpoint di ricezione all'offset degli eventi specificato.

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

Parametri

Nome	Descrizione
event	EventData Istanza di EventData che contiene le informazioni sul numero di offset e sequenza usate per il checkpoint. valore predefinito: None

Restituisce

Tipo	Descrizione
None

Attributi

last_enqueued_event_properties

Informazioni sull'evento più recenti.

Questa proprietà verrà aggiornata ogni volta che viene ricevuto un evento se il ricevitore viene creato con track_last_enqueued_event_properties impostato su True. Le proprietà dict includono le informazioni seguenti dell'ultimo evento inqueued:

• sequence_number (int)

• offset (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Restituisce

Tipo	Descrizione
dict, None