离线检查redis的数量

alg_recsys_coldstart_offlinecheck.py

@@ -31,7 +31,7 @@ def main():
             if not result:
                 result = []
             size = len(result)
-            log_str = "\t".join([date_cur, level, str(size)])
+            log_str = "\t".join([date_cur, "4", level, str(size)])
             print(log_str)
         for level in ["1", "2", "3", "4"]:
             key = "flow:pool:level:item:0:" + level
@@ -39,7 +39,15 @@ def main():
             if not result:
                 result = []
             size = len(result)
-            log_str = "\t".join([date_cur, level, str(size)])
+            log_str = "\t".join([date_cur, "0", level, str(size)])
+            print(log_str)
+        for level in ["1", "2", "3", "4"]:
+            key = "flow:pool:level:item:21:" + level
+            result = redis_helper.get_data_from_set(key)
+            if not result:
+                result = []
+            size = len(result)
+            log_str = "\t".join([date_cur, "21", level, str(size)])
             print(log_str)
         time.sleep(30)
         # date_write = datetime.now().strftime("%Y-%m-%d %H:%M")