import pymongo

定义方法：将指定数据库集合中的所有数据合并到目标数据库集合中

def merge_data(source_db_name, source_coll_name, target_db_name, target_coll_name): # MongoDB连接信息 client = pymongo.MongoClient("mongodb://localhost:27017/") source_db = client[source_db_name] target_db = client[target_db_name]

source_data = source_db[source_coll_name].find()
for doc in source_data:
    target_db[target_coll_name].update_one(
        {'_id': doc['_id']},
        {'$set': doc},
        upsert=True
    )

if name == 'main': # 定义数据库名称和集合名称变量 db_name1 = '客户总表' coll_name1 = '4月26' db_name2 = '历史总表' coll_name2 = '历史客户总表' # 调用方法：将客户总表4月26合并到历史总表历史客户总表中 merge_data(db_name1, coll_name1, db_name2, coll_name2