PluggableCheckpointStoreEventProcessor<TPartition> Classe
Définition
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.
Fournit une base pour la création d’un processeur d’événements avec une logique de traitement personnalisée qui consomme des événements sur toutes les partitions d’un Event Hub donné pour un groupe de consommateurs spécifique. Le processeur est capable de collaborer avec d’autres instances pour le même jumelage Event Hub et groupe de consommateurs pour partager le travail à l’aide d’une plateforme de stockage commune pour communiquer. La tolérance de panne est également intégrée, ce qui permet au processeur d’être résilient face aux erreurs.
public abstract class PluggableCheckpointStoreEventProcessor<TPartition> : Azure.Messaging.EventHubs.Primitives.EventProcessor<TPartition> where TPartition : EventProcessorPartition, new()type PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> = class
inherit EventProcessor<'Partition (requires 'Partition :> EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>Public MustInherit Class PluggableCheckpointStoreEventProcessor(Of TPartition)
Inherits EventProcessor(Of TPartition)Paramètres de type
- TPartition
Contexte de la partition pour laquelle une opération est effectuée.
- Héritage
Remarques
Pour activer la coordination pour le partage de partitions entre PluggableCheckpointStoreEventProcessor<TPartition> les instances, ils affirment un accès en lecture exclusif aux partitions pour le groupe de consommateurs. Aucun autre lecteur ne doit être actif dans le groupe de consommateurs autre que les processeurs qui ont l’intention de collaborer. Les lecteurs non exclusifs se verront refuser l’accès ; les lecteurs exclusifs, y compris les processeurs utilisant des emplacements de stockage différents, interfèrent avec le fonctionnement et les performances du processeur.
Le PluggableCheckpointStoreEventProcessor<TPartition> est sûr à mettre en cache et à utiliser pendant la durée de vie d’une application, et c’est la meilleure pratique lorsque l’application traite des événements régulièrement ou semi-régulièrement. Le processeur est responsable d’une gestion efficace des ressources, s’efforçant de maintenir une utilisation faible des ressources pendant les périodes d’inactivité et de gérer l’intégrité pendant les périodes d’utilisation plus élevée. L’appel de la StopProcessingAsync(CancellationToken) méthode ou StopProcessing(CancellationToken) lorsque le traitement est terminé ou lorsque l’application s’arrête garantit que les ressources réseau et autres objets non managés sont correctement nettoyés.
Constructeurs
Propriétés
| ConsumerGroup |
Nom du groupe de consommateurs auquel ce processeur d’événements est associé. Les événements seront lus uniquement dans le contexte de ce groupe. (Hérité de EventProcessor<TPartition>) |
| EventHubName |
Nom du hub d’événements auquel le processeur est connecté, spécifique à l’espace de noms Event Hubs qui le contient. (Hérité de EventProcessor<TPartition>) |
| FullyQualifiedNamespace |
Espace de noms Event Hubs complet auquel le processeur est associé. Cela est susceptible d’être similaire à |
| Identifier |
Nom unique utilisé pour identifier ce processeur d’événements. (Hérité de EventProcessor<TPartition>) |
| IsRunning |
Indique si ce processeur d’événements est en cours d’exécution. (Hérité de EventProcessor<TPartition>) |
| RetryPolicy |
Stratégie active qui régit les tentatives de nouvelle tentative pour le processeur. (Hérité de EventProcessor<TPartition>) |
Méthodes
| ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken) |
Tente de revendiquer la propriété des partitions spécifiées pour le traitement. Cette opération est utilisée par l’équilibrage de charge pour permettre la répartition de la responsabilité du traitement des partitions pour un hub d’événements et un regroupement de consommateurs entre les processeurs d’événements actifs. |
| CreateConnection() |
Crée un EventHubConnection à utiliser pour communiquer avec le service Event Hubs. (Hérité de EventProcessor<TPartition>) |
| GetCheckpointAsync(String, CancellationToken) |
Retourne un point de contrôle pour le hub d’événements, le groupe de consommateurs et l’identificateur de la partition associée au instance du processeur d’événements, afin que le traitement d’une partition donnée puisse être correctement initialisé. |
| ListOwnershipAsync(CancellationToken) |
Demande une liste des attributions de propriété pour les partitions entre chacune des instances de processeur d’événements qui coopèrent pour un appairage Event Hub et un groupe de consommateurs donné. Cette méthode est utilisée lors de l’équilibrage de charge pour permettre au processeur de découvrir d’autres collaborateurs actifs et de prendre des décisions sur la meilleure façon d’équilibrer le travail entre eux. |
| ListPartitionIdsAsync(EventHubConnection, CancellationToken) |
Requêtes pour les identificateurs des partitions Event Hub. (Hérité de EventProcessor<TPartition>) |
| OnInitializingPartitionAsync(TPartition, CancellationToken) |
Effectue les tâches d’initialisation d’une partition et de son contexte associé pour le traitement des événements. (Hérité de EventProcessor<TPartition>) |
| OnPartitionProcessingStoppedAsync(TPartition, ProcessingStoppedReason, CancellationToken) |
Effectue les tâches nécessaires lors de l’arrêt du traitement d’une partition. Cela se produit généralement lorsque la partition est revendiquée par un autre instance du processeur d’événements ou lorsque le instance actuel du processeur d’événements s’arrête. (Hérité de EventProcessor<TPartition>) |
| OnProcessingErrorAsync(Exception, TPartition, String, CancellationToken) |
Effectue les tâches nécessaires lorsqu’une exception inattendue se produit dans le fonctionnement de l’infrastructure du processeur d’événements. (Hérité de EventProcessor<TPartition>) |
| OnProcessingEventBatchAsync(IEnumerable<EventData>, TPartition, CancellationToken) |
Effectue les tâches nécessaires pour traiter un lot d’événements pour une partition donnée à mesure qu’ils sont lus à partir du service Event Hubs. (Hérité de EventProcessor<TPartition>) |
| ReadLastEnqueuedEventProperties(String) |
Ensemble d’informations sur le dernier événement en file d’attente d’une partition, comme observé par le client EventHubs associé à ce contexte, car les événements sont reçus du service Event Hubs. Cette option n’est disponible que si le consommateur a été créé avec TrackLastEnqueuedEventProperties set. (Hérité de EventProcessor<TPartition>) |
| StartProcessing(CancellationToken) |
Signale au pour commencer le EventProcessor<TPartition> traitement des événements. Si cette méthode est appelée pendant l’exécution du processeur, aucune action n’est effectuée. (Hérité de EventProcessor<TPartition>) |
| StartProcessingAsync(CancellationToken) |
Signale au pour commencer le EventProcessor<TPartition> traitement des événements. Si cette méthode est appelée pendant l’exécution du processeur, aucune action n’est effectuée. (Hérité de EventProcessor<TPartition>) |
| StopProcessing(CancellationToken) |
Signale l’arrêt du EventProcessor<TPartition> traitement des événements. Si cette méthode est appelée alors que le processeur n’est pas en cours d’exécution, aucune action n’est effectuée. (Hérité de EventProcessor<TPartition>) |
| StopProcessingAsync(CancellationToken) |
Signale l’arrêt du EventProcessor<TPartition> traitement des événements. Si cette méthode est appelée alors que le processeur n’est pas en cours d’exécution, aucune action n’est effectuée. (Hérité de EventProcessor<TPartition>) |
| UpdateCheckpointAsync(String, Int64, Nullable<Int64>, CancellationToken) |
Crée ou met à jour un point de contrôle pour une partition spécifique, identifiant une position dans le flux d’événements de la partition à partir de laquelle un processeur d’événements doit commencer à lire. |
| ValidateProcessingPreconditions(CancellationToken) |
Effectue les tâches nécessaires pour valider la configuration de base et les autorisations des dépendances nécessaires au fonctionnement du processeur. (Hérité de EventProcessor<TPartition>) |
S’applique à
Azure SDK for .NET