本文以查询天气为例介绍如何为[VeADK](https://volcengine.github.io/veadk-python/agent/agent/)构建的Agent集成MCP服务或MCP工具集。 :::warning 本文仅适用于入站身份认证为APIKey类型的MCP服务或工具集。 ::: ## 前提条件 * 已使用[VeADK](https://volcengine.github.io/veadk-python/agent/agent/)构建Agent。 * 已获取MCP服务的地址（URL），支持在MCP服务或工具集调用示例中获取，操作详情参见[获取MCP服务调用示例](https://www.volcengine.com/docs/86681/2222941)或[获取MCP工具集调用示例](https://www.volcengine.com/docs/86681/2227882)。 * 已获取MCP服务的入站API Key，支持在MCP服务或工具集的详情页的“基本信息\>入站身份认证”中获取。 ## 使用VeADK对接MCP 入站类型为API Key的MCP服务或工具集接入的代码示例如下。 ### 集成MCP服务 1. 配置环境变量。 ```Bash # 平台的AK和SK。 export VOLCENGINE_ACCESS_KEY= export VOLCENGINE_SECRET_KEY= # MCP服务的地址（URL），支持在MCP服务示例中获取，操作详情参见获取MCP服务调用示例。 export MCP_SERVICE_URL= # MCP服务的入站API Key凭证 export MCP_SERVICE_API_KEY= ``` 2. 安装Python依赖。 ```Bash pip install veadk-python ``` 3. 集成示例。 ```Python from veadk import Agent, Runner from google.adk.tools.mcp_tool.mcp_session_manager import StreamableHTTPConnectionParams from google.adk.tools.mcp_tool.mcp_toolset import MCPToolset import asyncio import os mcp_service_url = os.getenv("MCP_SERVICE_URL") mcp_service_api_key = os.getenv("MCP_SERVICE_API_KEY") mcp_service_tool = MCPToolset( connection_params=StreamableHTTPConnectionParams( url=mcp_service_url, headers={"Authorization": f"Bearer {mcp_service_api_key}"} ), ) agent = Agent( # instruction是Agent的 Prompt。这里只是一个示例，具体场景下需要根据实际情况调整。 instruction="You are an intelligent assistant, skilled at using the mcp_service_tool to solve problems and replying to users' questions politely.", tools=[mcp_service_tool], ) runner = Runner(agent=agent) user_prompt = "Hello, how many steps does it take to put an elephant into a refrigerator?" session_id = "mcp_service_session_id_123" response = asyncio.run( runner.run(messages=user_prompt, session_id=session_id) ) print(response) ``` ### 集成MCP工具集 1. 配置环境变量。 ```Bash # 平台的AK和SK。 export VOLCENGINE_ACCESS_KEY= export VOLCENGINE_SECRET_KEY= # MCP工具集的地址（URL），支持在工具集调用示例中获取，操作详情参见获取MCP工具集调用示例。 export TOOL_MCP_ROUTER_URL= # MCP工具集的入站API Key凭证 export TOOL_MCP_ROUTER_API_KEY= ``` 2. 安装Python依赖。 ```Bash pip install veadk-python ``` 3. 集成示例。 ```Python from veadk import Agent, Runner from veadk.tools.builtin_tools.mcp_router import mcp_router import asyncio agent = Agent( # instruction是Agent的 Prompt。这里只是一个示例，具体场景下需要根据实际情况调整。 instruction="You are an intelligent assistant, skilled at using the mcp_service_tool to solve problems and replying to users' questions politely.", tools=[mcp_router], ) runner = Runner(agent=agent) user_prompt = "Hello, how many steps does it take to put an elephant into a refrigerator?" session_id = "mcp_toolset_session_id_123" response = asyncio.run( runner.run(messages=user_prompt, session_id=session_id) ) print(response) ```

AgentKit