【发布时间】:2021-04-03 12:18:22
【问题描述】:
我有一个更改提要处理器:
var changeFeedProcessor = monitoredContainer
.GetChangeFeedProcessorBuilder<Model>("original-processor-name", HandleChangesAsync)
.WithInstanceName(Environment.MachineName)
.WithLeaseContainer(leaseContainer)
.Build();
HandleChangesAsync() 变得太大,故障不再被很好地隔离。我想将其分解为多个处理器,即“new-processor-name-1”和“new-processor-name-2”,但我不确定如何以新的方式进行处理处理器不会从一开始就重新处理所有现有文档。
有什么方法可以让新处理器从原来的处理器停止的地方开始?
【问题讨论】:
-
@jdweng 我不能说。您提到的具体内容可能会有所帮助吗?
-
代码示例。
-
@jdweng 我认为这两个代码示例都没有显示如何重命名或拆分提要处理器。谢谢
-
你是什么客户?
标签: c# azure-cosmosdb azure-cosmosdb-changefeed