update

redis_data_monitor.py

@@ -7,43 +7,7 @@ config_, _ = set_config()
 log_ = Log()
 redis_helper = RedisHelper()
 
-region_code = {
-    '河北省': '130000',
-    '山西省': '140000',
-    '辽宁省': '210000',
-    '吉林省': '220000',
-    '黑龙江省': '230000',
-    '江苏省': '320000',
-    '浙江省': '330000',
-    '安徽省': '340000',
-    '福建省': '350000',
-    '江西省': '360000',
-    '山东省': '370000',
-    '河南省': '410000',
-    '湖北省': '420000',
-    '湖南省': '430000',
-    '广东省': '440000',
-    '海南省': '460000',
-    '四川省': '510000',
-    '贵州省': '520000',
-    '云南省': '530000',
-    '陕西省': '610000',
-    '甘肃省': '620000',
-    '青海省': '630000',
-    '台湾省': '710000',
-    '北京': '110000',
-    '天津': '120000',
-    '内蒙古': '150000',
-    '上海': '310000',
-    '广西': '450000',
-    '重庆': '500000',
-    '西藏': '540000',
-    '宁夏': '640000',
-    '新疆': '650000',
-    '香港': '810000',
-    '澳门': '820000',
-    'None': '-1'
-}
+region_code = config_.REGION_CODE
 
 
 def rov_data_monitor(now_date, now_h):
@@ -143,7 +107,7 @@ def get_redis_data_keys(now_date, now_h):
         rov_key_name = f"{config_.RECALL_KEY_NAME_PREFIX}{now_date}"
         redis_data_keys.append(rov_key_name)
     # 地域分组小时级列表
-    rule_params = config_.RULE_PARAMS_REGION
+    rule_params = config_.RULE_PARAMS_REGION_APP_TYPE
     key_prefix_list = [
         config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H,
         config_.RECALL_KEY_NAME_PREFIX_DUP1_REGION_24H_H,
@@ -151,14 +115,16 @@ def get_redis_data_keys(now_date, now_h):
         config_.RECALL_KEY_NAME_PREFIX_DUP_REGION_H
     ]
     region_code_list = [code for region, code in region_code.items()]
-    for rule_key, _ in rule_params.items():
-        for region in region_code_list:
-            if region == '-1':
-                region_key_name = [f"{key_prefix_list[-1]}{region}.{rule_key}.{now_date}.{now_h}"]
-            else:
-                region_key_name = [f"{key_prefix}{region}.{rule_key}.{now_date}.{now_h}"
-                                   for key_prefix in key_prefix_list]
-            redis_data_keys.extend(region_key_name)
+    for app_type, params in rule_params.items():
+        for data_key, data_param in params['data_params'].items():
+            for rule_key, rule_param in params['rule_params'].items():
+                for region in region_code_list:
+                    if region == '-1':
+                        region_key_name = [f"{key_prefix_list[-1]}{region}.{app_type}.{data_key}.{rule_key}.{now_date}.{now_h}"]
+                    else:
+                        region_key_name = [f"{key_prefix}{region}.{app_type}.{data_key}.{rule_key}.{now_date}.{now_h}"
+                                           for key_prefix in key_prefix_list]
+                    redis_data_keys.extend(region_key_name)
 
     return redis_data_keys
 

region_rule_rank_h_by24h.py

@@ -324,7 +324,7 @@ def h_timer_check():
     rule_params = config_.RULE_PARAMS_REGION_24H_APP_TYPE
     project = config_.PROJECT_REGION_24H_APP_TYPE
     table = config_.TABLE_REGION_24H_APP_TYPE
-    region_code_list = [code for region, code in region_code.items()]
+    region_code_list = [code for region, code in region_code.items() if code != '-1']
     now_date = datetime.datetime.today()
     now_h = datetime.datetime.now().hour
     now_min = datetime.datetime.now().minute