0

我正在尝试在一个名为 Entity 的数据库上实现一个更改提要处理器,其中所有文件都作为“entitytype-entityid”导入。

  1. 我将如何使用租约来区分每种类型的文件?它正在监视一个集合。
Entity
/id                       /partition-id
customer499                customer499
product4051                product4051
productInventory4051       productInventory4051
  1. 他们还为此添加了版本控制组件。更改“customer499”时,旧记录更改为“customer499-[日期]”,新导入的记录添加为“customer499”。我只希望租约使用新记录,而更改提要使用新记录。

我是 CosmosDB 的新手,我会更改提要。我需要每个租约从其各自的实体类型开始并仅计算它。我想我必须在 HandleChangesAsync 期间调用的委托函数中定义这些东西,但我完全卡住了。

4

1 回答 1

1

Change Feed Processor 将侦听整个集合中的更改,包括其中的所有文档和模式存储,并跟踪所有插入和更新操作。您目前无法为特定更改添加过滤器。

如果您要存储多个不同的模式或想要根据特定的文档属性触发不同的流程,则需要在委托中定义它。

如果您正在处理不同的模式,您可以使用该dynamic类型在委托中接收任何类型的文档,然后根据其属性检查它需要转到哪个流。

于 2020-03-26T18:21:02.260 回答