update size

video_rank.py

@@ -238,6 +238,7 @@ def video_new_rank(videoIds, fast_flow_set, flow_set, size, top_K, flow_pool_P):
                 if i>= left_quato:
                     break
     print("rank_result:", rank_result)
+    print("add_flow_set:", add_flow_set)
     return rank_result[:size], add_flow_set
 
 

video_recall.py

@@ -2111,18 +2111,18 @@ class PoolRecall(object):
         recall_key = "sim_hot_"+str(self.video_id)
         print("recall_key:", recall_key)
         data = self.redis_helper.get_data_from_redis(key_name=recall_key)
-        print(data)
+        #print(data)
         recall_result = []
         if data is not  None:
             json_result =json.loads(data)
-            print("json_result:", json_result)
+            #print("json_result:", json_result)
             for per_item in json_result:
                 recall_result.append(
                     {'videoId': per_item[0], 'flowPool': '',
                      'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['sim_hot_vid_recall'],
                      'abCode': self.ab_code}
                 )
-        return recall_result
+        return recall_result[:500]
 
     # 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
+        return recall_result[:500]
 
     # 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
+        return recall_result[:500]
 
 
     def get_selected_recall(self, size=4, region_code='-1'):
@@ -2182,15 +2182,15 @@ class PoolRecall(object):
                      'abCode': self.ab_code}
                 )
         #print("recall_result:", recall_result)
-        return recall_result
+        return recall_result[:500]
 
     def get_no_selected_recall(self, size=4, region_code='-1'):
         """未选择召回池召回视频"""
         pool_key_prefix = config_.RECALL_KEY_NAME_PREFIX_DUP3_REGION_24H_H
         recall_key = f"{pool_key_prefix}{region_code}:{self.data_key}:{self.rule_key}"
-        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 = []
         if data is not None:
             json_result = json.loads(data)
@@ -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
+        return recall_result[:500]
 
     def get_fast_flow_pool_recall(self, size=4):
         """快速流量池召回视频"""