redis清理

test/get_redis_keys_hash.py

@@ -254,7 +254,8 @@ nodes=['7877da182171e313bc9326729f82999d1b629c79'
        ,'f3f1ec6df458a5093c31663517a3cadaed5ab29c'
        ,'d35c630aad0a8b7f579bf4100f2860401b5d4f52']
 # keys = ['rims:tag_v3:coldstart:','doris:tag_v3:coldstart:']
-search_keys = ['strategy:city_tag_id:device_id:']
+search_keys = ['']
+do_delete = False
 # conn2 = getRedisConn2()
 for search_key in search_keys:
     search_key = search_key + '*'
@@ -292,18 +293,19 @@ for search_key in search_keys:
         print("node: {}, cursor: {}, node_key_count: {}, node_del_key_count: {}, node_del_key_rate: {}%".format(node, cursor, node_key_count, node_del_key_count, 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)))
 
-        node_del_batch_size = 10000
-        node_has_del_key_count = 0
-        for batch_start_idx in range(0,node_del_key_count, node_del_batch_size):
-            node_del_key_batch_list = node_del_key_list[batch_start_idx : batch_start_idx + node_del_batch_size]
-            pipline = conn.pipeline()
-            for node_del_key in node_del_key_batch_list:
-                pipline.delete(node_del_key)
-                # pass
-            pipline.execute()
-            node_has_del_key_count += len(node_del_key_batch_list)
-            print("node: {}, node_has_del_key_count: {}, node_del_key_count: {}, node_has_del_key_rate: {}%".format(node, node_has_del_key_count, node_del_key_count, 100 * node_has_del_key_count / node_del_key_count))
-            print("node: {}, node_has_del_key_batch_sample_50: {}".format(node, np.random.choice(node_del_key_batch_list, 50, replace= False)))
+        if do_delete:
+            node_del_batch_size = 10000
+            node_has_del_key_count = 0
+            for batch_start_idx in range(0,node_del_key_count, node_del_batch_size):
+                node_del_key_batch_list = node_del_key_list[batch_start_idx : batch_start_idx + node_del_batch_size]
+                pipline = conn.pipeline()
+                for node_del_key in node_del_key_batch_list:
+                    pipline.delete(node_del_key)
+                    # pass
+                pipline.execute()
+                node_has_del_key_count += len(node_del_key_batch_list)
+                print("node: {}, node_has_del_key_count: {}, node_del_key_count: {}, node_has_del_key_rate: {}%".format(node, node_has_del_key_count, node_del_key_count, 100 * node_has_del_key_count / node_del_key_count))
+                print("node: {}, node_has_del_key_batch_sample_50: {}".format(node, np.random.choice(node_del_key_batch_list, 50, replace= False)))
 
         print("")
 #