Compartir a través de


PartitionReceiver Clase

Definición

Permite leer eventos de una partición específica de un centro de eventos y, en el contexto de un grupo de consumidores específico, leerse con un mayor nivel de control sobre la comunicación con el servicio Event Hubs que ofrece otros consumidores de eventos.

public class PartitionReceiver : IAsyncDisposable
type PartitionReceiver = class
    interface IAsyncDisposable
Public Class PartitionReceiver
Implements IAsyncDisposable
Herencia
PartitionReceiver
Implementaciones

Comentarios

Se recomienda usar o EventProcessorClientEventHubConsumerClient para leer y procesar eventos en la mayoría de los escenarios. El receptor de particiones está diseñado para habilitar escenarios con necesidades especiales que requieren un control más directo.

PartitionReceiver es seguro almacenar en caché y usar durante la vigencia de una aplicación, y que es el procedimiento recomendado cuando la aplicación lee eventos periódicamente o semestralmente. El receptor es responsable de garantizar un uso eficaz de la red, la CPU y la memoria. Al llamar a o CloseAsync(CancellationToken)DisposeAsync() a medida que se cierra la aplicación, se asegurará de que los recursos de red y otros objetos no administrados se limpien correctamente.

Constructores

PartitionReceiver()

Inicializa una nueva instancia de la clase PartitionReceiver.

PartitionReceiver(String, String, EventPosition, EventHubConnection, PartitionReceiverOptions)

Inicializa una nueva instancia de la clase PartitionReceiver.

PartitionReceiver(String, String, EventPosition, String, PartitionReceiverOptions)

Inicializa una nueva instancia de la clase PartitionReceiver.

PartitionReceiver(String, String, EventPosition, String, String, AzureNamedKeyCredential, PartitionReceiverOptions)

Inicializa una nueva instancia de la clase PartitionReceiver.

PartitionReceiver(String, String, EventPosition, String, String, AzureSasCredential, PartitionReceiverOptions)

Inicializa una nueva instancia de la clase PartitionReceiver.

PartitionReceiver(String, String, EventPosition, String, String, PartitionReceiverOptions)

Inicializa una nueva instancia de la clase PartitionReceiver.

PartitionReceiver(String, String, EventPosition, String, String, TokenCredential, PartitionReceiverOptions)

Inicializa una nueva instancia de la clase PartitionReceiver.

Propiedades

ConsumerGroup

Nombre del grupo de consumidores al que está asociado este cliente. Los eventos serán de solo lectura en el contexto de este grupo.

EventHubName

Nombre del centro de eventos al que está conectado el cliente, específico del espacio de nombres de Event Hubs que lo contiene.

FullyQualifiedNamespace

Espacio de nombres completo de Event Hubs al que está asociado el cliente. Es probable que sea similar a {yournamespace}.servicebus.windows.net.

Identifier

Nombre único que se usa para identificar este receptor.

InitialPosition

Posición dentro de la partición donde el cliente comienza a leer eventos.

IsClosed

Indica si se PartitionReceiver ha cerrado o no.

PartitionId

Identificador de la partición del centro de eventos a la que está asociado este cliente. Los eventos serán de solo lectura de esta partición.

Métodos

CloseAsync(CancellationToken)

Cierra el cliente.

DisposeAsync()

Realiza la tarea necesaria para limpiar los recursos utilizados por , PartitionReceiverincluida la garantía de que el propio cliente se ha cerrado.

GetPartitionPropertiesAsync(CancellationToken)

Recupera información sobre la partición a la que está asociado este cliente, incluidos los elementos que describen los eventos disponibles en el flujo de eventos de partición.

ReadLastEnqueuedEventProperties()

Conjunto de información sobre el último evento en cola de la partición asociada a este receptor, observado como eventos recibidos del servicio Event Hubs. Esto solo está disponible si el receptor se creó con TrackLastEnqueuedEventProperties set. De lo contrario, las propiedades contendrán valores predeterminados.

ReceiveBatchAsync(Int32, CancellationToken)

Recibe un lote de la partición del centro de EventData eventos a la que está asociado este cliente.

ReceiveBatchAsync(Int32, TimeSpan, CancellationToken)

Recibe un lote de la partición del centro de EventData eventos a la que está asociado este cliente.

Se aplica a

Consulte también