离线检查redis的数量

alg_recsys_coldstart_offlinecheck.py

@@ -16,23 +16,24 @@ 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" in date_cur:
+            break
+        # if date_write == date_cur:
+        #     time.sleep(10)
+        #     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)
+        time.sleep(20)
+        # date_write = datetime.now().strftime("%Y-%m-%d %H:%M")
 
 
 if __name__ == '__main__':