离线检查redis的数量

alg_recsys_coldstart_offlinecheck.py

@@ -18,7 +18,7 @@ def main():
     date_write = ""
     while True:
         date_cur = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-        if "2024-05-07 16:3" in date_cur:
+        if "2024-05-07 20:3" in date_cur:
             print("退出")
             break
         # if date_write == date_cur:
@@ -33,6 +33,14 @@ def main():
             size = len(result)
             log_str = "\t".join([date_cur, level, str(size)])
             print(log_str)
+        for level in ["1", "2", "3", "4"]:
+            key = "flow:pool:level:item:0:" + level
+            result = redis_helper.get_data_from_set(key)
+            if not result:
+                result = []
+            size = len(result)
+            log_str = "\t".join([date_cur, level, str(size)])
+            print(log_str)
         time.sleep(30)
         # date_write = datetime.now().strftime("%Y-%m-%d %H:%M")