CosmosDB 创建文档使用启用交叉分区查询不返回结果，但如果指定分区键，则会返回结果。

Question

我有一个问题，如果我为一个特定的查询指定分区键，我将得到我期望的记录。但是，如果我没有指定分区键，只是将EnableCrossPartitionQuery设置为true，它将不会返回/找到任何文档。

这实际上在我的一个宇宙数据库上按预期工作，但在另一个数据库上却没有。相同的记录/文档。

我正在使用以下设置：

> 微软公司。Azure.DocumentDB NuGet包版本2.3.0

具有无限容量的Cosmos DB集合（带有分区键=Application ationId）

数据库/集合上的三个非常简单的文档，通过 Azure 存储资源管理器手动创建

我的代码如下所示，相当简单。如果GetDocuments的调用者传递了partitionKey的值，那么我通过FeedOptions在查询中指定它。否则，我在FeedOptions上设置EnableCrossPartitionQuery。

数据库/集合上有效的文档与数据库/集合中无效的文档相同。

我使用相同的分区键（ApplicationId）以相同的方式创建集合

public async Task<IEnumerable<T>> GetDocuments<T>(Expression<Func<T, bool>> predicate, object partitionKey = null)
{
    IDocumentQuery<T> queryDetails = QueryDocument<T>(predicate, partitionKey);

    var queryData = await queryDetails.ExecuteNextAsync<T>();

    if (queryData.Any())
    {
        return queryData;
    }

    return default(IEnumerable<T>);
}

private IDocumentQuery<T> QueryDocument<T>(Expression<Func<T, bool>> predicate, object partitionKey = null)
{
    FeedOptions feedOptions;

    if (partitionKey == null)
    {
        feedOptions = new FeedOptions { EnableCrossPartitionQuery = true };
    }
    else
    {
        feedOptions = new FeedOptions { PartitionKey = new PartitionKey(partitionKey) };
    }

    var query = _client.CreateDocumentQuery<T>(DocumentCollectionUri, feedOptions);

    var queryDetails = query.Where(predicate).AsDocumentQuery();

    return queryDetails;
}

文档如下所示：

{
"id": "1",
"HubName": "abxyz-hub",
"ClientId": "abxyz",
"ApplicationId": 1,
"ApplicationName": "My App Name",
"_rid": "hSkpAJde99IBAAAAAAAAAA==",
"_self": "dbs/hSkpAA==/colls/hSkpAJde99I=/docs/hSkpAJde99IBAAAAAAAAAA==/",
"_etag": "\"53007677-0000-0100-0000-5cbb3c660000\"",
"_attachments": "attachments/",
"_ts": 1555774566
}

知道为什么这不起作用吗？

Answer 1

你的代码是错误的。你的错误在这张支票上:

if (queryData.Any())

您在实际获取所有数据之前返回。

您的代码使用分区键的原因是因为您的目标是一个物理分区（通过逻辑分区），并且包含的数据小于您提供的MaxItemCount或Request estOptions对象。

Cosmos DB 仅返回分页结果，并且它需要为这些值调用每个物理分区，有时是每个分区的多次，在某些情况下，迭代可能返回 0 数据，但下一个迭代可能有一些数据。您必须执行下一次同步，直到“更多结果”为假。

添加time循环以从跨分区查询将遇到的所有物理分区中获取所有分页结果将解决问题：

这是代码：

public async Task<IEnumerable<T>> GetDocuments<T>(Expression<Func<T, bool>> predicate, object partitionKey = null)
{
    IDocumentQuery<T> documentQuery = QueryDocument<T>(predicate, partitionKey);

    var results = new List<T>();

    while(documentQuery.HasMoreResults)
    {
        var docs = await documentQuery.ExecuteNextAsync<T>();    
        results.AddRange(docs)
    }

    return results;
}

private IDocumentQuery<T> QueryDocument<T>(Expression<Func<T, bool>> predicate, object partitionKey = null)
{
    FeedOptions feedOptions;

    if (partitionKey == null)
    {
        feedOptions = new FeedOptions { EnableCrossPartitionQuery = true };
    }
    else
    {
        feedOptions = new FeedOptions { PartitionKey = new PartitionKey(partitionKey) };
    }

    var query = _client.CreateDocumentQuery<T>(DocumentCollectionUri, feedOptions);

    var queryDetails = query.Where(predicate).AsDocumentQuery();

    return queryDetails;
}