refactor(skills): 提取vestack技能下载逻辑到独立函数并更新环境变量

将vestack环境下的技能下载逻辑提取到独立函数`_download_skill_via_vestack`中，提高代码复用性
同时将环境变量`AGENTKIT_TOOL_SCHEME`统一更新为`AGENTKIT_TOP_SCHEME`

Author: dawnguo

docs/docs/tools/builtin.md

@@ -187,6 +187,7 @@ VeADK 集成了以下火山引擎工具：
     - `AGENTKIT_TOOL_HOST`：用于调用火山引擎AgentKit Tools的EndPoint
     - `AGENTKIT_TOOL_SERVICE_CODE`：用于调用AgentKit Tools的ServiceCode
     - `AGENTKIT_TOOL_SCHEME`：用于切换调用 AgentKit Tools 的协议，允许 `http`/`https`，默认 `https`
+    - `AGENTKIT_TOP_SCHEME`：用于切换调用 AgentKit TOP 的协议，允许 `http`/`https`，默认 `https`
 
     环境变量列表：
 

veadk/skills/utils.py

@@ -174,7 +174,7 @@ def load_skills_from_cloud(skill_space_ids: str) -> list[Skill]:
                 "InnerTags": {"source": "sandbox"},
             }
             logger.debug(f"ListSkillsBySpaceId request body: {request_body}")
