PartitionContext Класс

Содержит сведения о контексте, связанные с разделами.

Экземпляр PartitionContext будет передан в обратные вызовы события, ошибки и инициализации, определенные при вызове EventHubConsumerClient.receive() . Пользователи могут вызывать update_checkpoint() этого класса для сохранения данных контрольных точек.

Наследование

builtins.object

PartitionContext

Конструктор

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

Параметры

Имя	Описание
fully_qualified_namespace Обязательно
eventhub_name Обязательно
consumer_group Обязательно
partition_id Обязательно
checkpoint_store	значение по умолчанию: None

Методы

update_checkpoint

Обновления контрольную точку получения в заданное смещение событий.

update_checkpoint

Обновления контрольную точку получения в заданное смещение событий.

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

Параметры

Имя	Описание
event	EventData Экземпляр EventData, содержащий сведения о смещениях и порядковых номерах, используемых для контрольной точки. значение по умолчанию: None

Возвращаемое значение

Тип	Описание
None

Атрибуты

last_enqueued_event_properties

Последние сведения о событии в очереди.

Это свойство будет обновляться каждый раз при получении события, если получатель создается с track_last_enqueued_event_properties задано значение True. Дикт свойств содержит следующие сведения о последнем событии в очереди:

• sequence_number (int)

• offset (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

Возвращаемое значение

Тип	Описание
Dict[str, Any], None