1 #coding:utf8
 2 import redis
 3 import json
 4
 5
 6 '''
 7 用于备份zset，zset分两种：score值唯一的zset、score值不唯一的zset
 8 使用时注意：不要在备份的同时对old_key执行添加和删除操作
 9 '''
10
11 redis1 = redis.StrictRedis.from_url("redis地址")
12 old_key = 'old_zset_name'
13 new_key = 'new_zset_name'
14
15
16 def zset_to_zset():
17     total = redis1.zcard(old_key)
18     start = 0
19     step = 10000
20     while start < total:
21         print start
22         end = start + step - 1
23         if end > total:
24             end = total
25         lis = redis1.zrange(old_key, start, end)
26         if lis:
27             dic = dict().fromkeys(lis, 0)
28             redis1.zadd(new_key, **dic)
29         start += step
30     # redis1.delete(old_key)
31     print 'all finished!'
32
33 def export_to_list(score, error_name):
34     total = redis1.zcount(old_key, score, score)                # 查询对应score值的链接数量
35     start = 0
36     step = 10000
37     while start < total:
38         print start
39         url_list = redis1.zrangebyscore(old_key, score, score, start, step)
40         if url_list:
41             dic = dict().fromkeys(url_list, int(score))
42             redis1.zadd(new_key, **dic)
43         start += step
44
45 def copy_error():
46     error_dic = redis1.hget('hash_dic', old_key)
47     error_dic = json.loads(error_dic)
48     for score, error_name in error_dic.items():
49         export_to_list(score, error_name)
50     error_dic = json.dumps(error_dic)
51     redis1.hset('hash_dic', new_key, error_dic)          # 将new_key存到hash中
52     # redis1.delete(old_key)
53     print 'all finished!'
54
55 if __name__ == '__main__':
56     # zset_to_zset()    # score值唯一的zset备份
57     copy_error()        # score值不唯一的zset备份

1 1 time false
2 2 geo false
3 3 startDate false