PartitionContext Klasa

Zawiera informacje kontekstowe powiązane z partycją.

Wystąpienie PartitionContext zostanie przekazane do zdarzenia, błędu i wywołań zwrotnych inicjowania zdefiniowanych podczas wywoływania klasy EventHubConsumerClient.receive(). Użytkownicy mogą wywoływać update_checkpoint() tej klasy, aby utrwały dane punktu kontrolnego.

Dziedziczenie

builtins.object

PartitionContext

Konstruktor

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

Parametry

Nazwa	Opis
fully_qualified_namespace Wymagane
eventhub_name Wymagane
consumer_group Wymagane
partition_id Wymagane
checkpoint_store	wartość domyślna: None

Metody

update_checkpoint

Aktualizacje punkt kontrolny odbierania do danego przesunięcia zdarzeń.

update_checkpoint

Aktualizacje punkt kontrolny odbierania do danego przesunięcia zdarzeń.

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

Parametry

Nazwa	Opis
event	EventData Wystąpienie EventData, które zawiera informacje dotyczące przesunięcia i numeru sekwencji używane do punktu kontrolnego. wartość domyślna: None

Zwraca

Typ	Opis
None

Atrybuty

last_enqueued_event_properties

Najnowsze informacje o zdarzeniu w kolejce.

Ta właściwość będzie aktualizowana za każdym razem, gdy zdarzenie zostanie odebrane, jeśli odbiornik zostanie utworzony z track_last_enqueued_event_properties ustawiony na wartość True. Dykt właściwości zawiera następujące informacje o ostatnim zdarzeniu w kolejce:

• sequence_number (int)

• przesunięcie (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Zwraca

Typ	Opis
Dict[str, Any], None