PartitionContext Klass

Innehåller partitionsrelaterad kontextinformation.

En PartitionContext-instans skickas till händelse-, fel- och initieringsåteranrop som definieras när eventHubConsumerClient.receive()anropas. Användare kan anropa update_checkpoint() i den här klassen för att spara kontrollpunktsdata.

Arv

builtins.object

PartitionContext

Konstruktor

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

Parametrar

Name	Description
fully_qualified_namespace Obligatorisk
eventhub_name Obligatorisk
consumer_group Obligatorisk
partition_id Obligatorisk
checkpoint_store	standardvärde: None

Metoder

update_checkpoint

Uppdateringar mottag kontrollpunkten till den angivna händelseförskjutningen.

update_checkpoint

Uppdateringar mottag kontrollpunkten till den angivna händelseförskjutningen.

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

Parametrar

Name	Description
event	EventData EventData-instansen som innehåller förskjutnings- och sekvensnummerinformationen som används för kontrollpunkten. standardvärde: None

Returer

Typ	Description
None

Attribut

last_enqueued_event_properties

Den senaste informationen om den aktuella händelsen.

Den här egenskapen uppdateras varje gång en händelse tas emot om mottagaren skapas med track_last_enqueued_event_properties inställd på Sant. Egenskapsdikten innehåller följande information om den senaste köade händelsen:

• sequence_number (int)

• offset (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Returer

Typ	Description
Dict[str, Any], None