Commit d01bb7f7 authored by 宋柯's avatar 宋柯

redis清理

parent 6395d4a5
...@@ -267,7 +267,7 @@ for search_key in search_keys: ...@@ -267,7 +267,7 @@ for search_key in search_keys:
for node in nodes: for node in nodes:
cursor = "0" cursor = "0"
node_key_count = 0 node_key_count = 0
node_del_key_set = set() node_del_key_list = []
while True: while True:
cursor, keys = conn.execute_command("scan {} match {} count {} {}".format(cursor,search_key,2000,node)) cursor, keys = conn.execute_command("scan {} match {} count {} {}".format(cursor,search_key,2000,node))
node_key_count += len(keys) node_key_count += len(keys)
...@@ -285,7 +285,7 @@ for search_key in search_keys: ...@@ -285,7 +285,7 @@ for search_key in search_keys:
idletime_list = pipline.execute() idletime_list = pipline.execute()
for idx,idletime in enumerate(idletime_list): for idx,idletime in enumerate(idletime_list):
if idletime > 2592000: if idletime > 2592000:
node_del_key_set.add(keys[idx]) node_del_key_list.append(keys[idx])
# print("idletime_list:{}".format(idletime_list)) # print("idletime_list:{}".format(idletime_list))
...@@ -293,7 +293,7 @@ for search_key in search_keys: ...@@ -293,7 +293,7 @@ for search_key in search_keys:
if cursor == "0": if cursor == "0":
break break
print("node: {}, cursor: {}, node_key_count: {}, node_del_key_count: {}".format(node, cursor, node_key_count, len(node_del_key_set))) print("node: {}, cursor: {}, node_key_count: {}, node_del_key_count: {}".format(node, cursor, node_key_count, len(node_del_key_list)))
print("") print("")
# #
# nodes = ['7877da182171e313bc9326729f82999d1b629c79' # nodes = ['7877da182171e313bc9326729f82999d1b629c79'
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment