现在我已经明确找到问题了，对于占用大量的 linux 文件句柄不释放的代码就是这个 notice ，因为我把这个部分代码下掉后就已经恢复了正常，你需要再次检查一下，你的代码存在这样的问题

Assistant

解决 FeishuWebhookNotifier 中的资源泄漏问题

您是正确的！我检查了 notice.py 中的 FeishuWebhookNotifier 类，确实存在文件句柄泄漏问题。主要原因是 aiohttp 会话没有被正确关闭，每次访问 session 属性时都可能创建新的连接，而这些连接没有被正确释放。

问题分析

1. 会话管理问题：

   • 每次访问 session 属性可能创建新的 ClientSession
   • 创建的会话依赖于外部代码来调用 close()，但实际上很少有地方调用

2. 连接池膨胀：

   • 定时任务每天执行 100 万次，可能导致大量连接池未被释放
   • 每个 aiohttp.TCPConnector 会保持多个打开的文件句柄

3. SSL 上下文：

   • 每次创建新会话都会创建新的 SSL 上下文，增加资源消耗

解决方案

以下是修复 FeishuWebhookNotifier 类的完整代码：

class FeishuWebhookNotifier(BaseNotifier): _instance = None _lock = threading.Lock() @classmethod def get_instance(cls): """获取单例实例""" if cls._instance is None: with cls._lock: if cls._instance is None: cls._instance = cls() return cls._instance def __init__(self): self.webhook_url = os.getenv('FEI_SHU_WEBHOOK_URL') self.logger = logging.getLogger(__name__) self._cOnnector= None self._session = None self._session_lock = threading.Lock() def _ensure_connector(self): """确保连接器已初始化""" if self._connector is None: # 创建不验证 SSL 证书的 SSL 上下文 ssl_cOntext= ssl.create_default_context() ssl_context.check_hostname = False ssl_context.verify_mode = ssl.CERT_NONE # 创建具有限制的连接器 self._cOnnector= aiohttp.TCPConnector( ssl=ssl_context, limit=50, # 限制最大连接数 force_close=True, # 强制关闭连接，防止泄漏 enable_cleanup_closed=True # 自动清理关闭的连接 ) self.logger.debug("已创建新的 aiohttp 连接器") @asynccontextmanager async def _get_session(self): """获取会话的上下文管理器 - 每次使用后自动关闭""" session = None try: with self._session_lock: self._ensure_connector() # 创建临时会话 session = aiohttp.ClientSession( cOnnector=self._connector, timeout=aiohttp.ClientTimeout(total=5) ) yield session finally: # 总是在完成后关闭会话 if session and not session.closed: await session.close() async def close(self): """关闭所有资源""" # 关闭会话 if self._session and not self._session.closed: await self._session.close() self._session = None # 关闭连接器 if self._connector and not self._connector.closed: await self._connector.close() self._cOnnector= None 

同时需要修改 AlertEngine 调用代码

您需要修改 alert_engine.py 中的 AlertTrigger 类，确保正确使用通知器单例：

关键改进点

1. 使用上下文管理器：每次请求都使用独立的临时会话，使用后立即关闭
2. 连接器共享：多个会话共享同一个连接器，减少资源消耗
3. 强制关闭连接：使用 force_close=True 确保连接在完成后关闭，防止泄漏
4. 单例模式：确保整个应用中只有一个通知器实例
5. 显式资源关闭：提供 close() 方法在应用关闭时清理资源

这样修改后，应该能有效解决文件句柄泄漏问题，即使在高频调用的情况下也能正常工作。

User

其实核心的问题是因为 FeishuWebhookNotifier 不是一个单例类，导致外面每次创建新的 FeishuWebhookNotifier 实例，每次实例都会去创建 session 进而导致连接释放不了对吗

Assistant

问题根源分析确认

对，您完全正确！核心问题就是 FeishuWebhookNotifier 不是单例类，导致每次实例化时都创建新的 HTTP 会话资源。这造成了以下连锁反应：

