PartitionContext Klasse

Enthält partitionsbezogene Kontextinformationen.

Eine PartitionContext-Instanz wird an die Beim Aufrufen von EventHubConsumerClient.receive()definierten Ereignis-, Fehler- und Initialisierungsrückrufe übergeben. Benutzer können update_checkpoint() dieser Klasse aufrufen, um Prüfpunktdaten zu speichern.

Vererbung

builtins.object

PartitionContext

Konstruktor

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

Parameter

Name	Beschreibung
fully_qualified_namespace Erforderlich
eventhub_name Erforderlich
consumer_group Erforderlich
partition_id Erforderlich
checkpoint_store	Standardwert: None

Methoden

update_checkpoint

Aktualisierungen den Empfangsprüfpunkt auf den angegebenen Ereignisoffset.

update_checkpoint

Aktualisierungen den Empfangsprüfpunkt auf den angegebenen Ereignisoffset.

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

Parameter

Name	Beschreibung
event	EventData Die EventData-Instanz, die die Für den Prüfpunkt verwendeten Offset- und Sequenznummerninformationen enthält. Standardwert: None

Gibt zurück

Typ	Beschreibung
None

Attribute

last_enqueued_event_properties

Die neuesten queuierten Ereignisinformationen.

Diese Eigenschaft wird jedes Mal aktualisiert, wenn ein Ereignis empfangen wird, wenn der Empfänger mit track_last_enqueued_event_properties auf True festgelegt wird. Das Eigenschaften-Dict enthält die folgenden Informationen des letzten enqueued-Ereignisses:

• sequence_number (int)

• offset (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Gibt zurück

Typ	Beschreibung
dict, None