all

alg_recsys_recall_undertake.py

@@ -16,7 +16,7 @@ redis_helper = RedisHelper()
 def main():
     log_.info("开始执行:" + datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
     #1 读取当前时间及上一时间
-    now_date = datetime.today()# - timedelta(hours=1)
+    now_date = datetime.today() # - timedelta(hours=1)
     hour = datetime.strftime(now_date, '%H').lstrip('0')
     date = datetime.strftime(now_date, '%Y%m%d')
     if hour == "":
@@ -48,13 +48,13 @@ def main():
         values = redis_helper.get_data_zset_with_index(read_key, 0, -1, True, True)
         print(str(read_key))
         print(str(values))
-        new_kvs = {}
-        for k, v in values:
-            new_kvs[k] = v
-        write_key = "recall:item:score:region:h:{}:data66:rule66:{}:{}".format(code, date_next, hour_next)
-        redis_helper.add_data_with_zset(write_key, new_kvs)
-        print(str(write_key))
-        break
+        if values and len(values) > 0:
+            new_kvs = {}
+            for k, v in values:
+                new_kvs[k] = v
+            write_key = "recall:item:score:region:h:{}:data66:rule66:{}:{}".format(code, date_next, hour_next)
+            redis_helper.add_data_with_zset(write_key, new_kvs)
+            print(str(write_key))
 
 
     # records_process_for_list(result, process_and_store, max_size=50, num_workers=8)