PartitionContext interface
Interfaz que describe el contexto pasado a cada una de las funciones que forman parte del SubscriptionEventHandlers. Al implementar cualquiera de estas funciones, use el objeto de contexto para obtener información sobre la partición, así como la capacidad de realizar puntos de control.
Propiedades
| consumer |
Nombre del grupo de consumidores. |
| event |
Nombre del centro de eventos. |
| fully |
Espacio de nombres completo de Event Hubs. Es probable que sea similar a <yournamespace.servicebus.windows.net> |
| last |
Información sobre el último evento en cola de la partición que se está procesando.
Esta propiedad solo se actualiza si la opción |
| partition |
Identificador de la partición del centro de eventos. |
Métodos
| update |
Actualiza el punto de control mediante los datos del evento. Un punto de control está diseñado para representar el último evento procesado correctamente por el usuario de una partición determinada de un grupo de consumidores en una instancia del Centro de eventos. |
Detalles de las propiedades
consumerGroup
Nombre del grupo de consumidores.
consumerGroup: stringValor de propiedad
string
eventHubName
Nombre del centro de eventos.
eventHubName: stringValor de propiedad
string
fullyQualifiedNamespace
Espacio de nombres completo de Event Hubs. Es probable que sea similar a <yournamespace.servicebus.windows.net>
fullyQualifiedNamespace: stringValor de propiedad
string
lastEnqueuedEventProperties
Información sobre el último evento en cola de la partición que se está procesando.
Esta propiedad solo se actualiza si la opción trackLastEnqueuedEventProperties está establecida en true al crear una instancia de EventProcessor.
lastEnqueuedEventProperties?: LastEnqueuedEventPropertiesValor de propiedad
partitionId
Identificador de la partición del centro de eventos.
partitionId: stringValor de propiedad
string
Detalles del método
updateCheckpoint(ReceivedEventData)
Actualiza el punto de control mediante los datos del evento.
Un punto de control está diseñado para representar el último evento procesado correctamente por el usuario de una partición determinada de un grupo de consumidores en una instancia del Centro de eventos.
function updateCheckpoint(eventData: ReceivedEventData): Promise<void>Parámetros
- eventData
- ReceivedEventData
Evento con el que desea actualizar el punto de control.
Devoluciones
Promise<void>