mirror of
https://gitee.com/wanwujie/deer-flow
synced 2026-04-22 21:54:45 +08:00
46 lines
1.3 KiB
Python
46 lines
1.3 KiB
Python
|
"""Load MCP tools using langchain-mcp-adapters."""
|
||
|
|
|
||
|
|
import logging
|
||
|
|
|
||
|
|
from langchain_core.tools import BaseTool
|
||
|
|
|
||
|
|
from src.config.mcp_config import get_mcp_config
|
||
|
|
from src.mcp.client import build_servers_config
|
||
|
|
|
||
|
|
logger = logging.getLogger(__name__)
|
||
|
|
|
||
|
|
|
||
|
|
async def get_mcp_tools() -> list[BaseTool]:
|
||
|
|
"""Get all tools from enabled MCP servers.
|
||
|
|
|
||
|
|
Returns:
|
||
|
|
List of LangChain tools from all enabled MCP servers.
|
||
|
|
"""
|
||
|
|
try:
|
||
|
|
from langchain_mcp_adapters.client import MultiServerMCPClient
|
||
|
|
except ImportError:
|
||
|
|
logger.warning("langchain-mcp-adapters not installed. Install it to enable MCP tools: pip install langchain-mcp-adapters")
|
||
|
|
return []
|
||
|
|
|
||
|
|
mcp_config = get_mcp_config()
|
||
|
|
servers_config = build_servers_config(mcp_config)
|
||
|
|
|
||
|
|
if not servers_config:
|
||
|
|
logger.info("No enabled MCP servers configured")
|
||
|
|
return []
|
||
|
|
|
||
|
|
try:
|
||
|
|
# Create the multi-server MCP client
|
||
|
|
logger.info(f"Initializing MCP client with {len(servers_config)} server(s)")
|
||
|
|
client = MultiServerMCPClient(servers_config)
|
||
|
|
|
||
|
|
# Get all tools from all servers
|
||
|
|
tools = await client.get_tools()
|
||
|
|
logger.info(f"Successfully loaded {len(tools)} tool(s) from MCP servers")
|
||
|
|
|
||
|
|
return tools
|
||
|
|
|
||
|
|
except Exception as e:
|
||
|
|
logger.error(f"Failed to load MCP tools: {e}", exc_info=True)
|
||
|
|
return []
|