Partager via


IPartitionProcessor Interface

Définition

Fournit une API pour exécuter un traitement continu sur une seule partition d’une ressource. Créé par Create(ILease, IChangeFeedObserver) ou Create(ILease, ILeaseCheckpointer, IChangeFeedObserver) après l’acquisition d’un bail par l’hôte actuel. Le traitement peut effectuer les tâches suivantes dans une boucle :

  1. Lire des données à partir de la partition de ressources.
  2. Gérer les problèmes possibles liés à la lecture.
  3. Transmettez les données obtenues à un observateur en appelant ProcessChangesAsync(IChangeFeedObserverContext, IReadOnlyList<Document>, CancellationToken) avec le contexte IChangeFeedObserverContext.
public interface IPartitionProcessor
type IPartitionProcessor = interface
Public Interface IPartitionProcessor

Méthodes

RunAsync(CancellationToken)

Effectuer le traitement de partition.

S’applique à