初始化桥接客户端 Args: base_url: HTTP 桥接服务器地址,默认从环境变量 ASTER_BRIDGE_URL 获取 max_retries: 最大重试次数(默认3次) retry_delay: 重试延迟秒数(默认0.5秒,指数退避)
(
self,
base_url: Optional[str] = None,
max_retries: int = 3,
retry_delay: float = 0.5,
)
| 43 | """ |
| 44 | |
| 45 | def __init__( |
| 46 | self, |
| 47 | base_url: Optional[str] = None, |
| 48 | max_retries: int = 3, |
| 49 | retry_delay: float = 0.5, |
| 50 | ): |
| 51 | """ |
| 52 | 初始化桥接客户端 |
| 53 | |
| 54 | Args: |
| 55 | base_url: HTTP 桥接服务器地址,默认从环境变量 ASTER_BRIDGE_URL 获取 |
| 56 | max_retries: 最大重试次数(默认3次) |
| 57 | retry_delay: 重试延迟秒数(默认0.5秒,指数退避) |
| 58 | """ |
| 59 | self.base_url = base_url or os.environ.get( |
| 60 | "ASTER_BRIDGE_URL", "http://localhost:8080" |
| 61 | ) |
| 62 | self.max_retries = max_retries |
| 63 | self.retry_delay = retry_delay |
| 64 | self._session: Optional[aiohttp.ClientSession] = None |
| 65 | |
| 66 | async def _get_session(self) -> aiohttp.ClientSession: |
| 67 | """获取或创建 HTTP 会话""" |