Freigeben über


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

Die EventData-Instanz, die die Für den Prüfpunkt verwendeten Offset- und Sequenznummerninformationen enthält.

Standardwert: None

Gibt zurück

Typ Beschreibung

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,