From 6009b85310c02a4aff03ae7444183e16cbbb0c87 Mon Sep 17 00:00:00 2001
From: aszerW <aszer27937@gmail.com>
Date: Sun, 26 Oct 2025 16:38:06 +0800
Subject: [PATCH] =?UTF-8?q?webhook=E5=8E=BB=E6=8E=89=E6=8B=AC=E5=8F=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 update_data.py | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git a/update_data.py b/update_data.py
index 44a2d88..af1dd73 100644
--- a/update_data.py
+++ b/update_data.py
@@ -10,6 +10,10 @@ import traceback
 from dingtalk import DingTalkBot
 import os
 
+webhook = "https://oapi.dingtalk.com/robot/send?access_token=21de667159edadd33172c6ec414a2addf9c6359189350ffd36819d2a20e8a0f4"
+secret = "SEC43a0fa0b29717f98637a119b92a0bd5f7b2b6da671bdd2bd1279ed8323454d5e"
+dingtalk = DingTalkBot(webhook, secret)
+
 
 def get_latest_index_kline_date():
     # df = pd.read_csv(
@@ -67,11 +71,7 @@ def main():
     if datetime.today().weekday() >= 5:
         logger.info(f"非交易日")
         return
-    webhook = (
-        "https://oapi.dingtalk.com/robot/send?access_token=21de667159edadd33172c6ec414a2addf9c6359189350ffd36819d2a20e8a0f4",
-    )  # 填写你的webhook
-    secret = "SEC43a0fa0b29717f98637a119b92a0bd5f7b2b6da671bdd2bd1279ed8323454d5e"
-    dingtalk = DingTalkBot(webhook, secret)
+
     try:
         db_config = DatabaseConfig()
         logger.info(f"数据库连接: {db_config.connection_string}")
@@ -96,13 +96,15 @@ def main():
             res = db_manager.insert_dataframe(df, "index_kline")
             logger.info(res)
     except Exception as e:
-        logger.error(f"main 函数执行异常: {e}\n{traceback.format_exc()}")
-        dingtalk.send_text(f"main 函数执行异常: {e}\n{traceback.format_exc()}")
+        error_message = f"{e}\n{traceback.format_exc()}"
+        logger.error(error_message)
+        dingtalk.send_text(f"A股指数抓取失败: \n{error_message}")
 
 
 if __name__ == "__main__":
     logger.info(datetime.now())
     PULL_SCHEDULE: str = os.getenv("PULL_SCHEDULE", "16:00")
+    logger.info(f"PULL_SCHEDULE: {PULL_SCHEDULE}")
     schedule.every().day.at(PULL_SCHEDULE).do(main)
     while True:
         schedule.run_pending()