update

config.py

@@ -226,6 +226,9 @@ class BaseConfig(object):
     # 小时级召回池更新时间 每个小时的15分更新成功
     ROV_H_UPDATE_MINUTE = 15
 
+    # 地域分组小时级召回池更新时间
+    REGION_H_UPDATE_MINUTE = 30
+
     # 天级规则更新列表更新时间 00:30更新成功
     ROV_DAY_UPDATE_MINUTE = 0
 

video_recall.py

@@ -985,7 +985,14 @@ class PoolRecall(object):
                 redis_date = now_date
             key_name = f"{key_name_prefix}{province_code}.{self.rule_key}.{redis_date}.{redis_h}"
             last_region_dup_key = \
-                f'{config_.LAST_VIDEO_FROM_REGION_DUP_PREFIX}{region_dup}.{self.app_type}.{self.mid}.{redis_h}'
+                f"{config_.LAST_VIDEO_FROM_REGION_DUP_PREFIX}{region_dup}.{self.app_type}.{self.mid}.{redis_h}"
+
+            # 判断当前时间是否晚于数据正常更新时间，发送消息到飞书
+            now_m = datetime.now().minute
+            feishu_text = f"{config_.ENV_TEXT} —— appType = {self.app_type}, h = {h}, key = {key_name}, " \
+                          f"province_code = {province_code} 数据未按时更新，请及时查看解决。"
+            if now_m > config_.REGION_H_UPDATE_MINUTE:
+                send_msg_to_feishu(feishu_text)
 
         value = self.redis_helper.get_data_from_redis(last_region_dup_key)
         if value: