c# - CosmosDB 更改更改源处理器名称

Question

我有一个更改提要处理器：

var changeFeedProcessor = monitoredContainer
    .GetChangeFeedProcessorBuilder<Model>("original-processor-name", HandleChangesAsync)
        .WithInstanceName(Environment.MachineName)
        .WithLeaseContainer(leaseContainer)
        .Build();

HandleChangesAsync()变得太大，故障不再被很好地隔离。我想将其分解为多个处理器，即“new-processor-name-1”和“new-processor-name-2”，但我不确定如何以新的方式进行处理处理者不会从一开始就重新处理所有现有文档。

有什么方法可以让新处理器从原来的处理器停止的地方开始？

Answer 1

您可以再创建一个changeFeedProcessor并编写它自己的HandleChangesAsync方法。另请注意，您可以在其设置中提供相同Lease prefix和相同Lease container的设置，以确保这两个处理器根据彼此的检查点工作（如果这是您想要实现的），否则如果您希望两个处理器单独使用自己的检查点工作，您可以为它们设置单独的 Lease 前缀。