update

laohaokan_recommend_update.py

@@ -154,14 +154,14 @@ def main():
             log_.info(f"param = {param} update end!")
 
         log_.info(f"laohaokan recommend data update end!")
-        send_msg_to_feishu(
+        # send_msg_to_feishu(
-            webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
+        #     webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
-            key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
+        #     key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
-            msg_text=f"rov-offline{config_.ENV_TEXT} - 老好看推荐视频数据更新完成\n"
+        #     msg_text=f"rov-offline{config_.ENV_TEXT} - 老好看推荐视频数据更新完成\n"
-                     f"now_date: {datetime.datetime.strftime(now_date, '%Y%m%d')}\n"
+        #              f"now_date: {datetime.datetime.strftime(now_date, '%Y%m%d')}\n"
-                     f"now_h: {now_h}\n"
+        #              f"now_h: {now_h}\n"
-                     f"finished time: {datetime.datetime.strftime(datetime.datetime.now(), '%Y%m%d %H:%M:%S')}"
+        #              f"finished time: {datetime.datetime.strftime(datetime.datetime.now(), '%Y%m%d %H:%M:%S')}"
-        )
+        # )
     except Exception as e:
         log_.error(f"老好看推荐视频数据更新失败, exception: {e}, traceback: {traceback.format_exc()}")
         send_msg_to_feishu(

redis_data_monitor.py

@@ -31,7 +31,9 @@ def rov_data_monitor(now_date, now_h):
 
 def region_data_monitor(now_date, now_h, rule_params, key_prefix_dict):
     """地域分组数据"""
-    region_code_list = [code for region, code in region_code.items()]
+    region_code_list = [code for region, code in region_code.items()] +\
+                       [code for city, code in config_.CITY_CODE.items()]
+    # print(region_code_list)
     for param in rule_params.get('params_list'):
         data_key = param.get('data')
         rule_key = param.get('rule')

region_rule_rank_h.py

@@ -810,14 +810,14 @@ def h_timer_check():
         else:
             # 数据没准备好，1分钟后重新检查
             Timer(60, h_timer_check).start()
-        send_msg_to_feishu(
+        # send_msg_to_feishu(
-            webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
+        #     webhook=config_.FEISHU_ROBOT['server_robot'].get('webhook'),
-            key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
+        #     key_word=config_.FEISHU_ROBOT['server_robot'].get('key_word'),
-            msg_text=f"rov-offline{config_.ENV_TEXT} - 推荐视频数据更新完成\n"
+        #     msg_text=f"rov-offline{config_.ENV_TEXT} - 推荐视频数据更新完成\n"
-                     f"now_date: {datetime.datetime.strftime(now_date, '%Y%m%d')}\n"
+        #              f"now_date: {datetime.datetime.strftime(now_date, '%Y%m%d')}\n"
-                     f"now_h: {now_h}\n"
+        #              f"now_h: {now_h}\n"
-                     f"finished time: {datetime.datetime.strftime(datetime.datetime.now(), '%Y%m%d %H:%M:%S')}"
+        #              f"finished time: {datetime.datetime.strftime(datetime.datetime.now(), '%Y%m%d %H:%M:%S')}"
-        )
+        # )
     except Exception as e:
         log_.error(f"地域分组小时级数据更新失败, exception: {e}, traceback: {traceback.format_exc()}")
         send_msg_to_feishu(