python操作Redis缓存

Posted 2020-10-29 _慕

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了python操作Redis缓存相关的知识，希望对你有一定的参考价值。

一、Redis的安装

　　xshell连上服务器，依次输入以下代码：

wget http://download.redis.io/releases/redis-3.0.6.tar.gz
tar xzf redis-3.0.6.tar.gz
cd redis-3.0.6
make

　　如果不巧发生以下截图中的错误：

　　说明未安装gcc，如果是centos系统，输入：yum install gcc安装gcc即可，然后再次输入make执行。

　　输入make后，很不幸，再次发生如下截图错误：

　　推测是因为编译库的问题。

　　将make改为make MALLOC=libc 再次运行！好事多磨。

　终于安装成功了！

　　还有配置文件的修改什么的先不折腾了，此时已然可以启动Redis服务

src/redis-server # 启动服务端

# 启动客户端的代码如下
src/redis-cli
redis> set foo bar
OK
redis> get foo
"bar"

　看到上面的图像，说明服务端已经起来了！

　　但是看到很多WARNING，没错，此时你用pycharm写了连接redis服务端的代码，但是你发现服务端竟然没有响应

　　OK，在服务端Ctrl + C ,先把服务断开

　　分别执行下面的语句：

echo 511 > /proc/sys/net/core/somaxconn
echo "vm.overcommit_memory = 1" >> /etc/sysctl.conf
sysctl vm.overcommit_memory=1
echo never > /sys/kernel/mm/transparent_hugepage/enabled

　　在/etc下的rc.local的最后添加：

echo never > /sys/kernel/mm/transparent_hugepage/enabled

　　最后的重点来了，折腾半天还是服务器不鸟我，无奈之下试了试临时关闭防火墙：

service iptables stop

　　唉呀呀，终于成功了！

　　我在另一台服务器用了另一种搭建方法：传送门也成功了，但是也不要忘记要临时关掉防火墙。

二、Redis的两种连接方式

1.简单连接

