首页 / PYTHON / python 对mongodb进行压力测试

python 对mongodb进行压力测试

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了python 对mongodb进行压力测试，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1375字，纯文字阅读大概需要2分钟。

内容图文

from pymongo import Connection,MongoClient,MongoReplicaSetClient import multiprocessing import time #connection = MongoClient(‘mongodb://10.120.11.212:27017/‘) #connection = Connection([‘10.120.11.122‘,‘10.120.11.221‘,‘10.120.11.212‘], 27017) ‘‘‘数据库采用了读写分离设置，连接mongoDB的模式要配对‘‘‘ connection=MongoReplicaSetClient( ‘10.120.11.122:27017,10.120.11.221:27017,10.120.11.212:27017‘, replicaSet=‘rs0‘, read_preference=3 # read_preference=3 ) db = connection[‘cms‘] db.authenticate(‘cms‘, ‘cms‘) #计时器 def func_time(func): def _wrapper(*args,**kwargs): start = time.time() func(*args,**kwargs) print func.__name__,‘run:‘,time.time()-start return _wrapper #插入测试方法 def insert(num): posts = db.userinfo for x in range(num): post = {"_id" : str(x), "author": str(x), "text": "My first blog post!" } 　　　　 posts.insert(post) #查询测试方法 def query(num): get=db.device for i in xrange(num): get.find_one({"scanid":"010000138101010000009aaaaa"}) @func_time def main(process_num,num): pool = multiprocessing.Pool(processes=process_num) for i in xrange(num): pool.apply_async(query, (num, )) pool.close() pool.join() print "Sub-process(es) done." if __name__ == "__main__": # query(500,1) main(800,500)

原文发表于http://www.cnblogs.com/reach296/

python 对mongodb进行压力测试

标签：

本文系统来源：http://www.cnblogs.com/clarke/p/5965756.html

内容总结

以上是互联网集市为您收集整理的python 对mongodb进行压力测试全部内容，希望文章能够帮你解决python 对mongodb进行压力测试所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/471351.html

来源：【匿名】