PartitionReceiver Classe

Referência

Definição

Namespace:: Azure.Messaging.EventHubs.Primitives

Assembly:: Azure.Messaging.EventHubs.dll

Pacote:: Azure.Messaging.EventHubs v5.11.3

Pacote:: Azure.Messaging.EventHubs v5.12.0-beta.1

Origem:: PartitionReceiver.cs

Origem:: PartitionReceiver.cs

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

Permite que a leitura de eventos de uma partição específica de um Hub de Eventos e, no contexto de um grupo de consumidores específico, seja lida com um nível maior de controle sobre a comunicação com o serviço hubs de eventos do que é oferecido por outros consumidores de eventos.

public class PartitionReceiver : IAsyncDisposable

type PartitionReceiver = class
    interface IAsyncDisposable

Public Class PartitionReceiver
Implements IAsyncDisposable

Herança: Object
PartitionReceiver

Implementações: IAsyncDisposable

Comentários

É recomendável que o EventProcessorClient ou EventHubConsumerClient seja usado para ler e processar eventos para a maioria dos cenários. O receptor de partição destina-se a habilitar cenários com necessidades especiais que exigem controle mais direto.

O PartitionReceiver é seguro para armazenar em cache e usar durante o tempo de vida de um aplicativo e qual é a melhor prática quando o aplicativo lê eventos regularmente ou semestralmente. O receptor é responsável por garantir o uso eficiente de rede, CPU e memória. Chamar ou CloseAsync(CancellationToken)DisposeAsync() como o aplicativo está sendo desligado garantirá que os recursos de rede e outros objetos não gerenciados sejam limpos corretamente.

Construtores

PartitionReceiver()	Inicializa uma nova instância da classe PartitionReceiver.
PartitionReceiver(String, String, EventPosition, EventHubConnection, PartitionReceiverOptions)	Inicializa uma nova instância da classe PartitionReceiver.
PartitionReceiver(String, String, EventPosition, String, PartitionReceiverOptions)	Inicializa uma nova instância da classe PartitionReceiver.
PartitionReceiver(String, String, EventPosition, String, String, AzureNamedKeyCredential, PartitionReceiverOptions)	Inicializa uma nova instância da classe PartitionReceiver.
PartitionReceiver(String, String, EventPosition, String, String, AzureSasCredential, PartitionReceiverOptions)	Inicializa uma nova instância da classe PartitionReceiver.
PartitionReceiver(String, String, EventPosition, String, String, PartitionReceiverOptions)	Inicializa uma nova instância da classe PartitionReceiver.
PartitionReceiver(String, String, EventPosition, String, String, TokenCredential, PartitionReceiverOptions)	Inicializa uma nova instância da classe PartitionReceiver.

Propriedades

ConsumerGroup	O nome do grupo de consumidores ao qual esse cliente está associado. Os eventos serão lidos somente no contexto desse grupo.
EventHubName	O nome do Hub de Eventos ao qual o cliente está conectado, específico ao namespace dos Hubs de Eventos que o contém.
FullyQualifiedNamespace	O namespace dos Hubs de Eventos totalmente qualificado ao qual o cliente está associado. É provável que isso seja semelhante a `{yournamespace}.servicebus.windows.net`.
Identifier	Um nome exclusivo usado para identificar esse receptor.
InitialPosition	A posição dentro da partição em que o cliente começa a ler eventos.
IsClosed	Indica se isso PartitionReceiver foi ou não fechado.
PartitionId	O identificador da partição do Hub de Eventos à qual esse cliente está associado. Os eventos serão lidos somente desta partição.

Métodos

CloseAsync(CancellationToken)	Fecha o cliente.
DisposeAsync()	Executa a tarefa necessária para limpo recursos usados pelo PartitionReceiver, incluindo garantir que o próprio cliente tenha sido fechado.
GetPartitionPropertiesAsync(CancellationToken)	Recupera informações sobre a partição à qual esse cliente está associado, incluindo elementos que descrevem os eventos disponíveis no fluxo de eventos de partição.
ReadLastEnqueuedEventProperties()	Um conjunto de informações sobre o último evento enfileirado da partição associada a esse receptor, observado como eventos são recebidos do serviço hubs de eventos. Isso só estará disponível se o receptor tiver sido criado com TrackLastEnqueuedEventProperties set. Caso contrário, as propriedades conterão valores padrão.
ReceiveBatchAsync(Int32, CancellationToken)	Recebe um lote de da partição do Hub de EventData Eventos à qual esse cliente está associado.
ReceiveBatchAsync(Int32, TimeSpan, CancellationToken)	Recebe um lote de da partição do Hub de EventData Eventos à qual esse cliente está associado.

Aplica-se a

Compartilhar via