使用CosmosClient查询CosmosDB并映射到对象

Question

现在，我有以下代码来查询我的CosmosDB：

var streamIterator = containerLogs.GetItemQueryStreamIterator("SELECT * FROM mycontainer");

while (streamIterator.HasMoreResults)
{
    var results = await streamIterator.ReadNextAsync();
    var stream = results.Content;
    using var reader = new StreamReader(stream);
    string data = await reader.ReadToEndAsync();

    // typeof what..?
    //var dbDocuments = JsonConvert.DeserializeObject<???>(data);
}

变量data将包含以下JSON：

{
    "_rid": "wDhMAJ9xYHE=",
    "Documents": [{
        "id": "c05c4eee-32d4-458a-8ae8-d22dd0f93839",
        "CustomProperty1": "Value 1",
        "CustomProperty2": "Value 2",
        "_rid": "wDhMAJ9xYHECAAAAAAAAAA==",
        "_self": "dbs\/wDhMAA==\/colls\/wDhMAJ9xYHE=\/docs\/wDhMAJ9xYHECAAAAAAAAAA==\/",
        "_etag": "\"00000000-0000-0000-7167-28c107aa01d6\"",
        "_attachments": "attachments\/",
        "_ts": 1597319093
    }],
    "_count": 1
}

Documents部分是我实际的“域”模型。如何轻松地将其映射回我的域模型类的列表？我使用相同的类来写入CosmosDB。

模型看起来像这样

public class MyModel
{
    [JsonProperty(PropertyName = "id")]
    public Guid Id {get;set;}
    public string CustomProperty1 {get;set;}
    public string CustomProperty1 {get;set;}
}

那么，如何查询我的CosmosDB，使其返回此类的列表？

Answer 1

下面是我发现的一些有用的samples。更简单的情况是使用类型化的GetItemQueryIterator<MyModel>，但也有一个stream deserialization示例。