webhook去掉括号
This commit is contained in:
@@ -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()
|
||||
|
||||
Reference in New Issue
Block a user