Compartir a través de


Microsoft.Azure.EventHubs.Processor Espacio de nombres

Clases

Checkpoint

Objeto de contexto utilizado para conservar el estado en la secuencia.

EventProcessorConfigurationException

Excepción que especifica que la EventProcessorHost configuración es incorrecta.

EventProcessorHost

Representa un host para procesar los datos de eventos de Event Hubs.

EventProcessorOptions

Define las opciones en tiempo de ejecución al registrar una IEventProcessor interfaz con un EventHubConsumerGroup. Este es también el mecanismo para detectar excepciones de una instancia de IEventProcessor utilizada por un EventProcessorHost objeto .

EventProcessorRuntimeException

Excepción producida durante el procesamiento de eventos.

ExceptionReceivedEventArgs

Proporciona datos para el evento Microsoft.Azure.EventHubs.Processor.EventProcessorOptions.NotifyOfException(System.String,System.String,System.Exception,System.String).

Lease

Contiene información de propiedad de partición.

LeaseLostException

Representa una excepción que se produce cuando se ha perdido la concesión del servicio.

PartitionContext

Encapsula la información relacionada con una partición de Event Hubs usada por IEventProcessor.

PartitionManagerOptions

Opciones para controlar varios aspectos de la distribución de particiones que se producen dentro de EventProcessorHost la instancia.

Interfaces

ICheckpointManager

Si desea que EventProcessorHost almacene puntos de control en algún lugar distinto de Azure Storage, puede escribir su propio administrador de puntos de control mediante esta interfaz.

Los administradores de Azure Storage usan el mismo almacenamiento para las concesiones y los puntos de control, por lo que ambas interfaces se implementan mediante la misma clase. Puede hacer lo mismo si tiene un almacén unificado para ambos tipos de datos.

Esta interfaz no especifica métodos de inicialización porque no tenemos ninguna manera de saber qué información requerirá la implementación.

IEventProcessor

Interfaz que deben implementar las clases de procesador de eventos.

Cualquier instancia determinada de una clase de procesador de eventos solo procesará eventos de una partición de un centro de eventos. PartitionContext se proporciona con cada llamada al procesador de eventos porque algunos parámetros podrían cambiar, pero siempre será la misma partición.

Aunque EventProcessorHost es multiproceso, las llamadas a una instancia determinada de una clase de procesador de eventos se serializan, excepto OnError(). Primero se llama a OnOpen() y, a continuación, a OnEvents() se le llamará cero o más veces. Cuando es necesario apagar el procesador de eventos, ya sea porque se produjo un error en algún lugar o se ha perdido la concesión de la partición, o porque se está cerrando todo el host del procesador, se llama a OnClose() después de que se devuelva la última llamada a OnEvents().

Se podría llamar a OnError() mientras onEvents() o OnClose() se está ejecutando. No se intenta realizar ninguna sincronización para evitar posiblemente interbloqueos.

IEventProcessorFactory

Interfaz que debe implementar una clase de generador de procesadores de eventos.

Los generadores proporcionados por el usuario son necesarios si la creación de un objeto de procesador de eventos requiere más trabajo que un nuevo con un constructor sin parámetros.

ILeaseManager

Si desea tener concesiones de almacén de EventProcessorHost en algún lugar distinto de Azure Storage, puede escribir su propio administrador de concesiones mediante esta interfaz.

Los administradores de Azure Storage usan el mismo almacenamiento para las concesiones y los puntos de control, por lo que ambas interfaces se implementan mediante la misma clase. Puede hacer lo mismo si tiene un almacén unificado para ambos tipos de datos.

Esta interfaz no especifica métodos de inicialización porque no tenemos ninguna manera de saber qué información requerirá la implementación.

Enumeraciones

CloseReason

Motivo para cerrar un .EventProcessorHost