|
|
@@ -2109,7 +2109,7 @@ class PoolRecall(object):
|
|
|
#linfan
|
|
|
def get_sim_hot_item_reall(self):
|
|
|
recall_key = "sim_hot_"+str(self.video_id)
|
|
|
- print("recall_key:", recall_key)
|
|
|
+ #print("recall_key:", recall_key)
|
|
|
data = self.redis_helper.get_data_from_redis(key_name=recall_key)
|
|
|
#print(data)
|
|
|
recall_result = []
|
|
|
@@ -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[:500]
|
|
|
+ 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[:500]
|
|
|
+ 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[:500]
|
|
|
+ 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[:500]
|
|
|
+ return recall_result[:200]
|
|
|
|
|
|
def get_no_selected_recall(self, size=4, region_code='-1'):
|
|
|
"""未选择召回池召回视频"""
|
|
|
@@ -2201,16 +2201,13 @@ class PoolRecall(object):
|
|
|
'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['rov_recall_24h_dup'],
|
|
|
'abCode': self.ab_code}
|
|
|
)
|
|
|
- return recall_result[:500]
|
|
|
+ return recall_result[:200]
|
|
|
|
|
|
def get_fast_flow_pool_recall(self, size=4):
|
|
|
"""快速流量池召回视频"""
|
|
|
recall_key = f"{config_.QUICK_FLOWPOOL_KEY_NAME_PREFIX}{self.app_type}:{config_.QUICK_FLOW_POOL_ID}"
|
|
|
|
|
|
- #recall_key = "recall:item:score:region:dup3:24h:" :{data_key}: {rule_key}
|
|
|
- print("recall_key:", recall_key)
|
|
|
data = self.redis_helper.get_data_from_redis(key_name=recall_key)
|
|
|
- print(data)
|
|
|
recall_result = []
|
|
|
if data is not None:
|
|
|
json_result = json.loads(data)
|
linfan