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

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_coll = source_db[source_coll_name] target_coll = target_db[target_coll_name]

source_data = source_coll.find()
for doc in source_data:
    target_coll.update_one(
        {'_id': doc['_id']},
        {'$set': doc},
        upsert=True
    )

调用方法：将客户总表4月26合并到历史总表历史客户总表中

merge_data('客户总表', '4月26', '历史总表', '历史客户总表'

修改以下的方法# MongoDB连接信息client = pymongoMongoClientmongodblocalhost27017db1 = clientdb_name1db2 = clientdb_name2coll1 = db1coll_name1coll2 = db2coll_name2封闭到方法中去在main中调用方法请修改import pymongo# 定义数据库名称和集合名称变量

原文地址: https://www.cveoy.top/t/topic/d51I 著作权归作者所有。请勿转载和采集!