MongoDB多集合链式Lookup问题：3个集合关联合并求助

你完全不需要分两次执行聚合操作，其实可以通过**链式$lookup**在单个聚合管道里完成所有关联，直接得到你想要的嵌套文档结构，这样比处理两个游标再合并高效得多。

完整聚合管道示例（Pymongo） #

from pymongo import MongoClient

client = MongoClient()
db = client.your_database_name  # 替换成你的实际数据库名

result = db.agreements.aggregate([
    # 第一步：关联agreement_conditions集合
    {
        "$lookup": {
            "from": "agreement_conditions",
            "localField": "condition",
            "foreignField": "_id",
            "as": "condition"
        }
    },
    # 每个agreement仅对应一个condition，展开数组为单个对象
    {
        "$unwind": "$condition"
    },
    # 第二步：关联agreement_intervals集合，基于condition中的interval字段
    {
        "$lookup": {
            "from": "agreement_intervals",
            "localField": "condition.interval",
            "foreignField": "_id",
            "as": "condition.interval"
        }
    },
    # 展开interval数组（单个元素）
    {
        "$unwind": "$condition.interval"
    },
    # 调整interval结构，仅保留name字段（匹配你期望的格式）
    {
        "$addFields": {
            "condition.interval": {
                "name": "$condition.interval.name"
            }
        }
    },
    # 可选：移除agreement_conditions中不需要的__v字段
    {
        "$project": {
            "condition.__v": 0
        }
    }
])

# 遍历结果即可得到目标文档
for doc in result:
    print(doc)

代码步骤解释 #

1. 第一个$lookup：将agreements的condition字段（ObjectId）与agreement_conditions的_id关联，结果存入condition数组。
2. $unwind：因为每个协议只会对应一个条件，所以把数组展开为单个对象，方便后续嵌套关联。
3. 第二个$lookup：基于condition.interval字段（ObjectId）关联agreement_intervals的_id，结果存入condition.interval数组。
4. 第二次$unwind：展开interval数组，得到单个interval对象。
5. $addFields：将interval对象替换为仅包含name的嵌套结构，完全匹配你想要的输出格式。
6. $project：按需移除agreement_conditions中的__v冗余字段。

如果必须处理两个游标（不推荐） #

如果因为特殊场景需要分两次聚合，你可以把第一个游标转为列表，再手动遍历匹配interval数据：

# 第一次聚合：agreements关联agreement_conditions
cursor1 = db.agreements.aggregate([
    {"$lookup": {"from": "agreement_conditions", "localField": "condition", "foreignField": "_id", "as": "condition"}},
    {"$unwind": "$condition"}
])
agreement_list = list(cursor1)

# 遍历文档，手动关联interval数据
for doc in agreement_list:
    interval_id = doc["condition"]["interval"]
    # 查询对应的interval，仅返回name字段
    interval = db.agreement_intervals.find_one({"_id": interval_id}, {"_id": 0, "name": 1})
    doc["condition"]["interval"] = interval

# 此时agreement_list就是你需要的合并文档
print(agreement_list)

这种方法效率远低于单次聚合，数据量大时会有明显性能问题，不建议使用。

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