FastAPI中PyMongo聚合$lookup返回空值及响应为空问题

问题1：关联后user字段为空数组 #

这是关联匹配条件未命中导致的，核心排查方向：

• 数据类型不匹配：检查group集合的usersId字段类型，是否和user集合的_id一致。比如usersId存的是字符串，但user._id是ObjectID，会直接匹配失败，需将usersId转为ObjectID后再查询，或在$lookup中处理类型兼容。
• 字段对应错误：确认group中存储用户ID的字段确实是usersId，且user集合的主键为_id。
• usersId为数组的适配：如果group的usersId是数组类型，默认$lookup会用整个数组去匹配user._id（单个值），自然匹配不到。需改用带管道的$lookup实现数组匹配：

{
    "$lookup": {
        "from": "user",
        "let": { "user_ids": "$usersId" },
        "pipeline": [
            { "$match": { "$expr": { "$in": ["$_id", "$$user_ids"] } } },
            { "$project": { "name": 1, "_id": 0 } }
        ],
        "as": "user"
    }
}

问题2：Postman返回空数组[] #

这是聚合游标被重复遍历导致的：MongoDB聚合查询返回的游标只能被消费一次，你先执行list(query)打印数据时已经耗尽了游标，后续再次调用list(query)自然返回空数组。

解决方法：提前将聚合结果存入变量，再重复使用：

# 一次性获取结果并存储
result = list(query)
print(json.dumps(result, default=str))

return JSONResponse(
    status_code=200,
    content=result
)

完整修正代码示例 #

query = group.collection.aggregate([
    { '$match':  {"usersId": {"$in": [ ObjectID('some id') ] }} },
    {
        "$lookup": {
            "from": "user",
            "let": { "user_ids": "$usersId" },
            "pipeline": [
                { "$match": { "$expr": { "$in": ["$_id", "$$user_ids"] } } },
                { "$project": { "name": 1, "_id": 0 } }
            ],
            "as": "user"
        }
    },
    {
        '$project': {
            '_id': 0,
            'createdAt': 1,
            'updatedAt': 1,
            'user': 1
        }
    }
])

result = list(query)
print(json.dumps(result, default=str))

return JSONResponse(
    status_code=200,
    content=result
)

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