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