使用PyMongo复制MongoDB集合进行备份无效果问题及免费替代方案咨询

首先，你遇到的问题很可能是因为pymongo的聚合游标是惰性执行的——你调用aggregate()后只是得到了一个游标对象，但并没有实际触发执行操作！解决这个问题最简单的办法就是迭代这个游标，比如转成列表：

cursor = db.coll.aggregate(pipeline)
# 触发聚合执行
list(cursor)

执行完之后再去MongoDB Atlas刷新看看，应该就能看到coll_backup集合了。

如果这个方法还是不生效（比如Atlas M0免费集群的资源限制导致操作被中断），这里还有几个免费的替代方案供你选择：

1. 用$merge替代$out #

$merge比$out更灵活，在资源有限的环境下可能更稳定，同样支持同库复制：

pipeline = [
    {"$match": {}},
    {"$merge": {
        "into": "coll_backup",
        "whenMatched": "replace",  # 如果有重复文档的处理方式
        "whenNotMatched": "insert"
    }}
]
# 同样需要迭代游标触发执行
list(db.coll.aggregate(pipeline))

2. 使用MongoDB官方的mongodump/mongorestore工具 #

这是最可靠的免费备份恢复工具，适合各种规模的集合：

• 先导出原集合：

mongodump --uri "mongodb+srv://{user}:{password}@cluster0.n2hnd.mongodb.net/test" --collection coll --out ./local_backup

• 再导入为备份集合：

mongorestore --uri "mongodb+srv://{user}:{password}@cluster0.n2hnd.mongodb.net/test" --collection coll_backup ./local_backup/test/coll.bson

注意替换命令里的{user}和{password}为你的实际账号密码。

3. 手动批量复制（适合小集合） #

如果你的集合数据量不大，直接查询所有文档再插入到新集合是最直观的方法：

# 小集合直接全量查询插入
docs = list(db.coll.find({}))
if docs:
    db.coll_backup.insert_many(docs)

如果是大集合，建议分批处理避免内存占用过高：

batch_size = 1000
cursor = db.coll.find({}, batch_size=batch_size)
while True:
    batch = list(cursor.next_batch(batch_size))
    if not batch:
        break
    db.coll_backup.insert_many(batch)

内容的提问来源于stack exchange，提问作者Revolucion for Monica