MongoDB复杂聚合查询的索引优化问题咨询

我无法理解如何通过索引提升以下聚合查询的性能。查询语句如下：

db.Vendite.aggregate([{$group: { 
_id: {
anno: "$anno", mese: "$mese", cod_age: "$cod_age", cod_int: "$cod_int",  cod_cli: "$cod_cli", cod_linea_comm: "$cod_linea_comm", cod_sett_comm: "$cod_sett_comm", _art: "$cod_art"}, 
vendite_quantita: {
   $sum: { 
      $add: [ {
         $subtract: ["$ven_quantita", "$res_quantita"]}, "$oma_quantita"]}}, 
            vendite_quantita_pz: {
                $sum: {
                   $add: [{
                      $subtract: ["$ven_quantita_pz", "$res_quantita_pz"]}, 
                        "$oma_quantita_pz"]}}, 
vendite_netto: {
   $sum: {
      $subtract: [{
         $subtract: ["$ven_lordo", {
            $add: ["$ven_incondizionato", "$ven_finanziari", "$ven_canvass", "$ven_offerta"]}]},
               {$subtract: ["$res_lordo", {$add: ["$res_incondizionato", "$res_finanziari", "$res_offerta", "$res_offerta"]]}]}] }}}, 
{ $sort: {"anno": 1, "mese": 1, "cod_age": 1, "cod_int": 1, "cod_cli": 1, "cod_linea_comm": 1, "cod_sett_comm": 1, "cod_art": 1 }}]).explain("executionStats")

该查询针对含270万条记录的Vendite集合，返回210万条结果。我按排序顺序创建了复合索引anno_1_mese_1_cod_age_1_cod_int_1_cod_cli_1_cod_linea_comm_1_cod_sett_comm_1_cod_art_1，但查询性能未得到提升。我猜测可能是返回结果过多导致索引作用有限，但不确定是否操作有误。此外，是否需要将聚合中用于$sum计算的字段纳入索引？未通过hint强制使用索引时，MongoDB会无索引执行该查询。

环境：MongoDB 7.0.6，Mongosh 2.1.5

问题分析与解决方案 #

为什么现有索引没效果 #

你的复合索引只包含了分组和排序的字段，但聚合计算需要的大量字段不在索引里。MongoDB如果走这个索引，需要先扫描索引条目，再逐个回表查询对应的文档获取计算字段，这个开销比直接全表扫描更大，所以优化器自动选择了无索引执行。另外，返回结果接近原文档数，说明分组粒度极细，分组操作本身的开销就很高，单纯的排序索引无法解决核心问题。

优化方案 #

1. 创建覆盖索引
   把聚合中用到的所有字段（分组字段+计算字段）都纳入索引，让MongoDB可以直接从索引中获取所有数据，无需回表。这样索引的有序性还能减少分组时的排序开销。

创建覆盖索引的命令：

db.Vendite.createIndex(
  { anno: 1, mese: 1, cod_age: 1, cod_int: 1, cod_cli: 1, cod_linea_comm: 1, cod_sett_comm: 1, cod_art: 1 },
  { include: [
    "ven_quantita", "res_quantita", "oma_quantita",
    "ven_quantita_pz", "res_quantita_pz", "oma_quantita_pz",
    "ven_lordo", "ven_incondizionato", "ven_finanziari", "ven_canvass", "ven_offerta",
    "res_lordo", "res_incondizionato", "res_finanziari", "res_offerta"
  ] }
)

2. 强制使用索引测试
   创建覆盖索引后，用hint强制MongoDB使用该索引，通过explain查看执行计划，对比扫描数、是否有FETCH阶段，验证性能提升：

db.Vendite.aggregate([
  // 原聚合查询内容不变
]).hint("anno_1_mese_1_cod_age_1_cod_int_1_cod_cli_1_cod_linea_comm_1_cod_sett_comm_1_cod_art_1").explain("executionStats")

3. 预聚合优化（针对频繁执行的场景）
   因为查询返回结果接近原文档数，说明分组粒度极细，实时聚合的开销本身就很高。如果这个查询是频繁执行的，建议定时预聚合结果到新集合，查询时直接读取预聚合数据：

• 定时执行原聚合查询，将结果写入VenditeAggregated集合（可以用$out或$merge操作符）
• 后续查询直接从VenditeAggregated读取，无需实时计算

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