redis清理

test/get_redis_keys_hash.py

@@ -3,6 +3,7 @@ import json
 import time
 import pymysql
 from rediscluster import StrictRedisCluster
+import numpy as np
 # def getRedisConn():
 #     conn = redis.Redis(host="172.18.51.10", port=6379,db=0)
 #     conn.execute_command()
@@ -269,31 +270,25 @@ for search_key in search_keys:
         node_key_count = 0
         node_del_key_list = []
         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,10000,node))
             node_key_count += len(keys)
             cursor = str(cursor,encoding='utf-8')
 
             pipline = conn.pipeline()
-
             for key in keys:
                 key = str(key, encoding='utf-8')
                 pipline.object('idletime', key)
-                # idletime = conn.object('idletime', key)
-                # if idletime > 2592000:
-                #     node_del_key_set.add(key)
 
             idletime_list = pipline.execute()
             for idx,idletime in enumerate(idletime_list):
                 if idletime > 2592000:
                     node_del_key_list.append(keys[idx])
 
-            # print("idletime_list:{}".format(idletime_list))
-
-            # break
-
             if cursor == "0":
                 break
+
         print("node: {}, cursor: {}, node_key_count: {}, node_del_key_count: {}".format(node, cursor, node_key_count, len(node_del_key_list)))
+        print("node: {}, node_del_key_sample_100: {}".format(node, np.random.choice(node_del_key_list, 50, replace= False)))
         print("")
 #
 #     nodes = ['7877da182171e313bc9326729f82999d1b629c79'