c# - 对分区的 CosmosDB 集合的查询不一致

Question

我有一个分区的 cosmos DB 集合，定义为无限制，吞吐量为 1000。它具有以下文档结构:

"Id": "b42129d2-5467-450c-9f7e-744f78dfe1e7", // Primary key
"ArrayOfObjects": [
 {
     // other properties omitted for brevity
     "SubId": "ed2a49fb-51d4-45b4-9690-df0721d6a32f"
 },
 {
     "SubId": "35c87833-9bea-4151-86da-4d9c482ae1fe"
 },
 "ParitionKey": "b42"

分区键是主键的前 3 个字母，它是一个 GUID。这给了我 32768 个具有良好基数的可能分区。我正在使用 CosmosDB .NetCore SDK .目前在约 6 千个分区中有约 17 万个文档。

我有一些功能需要通过“SubId”从集合中检索文档，而我不知道主键，这意味着我不知道分区键。不幸的是，我无法更改此功能以使用主键，因为它的依赖项是无法修改的遗留系统。

发生的事情是，我成功创建了一个新文档，然后在某个时候我需要使用“SubId”查询该文档。这是在 C# 中完成的，如下所示:

public async Task<DocumentModel> GetBySubId(string subId)
{
    var collectionId = _cosmosClient.CollectionId;
    var query = $@"SELECT * FROM {collectionId} c
                   WHERE ARRAY_CONTAINS(c.ArrayOfObjects, {{'SubId': '{subId}'}}, true)";

    var feedOptions = new FeedOptions { EnableCrossPartitionQuery = true };

    var docQuery = _cosmosClient.Client.CreateDocumentQuery(
            _collectionUri,
            query,
            feedOptions)
            .AsDocumentQuery();

    var executedQuery = await docQuery.ExecuteNextAsync<DocumentModel>();

     if (executedQuery.Count == 0)
     {
           return null;
     }

     return executedQuery.FirstOrDefault();
}

有时它查询成功有时不成功，我返回 null，然后从我的 Controller 返回 404。

之所以如此奇怪，是因为如果我检查数据库并直接运行该查询，文档就在那里并且实际上并没有丢失，但由于某种原因，当我使用 SDK 从 C# 查询时，它找不到文档。我还有其他功能可以使用主键(现在意味着我有分区键)和 SubId 进行查询，并且工作正常。只有当我使用 SubId 本身查询时(没有分区键)它找不到文档。

鉴于以上情况，我认为这与没有分区键的查询有关。在没有分区键的情况下查询时我遗漏了什么吗？

我目前尝试的是设置 database consistency从最终到强大。这似乎没有任何区别。

Answer 1

我来自 CosmosDB 工程团队。

您提到的行为可能是因为有时查询无法在一次继续中完成执行。请确保查询通过耗尽延续来完成执行。您可以在此处找到示例:https://learn.microsoft.com/en-us/azure/cosmos-db/performance-tips#throughput .在 IDocumentQuery.HasMoreResults 设置为 false 之前，查询执行不会被视为完成。