Partager via


PartitionReceiver Classe

Définition

Permet de lire des événements à partir d’une partition spécifique d’un Event Hub, et dans le contexte d’un groupe de consommateurs spécifique, d’être lus avec un niveau de contrôle plus élevé de la communication avec le service Event Hubs que celui offert par d’autres consommateurs d’événements.

public class PartitionReceiver : IAsyncDisposable
type PartitionReceiver = class
    interface IAsyncDisposable
Public Class PartitionReceiver
Implements IAsyncDisposable
Héritage
PartitionReceiver
Implémente

Remarques

Il est recommandé d’utiliser ou EventProcessorClientEventHubConsumerClient pour lire et traiter des événements pour la majorité des scénarios. Le récepteur de partition est destiné à permettre des scénarios avec des besoins spéciaux qui nécessitent un contrôle plus direct.

Le PartitionReceiver est sûr à mettre en cache et à utiliser pendant la durée de vie d’une application, ce qui est la meilleure pratique lorsque l’application lit des événements régulièrement ou semi-régulièrement. Le récepteur est chargé de garantir une utilisation efficace du réseau, du processeur et de la mémoire. L’appel de CloseAsync(CancellationToken) ou DisposeAsync() lorsque l’application s’arrête garantit que les ressources réseau et autres objets non managés sont correctement nettoyés.

Constructeurs

PartitionReceiver()

Initialise une nouvelle instance de la classe PartitionReceiver.

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

Initialise une nouvelle instance de la classe PartitionReceiver.

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

Initialise une nouvelle instance de la classe PartitionReceiver.

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

Initialise une nouvelle instance de la classe PartitionReceiver.

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

Initialise une nouvelle instance de la classe PartitionReceiver.

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

Initialise une nouvelle instance de la classe PartitionReceiver.

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

Initialise une nouvelle instance de la classe PartitionReceiver.

Propriétés

ConsumerGroup

Nom du groupe de consommateurs auquel ce client est associé. Les événements seront en lecture seule dans le contexte de ce groupe.

EventHubName

Nom du hub d’événements auquel le client est connecté, spécifique à l’espace de noms Event Hubs qui le contient.

FullyQualifiedNamespace

Espace de noms Event Hubs complet auquel le client est associé. Cela est susceptible d’être similaire à {yournamespace}.servicebus.windows.net.

Identifier

Nom unique utilisé pour identifier ce récepteur.

InitialPosition

Position dans la partition où le client commence à lire les événements.

IsClosed

Indique si cette PartitionReceiver opération a été fermée ou non.

PartitionId

Identificateur de la partition Event Hub à laquelle ce client est associé. Les événements seront en lecture seule à partir de cette partition.

Méthodes

CloseAsync(CancellationToken)

Ferme le client.

DisposeAsync()

Effectue la tâche nécessaire pour propre les ressources utilisées par le PartitionReceiver, notamment en s’assurant que le client lui-même a été fermé.

GetPartitionPropertiesAsync(CancellationToken)

Récupère des informations sur la partition à laquelle ce client est associé, y compris les éléments qui décrivent les événements disponibles dans le flux d’événements de partition.

ReadLastEnqueuedEventProperties()

Ensemble d’informations sur le dernier événement mis en file d’attente de la partition associée à ce récepteur, observé lorsque les événements sont reçus du service Event Hubs. Cette option est disponible uniquement si le récepteur a été créé avec TrackLastEnqueuedEventProperties set. Sinon, les propriétés contiennent des valeurs par défaut.

ReceiveBatchAsync(Int32, CancellationToken)

Reçoit un lot de EventData de la partition Event Hub à laquelle ce client est associé.

ReceiveBatchAsync(Int32, TimeSpan, CancellationToken)

Reçoit un lot de EventData de la partition Event Hub à laquelle ce client est associé.

S’applique à

Voir aussi