|
|
@@ -694,21 +694,25 @@ def video_sanke_rank(data, size, top_K, flow_pool_P, ab_Code=''):
|
|
|
if item.get('pushFrom') == config_.PUSH_FROM['rov_recall_region_h']]
|
|
|
region_h_recall_rank = sorted(region_h_recall, key=lambda k: k.get('rovScore', 0), reverse=True)
|
|
|
recall_dict['rov_recall_region_h'] = region_h_recall_rank
|
|
|
+ print("rov_recall_region_h:", len(rov_recall_region_h))
|
|
|
# 地域分组小时级更新24h规则更新数据
|
|
|
region_24h_recall = [item for item in data['rov_pool_recall']
|
|
|
if item.get('pushFrom') == config_.PUSH_FROM['rov_recall_region_24h']]
|
|
|
region_24h_recall_rank = sorted(region_24h_recall, key=lambda k: k.get('rovScore', 0), reverse=True)
|
|
|
recall_dict['rov_recall_region_24h'] = region_24h_recall_rank
|
|
|
+ print("rov_recall_region_24h:", len(region_24h_recall_rank))
|
|
|
|
|
|
# 相对24h规则更新数据
|
|
|
rule_24h_recall = [item for item in data['rov_pool_recall']
|
|
|
if item.get('pushFrom') == config_.PUSH_FROM['rov_recall_24h']]
|
|
|
rule_24h_recall_rank = sorted(rule_24h_recall, key=lambda k: k.get('rovScore', 0), reverse=True)
|
|
|
+ print("rov_recall_24h:", len(rule_24h_recall_rank))
|
|
|
recall_dict['rov_recall_24h'] = rule_24h_recall_rank
|
|
|
# 相对24h规则筛选后剩余更新数据
|
|
|
rule_24h_dup_recall = [item for item in data['rov_pool_recall']
|
|
|
if item.get('pushFrom') == config_.PUSH_FROM['rov_recall_24h_dup']]
|
|
|
rule_24h_dup_recall_rank = sorted(rule_24h_dup_recall, key=lambda k: k.get('rovScore', 0), reverse=True)
|
|
|
+ print("rov_recall_24h_dup:", len(rule_24h_dup_recall_rank))
|
|
|
recall_dict['rov_recall_24h_dup'] = rule_24h_dup_recall_rank
|
|
|
hot_recall = []
|
|
|
w2v_recall =[]
|
linfan