update

recommend.py

@@ -479,7 +479,7 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
 
     result['recallResult'] = recall_result_list
     result['recallTime'] = (time.time() - start_recall) * 1000
-    print("recall:", recall_result_list)
+    #print("recall:", recall_result_list)
     # ####### 排序
     start_rank = time.time()
     # log_.info('====== rank')
@@ -518,7 +518,7 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
     #if ab_code=="ab_new_test":
     #print("before data:", data)
     rank_result = video_new_rank2(data=data, size=size, top_K=top_K, flow_pool_P=float(flow_pool_P), ab_code=ab_code)
-    print(rank_result)
+    #print(rank_result)
 
     result['rankResult'] = rank_result
     result['rankTime'] = (time.time() - start_rank) * 1000

video_recall.py

@@ -2142,7 +2142,7 @@ class PoolRecall(object):
                 try:
                     vid = int(per_item[0])
                     video_ids.append(vid)
-                    recall_dict[vid] = {'videoId': per_item[0], 'flowPool': '',
+                    recall_dict[vid] = {'videoId': vid, 'flowPool': '',
                          'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['sim_hot_vid_recall'],
                          'abCode': self.ab_code}
                 except Exception as e:
@@ -2368,10 +2368,10 @@ class PoolRecall(object):
         if self.video_id is None:
             return  []
         recall_key = "hot_3day:"
-        print("recall_key:", recall_key)
+        #print("recall_key:", recall_key)
         data = self.redis_helper.get_data_from_redis(key_name=recall_key)
 
-        print(data)
+        #print(data)
         recall_result = []
         recall_dict  = {}
         video_ids = []
@@ -2387,7 +2387,7 @@ class PoolRecall(object):
                          'abCode': self.ab_code}
                 except Exception as e:
                     continue
-        print("vid len:", len(video_ids))
+        #print("vid len:", len(video_ids))
         if len(video_ids)<=0:
             return  recall_result
         video_ids = video_ids[:50]
@@ -2397,22 +2397,22 @@ class PoolRecall(object):
         filtered_viewed_videos = filter_.filter_videos(pool_type='rov')
         if filtered_viewed_videos is None:
             return recall_result
-        print("filtered_viewed_videos:", filtered_viewed_videos)
+        #print("filtered_viewed_videos:", filtered_viewed_videos)
         for vid in filtered_viewed_videos:
             if vid in recall_dict:
                 recall_result.append(recall_dict[vid])
-        print("hot recall_result:", recall_result)
-        print("recall_dict:", recall_dict)
+        #print("hot recall_result:", recall_result)
+        #print("recall_dict:", recall_dict)
         return recall_result
 
     def get_7days_hot_item_reall(self):
         if self.video_id is None:
             return  []
         recall_key = "hot_7day:"
-        print("recall_key:", recall_key)
+        #print("recall_key:", recall_key)
         data = self.redis_helper.get_data_from_redis(key_name=recall_key)
 
-        print(data)
+        #print(data)
         recall_result = []
         recall_dict  = {}
         video_ids = []
@@ -2441,5 +2441,5 @@ class PoolRecall(object):
         for vid in filtered_viewed_videos:
             if vid in recall_dict:
                 recall_result.append(recall_dict[vid])
-        print("hot recall_result:", recall_result)
+        #print("hot recall_result:", recall_result)
         return recall_result