MongoDB使用aggregate聚合时allAddresses字段undefined报错求解

你遇到的Cannot read properties of undefined (reading 'allAddresses')报错，核心原因是Mongoose的aggregate()是异步方法，你在调用后立刻同步读取response[0]时，聚合查询还未执行完成，此时response是Mongoose内部的thenable查询对象，不是实际返回的结果数组，response[0]为undefined，读取属性自然抛出错误。
你把聚合逻辑嵌套在Address.find()回调内的思路本身没有问题，问题出在没有正确处理异步逻辑的执行顺序，也没有做对应的错误捕获和空值兜底。

回调嵌套写法（适配原有代码风格） #

直接给aggregate传入回调函数，等聚合结果返回后再执行渲染逻辑，同时补充错误判断和空值兜底：

app.post('/indexReplaced.html', (req, res) => {
  Address.find({}, function(err, items) {
    if (err) return res.status(500).send('地址数据查询失败');
    Address.aggregate([
      {
        $group: {
          _id: null,
          addresses: { $push: "$addresses" }
        }
      },
      {
        $project: {
          allAddresses: {
            $reduce: {
              input: "$addresses",
              initialValue: [],
              in: { $concatArrays: ["$$value", "$$this"] }
            }
          }
        }
      }
    ], function(aggErr, aggResult) {
      if (aggErr) return res.status(500).send('聚合查询失败');
      // 空值兜底，避免无聚合结果时取值报错
      const allAddresses = aggResult[0]?.allAddresses || [];
      res.render("indexCalculated", {
        address: items,
        allAddresses: allAddresses
      })
    })
  })
});

async/await 写法（推荐） #

用async函数配合await处理异步逻辑，两个无依赖的查询可以用Promise.all并行执行，执行效率更高，代码结构更清晰：

app.post('/indexReplaced.html', async (req, res) => {
  try {
    // 并行执行普通查询和聚合查询，减少等待时间
    const [addressItems, aggResult] = await Promise.all([
      Address.find({}),
      Address.aggregate([
        {
          $group: {
            _id: null,
            addresses: { $push: "$addresses" }
          }
        },
        {
          $project: {
            allAddresses: {
              $reduce: {
                input: "$addresses",
                initialValue: [],
                in: { $concatArrays: ["$$value", "$$this"] }
              }
            }
          }
        }
      ])
    ]);
    const allAddresses = aggResult[0]?.allAddresses || [];
    res.render("indexCalculated", {
      address: addressItems,
      allAddresses: allAddresses
    })
  } catch (err) {
    res.status(500).send('数据加载失败');
  }
});

• Mongoose所有查询方法（find/aggregate/create等）都是异步执行的，必须通过回调、.then()或者await拿到最终结果后再操作返回值，不能同步直接取值
• 聚合返回结果是数组，即使是_id:null的固定分组场景，也建议加可选链和空数组兜底，避免集合无数据等极端场景下再次出现undefined取值报错
• 两个没有先后依赖的查询用Promise.all并行执行，比嵌套回调串行执行的接口响应速度更快

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