Поделиться через

PartitionContext interface

  • Ссылка
Пакет:
@azure/event-hubs

Интерфейс, описывающий контекст, передаваемый каждому из функций, которые являются частью SubscriptionEventHandlers. При реализации любой из этих функций используйте объект контекста для получения сведений о секции, а также возможности контрольной точки.

Свойства

consumerGroup

Имя группы потребителей.
eventHubName

Имя концентратора событий.
fullyQualifiedNamespace

Полное пространство имен Центров событий. Скорее всего, это похоже на .servicebus.windows.net
lastEnqueuedEventProperties

Сведения о последнем заквеченном событии в секции, которая обрабатывается. Это свойство обновляется только в том случае, если параметр trackLastEnqueuedEventProperties имеет значение true при создании экземпляра EventProcessor.
partitionId

Идентификатор секции Концентратора событий.

Методы

updateCheckpoint(ReceivedEventData)

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

Контрольная точка предназначена для представления последнего успешно обработанного пользователем события из определенной секции группы потребителей в экземпляре Концентратора событий.

Сведения о свойстве

consumerGroup

Имя группы потребителей.

consumerGroup: string

Значение свойства

string

eventHubName

Имя концентратора событий.

eventHubName: string

Значение свойства

string

fullyQualifiedNamespace

Полное пространство имен Центров событий. Скорее всего, это похоже на .servicebus.windows.net

fullyQualifiedNamespace: string

Значение свойства

string

lastEnqueuedEventProperties

Сведения о последнем заквеченном событии в секции, которая обрабатывается. Это свойство обновляется только в том случае, если параметр trackLastEnqueuedEventProperties имеет значение true при создании экземпляра EventProcessor.

lastEnqueuedEventProperties?: LastEnqueuedEventProperties

Значение свойства

LastEnqueuedEventProperties

partitionId

Идентификатор секции Концентратора событий.

partitionId: string

Значение свойства

string

Сведения о методе

updateCheckpoint(ReceivedEventData)

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

Контрольная точка предназначена для представления последнего успешно обработанного пользователем события из определенной секции группы потребителей в экземпляре Концентратора событий.

function updateCheckpoint(eventData: ReceivedEventData): Promise<void>

Параметры

eventData
ReceivedEventData

Событие, с которым требуется обновить контрольную точку.

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

Promise<void>