Python标准库系列之Redis模块

What is redis?

Redis is an open source (BSD licensed), in-memory data structure store, used as database, cache and message broker. It supports data structures such as strings, hashes, lists, sets, sorted sets with range queries, bitmaps, hyperloglogs and geospatial indexes with radius queries. Redis has built-in replication, Lua scripting, LRU eviction, transactions and different levels of on-disk persistence, and provides high availability via Redis Sentinel and automatic partitioning with Redis Cluster.

Redis官网:http://redis.io/

以上摘自官网介绍

安装Redis

安装

模块GitHub地址:https://github.com/WoLpH/redis-py

配置绑定的IP

启动并设置开机自启动

检查

查看端口

数据写入测试

安装redis-py

安装redis-py

或源码安装

检查安装是否成功

入门及使用

使用连接池连接到Redis

Behind the scenes, redis-py uses a connection pool to manage connections to a Redis server. By default, each Redis instance you create will in turn create its own connection pool. You can override this behavior and use an existing connection pool by passing an already created connection pool instance to the connection_pool argument of the Redis class. You may choose to do this in order to implement client side sharding or have finer grain control of how connections are managed.

使用套接字连接

API

redis-py提供的API用来操作redis

String API

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

参数 描述
ex 过期时间(秒)
px 过期时间(毫秒)
nx 如果设置为True,则只有name不存在时,当前set操作才执行
xx 如果设置为True,则只有name存在时,岗前set操作才执行

setex(name, value, time)

设置过期时间/秒

psetex(name, time_ms, value)

设置过期时间/毫秒

setnx(name, value)

设置值,只有key不存在时,执行设置操作

mset(*args, **kwargs)

同时设置多个key/value

get(name)

获取单个值

mget(keys, *args)

获取多个值

getset(name, value)

设置新值并获取原来的值

getrange(key, start, end)

通过索引的方式来获取value的值

setrange(name, offset, value)

根据索引修改value

setbit(name, offset, value)

getbit(name, offset)

获取value对应某一个索引位置对应的值0/1

bitcount(key, start=None, end=None)

获取key对应二进制中表示1的个数

bitop(operation, dest, *keys)

将多个值进行值运算,得出的结果保存到一个新值当中

operation支持AND(并)、OR(或)、NOT(非)、XOR(异或)

strlen(name)

获取value的长度

incr(name, amount=1)

对name的value进行自增,如果name不存在则创建,否则自增

incrbyfloat(name, amount=1.0)

同上,支持浮点数自增

decr(name, amount=1)

自减,同自增一样,如果进行自减的value不是整数就报错

append(key, value)

在value后面追加内容

Hash API

hset(name, key, value)

设置name的键值对,有则修改,没有则创建

hmset(name, mapping)

同时设置多个name的key/value

hget(name, key)

获取name中key的值

hmget(name, keys, *args)

同时获取多个

hgetall(name)

获取name对应的所有key/value

hlen(name)

获取name对应键值对的个数

hkeys(name)

获取name中所有的key

hvals(name)

获取name中所有的value

hexists(name, key)

检查当前name中是否有传入的key

hdel(self, name, *keys)

删除name中对应的key

hincrby(name, key, amount=1)

name中key对应的value进行自增,如果不存在则创建

hincrbyfloat(name, key, amount=1.0)

value自增,支持浮点数,同上

hscan(name, cursor=0, match=None, count=None)

增量式迭代获取,hscan可以实现分片的获取数据,并非一次性将数据全部获取完,从而放置内存被撑爆

参数 描述
name redis的name
cursor 游标(基于游标分批取获取数据)
match 匹配指定key,默认None 表示所有的key
count 每次分片最少获取个数,默认None表示采用Redis的默认分片个数

hscan_iter(name, match=None, count=None)

利用yield封装hscan创建生成器,实现分批去redis中获取数据

参数 描述
match 匹配指定key,默认None 表示所有的key
count 每次分片最少获取个数,默认None表示采用Redis的默认分片个数

如:

expire(name, time)

设置过期时间

ListAPI

lpush(name, *values)

在最左边添加值

rpush(name, *values)

在最右边添加值

lpushx(name, value)

只有name已经存在时,值添加到列表的最左边

rpushx(name, value)

只有name已经存在时,值添加到列表的最右边

llen(name)

获取name元素的个数

linsert(name, where, refvalue, value)

在name的某一个值前面或者后面插入一个新值

lset(name, index, value)

对name中index索引位置的值进行重新赋值

lrem(name, value, num=0)

删除指定value后面或者前面的值

  1. num=2,从前到后,删除2个;
  2. num=-2,从后向前,删除2个

lpop(name)

删除name中左侧第一个元素

rpop(name)

删除name中右侧第一个元素

lindex(name, index)

获取name中对应索引的值

lrange(name, start, end)

使用切片获取数据

ltrim(name, start, end)

在name对应的列表中移除没有在start-end索引之间的值

rpoplpush(src, dst)

