更改提要处理器库不支持更改提要处理器选项提要延迟/检查点频率

Question

我按照这个示例代码(https://github . com/Azure/Azure-document db-changeedprocessor-dot net # example)注册一个观察者来处理cosmos db集合中的变更提要。我使用一个实用程序在cosmos db集合中创建新文档(比如在一个for循环中创建400个文档)。我正在使用30秒的FeedPollDelay。但CFP自由党似乎并不认同这一点。即使在源轮询延迟间隔过期之前，ProcessChangesAsync方法也会被重复调用。在第一批中，检索到大约60个文档，在第二批中检索到大约20个文档，在第三批中检索到大约100个文档。

        DocumentCollectionInfo feedCollectionInfo = new DocumentCollectionInfo()
        {
            DatabaseName = databaseName,
            CollectionName = monitoredCollectionName,
            Uri = new Uri(uri),
            MasterKey = masterKey
        };

        DocumentCollectionInfo leaseCollectionInfo = new DocumentCollectionInfo()
        {
            DatabaseName = databaseName,
            CollectionName = leaseCollectionName,
            Uri = new Uri(uri),
            MasterKey = masterKey
        };

        ChangeFeedProcessorOptions feedProcessorOptions = new ChangeFeedProcessorOptions()
        {
            FeedPollDelay = TimeSpan.FromSeconds(30)
            //LeasePrefix = Guid.NewGuid().ToString(),
            //MaxItemCount = 100
        };
        ChangeFeedProcessorBuilder builder = new ChangeFeedProcessorBuilder();
        processor = await builder
            .WithHostName(hostName)
            .WithFeedCollection(feedCollectionInfo)
            .WithLeaseCollection(leaseCollectionInfo)
            .WithProcessorOptions(feedProcessorOptions)
            .WithObserver<LiveWorkItemChangeFeedObserver>()
            .BuildAsync();

        await processor.StartAsync();

在第一批中接收60个文档是可以的。但我希望在提要轮询延迟（30秒）间隔到期后，第二批将在单个批次中调用其余340个文档。

但是ProcessChangesAsync方法经常被触发，并且这个选项没有得到遵守。

Answer 1

当更改提要处理器读取更改提要并且没有发现新的更改时，使用FeedPollDelay，而不是在每个批处理之间。

示例流程：

1. CFP民意调查的变化，发现X。
2. 进程更改异步与 X 一起调用
3. 进程更改异步完成后，CFP 会立即轮询更改，找到 Y。
4. 进程更改异步使用 Y 调用。
5. 在进程更改异步完成后，CFP 会立即轮询更改，什么也没找到，等待源便提。
6. CFP 民意调查的变化，发现 Z.
7. 进程更改异步使用 Z 调用
8. 在进程更改异步完成后，CFP 会立即轮询更改，什么也没找到，等待源便提。
9. 等。。。。