Freigeben über

IPartitionProcessor Schnittstelle

  • Referenz

Definition

Namespace:
Microsoft.Azure.Documents.ChangeFeedProcessor.FeedProcessing
Assembly:
Microsoft.Azure.Documents.ChangeFeedProcessor.dll
Paket:
Microsoft.Azure.DocumentDB.ChangeFeedProcessor v2.4.0

Stellt eine API zum Ausführen einer kontinuierlichen Verarbeitung auf einer einzelnen Partition einer Ressource bereit. Wird von Create(ILease, IChangeFeedObserver) oder Create(ILease, ILeaseCheckpointer, IChangeFeedObserver) erstellt, nachdem eine Lease vom aktuellen Host erworben wurde. Die Verarbeitung kann die folgenden Aufgaben in einer Schleife ausführen:

  1. Liest einige Daten aus der Ressourcenpartition.
  2. Behandeln sie mögliche Probleme mit dem Lesevorgang.
  3. Übergeben Sie die abgerufenen Daten an einen Beobachter, indem Sie mit dem Kontext IChangeFeedObserverContextaufrufenProcessChangesAsync(IChangeFeedObserverContext, IReadOnlyList<Document>, CancellationToken).
public interface IPartitionProcessor
type IPartitionProcessor = interface
Public Interface IPartitionProcessor

Methoden

RunAsync(CancellationToken)

Führen Sie die Partitionsverarbeitung aus.

Gilt für: