Redis中redis-cluster如何删除指定的key

这篇文章主要为大家展示了“redis中redis-cluster如何删除指定的key”，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让小编带领大家一起研究并学习一下“Redis中redis-cluster如何删除指定的key”这篇文章吧。

创新互联坚持“要么做到，要么别承诺”的工作理念，服务领域包括：做网站、网站制作、企业官网、英文网站、手机端网站、网站推广等服务，满足客户于互联网时代的顺昌网站设计、移动媒体设计的需求，帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴！

需要从redis-cluster中删除指定的key

循环每个主节点的版本：

1. [root@ip-172-31-39-42 ~]# more delkey-single.py

2. # encoding: utf-8

4. import redis

5. import random

6. import string

7. import rediscluster

8. import time

9. all_nodes=['172.31.39.42','172.31.36.10','172.31.47.157','172.31.36.49','172.31.40.169','172.31.32.234']

12. def del_keys_without_pipe(newhost):

13.     pool = redis.ConnectionPool(host=newhost, port=6379, db=0,password='inH7HkD7iXoxKZCi')

14.     r = redis.StrictRedis(connection_pool=pool)

15.     start_time = time.time()

16.     result_length = 0

17.     for key in r.scan_iter(match='user:*:type:*:news:msg', count=100):

18.         if r.ttl(key) == -1:     如果未设置过期时间

19.            print key

20.    #       r.delete(key)

21.         result_length += 1

22.     print "normal ways end at:", time.time() - start_time

23.     print newhost,"normal ways delete numbers:", result_length

24. for i in all_nodes:

25.         del_keys_without_pipe(i)

注意：循环链接只能去链接主节点，如果链接从节点会报以下的错误：
>>> for key in r.scan_iter(count=10):
...     if r.ttl(key) == -1:
...        print key
... 
Traceback (most recent call last):
  File "", line 2, in
  File "/usr/lib/python2.7/site-packages/redis/client.py", line 1231, in ttl
    return self.execute_command('TTL', name)
  File "/usr/lib/python2.7/site-packages/redis/client.py", line 668, in execute_command
    return self.parse_response(connection, command_name, **options)
  File "/usr/lib/python2.7/site-packages/redis/client.py", line 680, in parse_response
    response = connection.read_response()
  File "/usr/lib/python2.7/site-packages/redis/connection.py", line 629, in read_response
    raise response
redis.exceptions.ResponseError: MOVED 12752 172.31.32.234:6379

链接集群版本

1. [root@ip-172-31-39-42 ~]# more delkey-cluster.py

2. # encoding: utf-8

4. import redis

5. import random

6. import string

7. import rediscluster

8. import time

11. def del_keys_without_pipe():

12.     startup_nodes = [{"host": "172.31.39.42", "port": 6379,"db":0}]

13.     r = rediscluster.StrictRedisCluster(startup_nodes=startup_nodes, password='inH7HkD7iXoxKZCi')

14.     start_time = time.time()

15.     result_length = 0

16.     for key in r.scan_iter(match='user:*:type:*:news:msg', count=100):

17.     #        r.delete(key)

18.         result_length += 1

19.     print "normal ways end at:", time.time() - start_time

20.     print "normal ways delete numbers:", result_length

22. del_keys_without_pipe()

以上是“Redis中redis-cluster如何删除指定的key”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注创新互联行业资讯频道！