PartitionContext Classe

Contient des informations de contexte liées à la partition.

Une instance PartitionContext est passée aux rappels d’événement, d’erreur et d’initialisation définis lors de l’appel d’EventHubConsumerClient.receive().. Les utilisateurs peuvent appeler update_checkpoint() de cette classe pour conserver les données de point de contrôle.

Héritage

builtins.object

PartitionContext

Constructeur

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

Paramètres

Nom	Description
fully_qualified_namespace Obligatoire
eventhub_name Obligatoire
consumer_group Obligatoire
partition_id Obligatoire
checkpoint_store	valeur par défaut: None

Méthodes

update_checkpoint

Mises à jour le point de contrôle de réception au décalage des événements donnés.

update_checkpoint

Mises à jour le point de contrôle de réception au décalage des événements donnés.

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

Paramètres

Nom	Description
event	EventData Instance EventData qui contient les informations de décalage et de numéro de séquence utilisées pour le point de contrôle. valeur par défaut: None

Retours

Type	Description
None

Attributs

last_enqueued_event_properties

Informations les plus récentes sur les événements mis en file d’attente.

Cette propriété est mise à jour chaque fois qu’un événement est reçu si le récepteur est créé avec track_last_enqueued_event_properties défini sur True. Le dicté des propriétés inclut les informations suivantes sur le dernier événement mis en file d’attente :

• sequence_number (int)

• offset (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Retours

Type	Description
dict, None