Python3操作Redis数据库（一）

redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash（哈希类型）。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。

Redis 是一个高性能的key-value数据库。 redis的出现，很大程度补偿了memcached这类key/value存储的不足，在部分场合可以对关系数据库起到很好的补充作用。它提供了Java，C/C++，C#，PHP，JavaScript，Perl，Object-C，Python，Ruby，Erlang等客户端，使用很方便。

Redis支持主从同步。数据可以从主服务器向任意数量的从服务器上同步，从服务器可以是关联其他从服务器的主服务器。这使得Redis可执行单层树复制。存盘可以有意无意的对数据进行写操作。由于完全实现了发布/订阅机制，使得从数据库在任何地方同步树时，可订阅一个频道并接收主服务器完整的消息发布记录。同步对读取操作的可扩展性和数据冗余很有帮助。

首先安装一个Python-redis的包

使用PIP

 pip install redis  或者使用 pip3 install redis

测试是否安装成功：

import redis

那么，启动redis服务来测试一下

（注:各环境下Redis服务各有不同，这里以Windows版为例）

测试

这里建立简单连接来测试

>>> import redis
>>> r = redis.StrictRedis(host='localhost', port=6379, db=0)
>>> r.set('foo', 'bar')
True
>>> r.get('foo')
'bar'

可以通过查看子类来了解所包含的参数选项

这里Redis是StrictRedis的子类

  def __init__(self, host='localhost', port=6379,
         db=0, password=None, socket_timeout=None,
         socket_connect_timeout=None,
         socket_keepalive=None, socket_keepalive_options=None,
         connection_pool=None, unix_socket_path=None,
         encoding='utf-8', encoding_errors='strict',
         charset=None, errors=None,
         decode_responses=False, retry_on_timeout=False,
         ssl=False, ssl_keyfile=None, ssl_certfile=None,
         ssl_cert_reqs=None, ssl_ca_certs=None):

redis 提供两个类 Redis 和 StrictRedis, StrictRedis 用于实现大部分官方的命令，Redis 是 StrictRedis 的子类，用于向后兼用旧版本。

redis 取出的结果默认是字节，我们可以设定 decode_responses=True 改成字符串。

>>> import redis   # 导入redis 模块
>>> r = redis.Redis(host='localhost', port=6379, decode_responses=True)
>>> r.set('name', 'daofengql')  # 设置 name 对应的值
True
>>> print(r['name'])
daofengql
>>> print(r.get('name'))  # 取出键 name 对应的值
daofengql
>>> print(type(r.get('name')))  # 查看类型
<class 'str'>
>>>

连接池

redis-py 使用 connection pool 来管理对一个 redis server 的所有连接，避免每次建立、释放连接的开销。

默认，每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池，然后作为参数 Redis，这样就可以实现多个 Redis 实例共享一个连接池。

>>> import redis    # 导入redis 模块
>>> pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
>>> r = redis.Redis(host='localhost', port=6379, decode_responses=True)
>>> r.set('name', 'daofengql')  # 设置 name 对应的值
True
>>> print(r.get('name'))  # 取出键 name 对应的值
daofengql
>>>

根据前面子类中对链接的定义，可以对照着传入其他参数，例如选择数据库的db数，安全链接的密码，超时等等

例如：

>>> import redis    # 导入redis 模块
>>> pool = redis.ConnectionPool(host='localhost', port=6379,db=1,password="passwd", decode_responses=True)

redis 基本命令 String

set(name, value, ex=None, px=None, nx=False, xx=False)

在 Redis 中设置值，默认，不存在则创建，存在则修改。

参数：

ex - 过期时间（秒）
px - 过期时间（毫秒）
nx - 如果设置为True，则只有name不存在时，当前set操作才执行
xx - 如果设置为True，则只有name存在时，当前set操作才执行

例：

1.ex - 过期时间（秒）这里过期时间是3秒，3秒后p，键food的值就变成None

import redis
pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)
r.set('who', 'daofeng', ex=5)    # 将键值对存入redis缓存设置5秒过期
print(r.get('who'))
print(r.get('who'))

2.px - 过期时间（豪秒）这里过期时间是3豪秒，3毫秒后，键foo的值就变成None

import redis
pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)
r.set('daofengql', '1', px=3)
print(r.get('daofengql'))

3.nx - 如果设置为True，则只有name不存在时，当前set操作才执行（新建）

import redis

pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)
print(r.set('daofengql', 'a dragon', nx=True))    # True--不存在
# 如果键不存在，那么输出是True；如果键已经存在，输出是None

4.xx - 如果设置为True，则只有name存在时，当前set操作才执行（修改）

import redis

pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)
print((r.set('name', 'a dragon', xx=True)))   # True--已经存在
# 如果键已经存在，那么输出是True；如果键不存在，输出是None

5.setnx(name, value)设置值，只有name不存在时，执行设置操作（添加）

import redis

pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)
print(r.setnx('whois', 'a dragon'))  # whois不存在，输出为True
r.set('name', 'a dragon')
print(r.setnx('name', 'a dragon'))  # name存在，输出为False

6.setex(name, time, value) time - 过期时间（数字秒或 timedelta对象）

import redis
import time

pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)
r.setex("whoisdaofeng", 5, "a dragon")
time.sleep(5)
print(r.get('whoisdaofeng'))  # 5秒后，取值就从a dragon变成None

下接：Python3操作Redis数据库（二）

Python3操作Redis数据库（一）

测试

连接池

redis 基本命令 String

评论 (0)