PartitionContext Osztály

Partícióval kapcsolatos környezeti információkat tartalmaz.

A rendszer egy PartitionContext-példányt ad át az EventHubConsumerClient.receive() hívásakor definiált esemény-, hiba- és inicializálási visszahívásoknak. A felhasználók meghívhatják az osztály update_checkpoint() az ellenőrzőpont-adatok megőrzéséhez.

Öröklődés

builtins.object

PartitionContext

Konstruktor

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

Paraméterek

Name	Description
fully_qualified_namespace Kötelező
eventhub_name Kötelező
consumer_group Kötelező
partition_id Kötelező
checkpoint_store	alapértelmezett érték: None

Metódusok

update_checkpoint

Frissítések a fogadási ellenőrzőpontot az adott események eltolásához.

update_checkpoint

Frissítések a fogadási ellenőrzőpontot az adott események eltolásához.

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

Paraméterek

Name	Description
event	EventData Az EventData-példány, amely az ellenőrzőponthoz használt eltolás- és sorszámadatokat tartalmazza. alapértelmezett érték: None

Válaszok

Típus	Description
None

Attribútumok

last_enqueued_event_properties

A legújabb lekérdezett eseményinformációk.

Ez a tulajdonság minden alkalommal frissül, amikor egy esemény érkezik, ha a fogadó létrejön , és track_last_enqueued_event_propertiesIgaz értékre van állítva. A tulajdonságokra vonatkozó diktálás az utolsó lekért esemény következő adatait tartalmazza:

• sequence_number (int)

• eltolás (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Válaszok

Típus	Description
Dict[str, Any], None