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()