我有一个分区的 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从最终到强大。这似乎没有任何区别。
请您参考如下方法:
我来自 CosmosDB 工程团队。
您提到的行为可能是因为有时查询无法在一次继续中完成执行。请确保查询通过耗尽延续来完成执行。您可以在此处找到示例:https://learn.microsoft.com/en-us/azure/cosmos-db/performance-tips#throughput .在 IDocumentQuery.HasMoreResults 设置为 false 之前,查询执行不会被视为完成。
