Node.js MongoDB驱动aggregate的$lookup查询未返回预期结果怎么办

问题核心原因 #

你编写的$lookup聚合管道逻辑本身没有错误，问题出在MongoDB Node.js驱动的调用方法上：

• db.collection.aggregate() 方法默认返回的是AggregationCursor游标对象，你打印的大体积对象就是游标本身，并非实际的查询结果集。
• 你用async声明了异步函数，但没有加await等待查询执行、拉取结果，游标不会自动解析为最终数据。

修正后的代码 #

你只需要在聚合调用后追加.toArray()方法，同时加上await等待异步执行完成，就能拿到最终的用户+角色填充数据：

dbManager.aggregate = async () => {
    // await等待异步执行，toArray()将游标转换为实际结果数组
    const userList = await dbInstance.collection('users').aggregate(
        [
            {
                $lookup:
                {
                    from: 'roles',
                    localField: 'roles',
                    foreignField: '_id',
                    as: 'user_roles'
                }
            }
        ]
    ).toArray()
    console.log('填充后的用户数据：', userList)
    return userList
}

得到的userList数组中每个元素都会携带user_roles字段，存储对应当前用户的角色完整文档。

其他可选的游标处理方式 #

如果你需要逐条处理查询结果，也可以通过游标自带的方法遍历：

const cursor = dbInstance.collection('users').aggregate([
  // 你的聚合管道逻辑
])
// 遍历游标逐条处理数据
while (await cursor.hasNext()) {
  const singleUser = await cursor.next()
  // 处理单个用户数据
}

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