Compartir a través de


IPartitionProcessor Interfaz

Definición

Proporciona una API para ejecutar el procesamiento continuo en una sola partición de algún recurso. Creado por Create(ILease, IChangeFeedObserver) o Create(ILease, ILeaseCheckpointer, IChangeFeedObserver) después de que el host actual adquiera alguna concesión. El procesamiento puede realizar las siguientes tareas en un bucle:

  1. Lea algunos datos de la partición de recursos.
  2. Controle posibles problemas con la lectura.
  3. Pase los datos obtenidos a un observador llamando ProcessChangesAsync(IChangeFeedObserverContext, IReadOnlyList<Document>, CancellationToken) a con el contexto IChangeFeedObserverContext.
public interface IPartitionProcessor
type IPartitionProcessor = interface
Public Interface IPartitionProcessor

Métodos

RunAsync(CancellationToken)

Realice el procesamiento de particiones.

Se aplica a