|
|
@@ -186,15 +186,15 @@ def dup_with_param(param, data_params_item, rule_params_item, region_code_list,
|
|
|
rule_key = param.get('rule')
|
|
|
rule_param = rule_params_item.get(rule_key)
|
|
|
log_.info(f"rule_key = {rule_key}, rule_param = {rule_param}")
|
|
|
- h_rule_key = param.get('h_rule_key', None)
|
|
|
- region_24h_rule_key = param.get('region_24h_rule_key', 'rule1')
|
|
|
- by_24h_rule_key = param.get('24h_rule_key', None)
|
|
|
- by_48h_rule_key = param.get('48h_rule_key', None)
|
|
|
- dup_remove = param.get('dup_remove', True)
|
|
|
+ h_rule_key = rule_param.get('h_rule_key', None)
|
|
|
+ region_24h_rule_key = rule_param.get('region_24h_rule_key', 'rule1')
|
|
|
+ by_24h_rule_key = rule_param.get('24h_rule_key', None)
|
|
|
+ by_48h_rule_key = rule_param.get('48h_rule_key', None)
|
|
|
+ dup_remove = rule_param.get('dup_remove', True)
|
|
|
# 屏蔽视频过滤
|
|
|
- shield_config = param.get('shield_config', config_.SHIELD_CONFIG)
|
|
|
+ shield_config = rule_param.get('shield_config', config_.SHIELD_CONFIG)
|
|
|
# 涉政视频过滤
|
|
|
- political_filter = param.get('political_filter', None)
|
|
|
+ political_filter = rule_param.get('political_filter', None)
|
|
|
task_list = [
|
|
|
gevent.spawn(dup_to_redis,
|
|
|
now_date, now_h, rule_key, h_rule_key, region_24h_rule_key, by_24h_rule_key,
|
