update

data_expire_time_update.py

@@ -0,0 +1,38 @@
+import datetime
+from db_helper import RedisHelper
+from config import set_config
+from log import Log
+config_, _ = set_config()
+log_ = Log()
+redis_helper = RedisHelper()
+region_code_list = [code for region, code in config_.REGION_CODE.items()]
+for _, city_list in config_.REGION_CITY_MAPPING.items():
+    for city_code in city_list:
+        region_code_list.append(city_code)
+
+key_prefix_list = [
+    config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H,
+    config_.RECALL_KEY_NAME_PREFIX_DUP1_REGION_24H_H,
+    config_.RECALL_KEY_NAME_PREFIX_DUP2_REGION_24H_H,
+    config_.RECALL_KEY_NAME_PREFIX_DUP3_REGION_24H_H,
+    config_.RECALL_KEY_NAME_PREFIX_DUP2_REGION_48H_H,
+    config_.RECALL_KEY_NAME_PREFIX_DUP3_REGION_48H_H,
+    config_.RECALL_KEY_NAME_PREFIX_30DAY
+]
+
+rule_param_list = [rule_param for rule_param in config_.RULE_PARAMS_REGION_APP_TYPE['params_list']]
+
+now_date = datetime.datetime.strftime(datetime.datetime.today(), '%Y%m%d')
+now_h = datetime.datetime.now().hour
+h_list = range(now_h + 1)
+
+for rule_param in rule_param_list:
+    data_key = rule_param.get('data')
+    rule_key = rule_param.get('rule')
+    for h in h_list:
+        for region in region_code_list:
+            for key_prefix in key_prefix_list:
+                key = f"{key_prefix}{region}:{data_key}:{rule_key}:{now_date}:{h}"
+                if redis_helper.key_exists(key_name=key):
+
+

db_helper.py

@@ -277,6 +277,14 @@ class RedisHelper(object):
         conn.setnx(name=key_name, value=value)
         conn.expire(name=key_name, time=int(expire_time))
 
+    def update_expire_time(self, key_name, expire_time):
+        """
+        修改过期时间
+        :param key_name: key
+        :param expire_time: 过期时间
+        :return:
+        """
+
 
 class HologresHelper(object):
     def __init__(self):