update

recommend.py

@@ -1796,15 +1796,15 @@ def video_relevant_recommend(request_id, video_id, mid, uid, size, app_type, ab_
 
     # redis数据刷新
     update_redis_st = time.time()
-    if ab_code == 60047 or ab_code == 60048 or  ab_code == 60049:
-         update_flow_redis_data(result=rank_result, app_type=app_type, mid=mid, top_K=top_K)
-    elif ab_code == 60050 or ab_code == 60051:
-         update_redis_data(result=rank_result, app_type=app_type, mid=mid, top_K=top_K)
-    elif ab_code == 60052 or ab_code == 60053 or ab_code == 60054 or ab_code == 60055 or \
-            ab_code == 60056 or ab_code==60057:
-         update_redis_data(result=rank_result, app_type=app_type, mid=mid, top_K=top_K)
-    else:
-         update_redis_data(result=rank_result, app_type=app_type, mid=mid, top_K=top_K)
+    # if ab_code == 60047 or ab_code == 60048 or  ab_code == 60049:
+    #      update_flow_redis_data(result=rank_result, app_type=app_type, mid=mid, top_K=top_K)
+    # elif ab_code == 60050 or ab_code == 60051:
+    #      update_redis_data(result=rank_result, app_type=app_type, mid=mid, top_K=top_K)
+    # elif ab_code == 60052 or ab_code == 60053 or ab_code == 60054 or ab_code == 60055 or \
+    #         ab_code == 60056 or ab_code==60057:
+    #      update_redis_data(result=rank_result, app_type=app_type, mid=mid, top_K=top_K)
+    # else:
+    #      update_redis_data(result=rank_result, app_type=app_type, mid=mid, top_K=top_K)
     # log_.info({
     #     'logTimestamp': int(time.time() * 1000),
     #     'request_id': request_id,

video_recall.py

@@ -1904,6 +1904,7 @@ class PoolRecall(object):
         else:
             return []
         # 获取相关redis key, 用户上一次在rov召回池对应的位置
+        print("recall_name:", key_flag,"last_video_key_prefix:", last_video_key_prefix)
         pool_key, idx = self.get_last_recommend_video_idx(province_code=province_code,
                                                           record_key_prefix=record_key_prefix,
                                                           pool_key_prefix=pool_key_prefix,
@@ -1966,6 +1967,7 @@ class PoolRecall(object):
             last_video_key = f'{last_video_key_prefix}{self.app_type}:{self.mid}'
             self.redis_helper.set_data_to_redis(key_name=last_video_key, value=recall_data[-1][0],
                                                 expire_time=expire_time)
+            print("update recall_data:", key_flag, "last_video_key_prefix:", last_video_key_prefix)
 
         # log_.info({
         #     'logTimestamp': int(time.time() * 1000),