PyMongo aggregate聚合查询如何传入外部自定义变量

你遇到的「名称未定义」错误来自3个层面的语法问题，和MongoDB传参逻辑无关：

• Python变量定义不合法：elements_list = "key1": "$abc.Key1", "Key2":"$abc.Key2" 不符合Python字典语法，没有用大括号包裹键值对，本身就会触发语法错误
• 聚合管道语法错误：操作符漏写$前缀（比如把$gt写成gt）、字段引用漏写$前缀（$unwind、$objectToArray的参数必须是带$的字段路径）、阶段名大小写错误（$addfields应为驼峰格式的$addFields）
• 字典构造逻辑错误：在Python字典字面量里直接写变量名elements_list不会自动展开变量内容，只会被识别成不存在的键名，触发名称未定义报错

所有可变参数全部抽离到管道外定义，后续修改场景只需要调整最上方的参数块即可，不需要动聚合逻辑：

from pymongo import MongoClient

# 建立数据库连接（按你的实际环境改连接串即可）
client = MongoClient("mongodb://localhost:27017/")
db = client["your_db_name"]

# --------------------------
# 可自定义参数块，后续适配场景仅修改这部分即可
# --------------------------
Parent_Key = "abc"
# 投影字段映射：key为返回结果的字段名，value为对应源字段路径
elements_list = {
    "key1": f"${Parent_Key}.Key1",
    "Key2": f"${Parent_Key}.Key2"
}

# 构造聚合管道
pipeline = [
    # $unwind 要求传入带$前缀的字段路径，用f-string拼接变量
    {"$unwind": f"${Parent_Key}"},
    {"$addFields": {
        "abcrecordexists": {
            "$gt": [
                # $objectToArray同样需要带$前缀的字段路径
                {"$size": {"$objectToArray": f"${Parent_Key}"}},
                0
            ]
        }
    }},
    {"$match": {"abcrecordexists": {"$gt": 0}}},
    {"$project": {
        "_id": 1,
        # 用**字典解包，把elements_list的所有键值对合并到投影规则里
        **elements_list
    }}
]

# 执行聚合查询
query_result = list(db.test.aggregate(pipeline))

• 所有MongoDB聚合操作符、聚合阶段名必须以$开头，且严格区分大小写
• 所有对文档字段的引用必须加$前缀：顶级字段写$字段名，嵌套字段写$父字段.子字段
• Python中合并字典键值对不要直接在字面量里写变量名，用**字典名的解包语法实现
• 如果需要新增/修改投影字段，只需要修改elements_list字典的键值对即可，不需要调整管道其他部分

内容的提问来源于stack exchange，提问作者Sunny.K