IPartitionProcessor Interface

Definição

Namespace:

Microsoft.Azure.Documents.ChangeFeedProcessor.FeedProcessing

Assembly:

Microsoft.Azure.Documents.ChangeFeedProcessor.dll

Pacote:

Microsoft.Azure.DocumentDB.ChangeFeedProcessor v2.4.0

Fornece uma API para executar o processamento contínuo em uma única partição de algum recurso. Criado por Create(ILease, IChangeFeedObserver) ou Create(ILease, ILeaseCheckpointer, IChangeFeedObserver) após a aquisição de alguma concessão pelo host atual. O processamento pode executar as seguintes tarefas em um loop:

1. Leia alguns dados da partição de recursos.
2. Lidar com possíveis problemas com a leitura.
3. Passe os dados obtidos para um observador chamando ProcessChangesAsync(IChangeFeedObserverContext, IReadOnlyList<Document>, CancellationToken) com o contexto IChangeFeedObserverContext.

public interface IPartitionProcessor

type IPartitionProcessor = interface

Public Interface IPartitionProcessor

Métodos

RunAsync(CancellationToken)

Executar o processamento de partição.