Share via


PartitionSender Classe

Définition

Cette classe d’expéditeur est une représentation logique de l’envoi d’événements à une partition EventHub spécifique. N’utilisez pas cette classe si vous ne vous souciez pas de l’envoi d’événements à des partitions spécifiques. Utilisez SendAsync(EventData)plutôt .

public sealed class PartitionSender : Microsoft.Azure.EventHubs.ClientEntity
type PartitionSender = class
    inherit ClientEntity
Public NotInheritable Class PartitionSender
Inherits ClientEntity
Héritage
PartitionSender

Propriétés

ClientId

Obtient l’ID client.

(Hérité de ClientEntity)
EventHubClient

Obtient le EventHubClient associé à ce PartitionSender.

IsClosed

Retourne une valeur booléenne qui indique si l’objet client est fermé ou non.

(Hérité de ClientEntity)
PartitionId

Obtient l’ID de partition pour ce PartitionSender.

RegisteredPlugins

Obtient la liste des plug-ins actuellement inscrits pour ce client.

(Hérité de ClientEntity)
RetryPolicy

Obtient le RetryPolicy pour ClientEntity.

(Hérité de ClientEntity)

Méthodes

Close()

Ferme ClientEntity.

(Hérité de ClientEntity)
CloseAsync()

Ferme et libère les ressources pour le PartitionSender.

CreateBatch()

Crée un lot dans lequel des objets de données d’événement peuvent être ajoutés pour un appel SendAsync ultérieur.

CreateBatch(BatchOptions)

Crée un lot dans lequel des objets de données d’événement peuvent être ajoutés pour un appel SendAsync ultérieur.

OnRetryPolicyUpdate()

Entité dérivée à remplacer pour les mises à jour de stratégie de nouvelle tentative.

(Hérité de ClientEntity)
RegisterPlugin(EventHubsPlugin)

Inscrit un EventHubsPlugin à utiliser avec ce client.

(Hérité de ClientEntity)
SendAsync(EventData)

Envoyer EventData à une partition EventHub spécifique. La partition cible est prédéterminée lors de la création de ce PartitionSender. Ce modèle d’envoi met l’accent sur la corrélation des données par rapport à la disponibilité générale et à la latence.

Il existe 3 façons d’envoyer à EventHubs, chacune exposée en tant que méthode (avec sa surcharge sendBatch) :

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

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

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

Utilisez ce type d’envoi si :

a. Le client souhaite prendre le contrôle direct de la distribution des données entre les partitions. Dans ce cas, il incombe au client de s’assurer qu’il existe au moins un expéditeur par partition de hub d’événements.

b. L’utilisateur ne peut pas utiliser la clé de partition comme moyen de diriger des événements vers une partition spécifique, mais il est nécessaire de mettre en corrélation les données avec le schéma de partitionnement.

SendAsync(EventDataBatch)

Envoyez un lot de EventData dans EventDataBatch.

SendAsync(IEnumerable<EventData>)

Envoyer EventData à une partition EventHub spécifique. La partition ciblée est prédéterminée lors de la création de ce PartitionSender.

Il existe 3 façons d’envoyer à EventHubs. Pour comprendre ce type particulier d’envoi, reportez-vous à la surcharge SendAsync(EventData), qui est le même type d’envoi et qui est utilisé pour envoyer un seul EventData.

L’envoi d’un lot de EventDataest utile dans les cas suivants :

i. Envoi efficace : l’envoi d’un lot de EventData optimise le débit global en utilisant de manière optimale le nombre de sessions créées pour le service EventHubs.

ii. Envoi de plusieurs EventDatadans une transaction. Pour obtenir les propriétés ACID, le service de passerelle transfère tous les EventDatafichiers du lot à une seule partition EventHub.

ThrowIfClosed()

Lève une exception si l’objet client est déjà fermé.

(Hérité de ClientEntity)
UnregisterPlugin(String)

Annule l’inscription d’un EventHubsPlugin.

(Hérité de ClientEntity)

S’applique à

Voir aussi