离线检查redis的数量

alg_recsys_coldstart_offlinecheck.py

@@ -16,23 +16,23 @@ redis_helper = RedisHelper()
 
 def main():
     date_write = ""
-    while True:
-        date_cur = datetime.now().strftime("%Y-%m-%d %H:%M")
-        if "2024-05-07 15:2" in date_cur:
-            break
-        if date_write == date_cur:
-            time.sleep(5)
-            continue
-
-        for level in ["1", "2", "3", "4"]:
-            key = "flow:pool:level:item:4:" + 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)
-        date_write = datetime.now().strftime("%Y-%m-%d %H:%M")
+    # while True:
+    date_cur = datetime.now().strftime("%Y-%m-%d %H:%M")
+    # if "2024-05-07 15:2" in date_cur:
+    #     break
+    # if date_write == date_cur:
+    #     time.sleep(5)
+    #     continue
+
+    for level in ["1", "2", "3", "4"]:
+        key = "flow:pool:level:item:4:" + 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)
+    date_write = datetime.now().strftime("%Y-%m-%d %H:%M")
 
 
 if __name__ == '__main__':