PartitionSender Clase

  • Referencia

Definición

Espacio de nombres:
Microsoft.Azure.EventHubs
Ensamblado:
Microsoft.Azure.EventHubs.dll
Paquete:
Microsoft.Azure.EventHubs v4.3.2
Source:
PartitionSender.cs

Esta clase de remitente es una representación lógica del envío de eventos a una partición de EventHub específica. No use esta clase si no le interesa enviar eventos a particiones específicas, en su lugar use SendAsync(EventData).

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

Propiedades

ClientId

Obtiene el identificador de cliente.

(Heredado de ClientEntity)
EventHubClient

Obtiene el EventHubClient objeto asociado a este partitionSender.
IsClosed

Devuelve un valor booleano que representa si el objeto de cliente está cerrado o no.

(Heredado de ClientEntity)
PartitionId

Obtiene el identificador de partición de este PartitionSenderobjeto .
RegisteredPlugins

Obtiene una lista de complementos registrados actualmente para este cliente.

(Heredado de ClientEntity)
RetryPolicy

Obtiene para RetryPolicy ClientEntity.

(Heredado de ClientEntity)

Métodos

Close()

Cierra ClientEntity.

(Heredado de ClientEntity)
CloseAsync()

Cierra y libera los recursos de .PartitionSender
CreateBatch()

Crea un lote en el que se pueden agregar objetos de datos de eventos para una llamada posterior a SendAsync.
CreateBatch(BatchOptions)

Crea un lote en el que se pueden agregar objetos de datos de eventos para una llamada posterior a SendAsync.
OnRetryPolicyUpdate()

Entidad derivada que se va a invalidar para las actualizaciones de directivas de reintento.

(Heredado de ClientEntity)
RegisterPlugin(EventHubsPlugin)

Registra un EventHubsPlugin objeto que se va a usar con este cliente.

(Heredado de ClientEntity)
SendAsync(EventData)

Enviar EventData a una partición de EventHub específica. La partición de destino se determina previamente cuando se creó partitionSender. Este patrón de envío resalta la correlación de datos sobre la disponibilidad y la latencia generales.

Hay 3 maneras de enviar a EventHubs, cada uno expuesto como método (junto con su sobrecarga sendBatch):

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

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

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

Use este tipo de envío si:

a. El cliente quiere tomar el control directo de la distribución de datos entre particiones. En este caso, el cliente es responsable de asegurarse de que hay al menos un remitente por partición del centro de eventos.

b. El usuario no puede usar la clave de partición como medio para dirigir eventos a una partición específica, pero hay una necesidad de correlación de datos con el esquema de partición.
SendAsync(EventDataBatch)

Envíe un lote de EventData en EventDataBatch.
SendAsync(IEnumerable<EventData>)

Enviar EventData a una partición de EventHub específica. La partición de destino se determina previamente cuando se creó partitionSender.

Hay 3 maneras de enviar a EventHubs, para comprender este tipo concreto de envío, haga referencia a la sobrecarga SendAsync(EventData), que es el mismo tipo de envío y se usa para enviar un solo EventData.

Enviar un lote de EventData's es útil en los casos siguientes:

i. Envío eficaz: el envío de un lote de EventData maximiza el rendimiento general mediante el uso óptimo del número de sesiones creadas en el servicio de EventHubs.

ii. Enviar varios EventDataen una transacción. Para lograr las propiedades ACID, el servicio de puerta de enlace reenviará todo EventDatael lote a una sola partición de EventHub.
ThrowIfClosed()

Produce una excepción si el objeto de cliente ya está cerrado.

(Heredado de ClientEntity)
UnregisterPlugin(String)

Anula el registro de un EventHubsPluginobjeto .

(Heredado de ClientEntity)

Se aplica a

Consulte también