linfan há 1 ano atrás
pai
commit
5217b82fb5
2 ficheiros alterados com 6 adições e 12 exclusões
  1. 3 5
      recommend.py
  2. 3 7
      video_recall.py

+ 3 - 5
recommend.py

@@ -364,6 +364,8 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
     # ####### 多进程召回
     start_recall = time.time()
     # log_.info('====== recall')
+
+    #print("abcode",ab_code)
     recall_result_list = []
     pool_recall = PoolRecall(request_id=request_id,
                              app_type=app_type, mid=mid, uid=uid, ab_code=ab_code,
@@ -382,9 +384,6 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
         t = [gevent.spawn(pool_recall.rov_pool_recall_with_region, size, expire_time),
              gevent.spawn(pool_recall.flow_pool_recall, size, config_.QUICK_FLOW_POOL_ID),
              gevent.spawn(pool_recall.flow_pool_recall, size)]
-        # if ab_code == 60052:
-        #     t.append(pool_recall.get_title_recall)
-        # el
         if  ab_code == 60054:
             t.append(gevent.spawn(pool_recall.get_sim_hot_item_reall_filter))
         if ab_code == 60055:
@@ -1553,8 +1552,7 @@ def video_homepage_recommend(request_id, mid, uid, size, app_type, algo_type,
     # simrecal: 60054
     # 3 days , 7days recall: 60005, test1
     # old video: 60056, test2
-    elif ab_code == 60052 or ab_code == 60053 or ab_code == 60054 or ab_code == 60055 or ab_code == 60056 \
-            or ab_code==60057:
+    elif ab_code == 60052 or ab_code == 60053 or ab_code == 60054 or ab_code == 60055 or ab_code == 60056 or ab_code==60057:
         result = video_old_recommend(request_id=request_id,
                                      mid=mid, uid=uid, app_type=app_type,
                                      size=size, top_K=top_K, flow_pool_P=flow_pool_P,

+ 3 - 7
video_recall.py

@@ -2365,13 +2365,11 @@ class PoolRecall(object):
         return flow_pool_recall_result[:size]
 
     def get_3days_hot_item_reall(self):
-        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 = []
@@ -2402,12 +2400,10 @@ class PoolRecall(object):
             if vid in recall_dict:
                 recall_result.append(recall_dict[vid])
         #print("hot recall_result:", recall_result)
-        print("recall_dict:", recall_dict)
+        #print("recall_dict:", recall_dict)
         return recall_result
 
     def get_hot_item_reall(self):
-        if self.video_id is None:
-            return  []
         recall_key = "hot_video:"
         #print("recall_key:", recall_key)
         data = self.redis_helper.get_data_from_redis(key_name=recall_key)