liqian 2 years ago
parent
commit
383730fedb
3 changed files with 24 additions and 24 deletions
  1. 8 8
      ad_users_data_update.py
  2. 8 8
      ad_video_data_update.py
  3. 8 8
      user_group_update.py

+ 8 - 8
ad_users_data_update.py

@@ -72,14 +72,14 @@ def timer_check():
             # 数据准备好,进行更新
             # 数据准备好,进行更新
             update_users_data(project=project, table=table, dt=dt, update_params=update_params)
             update_users_data(project=project, table=table, dt=dt, update_params=update_params)
             log_.info(f"ad user group data update end!")
             log_.info(f"ad user group data update end!")
-        elif now_min > 45:
-            log_.info('ad user group data is None!')
-            send_msg_to_feishu(
-                webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
-                key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
-                msg_text=f"rov-offline{config_.ENV_TEXT} - 用户组分享率数据未准备好!\n"
-                         f"traceback: {traceback.format_exc()}"
-            )
+        # elif now_min > 45:
+        #     log_.info('ad user group data is None!')
+        #     send_msg_to_feishu(
+        #         webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
+        #         key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
+        #         msg_text=f"rov-offline{config_.ENV_TEXT} - 用户组分享率数据未准备好!\n"
+        #                  f"traceback: {traceback.format_exc()}"
+        #     )
         else:
         else:
             # 数据没准备好,1分钟后重新检查
             # 数据没准备好,1分钟后重新检查
             Timer(60, timer_check).start()
             Timer(60, timer_check).start()

+ 8 - 8
ad_video_data_update.py

@@ -73,14 +73,14 @@ def timer_check():
             # 数据准备好,进行更新
             # 数据准备好,进行更新
             update_videos_data(project=project, table=table, dt=dt, update_params=update_params)
             update_videos_data(project=project, table=table, dt=dt, update_params=update_params)
             log_.info(f"ad video data update end!")
             log_.info(f"ad video data update end!")
-        elif now_min > 45:
-            log_.info('ad video data is None!')
-            send_msg_to_feishu(
-                webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
-                key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
-                msg_text=f"rov-offline{config_.ENV_TEXT} - 视频分享率数据未准备好!\n"
-                         f"traceback: {traceback.format_exc()}"
-            )
+        # elif now_min > 45:
+        #     log_.info('ad video data is None!')
+        #     send_msg_to_feishu(
+        #         webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
+        #         key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
+        #         msg_text=f"rov-offline{config_.ENV_TEXT} - 视频分享率数据未准备好!\n"
+        #                  f"traceback: {traceback.format_exc()}"
+        #     )
         else:
         else:
             # 数据没准备好,1分钟后重新检查
             # 数据没准备好,1分钟后重新检查
             Timer(60, timer_check).start()
             Timer(60, timer_check).start()

+ 8 - 8
user_group_update.py

@@ -75,14 +75,14 @@ def timer_check():
             # 数据准备好,进行更新
             # 数据准备好,进行更新
             update_user_group_to_redis(project=project, table=table, dt=dt, app_type_list=app_type_list)
             update_user_group_to_redis(project=project, table=table, dt=dt, app_type_list=app_type_list)
             log_.info(f"user group data update end!")
             log_.info(f"user group data update end!")
-        elif now_min > 45:
-            log_.info('user group data is None!')
-            send_msg_to_feishu(
-                webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
-                key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
-                msg_text=f"rov-offline{config_.ENV_TEXT} - 用户分组数据未准备好!\n"
-                         f"traceback: {traceback.format_exc()}"
-            )
+        # elif now_min > 45:
+        #     log_.info('user group data is None!')
+        #     send_msg_to_feishu(
+        #         webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
+        #         key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
+        #         msg_text=f"rov-offline{config_.ENV_TEXT} - 用户分组数据未准备好!\n"
+        #                  f"traceback: {traceback.format_exc()}"
+        #     )
         else:
         else:
             # 数据没准备好,1分钟后重新检查
             # 数据没准备好,1分钟后重新检查
             Timer(60, timer_check).start()
             Timer(60, timer_check).start()