simrecall

recommend.py

@@ -381,7 +381,7 @@ def new_video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
     if region_code == '':
         region_code = '-1'
     
-    print("region_code:", region_code)
+    #print("region_code:", region_code)
 
     #size =1000
     pool_recall = PoolRecall(request_id=request_id,
@@ -411,7 +411,7 @@ def new_video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
     all_recall_result = []
     #print(all_recall_result_list)
     result['recallTime'] = (time.time() - start_recall) * 1000
-    print("recall time:", result['recallTime'])
+    #print("recall time:", result['recallTime'])
     if not all_recall_result_list or len(all_recall_result_list)==0:
         return result
     for recall_item in all_recall_result_list:
@@ -471,7 +471,7 @@ def new_video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
         except:
             continue
     #print("recall_dict:", recall_dict)
-    print("recall time:", (time.time()-dup_time)*1000)
+    #print("recall time:", (time.time()-dup_time)*1000)
     #3. filter video, 先过预曝光
     filter_time = time.time()
     filter_ = FilterVideos(request_id=request_id,
@@ -482,7 +482,7 @@ def new_video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
     #all_recall_list = list(recall_dict.keys())
     all_recall_list = filter_.filter_videos_new(region_code=region_code, shield_config=shield_config, flow_set=flowFlag_dict.keys())
     #print("filer after:", all_recall_list)
-    print("filter_ time:", (time.time() - filter_time) * 1000)
+    #print("filter_ time:", (time.time() - filter_time) * 1000)
     #4. sort: old sort: flow 按概率出
     start_rank = time.time()
     #quick_flow_pool_P get from redis
@@ -516,7 +516,7 @@ def new_video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
 
     result['rankResult'] = rank_result
     result['rankTime'] = (time.time() - start_rank) * 1000
-    print("rank time:", result['rankTime'])
+    #print("rank time:", result['rankTime'])
     return result
     # return rank_result, last_rov_recall_key
 

video_recall.py

@@ -2122,7 +2122,7 @@ class PoolRecall(object):
                      'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['sim_hot_vid_recall'],
                      'abCode': self.ab_code}
                 )
-        return recall_result[:100]
+        return recall_result[:200]
 
     # get region_hour_recall
     def get_region_hour_recall(self, size=4, region_code='-1'):
@@ -2141,7 +2141,7 @@ class PoolRecall(object):
                      'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['rov_recall_region_h'],
                      'abCode': self.ab_code}
                 )
-        return recall_result[:100]
+        return recall_result[:200]
 
     # get region_day_recall
     def get_region_day_recall(self, size=4,region_code='-1'):
@@ -2161,7 +2161,7 @@ class PoolRecall(object):
                      'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['rov_recall_region_24h'],
                      'abCode': self.ab_code}
                 )
-        return recall_result[:100]
+        return recall_result[:200]
 
 
     def get_selected_recall(self, size=4, region_code='-1'):
@@ -2182,7 +2182,7 @@ class PoolRecall(object):
                      'abCode': self.ab_code}
                 )
         #print("recall_result:", recall_result)
-        return recall_result[:100]
+        return recall_result[:200]
 
     def get_no_selected_recall(self, size=4, region_code='-1'):
         """未选择召回池召回视频"""
@@ -2201,7 +2201,7 @@ class PoolRecall(object):
                      'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['rov_recall_24h_dup'],
                      'abCode': self.ab_code}
                 )
-        return recall_result[:100]
+        return recall_result[:200]
 
     def get_fast_flow_pool_recall(self, size=4):
         """快速流量池召回视频"""