MCP系列4:MCP与MCP Server啥区别，自己项目如何接入

from mcp_client import MCPClient

# 步骤1：初始化客户端（替换为实际URL）
client = MCPClient(
    transport="sse",  # 使用SSE协议
    endpoint="https://api.other-mcp-server.com/mcp"  # 对方服务地址
)

# 步骤2：调用工具（以"get_weather"为例）
try:
    # 同步调用
    result = client.call_tool(
        tool_name="get_weather",  # 工具名称（需对方提供）
        params={"city": "Beijing"},  # 参数（格式需匹配对方定义）
        timeout=10  # 超时时间（秒）
    )
    print(f"天气查询结果: {result['temperature']}℃")
    
except Exception as e:
    print(f"调用失败: {str(e)}")

from mcp_client import MCPClient

# 步骤1：初始化客户端（需知道对方可执行文件路径）
client = MCPClient(
    transport="stdio",
    command="/path/to/other_mcp_server",  # 对方服务的可执行文件
    args=["--config", "config.json"]     # 启动参数（如有）
)

# 步骤2：调用工具（与SSE方式相同）
result = client.call_tool("read_file", {"path": "/data/report.pdf"})

client = MCPClient(
    transport="sse",
    endpoint="https://api.secure-mcp.com/mcp",
    headers={"Authorization": "Bearer YOUR_API_KEY"}  # 添加认证头
)

# 异步流式调用（需Python 3.7+）
async with MCPClient("sse", endpoint=url) as client:
    async for chunk in client.stream_tool("generate_text", {"prompt": "Hello"}):
        print(chunk["text"], end="", flush=True)  # 逐块打印文本

tools = client.list_tools()  # 获取对方服务暴露的所有工具
print("可用工具:", [t["name"] for t in tools])

import logging
logging.basicConfig(level=logging.DEBUG)  # 查看详细通信日志

from mcp_client import MCPClient, MCPError

def fetch_user_data(user_id: str):
    client = MCPClient(
        transport="sse",
        endpoint="https://user-service.com/mcp",
        headers={"X-API-Key": "your_key_here"}
    )
    
    try:
        return client.call_tool(
            tool_name="get_user_profile",
            params={"user_id": user_id, "fields": ["name", "email"]}
        )
        
    except MCPError as e:
        if e.code == "TOOL_NOT_FOUND":
            print("工具不存在！请检查服务版本")
        elif e.code == "INVALID_PARAMS":
            print("参数错误:", e.message)
        else:
            print("未知错误:", str(e))
            
    finally:
        client.close()

# 使用示例
user_data = fetch_user_data("U123456")
print(user_data)