- import redis
- import hiredis
- pool = redis.ConnectionPool(host='127.0.0.1', port=6379, db=0)
- r = redis.Redis(connection_pool=pool)
- pipe = r.pipeline()
- pipe_size = 100000
- len = 0
- key_list = []
- for key in r.scan_iter(match='PREFIX_*', count=100000):
- key_list.append(key)
- pipe.get(key)
- if len < pipe_size:
- len += 1
- else:
- for (k, v) in zip(key_list, pipe.execute()):
- print k, v
- len = 0
- key_list = []
- for (k, v) in zip(key_list, pipe.execute()):
- print k, v
- #该片段来自于http://www.codesnippet.cn/detail/1905201512594.html
来源: http://www.codesnippet.cn/detail/1905201512594.html