CosmosDB：如何在插入文档时应用并发（并行请求）-Java 学习之路

Background:

我们有一个EventHub，每天记录数千个事件 . 在新消息到达时，Azure函数在此事件发生时触发器上配置 . azure函数执行以下两项任务：

Write 将原始邮件放入文档DB（集合1）
Upsert 摘要（聚合）消息到文档Db的集合2中 . 在编写消息之前，它会根据 partition key 和 unique id （非id）检查摘要消息是否已存在，如果存在doc，则会使用新的聚合值更新doc，如果没有，则插入新的doc . 此唯一ID基于业务逻辑创建 .

Problem Statement:

为PartitionKey和唯一ID创建了多个摘要文档

Scenario Details

让我们说，对于PartitionKey PartitionKey1 ，没有在Collection中为计算 unique key 创建的摘要文档 .
多条消息（假设2）到达eventhub并触发了azure函数 .
所有这两个请求同时运行，由于没有找到使用该查询的现有文档，因此每个请求都发出一条消息，现在几乎同时调用Upsert函数以通过并发请求编写摘要文档并导致有多个摘要文档对于PartitionKey和唯一ID .

我已经搜索并阅读了 Optimistic Concurrency ，我肯定会实现更新方案 . 但我无法找到可以处理 insert 场景的任何方法？

1 回答