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

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

async 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,
None