PartitionContext Třída

Obsahuje kontextové informace související s oddíly.

Instance PartitionContext se předá zpětná volání událostí, chyb a inicializace definovaných při volání EventHubConsumerClient.receive(). Uživatelé mohou volat update_checkpoint() této třídy k zachování dat kontrolního bodu.

Dědičnost

builtins.object

PartitionContext

Konstruktor

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

Parametry

Name	Description
fully_qualified_namespace Vyžadováno
eventhub_name Vyžadováno
consumer_group Vyžadováno
partition_id Vyžadováno
checkpoint_store	výchozí hodnota: None

Metody

update_checkpoint

Aktualizace kontrolní bod příjmu k danému posunu událostí.

update_checkpoint

Aktualizace kontrolní bod příjmu k danému posunu událostí.

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

Parametry

Name	Description
event	EventData Instance EventData, která obsahuje informace o posunu a pořadovém čísle používané pro kontrolní bod. výchozí hodnota: None

Návraty

Typ	Description
None

Atributy

last_enqueued_event_properties

Nejnovější informace o události ve frontě.

Tato vlastnost se aktualizuje při každém přijetí události, pokud je příjemce vytvořen s track_last_enqueued_event_properties nastavenou na Hodnotu True. Příkaz properties dict obsahuje následující informace o poslední události vložené do fronty:

• sequence_number (int)

• offset (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Návraty

Typ	Description
dict, None