Microsoft.Azure.EventHubs.Processor Espace de noms
Important
Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.
Classes
Checkpoint |
Objet de contexte utilisé pour conserver l’état dans le flux. |
EventProcessorConfigurationException |
Exception qui spécifie que la EventProcessorHost configuration est incorrecte. |
EventProcessorHost |
Représente un hôte pour le traitement des données d’événement Event Hubs. |
EventProcessorOptions |
Définit les options d’exécution lors de l’inscription d’une IEventProcessor interface auprès d’un EventHubConsumerGroup. Il s’agit également du mécanisme permettant d’intercepter les exceptions d’un instance IEventProcessor utilisé par un EventProcessorHost objet. |
EventProcessorRuntimeException |
Exception levée pendant le traitement des événements. |
ExceptionReceivedEventArgs |
Fournit des données pour l'événement Microsoft.Azure.EventHubs.Processor.EventProcessorOptions.NotifyOfException(System.String,System.String,System.Exception,System.String). |
Lease |
Contient des informations sur la propriété de la partition. |
LeaseLostException |
Représente une exception qui se produit lorsque le bail de service a été perdu. |
PartitionContext |
Encapsule les informations relatives à une partition Event Hubs utilisée par IEventProcessor. |
PartitionManagerOptions |
Options permettant de contrôler différents aspects de la distribution de partition au sein EventProcessorHost de instance. |
Interfaces
ICheckpointManager |
Si vous souhaitez avoir des points de contrôle de magasin EventProcessorHost ailleurs que stockage Azure, vous pouvez écrire votre propre gestionnaire de points de contrôle à l’aide de cette interface. Les responsables stockage Azure utilisent le même stockage pour les baux et les points de contrôle, de sorte que les deux interfaces sont implémentées par la même classe. Vous êtes libre de faire la même chose si vous disposez d’un magasin unifié pour les deux types de données. Cette interface ne spécifie pas les méthodes d’initialisation, car nous n’avons aucun moyen de savoir quelles informations votre implémentation aura besoin. |
IEventProcessor |
Interface qui doit être implémentée par les classes de processeur d’événements. Toute instance donnée d’une classe de processeur d’événements traite uniquement les événements d’une partition d’un hub d’événements. Un PartitionContext est fourni avec chaque appel au processeur d’événements, car certains paramètres peuvent changer, mais il s’agit toujours de la même partition. Bien qu’EventProcessorHost soit multithread, les appels à un instance donné d’une classe de processeur d’événements sont sérialisés, à l’exception de OnError(). OnOpen() est appelé en premier, puis OnEvents() est appelé zéro ou plusieurs fois. Lorsque le processeur d’événements doit être arrêté, que ce soit en raison d’un échec quelque part, ou parce que le bail de la partition a été perdu, ou parce que l’hôte du processeur entier est en cours d’arrêt, OnClose() est appelé après le retour du dernier appel OnEvents(). OnError() peut être appelé pendant que OnEvents() ou OnClose() s’exécute. Aucune synchronisation n’est tentée afin d’éviter un blocage éventuel. |
IEventProcessorFactory |
Interface qui doit être implémentée par une classe de fabrique du processeur d’événements. Des fabriques fournies par l’utilisateur sont nécessaires si la création d’un objet de processeur d’événements nécessite plus de travail qu’un simple nouveau avec un constructeur sans paramètre. |
ILeaseManager |
Si vous souhaitez avoir des baux de magasin EventProcessorHost ailleurs que stockage Azure, vous pouvez écrire votre propre gestionnaire de bail à l’aide de cette interface. Les responsables stockage Azure utilisent le même stockage pour les baux et les points de contrôle, de sorte que les deux interfaces sont implémentées par la même classe. Vous êtes libre de faire la même chose si vous disposez d’un magasin unifié pour les deux types de données. Cette interface ne spécifie pas les méthodes d’initialisation, car nous n’avons aucun moyen de savoir quelles informations votre implémentation aura besoin. |
Énumérations
CloseReason |
Raison de la fermeture d’un EventProcessorHost. |
Azure SDK for .NET