一、连接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()