MongoDB聚合管道$lookup返回空数组，pymongo两集合关联失败求助

核心错误点 #

你当前$lookup逻辑中最直接的错误是from字段取值错误：你填写的coll并不是要关联的question集合名称，需要替换为你实际存储问题数据的集合名（通常是question）。

其他需要排查的点 #

• 确认paid集合的questionId字段拼写正确，你提供的schema示例中该字段的引号存在语法错误（"questionId: {缺少闭合引号），需确认实际集合中该字段名没有拼写、大小写问题
• 再次验证字段类型：虽然你确认过类型一致，可额外执行代码验证单条数据类型：

from bson.objectid import ObjectId
# 输出应为 <class 'bson.objectid.ObjectId'>
print(type(paid.find_one()['questionId']))

• 确认paid和question两个集合处于同一个数据库下，$lookup默认不支持跨数据库关联
• 确认集合中存在可匹配的数据：你给出的示例中paid的questionId是60aba53d485bfcf514e0bc1d，question的_id是60ab8e0c485bfcf514e0bc18，两条示例数据本身就不匹配，可先找一对确实id一致的数据测试

完整实现需求的聚合管道 #

你需要在$lookup之后新增展开、分组逻辑才能完成用户主题问题数统计，完整代码如下：

pipeline = [
    # 关联question集合
    {
        '$lookup': {
            'from': 'question', # 替换为你实际的question集合名
            'localField': 'questionId',
            'foreignField': '_id',
            'as': 'question_detail'
        }
    },
    # 过滤未匹配到问题的记录，可根据需求保留或删除
    {
        '$match': {'question_detail': {'$ne': []}}
    },
    # 展开关联得到的数组
    {
        '$unwind': '$question_detail'
    },
    # 按userId和topic分组统计数量
    {
        '$group': {
            '_id': {
                'userId': '$userId',
                'topic': '$question_detail.topic'
            },
            'question_count': {'$sum': 1}
        }
    },
    # 格式化输出字段
    {
        '$project': {
            '_id': 0,
            'userId': '$_id.userId',
            'topic': '$_id.topic',
            'count': '$question_count'
        }
    }
]

records = list(paid.aggregate(pipeline))

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