Method record_token_failure

app/utils/token_pool.py:363–384

标记失败并实时同步数据库统计。

(self, token: str, error: Exception = None, dao=None)

                self.token_statuses[token].db_synced_successful_requests += 1

    async def record_token_failure(self, token: str, error: Exception = None, dao=None):
        """标记失败并实时同步数据库统计。"""
        self.mark_token_failure(token, error)

        token_id = self.get_token_id(token)
        if token_id is None:
            return

        if dao is None:
            from app.services.token_dao import get_token_dao

            dao = get_token_dao()

        try:
            await dao.record_failure(token_id)
        except Exception as e:
            logger.error(f"❌ 同步 Token 失败统计失败: {e}")
            return

        with self._lock:
            if token in self.token_statuses:
                self.token_statuses[token].db_synced_failed_requests += 1

    def get_token_id(self, token: str) -> Optional[int]:
        """获取 Token 的数据库 ID"""