|
@@ -173,9 +173,9 @@ def video_rank_h(df, now_date, now_h, rule_key, param, app_type, data_key):
|
|
f"{config_.RECALL_KEY_NAME_PREFIX_BY_24H}{app_type}.{data_key}.{rule_key}.{now_dt}.{now_h}"
|
|
f"{config_.RECALL_KEY_NAME_PREFIX_BY_24H}{app_type}.{data_key}.{rule_key}.{now_dt}.{now_h}"
|
|
if len(day_recall_result) > 0:
|
|
if len(day_recall_result) > 0:
|
|
log_.info(f"count = {len(day_recall_result)}")
|
|
log_.info(f"count = {len(day_recall_result)}")
|
|
- redis_helper.add_data_with_zset(key_name=day_recall_key_name, data=day_recall_result, expire_time=23 * 3600)
|
|
|
|
|
|
+ # redis_helper.add_data_with_zset(key_name=day_recall_key_name, data=day_recall_result, expire_time=23 * 3600)
|
|
# 清空线上过滤应用列表
|
|
# 清空线上过滤应用列表
|
|
- redis_helper.del_keys(key_name=f"{config_.H_VIDEO_FILER_24H}{app_type}.{data_key}.{rule_key}")
|
|
|
|
|
|
+ # redis_helper.del_keys(key_name=f"{config_.H_VIDEO_FILER_24H}{app_type}.{data_key}.{rule_key}")
|
|
|
|
|
|
# 去重更新rov模型结果,并另存为redis中
|
|
# 去重更新rov模型结果,并另存为redis中
|
|
# initial_data_dup = {}
|
|
# initial_data_dup = {}
|