你应该将# MongoDB连接信息client = pymongoMongoClientmongodblocalhost27017db1 = clientdb_name1db2 = clientdb_name2coll1 = db1coll_name1coll2 = db2coll_name2封闭到方法中然后if __name__ == __main__ # 定义数据库名称和集合名称变量
def merge_data(db1, coll_name1, db2, coll_name2): coll1 = db1[coll_name1] coll2 = db2[coll_name2] for doc in coll1.find(): coll2.insert_one(doc)
if name == 'main': # 定义数据库名称和集合名称变量 db_name1 = '客户总表' coll_name1 = '4月26' db_name2 = '历史总表' coll_name2 = '历史客户总表' # 连接MongoDB数据库 client = pymongo.MongoClient("mongodb://localhost:27017/") db1 = client[db_name1] db2 = client[db_name2] # 调用方法:将客户总表4月26合并到历史总表历史客户总表中 merge_data(db1, coll_name1, db2, coll_name2
原文地址: https://www.cveoy.top/t/topic/d50O 著作权归作者所有。请勿转载和采集!