（收藏）Python操作Redis的全面總結(jié)

#!/usr/bin/python
# -*- coding:utf-8 -*-
# __author__ = 'Jack'

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
r = redis.Redis(connection_pool=pool)
r.flushall() # 清空Redis

r.setex('name', value='liaogx', time=2) # 設(shè)置新值，過期時(shí)間為3s
r.mset(k1 = 'v1', k2 = 'v2', k3 = 'v3') # 批量設(shè)置新值
print(r.mget('k1', 'k2', 'k3', 'k4')) # 批量獲取新值
print(r.getset('name', 'liaogaoxiang')) # 設(shè)置新值并獲取原來的值
print(r.getrange('name', 0, 1)) # 獲取子序列 0 <= x <= 1
r.setrange('name', 0, 'LIAO') # 修改字符串內(nèi)容，從指定字符串索引開始向后替換（新值太長時(shí)，則向后添加），返回值的長度
i = 0
while i < 4:
 print(r.get('name'))
 time.sleep(1)
 i += 1
source = 'foo'
r.set('n1', source)
r.setbit('n1', 7, 1)
'''
注：如果在Redis中有一個(gè)對應(yīng)： n1 = "foo"，
 那么字符串foo的二進(jìn)制表示為：01100110 01101111 01101111
 所以，如果執(zhí)行 setbit('n1', 7, 1)，則就會將第7位設(shè)置為1，
 那么最終二進(jìn)制則變成 01100111 01101111 01101111，即："goo"
'''
print(r.get('n1'))
print(r.getbit('n1', 7)) # 獲取n1對應(yīng)的值的二進(jìn)制表示中的某位的值 （0或1）
r.set('n2', '廖高祥')
print(r.strlen('n2')) # 返回對應(yīng)的字節(jié)長度（一個(gè)漢字3個(gè)字節(jié)）
r.set('num', 1)
r.incr('num', amount=10)
r.decr('num', amount=1)
print(r.get('num')) # 自增num對應(yīng)的值，當(dāng)name不存在時(shí)，則創(chuàng)建name＝amount，否則，則自增。
r.append('num', 111)
print(r.get('num')) # 在redis num對應(yīng)的值后面追加內(nèi)容

[b'v1', b'v2', b'v3', None]
b'liaogx'
b'li'
b'LIAOgaoxiang'
b'LIAOgaoxiang'
b'LIAOgaoxiang'
b'LIAOgaoxiang'
b'goo'
1
9
b'10'
b'10111'

#!/usr/bin/python
# -*- coding:utf-8 -*-
# __author__ = 'Jack'

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
r = redis.Redis(connection_pool=pool)
r.flushall() # 清空Redis

r.lpush('oo', 11) # 保存順序?yàn)? 33,22,11
r.lpushx('oo', 00) # 在name對應(yīng)的list中添加元素，只有name已經(jīng)存在時(shí)，值添加到列表的最左邊
print(r.llen('oo')) # name對應(yīng)的list元素的個(gè)數(shù)

r.linsert('oo', 'before', 11, 99) # 在11之前插入值99
r.lset('oo', 1, 88) # 對name對應(yīng)的list中的某一個(gè)索引位置重新賦值
print(r.lrange('oo', 0, -1)) # 在name對應(yīng)的列表分片獲取數(shù)據(jù)

r.lrem('oo', 88, num=1) # 在name對應(yīng)的list中刪除指定的值.num=0，刪除列表中所有的指定值；num=2,從前到后，刪除2個(gè)；num=-2,從后向前，刪除2個(gè)
print(r.lrange('oo', 0, -1))

print(r.lpop('oo')) # 在name對應(yīng)的列表的左側(cè)獲取第一個(gè)元素并在列表中移除，返回值則是第一個(gè)元素
print(r.lindex('oo', 0)) # 在name對應(yīng)的列表中根據(jù)索引獲取列表元素
r.lpush('l1', 11) # index為0
r.rpush('l1', 22)
r.rpush('l1', 33)
r.rpush('l1', 44)
r.rpush('l1', 55) # index為4
r.ltrim('l1', 1, 3) # 在name對應(yīng)的列表中移除沒有在[start-end]索引之間的值
print(r.lrange('l1', 0, -1))

r.rpoplpush('l1', 'l1') # 從一個(gè)列表取出最右邊的元素，同時(shí)將其添加至另一個(gè)列表的最左邊;src要取數(shù)據(jù)的列表的name, dst要添加數(shù)據(jù)的列表的name
print(r.lrange('l1', 0, -1))

