处理 Cosmos Db 中的重复数据

Question

下面是我在 Cosmos Db 中添加 json 文档的代码。我的分区键是 TypeId，TypeId 和 CValue 的组合创建了一个唯一值。现在下面的代码能够在我的 cosmosDb 中添加文档，但它也允许添加重复的项目，我想避免这种情况并想知道我该如何处理？每当添加新文档时，它会检查具有相同唯一键（TypeId 和 CValue）的文档是否存在，如果存在，则覆盖或不添加它。

var content = JsonConvert.DeserializeObject<JObject>( lines );
var client = new DocumentClient( new Uri( DbInstance ),Key );
await client.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(
                Database, Collection ),
                content);

content 是一个 JObject，这里是 content 的示例输出：

"Classes": {
    "Subjects": {
      "Name": "testA",
      "TypeId": "AS88QW",
      "Public": "No"
    },
    "Sections": {
      "Scopes": true,
      "CValue": [12,12,1]
    }
  }

Answer 1

我按照大卫的想法进行了测试，但失败了，请允许我在下面展示我的测试结果以供后续讨论。

当我们创建容器时，我们可以设置唯一键，在你的情况下，你可以在字段中输入Classes/Subjects/TypeId,Classes/Sections/CValue。

但根据我的测试，它不能对类型数组产生影响。把CValue 变成字符串怎么样？

==================更新=======================

创建合成密钥，参考this sdk

using Microsoft.Azure.Cosmos;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;

namespace ConsoleApp1
{
    class Program
    {
        static async System.Threading.Tasks.Task Main(string[] args)
        {
            CosmosClient client = new CosmosClient("https://yourcosmosdb.documents.azure.com:443/", "cosmosdb_primary_key_here");
            Container container = await client.GetDatabase("database_name").DefineContainer(name: "container_name", partitionKeyPath: "/ptk")
                .WithUniqueKey()
                .Path("/combinedProperity_set_to_be_unique_key")
                .Attach()
                .CreateIfNotExistsAsync();

            var lines = "{\"id\":\"001\",\"TypeId\": \"AS88QW\",\"CValue\":[12,12,1]}";
            JObject content = JsonConvert.DeserializeObject<JObject>(lines);
            string TypeId = content.GetValue("TypeId").ToString();
            string CValue = content.GetValue("CValue").ToString();
            content.Add(new JProperty("combinedProperty", TypeId+"-"+ CValue));
            Console.WriteLine(content);
            ItemResponse<JObject> createResponse = await container.CreateItemAsync(content);
        }
    }
}