pymongo insert_many 批量插入的实例
作者:luoganttcc 时间:2023-05-30 04:27:43
我就废话不多说了,大家还是直接看代码吧~
lt=client.fangjia.district_stat_all_0416
dl = dt.find(query)
bf=[]
for m in dl:
bf.append(m)
if len(bf)==20000:
lt.insert_many(bf)
bf=[]
lt.insert_many(bf)
补充知识:Python操作Mongodb插入数据的两种方法:insert_one()与insert_many()
代码说明:
将mysql中table的数据插入到mongodb里
sys.setdefaultencoding('utf8')
import web
from pymongo import MongoClient
class getPltfList(object):
def __init__(self):
self.db1 = web.database(dbn='mysql', db = 'episode', user = 'root', pw= 'abc111--', host = '127.0.0.1')
self.db1.printing = False
self.db2 = web.database(dbn='mysql', db = 'episode_soc', user = 'root', pw= 'abc111--', host = '127.0.0.1')
self.db2.printing = False
self.db3 = web.database(dbn='mysql', db = 'cl_episode', user = 'root', pw= 'abc111--', host = '127.0.0.1')
self.db3.printing = False
self.db4 = web.database(dbn='mysql', db = 'cl_episode_soc', user = 'root', pw= 'abc111--', host = '127.0.0.1')
self.db4.printing = False
def __call__(self):
return self.createPltfList()
def createPltfList(self):
self.ckpltfList = list(self.db1.query('select name, ip from EPISODE_PLTF_INFO order by id DESC'))
self.ckpltfList += list(self.db2.query('select name, ip from EPISODE_PLTF_INFO order by id DESC'))
self.clpltfList = list(self.db3.query('select name, ip from EPISODE_PLTF_INFO order by id DESC'))
self.clpltfList += list(self.db4.query('select name, ip from EPISODE_PLTF_INFO order by id DESC'))
return self.ckpltfList,self.clpltfList
if __name__ == '__main__' :
mpList = list()
flag = 0
tmp = 0
sum1 = 0
sum2 = 0
pltfList = getPltfList()()
client = MongoClient("127.0.0.1", 27017)
mdb = client.episode
collection = mdb.pltf_basic_info
# print (type(pltfList[1])) #list
result= list()
for pltf_my in pltfList[0]:
pltf_mog = collection.find()
for record in pltf_mog:
IP = record.get('Cfg').get('Debug_IP')
Name = record.get('Cfg').get('Register_Name')
# print IP, Name
if IP == pltf_my['ip'] and Name == pltf_my['name'] :
flag = 1
# print IP, Name
break
else:
flag = 0
if flag == 0 :
data1 = {"Cfg" : {"Debug_IP" : pltf_my['ip'],"Register_Name":pltf_my['name'], "Site":"SH-CK"} }
# print data1
result.append((data1))
# collection.insert_one(data1)
# collection.delete_one(data)
sum1 = sum1+1
# print len(result)
# collection.insert_many(result)
for pltf_my in pltfList[1]:
pltf_mog = collection.find()
for record in pltf_mog:
IP = record.get('Cfg').get('Debug_IP')
Name = record.get('Cfg').get('Register_Name')
if pltf_my['ip'].encode("utf-8") == IP.encode("utf-8") and pltf_my['name'].encode("utf-8") == Name.encode("utf-8") :
tmp = 1
# print IP, Name
break
else:
tmp = 0
if tmp == 0 :
data2 = {"Cfg" : {"Debug_IP":pltf_my['ip'],"Register_Name":pltf_my['name'], "Site":"SH-CL"} }
# print data2
result.append((data2))
# collection.insert_one(data2)
# collection.delete_one(data)
sum2 = sum2+1
collection.insert_many(result)
print sum1,sum2
刚开始的时候我使用的是insert_one()方法,一条一条的插入到mongodb的集合里,但是计算出的sum有出入。
在调试的过程中我发现:
注释掉 # collection.insert_one(data1) # collection.insert_one(data2)
计算出来的sum1 = 193 sum2 = 222 这是合理的,因为ck_mysql里有193条记录,cl_mysql里有234条记录,mongod里有总共有15条,但是12条是与cl_mysql重复,所以正确。
但是当我去掉注释使用 collection.insert_one(data1) collection.insert_one(data2)时,打印出的sum1=181 sum2 = 213
也就是说少了几个数据,我不知道去哪了。
想了好多办法,于是采用insert_many()的方法插入。先定义一个list(),将每个数据(数据的类型是dict)追加到list里:reslult.append(data1/data2),最后result里就会含有所有的数据,一起插入。
于是乎,问题解决了。
可是我还是很困惑insert_one()哪里出问题了!!!!!!
来源:https://blog.csdn.net/luoganttcc/article/details/79962006
标签:pymongo,insert,many,插入
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
SQLserver 2005文件和文件组的作用说明
2024-01-26 09:45:57
SQL SERVER数据库开发之触发器的应用
2008-06-23 13:09:00
你凭什么说你的网站用户体验好
2011-03-31 17:08:00
深入理解python中函数传递参数是值传递还是引用传递
2022-02-21 10:08:33
flask中过滤器的使用详解
2023-03-01 16:00:55
BootStrap的alert提示框的关闭后再显示怎么解决
2024-04-28 09:50:24
Python使用Requests请求网页方式
2022-10-08 06:01:09
Mysql WorkBench安装配置图文教程
2024-01-20 00:53:14
![](https://img.aspxhome.com/file/2023/7/101367_0s.png)
两大步骤教您开启MySQL 数据库远程登陆帐号的方法
2024-01-16 10:01:35
Python实现向好友发送微信消息优化篇
2022-02-18 18:07:08
![](https://img.aspxhome.com/file/2023/7/135087_0s.png)
找到个很好的例子导出excel的
2008-09-28 13:12:00
Python类中__init__() 和self的详细解析
2021-04-22 22:05:06
![](https://img.aspxhome.com/file/2023/7/82647_0s.png)
Python实现轻松切割MP3文件
2023-09-23 21:40:32
![](https://img.aspxhome.com/file/2023/5/62605_0s.png)
Python3.6正式版新特性预览
2023-11-02 09:27:09
解决Python3中二叉树前序遍历的迭代问题
2022-04-11 09:05:24
![](https://img.aspxhome.com/file/2023/8/103308_0s.png)
Python约瑟夫生者死者小游戏实例讲解
2023-02-12 02:14:25
vue2.0+vue-dplayer实现hls播放的示例
2024-05-29 22:46:56
![](https://img.aspxhome.com/file/2023/2/123002_0s.png)
Python基础数据类型tuple元组的概念与用法
2022-11-25 03:59:16
不同分辨率下的自适用宽度
2008-11-24 12:58:00
![](https://img.aspxhome.com/file/UploadPic/200811/24/2008112413340367s.jpg)
小小聊天室Python代码实现
2022-05-27 15:23:44