From f4807a0003bade1c8b6986c1f406163be06206bc Mon Sep 17 00:00:00 2001 From: H Vs Date: Fri, 11 Apr 2025 09:05:53 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E5=BC=82=E5=B8=B8=E6=8D=95?= =?UTF-8?q?=E8=8E=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tasks.py | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/tasks.py b/tasks.py index ff8d7de..ee88436 100644 --- a/tasks.py +++ b/tasks.py @@ -17,6 +17,7 @@ import logging from model.models import AgentConfig import logging +import sys,traceback logger = logging.getLogger('redbeat') @@ -795,8 +796,20 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, await asyncio.sleep(random.uniform(1.5, 3)) + # except Exception as e: + # logger.error(f"任务执行过程中发生异常: {e}") + except Exception as e: - logger.error(f"任务执行过程中发生异常: {e}") + # 获取当前的堆栈跟踪 + tb = sys.exc_info()[2] + # 为异常附加堆栈跟踪 + e = e.with_traceback(tb) + # 输出详细的错误信息 + logger.error(f"任务执行过程中发生异常: {e}\n异常类型: {type(e).__name__}\n异常信息: {str(e)}\n堆栈跟踪: {traceback.format_exc()}") + # logger.error(f"异常类型: {type(e).__name__}") + # logger.error(f"异常信息: {str(e)}") + # logger.error(f"堆栈跟踪: {traceback.format_exc()}") + finally: await kafka_service.stop_producer()