Python对Redis操作
一、连接Redis数据库
作用：redis模块用于调用操作redis，而redis是一个基于内存的高性能key-value的存储系统，支持存储的类型有string、list、set、zset和hash。在处理大规模数据读写或高效的缓存的场景下运用比较多
安装：pip install redis
说明：redis模块中允许两种连接方式直接连接和连接池连接
直接连接
使用默认方式连接到数据库
<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的所有连接
使用默认方式连接到数据库
<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 连接 |
二、数据操作
根据数据类型的不同，调用相应的方法，完成读写
<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数据包，从而提高效率
<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()