你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

Microsoft.Azure.Documents.ChangeFeedProcessor.FeedProcessing 命名空间

接口

IChangeFeedObserver

此接口用于将更改事件传递到文档源观察程序。

IChangeFeedObserverContext

表示传递给 IChangeFeedObserver 事件的上下文。

IChangeFeedObserverFactory

用于创建 实例 () 的 IChangeFeedObserver工厂类。

ICheckpointPartitionProcessorFactory

用于创建 实例的工厂类 () IPartitionProcessor ,并允许重复使用默认检查点机制。

IPartitionProcessor

提供一个 API,用于在某些资源的单个分区上运行连续处理。 由 Create(ILease, IChangeFeedObserver)Create(ILease, ILeaseCheckpointer, IChangeFeedObserver) 当前主机获取某种租约或之后创建。 处理可以在循环中执行以下任务:

  1. 从资源分区中读取一些数据。
  2. 处理可能的读取问题。
  3. 通过使用上下文 IChangeFeedObserverContext调用 ProcessChangesAsync(IChangeFeedObserverContext, IReadOnlyList<Document>, CancellationToken) ,将获取的数据传递给观察程序。
IPartitionProcessorFactory

用于创建 实例 () 的 IPartitionProcessor工厂类。 用于 ICheckpointPartitionProcessorFactory 使用默认检查点机制。

枚举

ChangeFeedObserverCloseReason

关闭的原因 IChangeFeedObserver