azure-cosmosdb - 如何使用 c# 更新 cosmos db 中文档中的特定子值？

Question

我在 cosmos db 中有一个需要更新的文档，类似于以下文档

{
    "userId": "1234",
    "values": {
        "A": {
            "description": "first description",
            "timestamp": "2018-10-01T12:13:09.000Z",
            "value": 5000,
            "valueWithUnit": "202 W"
        },
        "B": {
            "description": "second description",
            "timestamp": "2018-10-01T12:13:09.000Z",
            "value": 2,
            "valueWithUnit": "2.00 %"
        }
     },
    "id": "1",
    "lastUpdate": "2018-09-20T14:39:00Z",
    "_rid":  "rid",
    "_self": "self",
    "_etag": "etag",
    "_attachments": "attachments/",
    "_ts": 1234
}

我需要将“B”中的值从 2 更新为 3。

下面是我到目前为止的代码..

public DocumentClient client = new DocumentClient(new Uri(EndpointUrl), PrimaryKey);

var collectionLink = UriFactory.CreateDocumentCollectionUri(databaseName, collectionName);

Document doc = client.CreateDocumentQuery<Document>(collectionLink)
            .Where(r => r.Id == "1")
            .AsEnumerable()
            .SingleOrDefault();

Document doc1 = doc.GetPropertyValue<Document>("values");

Document doc2 = doc1.GetPropertyValue<Document>("B");

doc2.SetPropertyValue("value", 3);

我现在如何更新文档以反映 cosmosdb 中的新属性值？

任何帮助将不胜感激

标签： azure-cosmosdb

Answer 1

有多种方法可以做到这一点。如果您不想进行任何特定的对象映射，而只想使用 json，那么您的代码应如下所示：

public DocumentClient client = new DocumentClient(new Uri(EndpointUrl), PrimaryKey);

var collectionLink = UriFactory.CreateDocumentCollectionUri(databaseName, collectionName);

Document doc = client.CreateDocumentQuery<Document>(collectionLink)
            .Where(r => r.Id == "1")
            .AsEnumerable()
            .SingleOrDefault();

var docValues = doc.GetPropertyValue<dynamic>("values");
docValues.B.value = 3;
doc.SetPropertyValue("values", docValues);

await documentClient.ReplaceDocumentAsync(doc);

如果您将Document对象与该GetPropertyValue方法一起使用，您还将添加所有文档元数据，这不是您想要做的。

请记住，如果您的集合是分区的，那么您还需要通过如下替换来提供分区键：

await documentClient.ReplaceDocumentAsync(doc, new RequestOptions{PartitionKey = new PartitionKey("partitionKeyValueHere")});

您还可以使用 UpsertDocumentAsync 如果文档不存在则插入，如果文档存在则更新。

var documentLink = UriFactory.CreateDocumentUri(databaseName, collectionName, "1");
await documentClient.UpsertDocumentAsync(documentLink, doc);

如果集合是分区的：

var documentLink = UriFactory.CreateDocumentUri(databaseName, collectionName, "1");
await documentClient.UpsertDocumentAsync(documentLink, doc, new RequestOptions{PartitionKey = new PartitionKey("partitionKeyValueHere")});

您还可以通过将其转换为直接读取来加快查询逻辑。

您可以通过执行以下操作简单地使用它的 id 获取文档：

var docUri = UriFactory.CreateDocumentUri(databaseName, collectionName, "1");
Document doc = await productStore.CosmonautClient.DocumentClient.ReadDocumentAsync(docUri);

如果您的集合已分区，您将需要RequestOptions具有分区键值的对象作为此文档的分区键。

这既更快又便宜。