import redis
conn = redis.Redis(host=\'207.148.120.229\', port=6379)
conn.set(\'foo\', \'Bar\')
print(conn.get(\'foo\'))
a = input(\'按任意键结束\')

2.使用连接池　　

　　为了减少每次建立、释放连接的开销，推荐使用连接池

　　redis使用connection pool来管理对一个redis服务的所有连接。

　　多个redis实例可共享一个连接池。

import redis
pool = redis.ConnectionPool(host=\'207.148.120.229\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.set(\'key\', \'Hello World\')
print(conn.get(\'key\'))
a = input(\'按任意键结束\')

三、五大数据类型

1.String操作　　

　　redis中的String在在内存中按照一个key对应一个value来存储。以键值对的方式存储。

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

在Redis中设置值，默认，不存在则创建，存在则修改
参数：
     ex，过期时间（秒）
     px，过期时间（毫秒）
     nx，如果设置为True，则只有name不存在时，当前set操作才执行
     xx，如果设置为True，则只有name存在时，当前set操作才执行

import redis
pool = redis.ConnectionPool(host=\'207.148.120.229\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.set(\'key\', \'Hello World\')
print(conn.get(\'key\'))

　 mset(*args, **kwargs) 批量设置值

# 批量设置值
import redis
pool = redis.ConnectionPool(host=\'207.148.120.229\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.mset(k1=\'v1\', k2=\'v2\')
# conn.mset({\'k1\': \'v1\', \'k2\': \'v2\'})

print(conn.get(\'k1\'))

View Code

　　get(name) 获取值

print(conn.get(\'k1\'))

　　mget(keys, *args) 批量获取值

# 批量获取值
import redis
pool = redis.ConnectionPool(host=\'207.148.120.229\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.mset(k1=\'v1\', k2=\'v2\')

print(conn.mget(\'k1\',\'k2\'))    # [b\'v1\', b\'v2\']
print(conn.mget([\'k1\',\'k2\']))  # [b\'v1\', b\'v2\']

View Code

　　getset(name, value) 设置新值并获取原来的值

import redis
pool = redis.ConnectionPool(host=\'207.148.120.229\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.mset(k1=\'v1\', k2=\'v2\')

ret = conn.getset(\'k1\',\'value_1\')
print(ret)             # b\'v1\'
print(conn.get(\'k1\')) # b\'value_1\'

View Code

　　getrange(key, start, end) 获取name对应value的指定字节

import redis
pool = redis.ConnectionPool(host=\'207.148.120.229\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.set(\'k1\',\'hello\')

print(conn.getrange(\'k1\',0,3)) # b\'hell\'\'
# 获取子序列（根据字节获取，非字符）
# 参数：
    # name，Redis 的 name
    # start，起始位置（字节）
    # end，结束位置（字节）
# 如： "hello" ，0-3表示 "hell"

View Code

　　setrange(name, offset, value) 从指定字节开始替换新值

import redis
pool = redis.ConnectionPool(host=\'207.148.120.229\',port=6379)
conn = redis.Redis(connection_pool=pool)

print(conn.get(\'k1\'))  # b\'hello\'
conn.setrange(\'k1\',2,\'long_time\')
print(conn.get(\'k1\'))  # b\'helong_time\'

# 修改字符串内容，从指定字符串索引开始向后替换（新值太长时，则向后添加）
# 参数：
    # offset，字符串的索引，字节（一个汉字三个字节）
    # value，要设置的值

View Code

　　strlen(name) 获取name对应的value的长度

import redis
pool = redis.ConnectionPool(host=\'207.148.120.229\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.set(\'k1\',\'hello\')
conn.set(\'k2\',\'天宝\')

print(conn.strlen(\'k1\'))  # 5
print(conn.strlen(\'k2\'))  # 6  一个汉字占3个字节

View Code

　　incr(self, name, amount=1) name存在，则自增amount，否则设置name的value值为amount

import redis
pool = redis.ConnectionPool(host=\'207.148.120.229\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.set(\'k1\',\'5\')
conn.incr(\'k1\',amount=3)

print(conn.get(\'k1\'))  # b\'8\'

# 自增 name对应的值，当name不存在时，则创建name＝amount，否则，则自增。

# 参数：
# name,Redis的name
# amount,自增数（必须是整数）

# 注：同incrby

View Code

　　decr(self, name, amount=1) 自减（整数）

import redis
pool = redis.ConnectionPool(host=\'207.148.121.149\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.set(\'k1\',\'5\')
conn.decr(\'k1\',amount=3)

print(conn.get(\'k1\'))  # b\'2\'

# 自减 name对应的值，当name不存在时，则创建name＝amount，否则，则自减。

# 参数：
# name,Redis的name
# amount,自减数（整数）

View Code

　 append(key, value)

import redis
pool = redis.ConnectionPool(host=\'207.148.121.149\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.set(\'k1\',\'hello_\')
conn.append(\'k1\',\'world\')

print(conn.get(\'k1\'))  # b\'hello_world\'

# 在redis name对应的值后面追加内容

# 参数：
# key, redis的name
# value, 要追加的字符串

View Code

2.Hash操作

　　hset(name, key, value) 设置值

import redis
pool = redis.ConnectionPool(host=\'207.148.121.149\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.hset(\'n1\',\'key_1\',\'hello\')
conn.hset(\'n1\',\'key_2\',\'world\')

print(conn.hget(\'n1\',\'key_1\'))  # b\'hello\'
print(conn.hget(\'n1\',\'key_2\'))  # b\'world\'

# name对应的hash中设置一个键值对（不存在，则创建；否则，修改）

# 参数：
# name，redis的name
# key，name对应的hash中的key
# value，name对应的hash中的value

# 注：
# hsetnx(name, key, value),当name对应的hash中不存在当前key时则创建（相当于添加）

View Code

　　hmset(name, mapping) 批量设置值

import redis
pool = redis.ConnectionPool(host=\'207.148.121.149\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.hmset(\'n1\',{\'k1\':\'v1\', \'k2\': \'v2\'})

print(conn.hget(\'n1\',\'k1\'))  # b\'v1\'
print(conn.hget(\'n1\',\'k2\'))  # b\'v2\'

# 在name对应的hash中批量设置键值对

# 参数：
# name，redis的name
# mapping，字典，如：{\'k1\':\'v1\', \'k2\': \'v2\'}

# 如：
# r.hmset(\'xx\', {\'k1\':\'v1\', \'k2\': \'v2\'})

View Code

　　hmget(name, keys, *args) 获取多个值

import redis
pool = redis.ConnectionPool(host=\'207.148.121.149\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.hmset(\'n1\',{\'k1\':\'v1\', \'k2\': \'v2\'})

print(conn.hmget(\'n1\',[\'k1\',\'k2\']))  # [b\'v1\', b\'v2\']

# 在name对应的hash中获取多个key的值

# 参数：
# name，reids对应的name
# keys，要获取key集合，如：[\'k1\', \'k2\', \'k3\']
# *args，要获取的key，如：k1,k2,k3

# 如：
# r.mget(\'xx\', [\'k1\', \'k2\'])
# 或
# print(r.hmget(\'xx\', \'k1\', \'k2\'))

View Code

　　hgetall(name) 获取name对应hash的所有键值

import redis
pool = redis.ConnectionPool(host=\'207.148.121.149\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.hmset(\'n1\',{\'k1\':\'v1\', \'k2\': \'v2\'})

print(conn.hgetall(\'n1\'))  # {b\'k1\': b\'v1\', b\'k2\': b\'v2\'}

View Code

　　hlen(name) 获取name对应的hash中键值对的个数

　　hkeys(name) 获取name对应的hash中所有的key的值

　　hvals(name) 获取name对应的hash中所有的value的值

　　hdel(name,*keys) 将name对应的hash中指定key的键值对删除

　　hincrby(name, key, amount=1) 自增（整数）

import redis
pool = redis.ConnectionPool(host=\'207.148.121.149\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.hmset(\'n1\',{\'k1\':\'10\', \'k2\': \'20\'})
conn.hincrby(\'n1\',\'k1\',amount=5)

print(conn.hget(\'n1\',\'k1\'))  # b\'15\'

# 自增name对应的hash中的指定key的值，不存在则创建key=amount
# 参数：
    # name，redis中的name
    # key， hash对应的key
    # amount，自增数（整数）

View Code

　　hincrbyfloat(name, key, amount=1.0) 自增（浮点数）

　　hscan(name, cursor=0, match=None, count=None) 增量式迭代获取

# 增量式迭代获取，对于数据大的数据非常有用，hscan可以实现分片的获取数据，并非一次性将数据全部获取完，从而放置内存被撑爆

# 参数：
#     name，redis的name
#     cursor，游标（基于游标分批取获取数据）
#     match，匹配指定key，默认None 表示所有的key
#     count，每次分片最少获取个数，默认None表示采用Redis的默认分片个数

# 如：
#     第一次：cursor1, data1 = r.hscan(\'xx\', cursor=0, match=None, count=None)
#     第二次：cursor2, data1 = r.hscan(\'xx\', cursor=cursor1, match=None, count=None)
#     ...
#     直到返回值cursor的值为0时，表示数据已经通过分片获取完毕

View Code

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

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

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

# 如：
# for item in r.hscan_iter(\'xx\'):
#     print item

View Code

3.List操作

　　lpush(name,values)

import redis
pool = redis.ConnectionPool(host=\'207.148.121.149\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.lpush(\'ww\',11)

print(conn.lindex(\'ww\',0))  # b\'11\'  # 根据所有获取值

# 在name对应的list中添加元素，每个新的元素都添加到列表的最左边

# 如：
# r.lpush(\'oo\', 11,22,33)
# 保存顺序为: 33,22,11

# 扩展：
# rpush(name, values) 表示从右向左操作

View Code

　　lpushx(name,value)

import redis
pool = redis.ConnectionPool(host=\'207.148.121.149\',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.lpushx(\'ww\',22)

print(conn.lrange(\'ww\',0,1))  # [b\'22\', b\'22\']

# 在name对应的list中添加元素，只有name已经存在时，值添加到列表的最左边

# 更多：
# rpushx(name, value) 表示从右向左操作

View Code

　　llen(name) name对应的list元素的个数

　　linsert(name, where, refvalue, value))

# 在name对应的列表的某一个值前或后插入一个新值

# 参数：
#     name，redis的name
#     where，BEFORE或AFTER
#     refvalue，标杆值，即：在它前后插入数据
#     value，要插入的数据

View Code

　　r.lset(name, index, value)

# 对name对应的list中的某一个索引位置重新赋值

# 参数：
#     name，redis的name
#     index，list的索引位置
#     value，要设置的值

View Code

　　r.lrem(name, value, num)

# 在name对应的list中删除指定的值

# 参数：
#     name，redis的name
#     value，要删除的值
#     num，  num=0，删除列表中所有的指定值；
#       num=2,从前到后，删除2个；
#       num=-2,从后向前，删除2个

View Code

　　lpop(name)

# 在name对应的列表的左侧获取第一个元素并在列表中移除，返回值则是第一个元素

# 更多：
#   rpop(name) 表示从右向左操作

View Code

　　lindex(name, index) 在name对应的列表中根据索引获取列表元素

　　lrange(name, start, end)

# 在name对应的列表分片获取数据
# 参数：
    # name，redis的name
    # start，索引的起始位置
    # end，索引结束位置

View Code

　　ltrim(name, start, end)

# 在name对应的列表中移除没有在start-end索引之间的值
# 参数：
    # name，redis的name
    # start，索引的起始位置
    # end，索引结束位置

View Code

　　rpoplpush(src, dst)

# 从一个列表取出最右边的元素，同时将其添加至另一个列表的最左边
# 参数：
    # src，要取数据的列表的name
    # dst，要添加数据的列表的name

View Code

　　blpop(keys, timeout)

# 将多个列表排列，按照从左到右去pop对应列表的元素
 
# 参数：
    # keys，redis的name的集合
    # timeout，超时时间，当元素所有列表的元素获取完之后，阻塞等待列表内有数据的时间（秒）, 0 表示永远阻塞
 
# 更多以上是关于python操作Redis缓存的主要内容，如果未能解决你的问题，请参考以下文章 
 Python操作Redis缓存数据库
 第二百九十七节，python操作redis缓存-List类型，可以理解为列表
 基于Python项目的Redis缓存消耗内存数据简单分析（附详细操作步骤）
 基于Python项目的Redis缓存消耗内存数据简单分析（附详细操作步骤）
 Python如何操作redis
 基于Python项目的Redis缓存消耗内存数据简单分析（附详细操作步骤）