Redis中redis

107次阅读
没有评论

共计 2163 个字符,预计需要花费 6 分钟才能阅读完成。

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

需要从 redis-cluster 中删除指定的 key
循环每个主节点的版本:[root@ip-172-31-39-42 ~]# more delkey-single.py

# encoding: utf-8

import redis

import random

import string

import rediscluster

import time

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]

def del_keys_without_pipe(newhost):

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

 r = redis.StrictRedis(connection_pool=pool)

 start_time = time.time()

 result_length = 0

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

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

 print key

   #       r.delete(key)

 result_length += 1

 print normal ways end at: , time.time() – start_time

 print newhost, normal ways delete numbers: , result_length

for i in all_nodes:

 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

链接集群版本 [root@ip-172-31-39-42 ~]# more delkey-cluster.py

# encoding: utf-8

import redis

import random

import string

import rediscluster

import time

def del_keys_without_pipe():

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

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

 start_time = time.time()

 result_length = 0

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

    #        r.delete(key)

 result_length += 1

 print normal ways end at: , time.time() – start_time

 print normal ways delete numbers: , result_length

del_keys_without_pipe()

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

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-07-24发表,共计2163字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)