PartitionContext Klas

Bevat informatie over de partitiegerelateerde context.

Een PartitionContext-exemplaar wordt doorgegeven aan de callbacks voor gebeurtenissen, fouten en initialisatie die zijn gedefinieerd bij het aanroepen van EventHubConsumerClient.receive(). Gebruikers kunnen update_checkpoint() van deze klasse aanroepen om controlepuntgegevens te behouden.

Overname

builtins.object

PartitionContext

Constructor

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

Parameters

Name	Description
fully_qualified_namespace Vereist
eventhub_name Vereist
consumer_group Vereist
partition_id Vereist
checkpoint_store	standaardwaarde: None

Methoden

update_checkpoint

Updates het ontvangstcontrolepunt naar de opgegeven gebeurtenis offset.

update_checkpoint

Updates het ontvangstcontrolepunt naar de opgegeven gebeurtenis offset.

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

Parameters

Name	Description
event	EventData Het EventData-exemplaar dat de offset- en volgnummergegevens bevat die voor het controlepunt worden gebruikt. standaardwaarde: None

Retouren

Type	Description
None

Kenmerken

last_enqueued_event_properties

De meest recente informatie over de enqueued-gebeurtenis.

Deze eigenschap wordt telkens bijgewerkt wanneer een gebeurtenis wordt ontvangen als de ontvanger wordt gemaakt met track_last_enqueued_event_properties ingesteld op True. Het eigenschappendict bevat de volgende informatie over de laatste enqueued-gebeurtenis:

• sequence_number (int)

• verschuiving (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Retouren

Type	Description
Dict[str, Any], None