-            scheme = os.getenv("AGENTKIT_TOOL_SCHEME", "https").lower()
+            scheme = os.getenv("AGENTKIT_TOP_SCHEME", "https").lower()
 
             response = ve_request(
                 request_body=request_body,

veadk/tools/skills_tools/download_skills_tool.py

@@ -28,6 +28,93 @@
 logger = get_logger(__name__)
 
 
+def _download_skill_via_vestack(
+    tos_path: str,
+    skill_name: str,
+    access_key: str,
+    secret_key: str,
+    session_token: str,
+    service: str,
+    region: str,
+    host: str,
+    scheme: str,
+    zip_path: Path,
+) -> bool:
+    import json
+    import requests
+    from veadk.utils.volcengine_sign import ve_request
+
+    try:
+        path_parts = tos_path.split("/")
+        if len(path_parts) >= 3:
+            skill_id = path_parts[1]
+            skill_version = path_parts[2]
+        else:
+            logger.error(
+                f"Invalid TosPath format for skill '{skill_name}': {tos_path}"
+            )
+            return False
+    except Exception as e:
+        logger.error(
+            f"Failed to parse TosPath for skill '{skill_name}': {e}"
+        )
+        return False
+
+    # Call GenTempTosObjectDownloadUrl API
+    temp_url_request_body = {
+        "SkillId": skill_id,
+        "SkillVersion": skill_version,
+    }
+    logger.debug(
+        f"GenTempTosObjectDownloadUrl request body: {temp_url_request_body}"
+    )
+
+    temp_url_res = ve_request(
+        request_body=temp_url_request_body,
+        action="GenTempTosObjectDownloadUrl",
+        ak=access_key,
+        sk=secret_key,
+        service=service,
+        version="2025-10-30",
+        region=region,
+        host=host,
+        header={"X-Security-Token": session_token},
+        scheme=scheme,
+    )
+
+    if isinstance(temp_url_res, str):
+        temp_url_res = json.loads(temp_url_res)
+
+    if (
+        "ResponseMetadata" in temp_url_res
+        and "Error" in temp_url_res["ResponseMetadata"]
+    ):
+        error_details = temp_url_res["ResponseMetadata"]["Error"]
+        logger.error(
+            f"Failed to get temporary download URL for '{skill_name}': {error_details}"
+        )
+        return False
+    else:
+        signed_url = temp_url_res.get("Result", {}).get("SignedUrl")
+        if not signed_url:
+            logger.error(
+                f"Failed to get SignedUrl from GenTempTosObjectDownloadUrl response: {temp_url_res}"
+            )
+            return False
+        else:
+            try:
+                response = requests.get(signed_url)
+                response.raise_for_status()
+                with open(zip_path, "wb") as f:
+                    f.write(response.content)
+                return True
+            except Exception as e:
+                logger.warning(
+                    f"Failed to download skill '{skill_name}' from minio: {e}"
+                )
+                return False
+
+
 def download_skills_tool(
     download_path: str, skill_names: Optional[list[str]] = None
 ) -> str:
@@ -92,7 +179,7 @@ def download_skills_tool(
 
         all_downloaded_skills = []
 
-        scheme = os.getenv("AGENTKIT_TOOL_SCHEME", "https").lower()
+        scheme = os.getenv("AGENTKIT_TOP_SCHEME", "https").lower()
         # Iterate through each skill space
         for skill_space_id in skill_space_ids_list:
             try:
@@ -165,79 +252,18 @@ def download_skills_tool(
                     zip_path = download_dir / f"{skill_name}.zip"
 
                     if cloud_provider == "vestack":
-                        import requests
-
-                        try:
-                            path_parts = tos_path.split("/")
-                            if len(path_parts) >= 3:
-                                skill_id = path_parts[1]
-                                skill_version = path_parts[2]
-                            else:
-                                logger.error(
-                                    f"Invalid TosPath format for skill '{skill_name}': {tos_path}"
-                                )
-                                success = False
-                                continue
-                        except Exception as e:
-                            logger.error(
-                                f"Failed to parse TosPath for skill '{skill_name}': {e}"
-                            )
-                            success = False
-                            continue
-
-                        # Call GenTempTosObjectDownloadUrl API
-                        temp_url_request_body = {
-                            "SkillId": skill_id,
-                            "SkillVersion": skill_version,
-                        }
-                        logger.debug(
-                            f"GenTempTosObjectDownloadUrl request body: {temp_url_request_body}"
-                        )
-
-                        temp_url_res = ve_request(
-                            request_body=temp_url_request_body,
-                            action="GenTempTosObjectDownloadUrl",
-                            ak=access_key,
-                            sk=secret_key,
+                        success = _download_skill_via_vestack(
+                            tos_path=tos_path,
+                            skill_name=skill_name,
+                            access_key=access_key,
+                            secret_key=secret_key,
+                            session_token=session_token,
                             service=service,
-                            version="2025-10-30",
                             region=region,
                             host=host,
-                            header={"X-Security-Token": session_token},
                             scheme=scheme,
+                            zip_path=zip_path,
                         )
-
-                        if isinstance(temp_url_res, str):
-                            temp_url_res = json.loads(temp_url_res)
-
-                        if (
-                            "ResponseMetadata" in temp_url_res
-                            and "Error" in temp_url_res["ResponseMetadata"]
-                        ):
-                            error_details = temp_url_res["ResponseMetadata"]["Error"]
-                            logger.error(
-                                f"Failed to get temporary download URL for '{skill_name}': {error_details}"
-                            )
-                            success = False
-                        else:
-                            signed_url = temp_url_res.get("Result", {}).get("SignedUrl")
-                            if not signed_url:
-                                logger.error(
-                                    f"Failed to get SignedUrl from GenTempTosObjectDownloadUrl response: {temp_url_res}"
-                                )
-                                success = False
-                            else:
-                                try:
-                                    response = requests.get(signed_url)
-                                    response.raise_for_status()
-                                    with open(zip_path, "wb") as f:
-                                        f.write(response.content)
-                                    success = True
-                                except Exception as e:
-                                    logger.warning(
-                                        f"Failed to download skill '{skill_name}' from minio: {e}"
-                                    )
-                                    success = False
                     else:
                         success = tos_client.download(
                             bucket_name=tos_bucket,

veadk/tools/skills_tools/register_skills_tool.py

@@ -135,7 +135,7 @@ def register_skills_tool(
                 return f"Error: Failed to get account id when registering skill '{skill_name}'."
 
         tos_bucket = f"agentkit-platform-{region}-{account_id}-skill"
-        scheme = os.getenv("AGENTKIT_TOOL_SCHEME", "https").lower()
+        scheme = os.getenv("AGENTKIT_TOP_SCHEME", "https").lower()
         if cloud_provider == "vestack":
             import requests