c# - 如何使用 CreateDocumentAsync 将 json 内容存储到 CosmosDB

Question

目标:创建控制台应用程序，其中 1) 从 Azure Data Lake Store 读取 json 2) 将数据以 json 形式存储到 Cosmos DB。 (下一步我将在存储之前解析代码中的json内容)

问题:在 CosmosDB 中创建了新文档，但它包含某种元数据而不是实际的 json 文件内容。字符串 json 确实包含我需要的内容，但它没有正确传递给 CreateDocumentAsync。我希望得到解决问题的帮助，并且也感谢使代码易于处理 json 的提示。

错误:没有错误消息，但将错误的内容存储到 CosmosDB。

代码:

private  async Task CreateDocumentsAsync()
    {
        string fileName = "/myjson.json";

        // Obtain AAD token for ADLS 
        var creds = new ClientCredential(applicationId, clientSecret);
        var clientCreds = ApplicationTokenProvider.LoginSilentAsync(tenantId, creds).GetAwaiter().GetResult();

        // Create ADLS client object
        AdlsClient client = AdlsClient.CreateClient(adlsAccountFQDN, clientCreds);

        String json = "";

        //Read file contents
        using (var readStream = new StreamReader(client.GetReadStream(fileName)))
        {
            string line;
            while ((line = readStream.ReadLine()) != null)
            {
                Console.WriteLine("Read file Line: " + line);
                json += line;
            }
        }

        //Read file to json
        JsonTextReader reader = new JsonTextReader(new StringReader(json));

        //Storing json to CosmosDB
        Uri collectionUri = UriFactory.CreateDocumentCollectionUri(databaseName, collectionName);

        using (DocumentClient DocumentDBclient2 = new DocumentClient(new Uri(endpointUrl), authorizationKey))
        {
            Document doc = await DocumentDBclient2.CreateDocumentAsync(collectionUri, reader);

        }
    }

}

JSON 示例(我想存储它):

[
{
    color: "red",
    value: "#f00"
},
{
    color: "green",
    value: "#0f0"
},
{
    color: "blue",
    value: "#00f"
},
{
    color: "cyan",
    value: "#0ff"
},
{
    color: "magenta",
    value: "#f0f"
},
{
    color: "yellow",
    value: "#ff0"
},
{
    color: "black",
    value: "#000"
}
]

JSON 存储到 COSMOSDB:

{
"ArrayPool": null,
"LineNumber": 0,
"LinePosition": 0,
"CloseInput": true,
"SupportMultipleContent": false,
"QuoteChar": "\u0000",
"DateTimeZoneHandling": 3,
"DateParseHandling": 1,
"FloatParseHandling": 0,
"DateFormatString": null,
"MaxDepth": null,
"TokenType": 0,
"Value": null,
"ValueType": null,
"Depth": 0,
"Path": "",
"Culture": "(Default)",
"id": "0189f287-b6ae-4e45-95b8-879293d4c8f3",
"_rid": "nDxrAL1JbwYIAAAAAAAAAA==",
"_self": "dbs/nDxrAA==/colls/nDxrAL1JbwY=/docs/nDxrAL1JbwYIAAAAAAAAAA==/",
"_etag": "\"00006cc5-0000-0000-0000-5a633c900000\"",
"_attachments": "attachments/",
"_ts": 1516453008
}

Answer 1

正如您提到的，您将不同的 json 存储到 documentDb，根本原因是您将 JsonTextReader 对象存储到 documentDB。

如果要将 Jarry 存储到 documentDB，可以将其存储为 Json 对象的属性值。

var jObject = new JObject {{"Data", json}};

Document doc = await DocumentDBclient2.CreateDocumentAsync(collectionUri, jObject);

注意:根据我的测试，不支持将 Jarray 对象直接存储到 documentDb。我使用 Azure 门户对其进行了测试。