r.brpoplpush('l1', 'l1', timeout=3) # # timeout，當(dāng)src對應(yīng)的列表中沒有數(shù)據(jù)時(shí)，阻塞等待其有數(shù)據(jù)的超時(shí)時(shí)間（秒），0 表示永遠(yuǎn)阻塞
print(r.lrange('l1', 0, -1))

print(r.blpop('l1', 3)) # 從列表頭部取出第一個(gè)元素，返回該元素值并從列表刪除（l代表left，左邊）
print(r.lrange('l1', 0, -1))
'''
 # 由于redis類庫中沒有提供對列表元素的增量迭代，如果想要循環(huán)name對應(yīng)的列表的所有元素，那么就需要：
 # 1、獲取name對應(yīng)的所有列表
 # 2、循環(huán)列表
 # 但是，如果列表非常大，那么就有可能在第一步時(shí)就將程序的內(nèi)容撐爆，所有有必要自定義一個(gè)增量迭代的功能：
'''
print('自定義增量迭代：')
r.flushall()
r.lpush('l1', 11) # index為0
r.rpush('l1', 22)
r.rpush('l1', 33)
r.rpush('l1', 44)
r.rpush('l1', 55) # index為4

def list_iter(name):
 list_count = r.llen(name)
 for index in range(list_count):
 yield r.lindex(name, index)

for item in list_iter('l1'):
 print(item)

2
[b'0', b'88', b'11']
[b'0', b'11']
b'0'
b'11'
[b'22', b'33', b'44']
[b'44', b'22', b'33']
[b'33', b'44', b'22']
(b'l1', b'33')
[b'44', b'22']
自定義增量迭代：
b'11'
b'22'
b'33'
b'44'
b'55'

#!/usr/bin/python
# -*- coding:utf-8 -*-
# __author__ = 'Jack'

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
r = redis.Redis(connection_pool=pool)
r.flushall() # 清空Redis

r.sadd('s1', 'v1', 'v1', 'v2', 'v3') # name對應(yīng)的集合中添加元素
r.sadd('s2', 'v2', 'v4') # name對應(yīng)的集合中添加元素
print(r.scard('s1')) # 獲取name對應(yīng)的集合中元素個(gè)數(shù)
print(r.sdiff('s1', 's2')) #在第一個(gè)name對應(yīng)的集合中且不在其他name對應(yīng)的集合的元素集合

r.sdiffstore('s3', 's1', 's2') # 獲取第一個(gè)name對應(yīng)的集合中且不在其他name對應(yīng)的集合，再將其新加入到dest對應(yīng)的集合中
print(r.smembers('s3')) # 獲取s3對應(yīng)的集合的所有成員

print(r.sinter('s1', 's2')) # 獲取s1, s2對應(yīng)集合的交集
r.sinterstore('s4', 's1', 's2') # 獲取s1, s2對應(yīng)集合的交集，并將其存放到集合是s4中
print(r.smembers('s4'))

print(r.sunion('s1', 's2')) # 獲取s1, s2對應(yīng)集合的并集

r.sunionstore('s5', 's1', 's2') # 獲取s1, s2對應(yīng)集合的交集，并將其存放到集合是s5中
print(r.smembers('s5'))

print(r.sismember('s4', 'v4')) # 檢查value是否是name對應(yīng)的集合的成員

r.smove('s2', 's1', 'v4') # 將集合s2中成員v4移至集合s1中
print(r.smembers('s1'))
r.srem('s1', 'v1') # 在name對應(yīng)的集合中刪除某些值

print(r.spop('s1')) # 從集合的右側(cè)（尾部）移除一個(gè)成員，并將其返回 注意：集合是無序的，故結(jié)果隨機(jī)！

print(r.srandmember('s1')) # 從name對應(yīng)的集合中隨機(jī)獲取 numbers 個(gè)元素(Redis 2.6+)

3
{b'v3', b'v1'}
{b'v3', b'v1'}
{b'v2'}
{b'v2'}
{b'v3', b'v2', b'v4', b'v1'}
{b'v3', b'v2', b'v4', b'v1'}
False
{b'v3', b'v2', b'v4', b'v1'}
b'v2'
b'v3'

#!/usr/bin/python
# -*- coding:utf-8 -*-
# __author__ = 'Jack'

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
r = redis.Redis(connection_pool=pool)
r.flushall() # 清空Redis

