update

config.py

@@ -92,7 +92,9 @@ class BaseConfig(object):
 
 
 class DevelopmentConfig(BaseConfig):
-    """测试环境配置"""
+    """开发环境配置"""
+    # 报警内容 环境区分
+    ENV_TEXT = "开发环境"
     # 测试环境redis地址
     REDIS_INFO = {
         'host': 'r-bp1ps6my7lzg8rdhwx682.redis.rds.aliyuncs.com',
@@ -132,6 +134,8 @@ class DevelopmentConfig(BaseConfig):
 
 class TestConfig(BaseConfig):
     """测试环境配置"""
+    # 报警内容 环境区分
+    ENV_TEXT = "测试环境"
     # 测试环境redis地址
     REDIS_INFO = {
         'host': 'r-bp1ps6my7lzg8rdhwx682.redis.rds.aliyuncs.com',
@@ -171,6 +175,8 @@ class TestConfig(BaseConfig):
 
 class PreProductionConfig(BaseConfig):
     """预发布环境配置"""
+    # 报警内容 环境区分
+    ENV_TEXT = "预发布环境"
     # 线上环境redis地址
     REDIS_INFO = {
         'host': 'r-bp1fogs2mflr1ybfot.redis.rds.aliyuncs.com',
@@ -210,6 +216,8 @@ class PreProductionConfig(BaseConfig):
 
 class ProductionConfig(BaseConfig):
     """生产环境配置"""
+    # 报警内容 环境区分
+    ENV_TEXT = "生产环境"
     # 线上环境redis地址
     REDIS_INFO = {
         'host': 'r-bp1fogs2mflr1ybfot.redis.rds.aliyuncs.com',
@@ -248,7 +256,7 @@ class ProductionConfig(BaseConfig):
 
 
 def set_config():
-    # return DevelopmentConfig()
+    return DevelopmentConfig()
     # return TestConfig()
     # return PreProductionConfig()
-    return ProductionConfig()
+    # return ProductionConfig()

video_rank.py

@@ -106,8 +106,8 @@ def bottom_strategy(size, app_type, ab_code):
     redis_helper = RedisHelper()
     data = redis_helper.get_data_zset_with_index(key_name=key_name, start=0, end=1000)
     if not data:
-        log_.info('生产环境 —— ROV推荐进入了二次兜底, data = {}'.format(data))
-        send_msg_to_feishu('生产环境 —— ROV推荐进入了二次兜底，请查看是否有数据更新失败问题。')
+        log_.info('{} —— ROV推荐进入了二次兜底, data = {}'.format(config_.ENV_TEXT, data))
+        send_msg_to_feishu('{} —— ROV推荐进入了二次兜底，请查看是否有数据更新失败问题。'.format(config_.ENV_TEXT))
         # 二次兜底
         bottom_data = bottom_strategy_last(size=size, app_type=app_type, ab_code=ab_code)
         return bottom_data

video_recall.py

@@ -287,8 +287,8 @@ class PoolRecall(object):
                                                     redis_date - 1)
                     # 判断当前时间是否晚于数据正常更新时间，发送消息到飞书
                     now_m = datetime.now().minute
-                    feishu_text = '生产环境 —— appType = {}, h = {} 数据未按时更新，请及时查看解决。'.format(self.app_type,
-                                                                                         redis_date)
+                    feishu_text = '{} —— appType = {}, h = {} 数据未按时更新，请及时查看解决。'.format(
+                        config_.ENV_TEXT, self.app_type, redis_date)
                     if now_m > 2:
                         send_msg_to_feishu(feishu_text)
                     return key_name, redis_date - 1
@@ -307,7 +307,7 @@ class PoolRecall(object):
                     # 判断当前时间是否晚于rov召回池更新时间 + 1h，发送消息到飞书
                     now_h = datetime.now().hour
                     now_m = datetime.now().minute
-                    feishu_text = '生产环境 —— 今日ROV召回池数据未按时更新，请及时查看解决。'
+                    feishu_text = '{} —— 今日ROV召回池数据未按时更新，请及时查看解决。'.format(config_.ENV_TEXT)
                     if now_h == config_.ROV_UPDATE_H + 1 and now_m > config_.ROV_UPDATE_MINUTE:
                         send_msg_to_feishu(feishu_text)
                     elif now_h > config_.ROV_UPDATE_H + 2: