下面看看Python模块对Redis数据库的毗连与使用:
1.Python毗连Redis数据库方法:
- import redis
-
- res = redis.Redis(
- host="127.0.0.1",
- port=6379,
- db=0,
- password="XXXXXX",
- decode_responses=True
- )
- res.set("name","Li")
-
- print(res.get("name"))
复制代码
redis.Redis()参数解说:
1.host:表示毗连的主机的iP所在。
2.port:表示毗连的端口。
3.db:表示使用的数据库的标号。
4.password:表示毗连的数据库的密码。没有不添加该参数即可。
5.decode_responses:我们从redis数据库中取出的数据默以为字节范例,加上该参数则将取出的数据默以为字符串范例。
2.Python使用毗连池毗连Redis数据库:- import redis
-
- connection = redis.ConnectionPool(
- host="127.0.0.1",
- port=6379,
- password="XXXXXX",
- decode_responses=True
- )
- res = redis.StrictRedis(connection_pool=connection)
- res.set("name","666")
-
- print(res.get("name"))
复制代码
这里使用毗连池的作用可以镌汰中心斲丧的时间,当我们这里用完这个毗连后将他再次放回毗连池中,别的实例使用可以直接使用而不需要重新毗连数据库,如许就大幅度的镌汰了的中心斲丧的时间。
毗连成功后,下面就是使用Python对redis数据库的操纵:
对字符串(String)内部的操纵:
1.res.set()函数:
- res.set("name","666",ex=m,px=n,nx=True,xx=True)
复制代码
这里后四个参数中,ex与px不能共存,nx与xx也不能共存。
ex,px表示数据逾期时间,ex是以秒作为单位,px是以毫秒作为单位。当数据逾期时键仍旧存在,值变为None。
nx与xx表示数据插入数据库的键的状态,nx(新建)为True表示当键不存在时set操纵的返回值为True,且新建数据;而xx(修改)为True表示在键存在时set操纵返回值为True,且修改数据。否则上述操纵返回None。
**故上述操纵衍生出的新函数:res.setex(“键”,逾期时间(秒),“值”) **
res.setnx(“键”,“值”) 键不存在,返回True并新建。
res.psetex(“键”,逾期时间(毫秒),“值”)
res.mset({“键”:“值”,…}) 批量添加键-值数据。
res.mset(“键”,“键”,…) 批量增加键数据。
res.getset(“键”,“值”) 修改为新值并返回原值。
2.res.strlen(“键”) 返回键对应的值的字节长度。
3.res.incr(“键”,amount=自增的步长) 不存在则创建,否则自增。
res.decr(“键”,amount=自减的步长) 不存在则创建,否则自减。
res.incrbyfloat(“键”,amount=自增的步长(浮点型))
4.res.append(“键”,“值”) 将值追加在键对应的值 的 原始字符串后边。
对哈希表(Hash)内部的操纵:
1.单个增加:res.hset(“Hash表名”,“键”,“值”)
2.批量增加:res.hmset(“Hash表名”,{“键值对”…})
3.单个取出:res.hget(“Hash表名”,“键”)
4.多个取出:res.hmget(“Hash表名”,“键”,“键”,…)
5.只能新建的方法:res.hsetnx(“Hash表名”,“键”,“值”) 当没有时才起新建得作用。
6.取出hash中的全部键值对:res.hgetall(“Hash表名”)
7.得到hash中的hash长度(即hash中的键值对个数):res.hlen(“Hash表名”)
8.得到hash中的全部的键:res.hkeys(“Hash表名”)
得到hash中的全部的值:res.hvals(“Hash表名”)
9.判断hash中是否存在该成员:res.hexists(“Hash表名”,“键”)
10.删除hash中的键值对:hdel(“Hash表名”,“键”)
对列表(List)内部的操纵:
1.列表的添加操纵: 从左向右添加: res.lpush(“List表名”,“值”,…)
从右向左添加:res.rpush(“List列表”,“值”,…)
这两种方式如果没有该列表就创建,res.l/rpushx()如果没有不创建,且不插入
2.向固定的索引号位置插入元素:res.linsert(“表名”,“位置”,“将需要插入的元素插入到 ‘该元素' 之前的索引位置(m)”,“被插入的元素(n)”)
比方:res.linsert(“list2”, “before”, “11”, “00”) 往列表中左边第一个出现的“m”元素前插入元素"n"。
3.修改(指定索引号进行修改):res.lset(“表名”, index, “值”)
4.删除指定索引的值:res.lrem(“表名”, “值”,矢量删除数(正左负右0全部))
5.res.l/rpop(“表名”),移除表中的左/右边的第一个数据并将值返回。
6.取值:res.lindex(“表名”,index)
对集合(Set)内部的操纵:
1.增加数据:res.sadd(“集合名”,“值”)
2.获取集合的全部成员:res.smembers(“集合名”)
3.获取集合内的数据数目:res.scard(“集合名”)
4.以元组格式获取集合的全部成员:res.sscan(“集合名”)
5.判断值是不是集合的成员:res.sismember(“集合名”,“值”)
6.删除指定的值:res.srem(“集合名”,“值”)
对集合,列表,字符串,哈希的操纵:
1.删除:res.delete(“键”) 删除该键的数据,不受表范例的束缚。
2.检查名字是否存在:exists(“表名”)
3.暗昧匹配:- KEYS * 匹配数据库中所有 key 。
- KEYS h?llo 匹配 hello , hallo 和 hxllo 等。
- KEYS hllo 匹配 hllo 和 heeeeello 等。
- KEYS h[ae]llo 匹配 hello 和 hallo ,但不匹配 hillo
-
- 上述为终端命令,下面是Python语法:
-
- res.keys() 匹配数据库中所有 key 。
- res.keys("h?llo") 匹配 hello , hallo 和 hxllo 等。
- res.keys("hllo") 匹配 hllo 和 heeeeello 等。
- res.keys("h[ae]llo") 匹配 hello 和 hallo ,但不匹配 hillo
复制代码
4.表级重定名:res.rename(“原名”,“新名”)
5.获取表级的范例:res.type(“表名”)
6.查察全部元素:res.scan(“表名”)
7.查察全部元素并天生迭代器:res.scan_iter(“表名”)
8.获取值:res.get(“键”)
9.查察当前数据库中包罗多少条数据:res.dbsize()
10.将数据写回磁盘,生存时壅闭:res.save()
11.清空数据库的全部数据:res.flushdb()
管道(pipeline):
redis默认在实行每次请求都会创建(毗连池申请毗连)和断开(归还毗连池)一次毗连操纵,如果想要在一次请求中指定多个下令,则可以使用pipline实现一次请求指定多个下令,而且默认情况下一次pipline 是原子性操纵。
管道(pipeline)是redis在提供单个请求中缓冲多条服务器下令的基类的子类。它通过镌汰服务器-客户端之间反复的TCP数据库包,从而大大进步了实行批量下令的功能。
管道操纵:- pipe = res.pipeline() # 创建一个管道
-
- pipe.set('name', 123)
- pipe.set('role', 456)
- pipe.incr('num') # 如果num不存在则vaule为1,如果存在,则value自增1。
- pipe.execute() # 无论多少操作最后都需要提交,类似于MySQL的事务。
复制代码
上述代码可以简化为:- pipe = res.pipeline() # 创建一个管道
-
- pipe.set('name', 123).set('role', 456).incr('num').execute()
复制代码
到此这篇关于Python模块对Redis数据库的毗连与使用的文章就介绍到这了,更多干系Python Redis毗连与使用内容请搜刮脚本之家从前的文章或继续欣赏下面的干系文章希望各人以后多多支持脚本之家! |