如何在MongoDB及PyMongo中替换数组内字符串的指定内容

针对你的需求，有两种可行方案，并非只能遍历每个文档，但遍历是兼容性最好的选择：

方案一：客户端遍历+逐个更新（兼容所有CosmosDB API版本） #

这是最稳妥的方式，适合所有环境，尤其是不确定CosmosDB是否支持高级聚合操作的情况。通过PyMongo查询所有包含Comments数组的文档，在客户端处理字符串后更新回数据库：

from pymongo import MongoClient

# 替换为你的CosmosDB连接字符串
client = MongoClient("mongodb://<username>:<password>@<account-name>.mongo.cosmos.azure.com:10255/?ssl=true&replicaSet=globaldb&retrywrites=false&maxIdleTimeMS=120000&appName=@<account-name>@")
db = client["你的数据库名"]
coll = db["你的集合名"]

# 遍历所有包含Comments数组的文档
for doc in coll.find({"Comments": {"$exists": True, "$type": "array"}}):
    # 移除每个评论中的方括号
    updated_comments = [comment.replace("[", "").replace("]", "") for comment in doc["Comments"]]
    # 更新当前文档的Comments字段
    coll.update_one(
        {"_id": doc["_id"]},
        {"$set": {"Comments": updated_comments}}
    )

方案二：数据库端聚合更新（需CosmosDB API for MongoDB 4.2+支持） #

如果你的CosmosDB实例支持MongoDB 4.2及以上版本，可以直接用聚合管道配合update_many，在数据库端完成字符串替换，无需客户端遍历，效率更高：

from pymongo import MongoClient

client = MongoClient("你的连接字符串")
db = client["你的数据库名"]
coll = db["你的集合名"]

# 使用聚合管道批量更新
coll.update_many(
    {"Comments": {"$exists": True, "$type": "array"}},
    [
        {
            "$set": {
                "Comments": {
                    "$map": {
                        "input": "$Comments",
                        "as": "comment",
                        "in": {
                            # 先替换左方括号，再替换右方括号
                            "$replaceAll": {
                                "input": {"$replaceAll": {"input": "$$comment", "find": "[", "replacement": ""}},
                                "find": "]",
                                "replacement": ""
                            }
                        }
                    }
                }
            }
        }
    ]
)

注意事项 #

• findAndModify确实仅能处理单个文档，不适合批量更新场景，无需考虑。
• 方案二需要确认你的CosmosDB API for MongoDB版本是否支持$replaceAll和聚合管道更新操作，若版本较低，方案一为必选。

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