neir
一、列表的基本操作
二、列表的高级使用
一、列表的基本操作
1. lpush(name,values)
import redis class MyRedis(): def __enter__(self): self.conn = redis.Redis() return self.conn def __exit__(self, exc_type, exc_val, exc_tb): self.conn.close() with MyRedis() as conn: #列表操作 # 1 lpush(name,values) conn.lpush('l1',1,2,3,4,5,'lili')
2. rpush（name,value）
conn.rpush('l1','haha')
3. lpushx(name,value) rpushx(name,value)
# 在name对应的list中添加元素，只有name已经存在时，值添加到列表的最左边 # conn.lpushx('l2',9)#插入不进去，因为l1不存在 # conn.lpushx('l1',9)#可以插入进去 conn.rpushx('l1', 9) # 可以插入进去
4. llen(name)
conn.lpush('l1', 1, 2, 3, 4, 5, 'lili') res=conn.llen('l1') #6 print(res)
5. linsert(name, where, refvalue, value)) 在某个位置插入值
# where :BEFORE或AFTER,大小写都行 # refvalue: lili 表示以lili为标准（不是下标索引）。如果有两个lili，那么就会插入到序号小的那里，不会再往下找了 # conn.linsert('l1','after','lili','刘亦菲') conn.linsert('l1','before','lili','baby')
6. lset(name,index,value)
# conn.lset('l1',0,'黄晓明')#把第0个位置设置成 黄晓明，注意是从0开始的 conn.lset('l1',5,'老伙计')#把第5个位置设置成老伙计，注意是从0开始的
7. lrem(name,value,num)
# 第二个参数count： # count = 0，删除列表中所有的指定值； # count=2,从前到后，删除2个； # count=-2,从后向前，删除2个 # conn.lrem('l1',0,'lili') # 把所有lqz都删除 # conn.lrem('l1',2,'lili') # 从前往后，删除2个lili conn.lrem('l1',-1,'lili') # 从后往前，删除1个lili
8. lpop(name)
# res=conn.lpop('l1') res=conn.rpop('l1') print(res)
9. lindex(name,num)
# lindex(不删除,只是索引取值) res=conn.lindex('l1',0) print(res)
10. lrange(name,start,end) # 是前闭后闭区间
# res = conn.lrange('l1', 0, 0) #返回一个值 res = conn.lrange('l1', 0, 1)#返回2个值 print(res)
11. ltrim(start,end)
res=conn.ltrim('l1',3,5) #只保留3到5之间的数据，前闭后闭 print(res)
12.rpoplpush
# rpoplpush 需要两个列表 # conn.lpush('l1',1,2,3) # conn.lpush('l2',4,5,6) #把l1的最后一个pop出来放到l1里第一个位置 conn.rpoplpush('l1','l1') # 把l1的最后一个pop出来放到l2里 conn.rpoplpush('l1','l2')
13.blpop #block阻塞 左边弹出
# res=conn.blpop('l1') # print(res)
小应用:
rpc:是远程过程调用
14. blpoprpush
****总结
lpush llen linsert lset lrem lpop lrange # 使用它，自定义增量迭代 blpop
二、列表的高级使用
1. lrange
redis类库中没有提供对列表元素的增量迭代，借助lrange
# res=conn.lrange('l2',0,9999) # 全部取出来 # res=conn.lrange('l2',0,conn.llen('l2')) # 从0取到列表长度
lrange类似于字典的hgetall，一次性全取出来，存在的问题是，因为不知道列表有多大，很有可能撑爆内存
解决办法:增量迭代
#制造1000条数据 for i in range(1000): conn.lpush('l_test','test_%s'%i) #原来的方式： # res=conn.lrange('l3',0,conn.llen('l3')) # print(res)#一次性取出来会占用很大内存，可能撑爆 # res = conn.lrange('l_test', 0, 9) # print(res) #lscan_iter方式一： # def lscan_iter(name, conn, count=10): # cursor = 0 # lenght = conn.llen(name) # 计算列表总长度 # while cursor < lenght: # data = conn.lrange(name, cursor, (cursor+count) - 1) # cursor += count # # for item in data: # yield item # for i in lscan_iter('l_test',conn,20): # print(i) #lscan_iter方式二： def lscan_iter(name, conn, count=10): cursor = 0 while True: data = conn.lrange(name, cursor, (cursor + count) - 1) if data: cursor += count for item in data: yield item else: break for i in lscan_iter('l_test',conn,20): print(i)
三、redis其他操作
增加key,可以为以下5种类型
import redis class MyRedis(): def __enter__(self): self.conn = redis.Redis() return self.conn def __exit__(self, exc_type, exc_val, exc_tb): self.conn.close() with MyRedis() as conn: ## 公共操作 # 如果搭建哨兵。用了集群，这个模块就不够用了 # delete # res=conn.delete('l2','name')#删l2不管name是否存在 # res=conn.delete('l1','name')#删l1不管name是否存在 # exists # res=conn.exists('l1','l_test','l2') #打印1 说明只有一个存在 # res=conn.exists('l_test')#打印1 说明l_test存在 # print(res) # expire # res=conn.expire('l_test',5) #5秒后删除l_test # print(res) # rename # conn.lpush('l1',1,2,3) # res=conn.rename('l1','l2') #重命名位l2 # res=conn.move('l2',3) #把l2移到db3下 ## redis的库是隔离的 # res=conn.lpop('l2') # print(res) #None 如果要获取db3下的l2，那就要先切换到db3库 # 随机出一个key值 # conn.lpush('l1', 1, 2, 3) # conn.lpush('l2', 1, 2, 3) # conn.lpush('l3', 1, 2, 3) # res=conn.randomkey() # print(res) #随机获取key值 # # 应用：利用redis随机抽奖 # conn.sadd('choujiang',9) # conn.sadd('choujiang',90) # conn.sadd('choujiang',99) # res = conn.spop('choujiang') # print(res) # type----查看类型 # res=conn.type('choujiang') #b'set' # res=conn.type('ss') #b'string' res = conn.type('zzz')#b'zset' print(res)
四、redis通过管道实现事务
### redis是数据库，非关系型数据库，不支持事务 ## redis提供了管道，通过管道，实现事务 注意：在mysql中通过混滚实现事务 # 开启一个管道 pi = conn.pipeline(transaction=True) pi.multi() #用于批量实现业务 # 只要人的年龄加了1，工资加1w pi.incr('age') raise Exception('出异常了') pi.incr('salary', 10000) # 向管道中发送了两个命令，并没有真正的执行 pi.execute() # 表示一次性执行管道中的命令，抛异常后年龄不加，薪资不加，实现事务 # ## 原来操作--抛异常后，年龄增加，薪资不加 # conn.incr('age') # raise Exception('出错误了') # conn.incr('salary',1000)