azure - 更改源处理器库不支持 ChangeFeedProcessorOptions FeedPollDelay/CheckPointFrequency

Question

我按照此示例代码 ( https://github.com/Azure/azure-documentdb-changefeedprocessor-dotnet#example ) 注册一个观察者来处理 cosmos db 集合中的更改源。我正在使用实用程序在 cosmos db 集合中创建新文档(例如在 for 循环中创建 400 个文档)。我正在使用 30 秒的 FeedPollDelay。但 CFP lib 似乎并没有尊重它。即使在 Feed 轮询延迟间隔到期之前，也会重复调用 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 份文档就可以了。但我预计在 Feed 轮询延迟(30 秒)间隔到期后，将在单个批处理中调用第二批，并包含其余 340 个文档。

但是 ProcessChangesAsync 方法会频繁触发，并且此选项未得到遵守。

Answer 1

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

流程示例:

1. CFP 轮询更改，发现 X。
2. 使用 X 调用 ProcessChangesAsync
3. ProcessChangesAsync 完成后，CFP 立即轮询更改，找到 Y。
4. 使用 Y 调用 ProcessChangesAsync。
5. ProcessChangesAsync 完成后，CFP 立即轮询更改，但什么也没发现，然后等待 FeedPollDelay。
6. CFP 轮询变化，发现 Z。
7. 使用 Z 调用 ProcessChangesAsync
8. ProcessChangesAsync 完成后，CFP 立即轮询更改，但什么也没发现，然后等待 FeedPollDelay。
9. 等等……