PyMongo实现MongoDB嵌套数组对象更新插入（双层push）

核心更新规则 #

• 目标集合文档外层存在Match_Tasks数组，每个数组元素对应一个任务负责人，结构为{Asignee: 负责人邮箱, "Task_ID's": [该负责人关联的任务ID列表]}
• 每次迭代传入单条Asignee+Task_ID数据时，按以下逻辑更新：
  • 若传入的Asignee已存在于Match_Tasks数组：将当前Task_ID追加到对应元素的"Task_ID's"嵌套数组中
  • 若传入的Asignee不存在：在Match_Tasks数组末尾新增该负责人的完整条目，初始化"Task_ID's"数组并存入当前Task_ID

原写法错误说明 #

你之前尝试的聚合语句存在3个致命问题，导致无法正常运行：

• $push是常规更新操作符，不能直接在$map等聚合表达式内部使用，聚合管道中操作数组需要使用$concatArrays、$mergeObjects这类专用聚合操作符
• 仅用$map遍历原有Match_Tasks元素，完全没有覆盖「Asignee不存在时需要新增外层数组元素」的逻辑分支
• 变量引用混乱：混用Asignee、email变量，且$ID不是MongoDB合法的聚合操作符

可直接运行的PyMongo实现（适配MongoDB 4.2+版本） #

直接使用带聚合管道的update_one方法即可，不需要单独调用聚合接口，支持upsert场景：

from pymongo import MongoClient

# 按实际环境修改数据库连接配置
client = MongoClient("mongodb://localhost:27017/")
db = client["你的业务库名"]
col = db["你的集合名"]

# 每次迭代传入的待更新参数，替换为实际迭代拿到的值
current_asignee = "Mike@gmail.com"
current_task_id = "ObjectID_(1)"

col.update_one(
    # 匹配目标候选人文档
    {"Canditate": "Clark weg"},
    [
        {
            "$set": {
                "Match_Tasks": {
                    "$cond": [
                        # 判断当前负责人是否已经存在于Match_Tasks列表
                        {"$in": [current_asignee, "$Match_Tasks.Asignee"]},
                        # 分支1：负责人已存在，遍历数组给对应项追加任务ID
                        {
                            "$map": {
                                "input": "$Match_Tasks",
                                "as": "task_item",
                                "in": {
                                    "$cond": [
                                        {"$eq": ["$$task_item.Asignee", current_asignee]},
                                        # 匹配到对应负责人，合并原有字段和追加后的任务数组
                                        {
                                            "$mergeObjects": [
                                                "$$task_item",
                                                {
                                                    "Task_ID's": {
                                                        "$concatArrays": [
                                                            "$$task_item.Task_ID's",
                                                            [{"ID": current_task_id}]
                                                        ]
                                                    }
                                                }
                                            ]
                                        },
                                        # 非目标负责人的条目直接原样保留
                                        "$$task_item"
                                    ]
                                }
                            }
                        },
                        # 分支2：负责人不存在，在数组末尾追加新的负责人条目
                        {
                            "$concatArrays": [
                                "$Match_Tasks",
                                [
                                    {
                                        "Asignee": current_asignee,
                                        "Task_ID's": [{"ID": current_task_id}]
                                    }
                                ]
                            ]
                        }
                    ]
                }
            }
        }
    ],
    # 匹配不到对应候选人文档时自动新建，不需要可以删掉
    upsert=True
)

扩展说明 #

• 如果需要避免同一个任务ID重复添加到同一负责人的任务列表中，只要把$concatArrays的返回值套一层$setUnion即可自动去重
• 字段名Task_ID's包含特殊字符，所有引用该字段的位置都需要用字符串引号包裹，和代码中写法保持一致

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