如何优化MongoDB C#中聚合管道的查询性能？

问题核心原因 #

你的聚合管道执行缓慢的根本原因是**$lookup阶段使用$expr引用变量，导致MongoDB无法利用索引进行匹配**，每次执行lookup都要对tax_assessor集合做全表扫描，这也是执行计划中lookup阶段耗时占比极高的直接原因。

优化方案1：添加复合索引并调整$lookup写法 #

步骤1：创建针对性复合索引 #

为tax_assessor集合创建覆盖lookup查询条件的复合索引，让MongoDB能够快速定位匹配文档：

db.tax_assessor.createIndex({ OwnerName: 1, PropertyCity: 1, PropertyState: 1 })

步骤2：修改$lookup阶段逻辑 #

去掉$expr，将固定的城市、州条件直接写入$match（无需通过let传递变量），让索引能够被正常触发：

{
  $lookup: {
    from: "tax_assessor",
    localField: "OwnerName",
    foreignField: "OwnerName",
    pipeline: [
      {
        $match: {
          PropertyCity: "Chicago",
          PropertyState: "IL"
        }
      }
    ],
    as: "NumberOfProperties"
  }
}

优化方案2：重构聚合逻辑，避免多次$lookup查询 #

如果指定城市和州的房产数据量较大，多次lookup的开销依然可观，可以通过预聚合统计该区域内的业主房产数量，再与地理查询结果关联，只执行一次统计操作：

完整重构后的聚合管道 #

[
  // 并行执行地理查询与业主房产数量预统计
  {
    $facet: {
      "geoResults": [
        {
          $geoNear: {
            near: { type: "Point", coordinates: [-110.29665, 31.535699] },
            distanceField: "distance",
            maxDistance: 100,
            query: {
              IsResidential: true,
              DaysSinceLastSale: { $gt: 10 }
            },
            spherical: true
          }
        },
        {
          $project: {
            _id: 0,
            FullAddress: 1,
            OwnerName: 1,
            distance: 1,
            YearBuilt: 1
          }
        }
      ],
      "ownerPropertyCounts": [
        {
          $match: {
            PropertyCity: "Chicago",
            PropertyState: "IL"
          }
        },
        {
          $group: {
            _id: "$OwnerName",
            count: { $sum: 1 }
          }
        }
      ]
    }
  },
  // 关联地理查询结果与统计数据
  {
    $unwind: "$geoResults"
  },
  {
    $lookup: {
      from: "$ownerPropertyCounts",
      localField: "geoResults.OwnerName",
      foreignField: "_id",
      as: "propertyCount"
    }
  },
  // 整理输出格式
  {
    $project: {
      OwnerName: "$geoResults.OwnerName",
      FullAddress: "$geoResults.FullAddress",
      distance: "$geoResults.distance",
      YearBuilt: "$geoResults.YearBuilt",
      NumberOfProperties: { $ifNull: [{ $arrayElemAt: ["$propertyCount.count", 0] }, 0] }
    }
  },
  // 按距离排序
  {
    $sort: { distance: 1 }
  }
]

该方案通过$facet并行执行两个任务，避免了对每条地理查询结果都执行一次lookup，大幅减少查询次数。

额外小优化 #

• 在$geoNear之后立即添加$project，只保留后续需要的字段，减少数据传输和处理开销（大数量场景下效果更明显）。
• 当前$geoNear使用的sta_geo_idx索引{PropertyGeoPoint: "2dsphere", DaysSinceLastSale: 1, IsResidential: 1}已经匹配查询条件，无需调整。

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