Method call_tool

client-sdks/python-bridge/aster.py:72–161

调用工具(带重试逻辑) Args: name: 工具名称 **kwargs: 工具输入参数 Returns: 工具执行结果 Raises: ToolExecutionError: 工具执行失败 NetworkError: 网络错误(重试后仍失败)

(self, name: str, **kwargs)

        return self._session

    async def call_tool(self, name: str, **kwargs) -> Any:
        """
        调用工具(带重试逻辑)

        Args:
            name: 工具名称
            **kwargs: 工具输入参数

        Returns:
            工具执行结果

        Raises:
            ToolExecutionError: 工具执行失败
            NetworkError: 网络错误(重试后仍失败)
        """
        last_error = None

        for attempt in range(self.max_retries):
            try:
                session = await self._get_session()

                async with session.post(
                    f"{self.base_url}/tools/call",
                    json={"tool": name, "input": kwargs},
                    timeout=aiohttp.ClientTimeout(total=60),
                ) as resp:
                    # 检查 HTTP 状态码
                    if resp.status >= 500:
                        # 服务器错误,可以重试
                        error_text = await resp.text()
                        last_error = NetworkError(
                            f"Server error (HTTP {resp.status}): {error_text}"
                        )
                        if attempt < self.max_retries - 1:
                            await asyncio.sleep(self.retry_delay * (2 ** attempt))
                            continue
                        raise last_error

                    if resp.status >= 400:
                        # 客户端错误,不重试
                        error_text = await resp.text()
                        raise NetworkError(
                            f"Client error (HTTP {resp.status}): {error_text}"
                        )

                    # 解析响应
                    result = await resp.json()

                    # 检查工具执行结果
                    if not result.get("success"):
                        error_msg = result.get("error", "Unknown error")
                        raise ToolExecutionError(name, error_msg)

                    return result.get("result")

            except aiohttp.ClientConnectorError as e:
                # 连接错误,可以重试
                last_error = NetworkError(