PartitionSender Classe

  • Referência

Definição

Namespace:
Microsoft.Azure.EventHubs
Assembly:
Microsoft.Azure.EventHubs.dll
Pacote:
Microsoft.Azure.EventHubs v4.3.2
Origem:
PartitionSender.cs

Essa classe de remetente é uma representação lógica do envio de eventos para uma partição específica do EventHub. Não use essa classe se você não se importar em enviar eventos para partições específicas, em vez disso, use SendAsync(EventData).

public sealed class PartitionSender : Microsoft.Azure.EventHubs.ClientEntity
type PartitionSender = class
    inherit ClientEntity
Public NotInheritable Class PartitionSender
Inherits ClientEntity
Herança
Object
ClientEntity
PartitionSender

Propriedades

ClientId

Obtém a ID do cliente.

(Herdado de ClientEntity)
EventHubClient

Obtém o EventHubClient associado a este PartitionSender.
IsClosed

Retorna um booliano que representa se o objeto cliente está fechado ou não.

(Herdado de ClientEntity)
PartitionId

Obtém a ID da partição para este PartitionSender.
RegisteredPlugins

Obtém uma lista de plug-ins registrados no momento para este Cliente.

(Herdado de ClientEntity)
RetryPolicy

Obtém o RetryPolicy para a ClientEntity.

(Herdado de ClientEntity)

Métodos

Close()

Fecha a ClientEntity.

(Herdado de ClientEntity)
CloseAsync()

Fecha e libera recursos para o PartitionSender.
CreateBatch()

Cria um lote em que objetos de dados de evento podem ser adicionados para uma chamada SendAsync posterior.
CreateBatch(BatchOptions)

Cria um lote em que objetos de dados de evento podem ser adicionados para uma chamada SendAsync posterior.
OnRetryPolicyUpdate()

Entidade derivada a ser substituída por atualizações de política de repetição.

(Herdado de ClientEntity)
RegisterPlugin(EventHubsPlugin)

Registra um EventHubsPlugin a ser usado com esse cliente.

(Herdado de ClientEntity)
SendAsync(EventData)

Enviar EventData para uma partição específica do EventHub. A partição de destino é predeterminada quando esse PartitionSender foi criado. Esse padrão de envio enfatiza a correlação de dados em relação à disponibilidade geral e à latência.

Há três maneiras de enviar para EventHubs, cada uma exposta como um método (juntamente com sua sobrecarga sendBatch):

i. SendAsync(EventData) ou SendAsync(IEnumerable<EventData>)

ii. SendAsync(EventData, String) ou SendAsync(IEnumerable<EventData>, String)

iii. SendAsync(EventData) ou SendAsync(IEnumerable<EventData>)

Use esse tipo de envio se:

a. O cliente deseja assumir o controle direto da distribuição de dados entre partições. Nesse caso, o cliente é responsável por garantir que haja pelo menos um remetente por partição do hub de eventos.

b. O usuário não pode usar a chave de partição como uma média para direcionar eventos para uma partição específica, mas há a necessidade de correlação de dados com o esquema de particionamento.
SendAsync(EventDataBatch)

Envie um lote de EventData em EventDataBatch.
SendAsync(IEnumerable<EventData>)

Enviar EventData para uma partição específica do EventHub. A partição de destino é predeterminada quando esse PartitionSender foi criado.

Há três maneiras de enviar para EventHubs, para entender esse tipo específico de envio, consulte a sobrecarga SendAsync(EventData), que é o mesmo tipo de envio e é usada para enviar um único EventData.

O envio de um lote de EventDataé útil nos seguintes casos:

i. Envio eficiente – o envio de um lote de maximiza a taxa de EventData transferência geral de maneira ideal usando o número de sessões criadas para o serviço do EventHubs.

ii. Enviando vários EventDataem uma transação. Para obter propriedades ACID, o Serviço de Gateway encaminhará todos EventDatano lote para uma única partição do EventHub.
ThrowIfClosed()

Gera uma exceção se o objeto de cliente já estiver fechado.

(Herdado de ClientEntity)
UnregisterPlugin(String)

Cancela o registro de um EventHubsPlugin.

(Herdado de ClientEntity)

Aplica-se a

Confira também