r.zadd('z1', '11', 1, '22', 2, '33', 3, '44', 4, '55', 5, '66', 6, '66', 7) # 在name對應(yīng)的有序集合中添加元素
print(r.zcard('z1')) # 獲取name對應(yīng)的有序集合元素的數(shù)量
print(r.zcount('z1', 1, 2)) # 獲取name對應(yīng)的有序集合中分?jǐn)?shù) 在 [min,max] 之間的個(gè)數(shù)
r.zincrby('z1', '11', amount=5) # 自增name對應(yīng)的有序集合的 name 對應(yīng)的分?jǐn)?shù)
print(r.zrange('z1', 0, -1, desc=False, withscores=True)) # 值11被排序到最后;此處表示按元素的值升序排列

print(r.zrank('z1', 33)) # 獲取某個(gè)值在 name對應(yīng)的有序集合中的排行（從 0 開始）

r.zrem('z1', '66') # 刪除name對應(yīng)的有序集合中值是values的成員
print(r.zrange('z1', 0, -1, desc=False, withscores=True))

r.zremrangebyrank('z1', 0, 1) # 根據(jù)排行范圍刪除
print(r.zrange('z1', 0, -1, desc=False, withscores=True))

r.zremrangebyscore('z1', 4.5, 5.5) # 根據(jù)分?jǐn)?shù)范圍刪除
print(r.zrange('z1', 0, -1, desc=False, withscores=True))

print(r.zscore('z1', 11)) # 獲取name對應(yīng)有序集合中 value 對應(yīng)的分?jǐn)?shù)

r.zadd("zset_name", "a1", 6, "a2", 2, "a3", 5)
r.zadd('zset_name1', a1=7, b1=10, b2=5)
'''
 獲取兩個(gè)有序集合的交集并放入dest集合，如果遇到相同值不同分?jǐn)?shù)，則按照aggregate進(jìn)行操作
 aggregate的值為: SUM MIN MAX
'''
r.zinterstore('zset_name2', ('zset_name', 'zset_name1'), aggregate='Sum')

print(r.zrange('zset_name2', 0, -1, desc=False, withscores=True))

6
2
[(b'22', 2.0), (b'33', 3.0), (b'44', 4.0), (b'55', 5.0), (b'11', 6.0), (b'66', 6.0)]
1
[(b'22', 2.0), (b'33', 3.0), (b'44', 4.0), (b'55', 5.0), (b'11', 6.0)]
[(b'44', 4.0), (b'55', 5.0), (b'11', 6.0)]
[(b'44', 4.0), (b'11', 6.0)]
6.0
[(b'a1', 13.0)]

#!/usr/bin/python
# -*- coding:utf-8 -*-
# __author__ = 'Jack'

pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
r = redis.Redis(connection_pool=pool)
r.flushall() # 清空Redis

r.hset('n1', 'k1', 'v1') # hset(name, key, value),name對應(yīng)的hash中設(shè)置一個(gè)鍵值對（不存在，則創(chuàng)建；否則，修改）
print(r.hget('n1', 'k1'))
r.hmset('n2', {'k1': 'v1', 'k2': 'v2', 'k3': 'v3'}) # hmset(name, mapping),在name對應(yīng)的hash中批量設(shè)置鍵值對
print(r.hmget('n2', 'k2'))
print(r.hgetall('n2')) # 獲取name對應(yīng)hash的所有鍵值
print(r.hlen('n2')) # 獲取name對應(yīng)的hash中鍵值對的個(gè)數(shù)
print(r.hkeys('n2')) # 獲取name對應(yīng)的hash中所有的key的值
print(r.hvals('n2')) # 獲取name對應(yīng)的hash中所有的value的值
print(r.hexists('n2', 'k4')) # 檢查name對應(yīng)的hash是否存在當(dāng)前傳入的key
r.hdel('n2', 'k3') # 將name對應(yīng)的hash中指定key的鍵值對刪除
r.hset('n3', 'k1', 1)
r.hincrby('n3', 'k1', amount=1) # hincrby(name, key, amount=1),自增name對應(yīng)的hash中的指定key的value的值，不存在則創(chuàng)建key=amount
print(r.hgetall('n3'))

b'v1'
[b'v2']
{b'k1': b'v1', b'k2': b'v2', b'k3': b'v3'}
3
[b'k1', b'k2', b'k3']
[b'v1', b'v2', b'v3']
False
{b'k1': b'2'}