update

data_expire_time_update.py

@@ -27,12 +27,15 @@ now_h = datetime.datetime.now().hour
 h_list = range(now_h + 1)
 
 for rule_param in rule_param_list:
+    log_.info(rule_param)
     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:
+        for key_prefix in key_prefix_list:
+            for region in region_code_list:
                 key = f"{key_prefix}{region}:{data_key}:{rule_key}:{now_date}:{h}"
                 if redis_helper.key_exists(key_name=key):
-
-
+                    redis_helper.update_expire_time(key_name=key, expire_time=2 * 24 * 3600)
+            log_.info(f"{key_prefix} end!")
+        log_.info(f"h = {h} end!")
+    log_.info(f"{rule_param} end!")

db_helper.py

@@ -284,6 +284,8 @@ class RedisHelper(object):
         :param expire_time: 过期时间
         :return:
         """
+        conn = self.connect()
+        conn.expire(name=key_name, time=int(expire_time))
 
 
 class HologresHelper(object):