Python对Redis操作

2022-09-08 20:47:03 浏览数 (1)

一、连接Redis数据库

作用:redis模块用于调用操作redis,而redis是一个基于内存的高性能key-value的存储系统,支持存储的类型有string、list、set、zset和hash。在处理大规模数据读写或高效的缓存的场景下运用比较多

安装:pip install redis

说明:redis模块中允许两种连接方式直接连接和连接池连接

直接连接

使用默认方式连接到数据库

代码语言:javascript复制
<span class="hljs-keyword">import</span> redis

<span class="hljs-keyword">try</span>:
    r = redis.StrictRedis(host=<span class="hljs-string">"8.8.8.8"</span>, port=<span class="hljs-number">6379</span>, password=<span class="hljs-string">"zutuanxue_com"</span>, db=<span class="hljs-number">0</span>)
<span class="hljs-keyword">except</span>:
    print(<span class="hljs-string">"连接Redis失败"</span>)

使用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 连接

连接池连接

连接池的原理是,通过预先创建多个连接, 当进行redis操作时,直接获取已经创建的连接进行操作,而且操作完成后,不会释放,用于后续的其他redis操作,这样就达到了避免频繁的redis连接创建和释放的目的,从而提高性能。redis模块采用ConnectionPool来管理对redis server的所有连接

使用默认方式连接到数据库

代码语言:javascript复制
<span class="hljs-keyword">import</span> redis

pool = redis.ConnectionPool(host=<span class="hljs-string">'8.8.8.8'</span>, port=<span class="hljs-number">6379</span>, password=<span class="hljs-string">"zutuanxue_com"</span>, db=<span class="hljs-number">0</span>)

<span class="hljs-keyword">try</span>:
    r = redis.StrictRedis(connection_pool=pool)
<span class="hljs-keyword">except</span>:
    print(<span class="hljs-string">"连接Redis失败"</span>)

使用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 连接

二、数据操作

根据数据类型的不同,调用相应的方法,完成读写

代码语言:javascript复制
<span class="hljs-keyword">import</span> redis

pool = redis.ConnectionPool.from_url(<span class="hljs-string">'redis://:zutuanxue_com@8.8.8.8:6379/0'</span>)
<span class="hljs-keyword">try</span>:
    r = redis.StrictRedis(connection_pool=pool)
<span class="hljs-keyword">except</span>:
    print(<span class="hljs-string">"连接Redis失败"</span>)

r.set(<span class="hljs-string">"zutuanxue_com"</span>, <span class="hljs-string">"good"</span>)
print(r.get(<span class="hljs-string">"zutuanxue_com"</span>))

问题:一条数据操作一次数据库,访问频繁效率低

pipline方式访问数据库

优点:缓冲多条命令,然后依次执行,减少服务器-客户端之间的TCP数据包,从而提高效率

代码语言:javascript复制
<span class="hljs-keyword">import</span> redis

pool = redis.ConnectionPool.from_url(<span class="hljs-string">'redis://:zutuanxue_com@8.8.8.8:6379/0'</span>)
<span class="hljs-keyword">try</span>:
    r = redis.StrictRedis(connection_pool=pool)
<span class="hljs-keyword">except</span>:
    print(<span class="hljs-string">"连接Redis失败"</span>)

pipe = r.pipeline()
pipe.set(<span class="hljs-string">"aa"</span>, <span class="hljs-string">"111"</span>)
pipe.set(<span class="hljs-string">"bb"</span>, <span class="hljs-string">"222"</span>)
pipe.set(<span class="hljs-string">"cc"</span>, <span class="hljs-string">"333"</span>)
pipe.set(<span class="hljs-string">"dd"</span>, <span class="hljs-string">"444"</span>)
pipe.execute()

0 人点赞