server启动之后,填入callback
This commit is contained in:
@@ -56,9 +56,7 @@ def start_fastapi_server(host="0.0.0.0", port=8999):
|
|||||||
server_thread.start()
|
server_thread.start()
|
||||||
logger.info(f"FastAPI 服务已在 http://{host}:{port} 启动")
|
logger.info(f"FastAPI 服务已在 http://{host}:{port} 启动")
|
||||||
logger.info(f"回调URL: http://{host}:{port}/gewechat/callback")
|
logger.info(f"回调URL: http://{host}:{port}/gewechat/callback")
|
||||||
# 启动之后,填入callback
|
|
||||||
gewe_client.client_set_callback()
|
|
||||||
# 返回启动的端口,以便调用者知道实际使用的端口
|
|
||||||
return port
|
return port
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"启动FastAPI服务器失败: {e}", exc_info=True)
|
logger.error(f"启动FastAPI服务器失败: {e}", exc_info=True)
|
||||||
|
|||||||
@@ -40,18 +40,9 @@ class Client:
|
|||||||
|
|
||||||
def client_set_callback(self):
|
def client_set_callback(self):
|
||||||
"""在server启动后调用此方法设置回调"""
|
"""在server启动后调用此方法设置回调"""
|
||||||
max_retries = 5
|
resp = self.client.set_callback(self.app_id, self.callback_url)
|
||||||
retry_interval = 5 # 秒
|
print(f"set_callback 成功: {resp}")
|
||||||
for attempt in range(1, max_retries + 1):
|
|
||||||
resp = self.client.set_callback(self.app_id, self.callback_url)
|
|
||||||
if resp and resp.get("success", False):
|
|
||||||
print(f"set_callback 成功: {resp}")
|
|
||||||
break
|
|
||||||
else:
|
|
||||||
logger.warning(f"set_callback 第{attempt}次失败,{retry_interval}秒后重试...")
|
|
||||||
time.sleep(retry_interval)
|
|
||||||
else:
|
|
||||||
logger.error("set_callback 多次重试后仍失败,请检查server状态。")
|
|
||||||
|
|
||||||
# 项目全局唯一 client 实例
|
# 项目全局唯一 client 实例
|
||||||
gewe_client = Client()
|
gewe_client = Client()
|
||||||
5
main.py
5
main.py
@@ -52,7 +52,10 @@ def main(chat_type: int):
|
|||||||
#
|
#
|
||||||
# # 秀人网每天自动发pdf
|
# # 秀人网每天自动发pdf
|
||||||
# robot.onEveryTime("17:30", robot.xiu_ren_pdf_send)
|
# robot.onEveryTime("17:30", robot.xiu_ren_pdf_send)
|
||||||
|
time.sleep(5)
|
||||||
|
# 启动之后,填入callback
|
||||||
|
gewe_client.client_set_callback()
|
||||||
|
# 返回启动的端口,以便调用者知道实际使用的端口
|
||||||
# 启动Dashboard服务器
|
# 启动Dashboard服务器
|
||||||
dashboard_server = None
|
dashboard_server = None
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user