Python对Redis操作
阅读 (216161)
分享
一、连接Redis数据库
作用:redis模块用于调用操作redis,而redis是一个基于内存的高性能key-value的存储系统,支持存储的类型有string、list、set、zset和hash。在处理大规模数据读写或高效的缓存的场景下运用比较多
安装:pip install redis
说明:redis模块中允许两种连接方式直接连接和连接池连接
直接连接
-
使用默认方式连接到数据库
import redis try: r = redis.StrictRedis(host="8.8.8.8", port=6379, password="zutuanxue_com", db=0) except: print("连接Redis失败")
-
使用url方式连接到数据库
格式 说明 redis://[:password]@host:port/db
TCP连接 rediss://[:password]@host:port/db
Redis TCP+SSL 连接 unix://[:password]@/path/to/socket.sock?db=db
Redis Unix Socket 连接 import redis try: r = redis.StrictRedis.from_url('redis://:zutuanxue_com@8.8.8.8:6379/0') except: print("连接Redis失败")
连接池连接
连接池的原理是,通过预先创建多个连接, 当进行redis操作时,直接获取已经创建的连接进行操作,而且操作完成后,不会释放,用于后续的其他redis操作,这样就达到了避免频繁的redis连接创建和释放的目的,从而提高性能。redis模块采用ConnectionPool来管理对redis server的所有连接
-
使用默认方式连接到数据库
import redis pool = redis.ConnectionPool(host='8.8.8.8', port=6379, password="zutuanxue_com", db=0) try: r = redis.StrictRedis(connection_pool=pool) except: print("连接Redis失败")
-
使用url方式连接到数据库
格式 说明 redis://[:password]@host:port/db
TCP连接 rediss://[:password]@host:port/db
Redis TCP+SSL 连接 unix://[:password]@/path/to/socket.sock?db=db
Redis Unix Socket 连接 import redis pool = redis.ConnectionPool.from_url('redis://:zutuanxue_com@8.8.8.8:6379/0') try: r = redis.StrictRedis(connection_pool=pool) except: print("连接Redis失败")
二、数据操作
根据数据类型的不同,调用相应的方法,完成读写
import redis
pool = redis.ConnectionPool.from_url('redis://:zutuanxue_com@8.8.8.8:6379/0')
try:
r = redis.StrictRedis(connection_pool=pool)
except:
print("连接Redis失败")
r.set("zutuanxue_com", "good")
print(r.get("zutuanxue_com"))
问题:一条数据操作一次数据库,访问频繁效率低
pipline方式访问数据库
优点:缓冲多条命令,然后依次执行,减少服务器-客户端之间的TCP数据包,从而提高效率
import redis
pool = redis.ConnectionPool.from_url('redis://:zutuanxue_com@8.8.8.8:6379/0')
try:
r = redis.StrictRedis(connection_pool=pool)
except:
print("连接Redis失败")
pipe = r.pipeline()
pipe.set("aa", "111")
pipe.set("bb", "222")
pipe.set("cc", "333")
pipe.set("dd", "444")
pipe.execute()
需要
登录
才可以提问哦
: