Python操作redis和mongoDB的方法
一、操作redis
redis是一个key-value存储系统,value的类型包括string(字符串),list(链表),set(集合),zset(有序集合),hash(哈希类型)。为了保证效率,数据都是缓冲在内存中,在处理大规模数据读写的场景下运用比较多。
备注:默认redis有16个数据库,即db0~db15,一般存取数据如果不指定库的话,默认都是存在db0中。
resid提供2种连接方式:直接连接、连接池连接
1、直接连接示例:
importredis#pip3installredis
#创建redis连接对象
definit_redis():
redis_config={
"host":"172.29.0.17",
"port":6379
}
globalRedis_Conn
Redis_Conn=redis.Redis(**redis_config)
#Redis_Conn=redis.Redis(host='172.29.0.17',port=6379,db=1)#指定数据库
#插入值,Value为str类型为例
definsert_redis_key_value(key,value):
Redis_Conn.set("name","Zhu")
#获取值,Value为str类型为例
defget_redis_key_value(key):
globalRedis_Conn
print("rediskeyvalue:%s"%Redis_Conn.get(key))
连接池的原理是,通过预先创建多个连接,当进行redis操作时,直接获取已经创建的连接进行操作,而且操作完成后,不会释放,用于后续的其他redis操作,这样就达到了避免频繁的redis连接创建和释放的目的,从而提高性能。
redis模块采用ConnectionPool来管理对redisserver的所有连接。
2、连接池连接示例:
importredis
pool=redis.ConnectionPool(host='172.29.0.17',port=6379,db=1)
red=redis.Redis(connection_pool=pool)
red.set('key1','value1')
red.set('key2','value2')
二、操作mongoDB
1、mongoDB是一个非关系型数据库(NoSQL),介于关系数据库和非关系数据库之间的产品。拥有很多优秀特性,例如高性能、高可用、支持丰富的查询语句、无需预定义数据模型和水平可伸缩等。
2、mongoDB是非关系数据库当中功能最丰富,最像关系数据库的。它支持的数据结构非常松散,是类似json的bson格式,因此可以存储比较复杂的数据类型。
3、mongoDB最大的特点是它支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且还支持对数据建立索引。
4、mongoDB的适用场景为:数据不是特别重要(例如通知,推送)、数据表结构变化较为频繁、数据量特别大、数据的并发性特别高、数据结构比较特别(例如地图的位置坐标),
这些情况下用mongoDB,其他情况就还是用MySQL,这样组合使用就可以达到最大的效率。
importpymongo#pip3installpymongo
#创建mongo连接对象
definit_mongo():
globalMongo_Conn
Mongo_Conn=pymongo.MongoClient(host="172.29.0.14",port=27017)
admin=Mongo_Conn.admin
admin.authenticate('root','')
#数据操作
defget_mongo_key_value(token_id):
db=Mongo_Conn['device_center']#创建数据库"device_center",命名为"db"
col=db['token_info']#创建集合"token_info",命名为"col"
mydict={"name":"Zhuyu","alexa":"160","sex":"male"}
col.insert_one(mydict)#插入一条数据
mylist=[
{"name":"ating","alexa":"168","sex":"male"},
{"name":"Liang","alexa":"165","sex":"female"},
{"name":"Libai","alexa":"156","sex":"female"}
]
col.insert_one(mylist)#插入一组数据
query1=col.find_one()#查询一条数据
query2=col.find({},{"alexa":1})#查询指定字段的数据
query3=col.find()#查询集合中的所有数据
query4=col.find({"name":"ating"})#根据指定条件查询
myquery1={"alexa":"160"}
newvalues1={"$set":{"alexa":"161"}}
col.update_one(myquery1,newvalues1)#修改匹配到的第一条记录
myquery2={"name":{"$regex":"^L"}}
newvalues2={"$set":{"alexa":"123"}}
col.update_many(myquery2,newvalues2)#修改所有匹配到的记录,将查找所有以L开头的name字段,并将匹配到所有记录的alexa字段修改为123
query5=col.find().sort("alexa")#sort()方法第一个参数为要排序的字段,第二个字段指定排序规则,1为升序,-1为降序,默认为升序
forxinquery5:
print(x)
#结果
{"name":"Libai","alexa":"156","sex":"female"}
{"name":"Zhuyu","alexa":"160","sex":"male"}
{"name":"Liang","alexa":"165","sex":"female"}
{"name":"ating","alexa":"168","sex":"male"}
query6=col.find().sort("alexa",-1)#降序
forxinquery6:
print(x)
#结果
{"name":"ating","alexa":"168","sex":"male"}
{"name":"Liang","alexa":"165","sex":"female"}
{"name":"Zhuyu","alexa":"160","sex":"male"}
{"name":"Libai","alexa":"156","sex":"female"}
myquery3={"name":"Libai"}#删除一条数据
mycol.delete_one(myquery3)
myquery4={"name":{"$regex":"^L"}}#删除多个数据
x1=mycol.delete_many(myquery4)
print(x1.deleted_count,"个文档已删除")#2个文档已删除
x2=mycol.delete_many({})#删除集合中的所有数据
print(x2.deleted_count,"个文档已删除")#4个文档已删除
#断开mongo连接
defdisconnect_mongo():
Mongo_Conn.disconnect()
总结
以上所述是小编给大家介绍的Python操作redis和mongoDB的方法,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。