调整异常捕获

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