update

redis_data_monitor.py

@@ -29,17 +29,17 @@ def rov_data_monitor(now_date, now_h):
             )
 
 
-def region_data_monitor(now_date, now_h, rule_params):
+def region_data_monitor(now_date, now_h, rule_params, key_prefix_dict):
     """地域分组数据"""
     # 地域分组小时级列表
     # rule_params = config_.RULE_PARAMS_REGION_APP_TYPE
-    key_prefix_dict = {
-        '地域分组小时级数据': config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H,
-        '地域分组相对24h去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP1_REGION_24H_H,
-        '不区分地域相对24h去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP2_REGION_24H_H,
-        '不区分地域相对24h筛选后剩余去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP3_REGION_24H_H,
-        'rov模型预测列表去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP_REGION_H,
-    }
+    # key_prefix_dict = {
+    #     '地域分组小时级数据': config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H,
+    #     '地域分组相对24h去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP1_REGION_24H_H,
+    #     '不区分地域相对24h去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP2_REGION_24H_H,
+    #     '不区分地域相对24h筛选后剩余去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP3_REGION_24H_H,
+    #     'rov模型预测列表去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP_REGION_H,
+    # }
     region_code_list = [code for region, code in region_code.items()]
     for app_type, params in rule_params.items():
         for param in params.get('params_list'):
@@ -138,8 +138,24 @@ def get_redis_data_keys(now_date, now_h):
 
 def monitor(now_date, now_h):
     rov_data_monitor(now_date=now_date, now_h=now_h)
-    region_data_monitor(now_date=now_date, now_h=now_h, rule_params=config_.RULE_PARAMS_REGION_APP_TYPE)
-    region_data_monitor(now_date=now_date, now_h=now_h, rule_params=config_.RULE_PARAMS_REGION_APP_TYPE_48H)
+    key_prefix_dict_24h = {
+        '地域分组小时级数据': config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H,
+        '地域分组相对24h去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP1_REGION_24H_H,
+        '不区分地域相对24h去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP2_REGION_24H_H,
+        '不区分地域相对24h筛选后剩余去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP3_REGION_24H_H,
+        'rov模型预测列表去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP_REGION_H,
+    }
+    region_data_monitor(now_date=now_date, now_h=now_h, rule_params=config_.RULE_PARAMS_REGION_APP_TYPE,
+                        key_prefix_dict=key_prefix_dict_24h)
+    key_prefix_dict_48h = {
+        '地域分组小时级数据': config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H,
+        '地域分组相对24h去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP1_REGION_24H_H,
+        '不区分地域相对48h去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP2_REGION_48H_H,
+        '不区分地域相对48h筛选后剩余去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP3_REGION_48H_H,
+        'rov模型预测列表去重后数据': config_.RECALL_KEY_NAME_PREFIX_DUP_REGION_H,
+    }
+    region_data_monitor(now_date=now_date, now_h=now_h, rule_params=config_.RULE_PARAMS_REGION_APP_TYPE_48H,
+                        key_prefix_dict=key_prefix_dict_48h)
     special_videos_monitor(now_date=now_date, now_h=now_h)
     # whole_movies_monitor(now_date=now_date, now_h=now_h)