EventProcessorHost Clase

Definición

Espacio de nombres:

Microsoft.Azure.EventHubs.Processor

Ensamblado:

Microsoft.Azure.EventHubs.Processor.dll

Paquete:

Microsoft.Azure.EventHubs.Processor v4.3.2

Source:

EventProcessorHost.cs

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

public sealed class EventProcessorHost

type EventProcessorHost = class

Public NotInheritable Class EventProcessorHost

Herencia

Object

EventProcessorHost

Constructores

EventProcessorHost(String, String, String, String, ICheckpointManager, ILeaseManager)	Cree un nuevo host para procesar eventos desde un centro de eventos. Esta sobrecarga del constructor permite la máxima flexibilidad. Esto permite al autor de la llamada especificar también el nombre del host del procesador. La sobrecarga también permite al autor de la llamada proporcionar sus propios administradores de puntos de control y concesión para reemplazar los integrados basados en Azure Storage.
EventProcessorHost(String, String, String, String, String)	Cree un nuevo host para procesar eventos desde un centro de eventos. Dado que Event Hubs se usa con frecuencia para escenarios de escalado horizontal y de alto tráfico, por lo general solo habrá un host por proceso y los procesos se ejecutarán en máquinas independientes. Sin embargo, se admite la ejecución de varios hosts en una máquina, o incluso dentro de un proceso, si el rendimiento no es un problema. Esta sobrecarga del constructor usa los administradores de puntos de control y concesión integrados predeterminados. Los administradores integrados usan la cuenta de Azure Storage especificada por el parámetro storageConnectionString para registrar concesiones y puntos de control.
EventProcessorHost(String, String, String, String, String, String, String)	Cree un nuevo host para procesar eventos desde un centro de eventos. Esta sobrecarga del constructor usa los administradores de puntos de control y concesión integrados predeterminados.
EventProcessorHost(String, Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)	Creación de un nuevo host para procesar eventos desde un centro de eventos con proporcionado TokenProvider
EventProcessorHost(String, Uri, String, String, ITokenProvider, ICheckpointManager, ILeaseManager, Nullable<TimeSpan>, TransportType)	Creación de un nuevo host para procesar eventos desde un centro de eventos con proporcionado TokenProvider
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String)	Creación de un nuevo host para procesar eventos desde un centro de eventos con proporcionado TokenProvider
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)	Creación de un nuevo host para procesar eventos desde un centro de eventos con proporcionado TokenProvider

Propiedades

ConsumerGroupName	Obtiene el nombre del grupo de consumidores.
EndpointAddress	Obtiene el URI del punto de conexión de evento.
EventHubPath	Obtiene la ruta de acceso del centro de eventos.
HostName	Devuelve el nombre de host del procesador. Si el nombre de host del procesador se generó automáticamente, esta es la única manera de obtenerlo.
OperationTimeout	Obtiene el tiempo de espera de la operación.
PartitionManagerOptions	Obtiene o establece la PartitionManagerOptions instancia usada por el EventProcessorHost objeto .
TransportType	Obtiene el tipo de transporte.

Métodos

RegisterEventProcessorAsync<T>()	Esto registra la IEventProcessor implementación con el host mediante Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1. Esto también inicia el host y hace que empiece a participar en el proceso de distribución de particiones.
RegisterEventProcessorAsync<T>(EventProcessorOptions)	Esto registra la IEventProcessor implementación con el host mediante Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1. Esto también inicia el host y hace que empiece a participar en el proceso de distribución de particiones.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory)	Esto registra IEventProcessorFactory la implementación con el host que se usa para crear una instancia de IEventProcessor cuando toma posesión de una partición. Esto también inicia el host y hace que empiece a participar en el proceso de distribución de particiones.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)	Esto registra IEventProcessorFactory la implementación con el host que se usa para crear una instancia de IEventProcessor cuando toma posesión de una partición. Esto también inicia el host y hace que empiece a participar en el proceso de distribución de particiones.
UnregisterEventProcessorAsync()	Detenga el procesamiento de eventos. No devuelve hasta que se complete el apagado.