all

alg_recsys_recall_undertake.py

@@ -41,13 +41,13 @@ def main():
 
         '广州': '440100', '深圳': '440300', '成都': '510100', '长沙': '430100',
     }
+    keys = []
     for _, code in REGION_CODE.items():
         read_key = "recall:item:score:region:h:{}:data66:rule66:{}:{}".format(code, date, hour)
-        value = redis_helper.get_data_from_set(read_key)
-        print(read_key)
-        print(value)
+        keys.append(read_key)
         write_key = "recall:item:score:region:h:{}:data66:rule66:{}:{}".format(code, date_next, hour_next)
-        print(write_key)
+    value = redis_helper.get_data_from_set(set(keys))
+    print(str(value))
 
     # records_process_for_list(result, process_and_store, max_size=50, num_workers=8)
     log_.info("完成执行:" + datetime.now().strftime("%Y-%m-%d %H:%M:%S"))