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

def merge_data(source_db, source_coll, target_db, target_coll, db_name1, db_name2, coll_name1, coll_name2): # MongoDB连接信息 client = pymongo.MongoClient("mongodb://localhost:27017/") source_db = client[db_name1] target_db = client[db_name2] source_coll = source_db[coll_name1] target_coll = target_db[coll_name2]

source_data = source_coll.find()
for doc in source_data:
    target_coll.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(source_db, source_coll, target_db, target_coll, db_name1, db_name2, coll_name1, coll_name2

用python 写一个处理mongdb数据库将数据库的名称和集合名称都设成变量将代码尽量封装成方法通过调用方法完成以下操作：将数据库名为：客户总表集合名为：4月26 中的所有数据合并到数据库名为：历史总表集合名为：历史客户总表原客户总表不改变历史总表中的文档如果已经包含有客户总表的数据则更新去重处理要求将更新原数据库名称和集合更新后数据库名称和集合都设置成变量方便后期调用修改以下的代码并将修改后

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