1. 每次创建新实例：当 AlertTrigger 或其他代码初始化时创建了新的 FeishuWebhookNotifier
2. 会话重复创建：每个实例在第一次需要发送消息时通过 session 属性创建 aiohttp.ClientSession
3. 资源未释放：这些会话没有被正确关闭，即使有 close() 方法，但外部代码可能未调用
4. 连接池泄漏：每个 ClientSession 内部的 TCPConnector 保持了网络连接，占用文件句柄
5. 资源耗尽：随着时间推移和大量任务执行，文件句柄不断累积，最终超过系统限制

在高频任务环境下（每天 100 万次请求），即使小比例的通知调用也会创建大量未关闭的连接，导致最终的资源耗尽。

最简单的解决方案

最直接的解决方法是将 FeishuWebhookNotifier 改造为单例模式，并确保所有使用点都使用这个单例：

class FeishuWebhookNotifier(BaseNotifier): # 单例实例和锁 _instance = None _lock = threading.Lock() @classmethod def get_instance(cls): """获取单例实例""" if cls._instance is None: with cls._lock: if cls._instance is None: cls._instance = cls() return cls._instance def __init__(self): # 只在首次创建单例时执行一次 if hasattr(self.__class__, '_initialized') and self.__class__._initialized: return self.webhook_url = os.getenv('FEI_SHU_WEBHOOK_URL') self.logger = logging.getLogger(__name__) # 创建一个带限制的连接器 ssl_cOntext= ssl.create_default_context() ssl_context.check_hostname = False ssl_context.verify_mode = ssl.CERT_NONE self._cOnnector= aiohttp.TCPConnector( ssl=ssl_context, limit=50, # 限制连接池大小 force_close=False, # 允许连接复用但防止无限增长 enable_cleanup_closed=True ) # 创建一个共享的会话 self._session = aiohttp.ClientSession( cOnnector=self._connector, timeout=aiohttp.ClientTimeout(total=5) ) self.__class__._initialized = True self.logger.info("飞书通知器已初始化") async def close(self): """关闭会话和连接器""" if hasattr(self, '_session') and self._session and not self._session.closed: await self._session.close() self.logger.info("飞书通知器会话已关闭") 

然后，在 AlertTrigger 和其他使用点修改为：

# 在 AlertTrigger 初始化时 from data_collection.compoment.notice import FeishuWebhookNotifier # 使用单例 self.notifier = FeishuWebhookNotifier.get_instance() 

这样，整个应用中只会创建一个 FeishuWebhookNotifier 实例和一个 ClientSession，解决资源泄漏问题。

这是最简单有效的解决方案，不需要复杂的上下文管理器或连接池管理，直接解决了问题的根源。

User

现在前面的改动，只有第一次处理的时候是 OK 的，后面如果再有线程进行处理的时候就会出现发送告警失败: 请求异常: Session is closed 为什么

Assistant

修复 "Session is closed" 错误问题

问题的根源在于：虽然我们已经将 FeishuWebhookNotifier 改为单例模式，但我们的实现使用了上下文管理器 (_get_session())，它在每次请求结束后都会关闭会话。这导致下一次使用时会话已经关闭。

解决方案

我们需要修改会话的管理方式，有两种解决思路：

方案 1：保持会话常驻（推荐）

方案 2：为每个请求创建新会话，但不共享连接器

如果您希望每个请求都有独立的会话，但不希望因此泄漏资源：

为什么会出现这个问题？

理解为何会出现这个问题很重要：

1. 单例模式确保了通知器对象只有一个实例
2. 但我们的上下文管理器 _get_session() 在每次请求结束后都关闭会话
3. 第一次请求完成后，会话被关闭
4. 下一次请求开始时，上下文管理器会尝试使用同一个会话，但它已被关闭

建议采用方案 1 的原因

方案 1 （常驻会话）有以下优势：

1. 性能更好：重用连接，减少 TCP 握手和 SSL 协商的开销
2. 资源消耗更低：不需要为每个请求创建/销毁连接
3. 连接池管理：内置连接池限制确保资源不会无限增长
4. 错误处理：自动检测并处理会话关闭的情况

# 关键修改：将发送告警封装在任务中执行 # 创建一个明确的任务来执行发送操作 send_task = asyncio.create_task(self._send_alert(alert_data)) try: # 等待任务完成 await send_task except Exception as e: logger.error(f"发送告警任务执行失败: {str(e)}")