为何Azure CosmosDB查询重复邮箱仅返回部分结果？如何解决？

问题根因 #

• Azure门户Data Explorer默认存在单次查询返回结果条数上限，你使用的GROUP BY属于跨分区聚合查询，需要通过*延续令牌（Continuation Token）*分页拉取全量结果，门户默认不会自动迭代所有分页，仅返回第一页内容，你看到的4条结果就是第一页的返回数据。
• 你观测到的429错误是瞬时RU尖峰导致的：虽然71秒查询周期的平均RU消耗为3905 RU/s，低于6000 RU/s的自动缩放上限，但GROUP BY全量扫描400万文档的过程中会出现短时间RU消耗突增，自动缩放的RU额度调整存在秒级延迟，尖峰时段会触发限流。门户Data Explorer内置的重试逻辑有限，部分分片请求重试失败会导致聚合结果缺失。

解决方案 #

方案1：通过官方SDK执行查询（最稳妥） #

使用Cosmos DB任意语言的官方SDK执行查询，手动迭代所有延续令牌直到拉取完全量结果，同时配置429错误重试逻辑即可拿到完整的重复邮箱列表，C#示例逻辑如下：

var query = container.GetItemQueryIterator<dynamic>(
    "SELECT * FROM (SELECT c.Email, COUNT(1) as cnt FROM c GROUP BY c.Email) a WHERE a.cnt > 1",
    requestOptions: new QueryRequestOptions
    {
        MaxItemCount = -1,
        MaxBufferedItemCount = 10000
    });
var duplicateEmails = new List<dynamic>();
while (query.HasMoreResults)
{
    try
    {
        var page = await query.ReadNextAsync();
        duplicateEmails.AddRange(page);
    }
    catch (CosmosException ex) when (ex.StatusCode == (System.Net.HttpStatusCode)429)
    {
        await Task.Delay(ex.RetryAfter ?? TimeSpan.FromSeconds(1));
    }
}

方案2：调整门户配置临时验证 #

在Data Explorer的查询设置中，将单次最大返回条数调整为1000以上，每次查询后复制响应头返回的延续令牌，粘贴到查询选项的延续令牌输入框中反复执行，直到没有新结果返回即可凑齐全量重复邮箱列表。

方案3：临时调大吞吐量规避限流 #

查询执行前将集合吞吐量临时切换为手动模式，设置为10000 RU/s，避免查询过程中的RU尖峰触发限流，查询完成后再切回自动缩放模式即可。

内容的提问来源于stack exchange，提问作者Blu3