在pymongo中聚合两个集合并更新第一个集合中的文档

from pymongo import MongoClient

# 连接MongoDB数据库
client = MongoClient('mongodb://localhost:27017/')
db = client['your_database']  # 替换为你的数据库名
collection1 = db['collection1']  # 替换为你的第一个集合名
collection2 = db['collection2']  # 替换为你的第二个集合名

# 聚合操作，合并两个集合并更新第一个集合中的文档
pipeline = [
    {
        '$lookup': {
            'from': 'collection2',  # 第二个集合名
            'localField': 'common_field',  # 第一个集合中用于关联的字段
            'foreignField': 'common_field',  # 第二个集合中用于关联的字段
            'as': 'merged_docs'  # 合并后的文档存放的字段名
        }
    },
    {
        '$out': 'collection1'  # 更新第一个集合中的文档
    }
]

db.command('aggregate', 'collection1', pipeline=pipeline)

# 关闭数据库连接
client.close()