update update new rank

recommend.py

@@ -419,7 +419,7 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
                 'flow_pool_recall': recall_result_list[2]
             }
     #if ab_code=="ab_new_test":
-    print("before data:", data)
+    #print("before data:", data)
     rank_result = video_new_rank2(data=data, size=size, top_K=top_K, flow_pool_P=float(flow_pool_P))
     #print(rank_result)
 
@@ -1587,12 +1587,12 @@ 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)
-    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)
+    # 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_rank.py

@@ -613,9 +613,9 @@ def video_new_rank2(data, size, top_K, flow_pool_P):
         vid = recall_item.get("videoId",0)
         vidKeys.append("k_p:" + str(vid))
         recall_list.append(recall_item)
-    print("vidKeys:", vidKeys)
+    #print("vidKeys:", vidKeys)
     video_scores = redisObj.get_batch_key(vidKeys)
-    print("video_score:",video_scores)
+    #print("video_score:",video_scores)
     for i in range(len(video_scores)):
          try:
             # print(video_scores[i])
@@ -623,7 +623,7 @@ def video_new_rank2(data, size, top_K, flow_pool_P):
                 recall_list[i]['sort_score']= 0.0
             else:
                 video_score_str = json.loads(video_scores[i])
-                print("video_score_str:", video_score_str)
+                #print("video_score_str:", video_score_str)
                 recall_list[i]['sort_score'] = video_score_str[0]
          except Exception :
                 recall_list[i]['sort_score'] = 0.0