从src列表中取出最右边的元素,同时将其添加至dst列表的最左边

blpop(keys, timeout=0)
brpop(keys, timeout=0)

brpoplpush(src, dst, timeout=0)

从src列表的右侧移除一个元素并将其添加到dst列表的左侧

timeout,当src对应的列表中没有数据时,阻塞等待其有数据的超时时间(秒),0 表示永远阻塞

自定义增量迭代

由于redis类库中没有提供对列表元素的增量迭代,如果想要循环name对应的列表的所有元素,那么就需要:

  1. 获取name对应的所有列表
  2. 循环列表

但是,如果列表非常大,那么就有可能在第一步时就将程序的内容撑爆,所有有必要自定义一个增量迭代的功能:

使用

SET API

sadd(name, *values)

为name添加值,如果存在则不添加

scard(name)

返回name的元素数量

sdiff(keys, *args)

在keys集合中不在其他集合中的数据

sdiffstore(dest, keys, *args)

在keys集合中不在其他集合中的数据保存到dest集合中

sinter(keys, *args)

获取keys集合中与其他集合中的并集

sinterstore(dest, keys, *args)

获取keys集合中与其他集合中的并集数据并保存到dest集合中

sismember(name, value)

获取value是否是name集合中的成员

smembers(name)

获取name集合中所有的成员

smove(src, dst, value)

将src中的value移动到dst中

spop(name)

删除并返回name中的随机成员

srandmember(name, number=None)

随机获取name集合中的number个成员,默认number=1

srem(name, *values)

删除name集合中的values数据

sunion(keys, *args)

获取keys集合与其他集合的并集

sunionstore(dest, keys, *args)

获取keys集合与其他集合的并集并保存到dest中

Ordered set API

zadd(name, *args, **kwargs)

zcard(name)

返回有序集合name元素的数量

zcount(name, min, max)

返回在name中值在min与max之间的值个数

zincrby(name, value, amount=1)

name中让value的值加上amount

zinterstore(dest, keys, aggregate=None)
zlexcount(name, min, max)

zrange(name, start, end, desc=False, withscores=False, score_cast_func=float)

参数 描述
name redis的name
start 有序集合索引起始位置(非分数)
end 有序集合索引结束位置(非分数)
desc 排序规则,默认按照分数从小到大排序
withscores 是否获取元素的分数,默认只获取元素的值
score_cast_func 对分数进行数据转换的函数

zrangebylex(name, min, max, start=None, num=None)

当有序集合的所有成员都具有相同的分值时,有序集合的元素会根据成员的 值 (lexicographical ordering)来进行排序,而这个命令则可以返回给定的有序集合键 key 中, 元素的值介于 min 和 max 之间的成员

对集合中的每个成员进行逐个字节的对比(byte-by-byte compare), 并按照从低到高的顺序, 返回排序后的集合成员。 如果两个字符串有一部分内容是相同的话, 那么命令会认为较长的字符串比较短的字符串要大

参数 描述
name redis的name
min 左区间(值) + 表示正无限; – 表示负无限; ( 表示开区间; [ 则表示闭区间
min 右区间(值)
start 对结果进行分片处理,索引位置
num 对结果进行分片处理,索引后面的num个元素

如:

更多:

zrevrangebylex(name, max, min, start=None, num=None)

zrangebyscore(name, min, max, start=None, num=None, withscores=False, score_cast_func=float)**

zrank(name, value)

返回基于0的值,指示在排序集名称的值排名

zrevrank(name, value),从大到小排序

zrem(name, *values)

删除name中对应的values

zremrangebyrank(name, min, max)

根据排行范围进行删除

zremrangebyscore(name, min, max)

根据分数范围进行删除

zscore(name, value)

返回指定value的值是多少

zunionstore(dest, keys, aggregate=None)

Global API

delete(*names)

在redis中删除names

exists(name)

检测name是否存在

keys(pattern=’*’)

rename(src, dst)

把src重命名成dst

move(name, db)

将redis的某个值移动到指定的db下

randomkey()

随机获取一个redis的name,不进行删除

type(name)

查看name的类型

管道

redis-py默认在执行每次请求都会创建(连接池申请连接)和断开(归还连接池)一次连接操作,如果想要在一次请求中指定多个命令,则可以使用pipline实现一次请求指定多个命令,并且默认情况下一次pipline 是原子性操作(MySQL中的事务)。

发布订阅

实例

让redis缓存tornado页面

数据缓存5秒,如图所示

基于Redis的Session存储

app.py

template\index.html

RedisToSession.py

演示如图:

2 10 收藏 2 评论

可能感兴趣的话题



直接登录
最新评论
  • aishangxue 十八线码农 02/03

    标准库是啥意思?

    • iPixelOldC 学生,Python爱好者 02/05

      +1,目测要不是手残打错,要不就是标题党。。。文章里面都说用pip安装了。。。还说是标准库里面的。。。这也太不仔细了吧

跳到底部
返回顶部