refactor: add explicit parameters to Recognition API

Author: kevin

dashscope/api_entities/aio_session.py

@@ -16,9 +16,6 @@
 import aiohttp
 import certifi
 
-from dashscope.common.constants import (
-    DEFAULT_CONNECTION_POOL_IDLE_TIMEOUT_SECONDS,
-)
 from dashscope.common.logging import logger
 
 _shared_ssl_context: Optional[ssl.SSLContext] = None
@@ -41,8 +38,7 @@ async def get_shared_aio_session() -> aiohttp.ClientSession:
 
     The session is lazily created on first use and reused for all
     subsequent calls on the same event loop. Connection pooling (keep-alive)
-    is handled by the underlying TCPConnector with idle timeout configured
-    to close stale connections.
+    is handled by the underlying TCPConnector.
     """
     loop = asyncio.get_running_loop()
 
@@ -51,10 +47,7 @@ async def get_shared_aio_session() -> aiohttp.ClientSession:
         if session is not None and not session.closed:
             return session
 
-        connector = aiohttp.TCPConnector(
-            ssl=get_ssl_context(),
-            keepalive_timeout=DEFAULT_CONNECTION_POOL_IDLE_TIMEOUT_SECONDS,
-        )
+        connector = aiohttp.TCPConnector(ssl=get_ssl_context())
         session = aiohttp.ClientSession(connector=connector, trust_env=True)
 
         _aio_sessions[loop] = session

dashscope/api_entities/http_request.py

@@ -8,7 +8,6 @@
 
 import aiohttp
 import requests
-from requests.adapters import HTTPAdapter
 
 from dashscope.api_entities.aio_session import (
     get_shared_aio_session,
@@ -40,21 +39,13 @@ def _get_shared_sync_session() -> requests.Session:
     """Return a shared requests.Session for connection pooling.
 
     The session is created lazily and reused for the process lifetime;
-    it is never closed explicitly. Connection pool is configured with
-    pool size limits to control concurrent connections.
+    it is never closed explicitly.
     """
     global _shared_sync_session
     if _shared_sync_session is None:
         with _shared_sync_session_lock:
             if _shared_sync_session is None:
                 _shared_sync_session = requests.Session()
-                # Configure connection pool size
-                adapter = HTTPAdapter(
-                    pool_connections=10,
-                    pool_maxsize=10,
-                )
-                _shared_sync_session.mount("http://", adapter)
-                _shared_sync_session.mount("https://", adapter)
     return _shared_sync_session
 
 

dashscope/common/constants.py

@@ -17,8 +17,7 @@
     "api_key",
 )
 
-DEFAULT_REQUEST_TIMEOUT_SECONDS = 120
-DEFAULT_CONNECTION_POOL_IDLE_TIMEOUT_SECONDS = 120
+DEFAULT_REQUEST_TIMEOUT_SECONDS = 300
 REQUEST_TIMEOUT_KEYWORD = "request_timeout"
 SERVICE_API_PATH = "services"
 DASHSCOPE_LOGGING_LEVEL_ENV = "DASHSCOPE_LOGGING_LEVEL"