|
|
@@ -739,6 +739,8 @@ def h_rank_bottom(now_date, now_h, rule_params, region_code_list, rule_rank_h_fl
|
|
|
by_48h_rule_key = rule_param.get('48h_rule_key', None)
|
|
|
# 涉政视频过滤
|
|
|
political_filter = param.get('political_filter', None)
|
|
|
+ # 屏蔽视频过滤
|
|
|
+ shield_config = param.get('shield_config', config_.SHIELD_CONFIG)
|
|
|
for region in region_code_list:
|
|
|
log_.info(f"region = {region}")
|
|
|
key_name = f"{key_prefix}{region}:{data_key}:{rule_key}:{redis_dt}:{redis_h}"
|
|
|
@@ -760,13 +762,13 @@ def h_rank_bottom(now_date, now_h, rule_params, region_code_list, rule_rank_h_fl
|
|
|
region_24h_rule_key=region_24h_rule_key, region=region,
|
|
|
data_key=data_key, by_24h_rule_key=by_24h_rule_key,
|
|
|
by_48h_rule_key=by_48h_rule_key, rule_rank_h_flag=rule_rank_h_flag,
|
|
|
- political_filter=political_filter)
|
|
|
+ political_filter=political_filter, shield_config=shield_config)
|
|
|
# 特殊城市视频数据准备
|
|
|
for region, city_list in config_.REGION_CITY_MAPPING.items():
|
|
|
t = [
|
|
|
gevent.spawn(
|
|
|
copy_data_for_city,
|
|
|
- region, city_code, data_key, rule_key, now_date, now_h
|
|
|
+ region, city_code, data_key, rule_key, now_date, now_h, shield_config
|
|
|
)
|
|
|
for city_code in city_list
|
|
|
]
|
