redis

1.安装模块:pip install redis

2.使用from redis import Redis

3.Redis实例化产生的对象是一个redis的连接conn=Redis()

4.redis属于io操作

5.操作reids(value部分都是byte格式存储的)ret=conn.get(\’name\’)   print(ret)

Python操作Redis之连接池

来一个请求一个连接,单个项目的话搞不垮,可能redis数据库给多个项目用,达到链接数处理不了就会崩掉,需要用到连接池,(不管什么池子本质就是一个池子拿了好多连接,请求资源就使用我池子里面的资源,如果超出的话就等待),这样的话就能保证reids不被冲垮,连接池实质就是一个个连接对象放在列表中

redis-py使用connection pool来管理对一个redis server的所有连接,避免每次建立、释放连接的开销。默认,每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池,然后作为参数Redis,这样就可以实现多个Redis实例共享一个连接池

import redis

pool = redis.ConnectionPool(host=\'127.0.0.1\', port=6379)
r = redis.Redis(connection_pool=pool)
r.set(\'foo\', \'Bar\')
print(r.get(\'foo\'))
from redis import ConnectionPool

#reids连接池
#可以指定链接数,不传就默认,max_connections=100是指用的时候创建一条,只到只能用到100条,而不是一下子就创建出来
#pool需要做成单例(避免每次运行的时候重新生成一个池子,)(自己做)
pool=ConnectionPool(host=\'127.0.0.1\',post=6379,max_connections=100)
#每次实例化的时候就从池子里拿一个连接
conn = Redis(connection_pool=pool)
print(conn.get(\'name\'))

 

redis之字符串

String操作,redis中的String在在内存中按照一个name对应一个value来存储。如图:

set(name, value, ex=None, px=None, nx=False, xx=False)  (默认参数)

在Redis中设置值,默认,不存在则创建,存在则修改
参数:
     ex,过期时间(秒)    
     px,过期时间(毫秒)
     nx,如果设置为True,则只有name不存在时,当前set操作才执行,值存在,就修改不了,执行没效果(相当于default默认值)
name,value是当前set中的name和value xx,如果设置为True,则只有name存在时,当前set操作才执行,值存在才能修改,值不存在,不会设置新值

ex:场景:如果订单几分钟不付款就取消订单

 

setnx(name, value) 相当于set(name,value,nx=True)  原先默认的是set(name,value,nx=False)

设置值,只有name不存在时,执行设置操作(添加),如果存在,不会修改
from redis import Redis
conn=Redis()
conn.set(\'name\',\'egon\',ex=5,xx=True)
conn.setnx(\'name\',\'fff\') #name存在所以不会修改原来的key中的value=\'egon\'
conn.setnx(\'ccc\',\'rrrr\') #ccc不存在,就添加一对key,value

setex(name, value, time)

# 设置值
# 参数:
    # time,过期时间(数字秒 或 timedelta对象)
from redis import Redis
conn=Redis()
conn.set(\'name\',\'egon\',ex=5,xx=True)
conn.setex(\'xxx\',5,\'ppp\') #设置值,然后存在redis中,存在五秒刷新就消失

psetex(name, time_ms, value)

# 设置值
# 参数:
    # time_ms,过期时间(数字毫秒 或 timedelta对象

mset(*args, **kwargs)

批量设置值
    mget({\'k1\': \'v1\', \'k2\': \'v2\'})

get(name)

获取值

mget(keys, *args)

批量获取
如:
    mget(\'k1\', \'k2\')
    或
    r.mget([\'k3\', \'k4\'])
 mget(\'k1\', \'k2\')

getset(name, value)

设置新值并获取原来的值

getrange(key, start, end)

# 获取子序列(根据字节获取,非字符)
# 参数:
    # name,Redis 的 name
    # start,起始位置(字节)
    # end,结束位置(字节)
# 如: "刘清政" ,0-3表示 "刘"

setrange(name, offset, value)

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

setrange(name, offset, value)

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

新的value比要替换的value长的话就往后放,短的话就替换

setbit(name, offset, value)

复制代码
# 对name对应值的二进制表示的位进行操作
 
# 参数:
    # name,redis的name
    # offset,位的索引(将值变换成二进制后再进行索引)
    # value,值只能是 1 或 0
 
# 注:如果在Redis中有一个对应: n1 = "foo",
        那么字符串foo的二进制表示为:01100110 01101111 01101111
    所以,如果执行 setbit(\'n1\', 7, 1),则就会将第7位设置为1,
        那么最终二进制则变成 01100111 01101111 01101111,即:"goo"
复制代码

getbit(name, offset)

# 获取name对应的值的二进制表示中的某位的值 (0或1)

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

# 获取name对应的值的二进制表示中 1 的个数
# 参数:
    # key,Redis的name
    # start,位起始位置
    # end,位结束位置

bitop(operation, dest, *keys)

复制代码
# 获取多个值,并将值做位运算,将最后的结果保存至新的name对应的值
 
# 参数:
    # operation,AND(并) 、 OR(或) 、 NOT(非) 、 XOR(异或)
    # dest, 新的Redis的name
    # *keys,要查找的Redis的name
 
# 如:
    bitop("AND", \'new_name\', \'n1\', \'n2\', \'n3\')
    # 获取Redis中n1,n2,n3对应的值,然后讲所有的值做位运算(求并集),然后将结果保存 new_name 对应的值中
复制代码

strlen(name)

# 返回name对应值的字节长度(一个汉字3个字节)

incr(self, name, amount=1)

复制代码
# 自增 name对应的值,当name不存在时,则创建name=amount,否则,则自增。
 
# 参数:
    # name,Redis的name
    # amount,自增数(必须是整数)自定义写3,也就是每执行一次自增三个数
 
# 注:同incrby


例子:
重点(应用场景:文章的阅读数,网站访问量)
每次点一次就自增一次,然后如等到晚上12:00再将这些阅读数保存到数据库,以前的话就是点一次就走一次数据库
conn.incr(\'age\')
复制代码

incrbyfloat(self, name, amount=1.0)

# 自增 name对应的值,当name不存在时,则创建name=amount,否则,则自增。
 
# 参数:
    # name,Redis的name
    # amount,自增数(浮点型)

decr(self, name, amount=1)

# 自减 name对应的值,当name不存在时,则创建name=amount,否则,则自减。
 
# 参数:
    # name,Redis的name
    # amount,自减数(整数)

append(key, value)

# 在redis name对应的值后面追加内容
 
# 参数:
    key, redis的name
    value, 要追加的字符串

redis之字典操作

Hash操作,redis中Hash在内存中的存储格式如下图:

 

conn.hset(\’hash1\’,\’k1\’,\’v1\’)

conn.hset(\’hash1\’,\’k2\’,\’v2\’)

 

hset(name, key, value)

复制代码
# name对应的hash中设置一个键值对(不存在,则创建;否则,修改)
 
# 参数:
    # name,redis的name
    # key,name对应的hash中的key
    # value,name对应的hash中的value
 
# 注:
    # hsetnx(name, key, value),当name对应的hash中不存在当前key时则创建(相当于添加)
复制代码

hmset(name, mapping)

复制代码
# 在name对应的hash中批量设置键值对
 
# 参数:
    # name,redis的name
    # mapping,字典,如:{\'k1\':\'v1\', \'k2\': \'v2\'}
 
# 如:
    # r.hmset(\'xx\', {\'k1\':\'v1\', \'k2\': \'v2\'})
复制代码

 

hget(name,key)

# 在name对应的hash中获取根据key获取value
conn.hget(\'hash1\',\'k1\')

hmget(name, keys, *args)

复制代码
# 在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\')

print(conn.hmget(\'hash2\',[\'name\',\'age\'])) 列表中

hgetall(name)

# 获取name对应hash的所有键值
print(re.hgetall(\'xxx\').get(b\'name\'))
print(conn.hgetall(\'hash2\')) 获取出hash2中所有的值放入到字典中

hlen(name)

# 获取name对应的hash中键值对的个数
print(conn.hlen(\'hash1\'))

hkeys(name)

# 获取name对应的hash中所有的key的值

hvals(name)

# 获取name对应的hash中所有的value的值

hexists(name, key)

# 检查name对应的hash是否存在当前传入的key

hdel(name,*keys)

# 将name对应的hash中指定key的键值对删除
print(re.hdel(\'xxx\',\'sex\',\'name\'))

print(conn.hdel(\'hash1\',\'k1\',\'k2\')) hash1就是hash1这张表,表中的看,k2键值对

hincrby(name, key, amount=1)

# 自增name对应的hash中的指定key的值,不存在则创建key=amount
# 参数:
    # name,redis中的name
    # key, hash对应的key
    # amount,自增数(整数)

hincrbyfloat(name, key, amount=1.0)

复制代码
# 自增name对应的hash中的指定key的值,不存在则创建key=amount
 
# 参数:
    # name,redis中的name
    # key, hash对应的key
    # amount,自增数(浮点数)
 
# 自增name对应的hash中的指定key的值,不存在则创建key=amount
复制代码

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时,表示数据已经通过分片获取完毕
复制代码

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
复制代码

源码:

版权声明:本文为huangxuanya原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/huangxuanya/p/11161108.html