1

我在 Azure Cosmos DB 容器中为字段定义了 UniqueKey 策略UniqueName

下面的函数正在定时器上调用。

我正在尝试使用 Azure Functions 绑定在 Azure Cosmos DB 中更新文档，如下所示：

public async Task ManageItems([ActivityTrigger] string records,
        [CosmosDB(
        databaseName: "mydatabase",
        collectionName: "items",
        ConnectionStringSetting = "CosmosDbConnectionString")] DocumentClient client,
        ILogger log)
        {
             var collectionUri = UriFactory.CreateDocumentCollectionUri("mydatabase", "items");


            
            foreach (var record in records)
            {
                log.LogDebug($"Upserting itemNumber={record.UniqueName}");
                await client.UpsertDocumentAsync(collectionUri, record);
            }
         }

在空白“项目”容器中的第一次执行期间，每个记录的 Upsert 工作出色，将每个记录作为特定文档插入。

但是，在对与第一次执行相同的数据进行测试时，但现在期待“更新”而不是“插入”尝试，我得到一个异常：

UpsertDocumentAsync方法运行后违反唯一索引约束。

我在这里想念什么？

据我了解，Upsert 是更新或插入，具体取决于对象是否存在，通过它的唯一标识符。

检查来自该方法的传出对象唯一 ID 是否与现有文档唯一 ID 匹配应该在 Cosmos DB 容器级别进行。

我期望发生的是调用通知具有该唯一 ID 的文档已经存在，并且它执行更新，而不是抛出异常。如果方法是Insert only，我希望它会抛出异常。

4

1 回答 1

0

"id"通过在“记录”来自的类中指定一个显式字段来解决此问题。

"id"被设置为我想用作唯一值的唯一“recordNumber” 。

为了更好地衡量，我在 UpsertDocumentAsync 方法中将 disableAutomaticIdGeneration 设置为 true

UpsertDocumentAsync(collectionUri, record, disableAutomaticIdGeneration:true);

不再有唯一索引违规，也没有重复。

值得注意的解决方案与此类似：How can I insert/update data in CosmosDB in an Azure function

于 2021-11-30T16:39:20.810 回答