redis清理

test/get_redis_keys_hash.py

@@ -254,7 +254,7 @@ nodes=['7877da182171e313bc9326729f82999d1b629c79'
        ,'f3f1ec6df458a5093c31663517a3cadaed5ab29c'
        ,'d35c630aad0a8b7f579bf4100f2860401b5d4f52']
 # keys = ['rims:tag_v3:coldstart:','doris:tag_v3:coldstart:']
-search_keys = ['']
+search_keys = ['strategy:city_tag_id:device_id:']
 # conn2 = getRedisConn2()
 for search_key in search_keys:
     search_key = search_key + '*'
@@ -271,12 +271,13 @@ for search_key in search_keys:
         node_del_key_list = []
         while True:
             cursor, keys = conn.execute_command("scan {} match {} count {} {}".format(cursor,search_key,10000,node))
+            keys = list(map(lambda key:str(key, encoding='utf-8'),keys))
+
             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_list = pipline.execute()
@@ -287,7 +288,7 @@ for search_key in search_keys:
             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: {}, cursor: {}, node_key_count: {}, node_del_key_count: {}, node_del_key_rate: {}%".format(node, cursor, node_key_count, len(node_del_key_list), 100 * len(node_del_key_list) / node_key_count))
         print("node: {}, node_del_key_sample_100: {}".format(node, np.random.choice(node_del_key_list, 50, replace= False)))
         print("")
 #