IPartitionProcessor インターフェイス

定義

名前空間:

Microsoft.Azure.Documents.ChangeFeedProcessor.FeedProcessing

アセンブリ:

Microsoft.Azure.Documents.ChangeFeedProcessor.dll

パッケージ:

Microsoft.Azure.DocumentDB.ChangeFeedProcessor v2.4.0

一部のリソースの 1 つのパーティションで連続処理を実行する API を提供します。 現在のホストによって Create(ILease, IChangeFeedObserver) リースが取得された後または Create(ILease, ILeaseCheckpointer, IChangeFeedObserver) によって作成されます。 処理では、ループ内で次のタスクを実行できます。

1. リソース パーティションからデータを読み取ります。
2. 読み取りで発生する可能性のある問題を処理します。
3. コンテキスト を使用して を呼び出 ProcessChangesAsync(IChangeFeedObserverContext, IReadOnlyList<Document>, CancellationToken) して、取得したデータをオブザーバーに渡します IChangeFeedObserverContext。

public interface IPartitionProcessor

type IPartitionProcessor = interface

Public Interface IPartitionProcessor

メソッド

RunAsync(CancellationToken)

パーティション処理を実行します。