MongoDB基于地理点的双集合聚合查询问题：查找用户附近餐厅的报错排查与实现方案

首先来看你遇到的报错：$geoNear requires a 'near' option as an Array，这是因为在$lookup的子管道中直接引用$$personPoint作为$geoNear的near参数时，MongoDB无法正确解析这个GeoJSON变量（尤其是部分旧版本）。我们可以换一种更可靠的聚合写法来实现需求：

修正后的聚合管道查询 #

db.person.aggregate([
  {
    $lookup: {
      from: "restaurant",
      let: { personLocation: "$address.location" },
      as: "nearby_restaurants",
      pipeline: [
        // 第一步：筛选出用户10公里范围内的餐厅
        {
          $match: {
            $expr: {
              $geoWithin: {
                $centerSphere: [
                  "$$personLocation.coordinates",
                  10 / 6378.1 // 将10公里转换为弧度（地球半径约6378.1公里）
                ]
              }
            }
          }
        },
        // 第二步：计算餐厅到用户的距离（转换为公里）
        {
          $addFields: {
            distance: {
              $multiply: [
                { $distanceSphere: ["$location", "$$personLocation"] },
                0.001 // 米转公里
              ]
            }
          }
        },
        // 第三步：只保留需要的字段
        {
          $project: {
            name: 1,
            distance: 1,
            _id: 0 // 不需要返回_id的话可以加上
          }
        }
      ]
    }
  }
])

这个查询的逻辑是：

1. 用$geoWithin + $centerSphere先筛选出用户10公里内的餐厅，这里需要把公里数转为弧度（公里数除以地球平均半径6378.1）
2. 用$distanceSphere计算两个GeoJSON点之间的球面距离，再乘以0.001把单位从米转成公里
3. 最后用$project只保留你需要的name和distance字段，避免返回多余数据

备选方案：遍历用户文档实现 #

如果因为版本限制或者其他原因无法使用聚合管道，你可以通过遍历每个用户文档的方式来实现需求（适合数据量不大的场景）：

// 先获取所有用户数据
const allPersons = db.person.find().toArray();

// 遍历每个用户，查询附近餐厅
allPersons.forEach(person => {
  // 查询当前用户10公里内的餐厅，并计算距离
  const nearbyRestaurants = db.restaurant.aggregate([
    {
      $geoNear: {
        near: person.address.location,
        spherical: true,
        distanceField: "distance",
        maxDistance: 10 * 1000, // 10公里转为米
        distanceMultiplier: 0.001 // 结果转为公里
      }
    },
    {
      $project: {
        name: 1,
        distance: { $round: ["$distance", 1] }, // 可选：保留1位小数让结果更整洁
        _id: 0
      }
    }
  ]).toArray();

  // 这里可以选择更新数据库中的用户文档，或者直接打印结果
  // 更新文档的写法：
  db.person.updateOne(
    { _id: person._id },
    { $set: { nearby_restaurants: nearbyRestaurants } }
  );

  // 或者直接输出结果：
  console.log({
    ...person,
    nearby_restaurants: nearbyRestaurants
  });
});

注意：如果你的用户数据量非常大，这种遍历方式会把所有用户数据加载到客户端内存，可能影响性能，这时候优先选择聚合管道的方案。

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