Merge branch 'dev' of https://github.com/MoFox-Studio/MoFox_Bot into dev
This commit is contained in:
@@ -1 +0,0 @@
|
|||||||
|
|
||||||
@@ -10,7 +10,7 @@ from pathlib import Path
|
|||||||
from typing import Any
|
from typing import Any
|
||||||
|
|
||||||
import mcp.types
|
import mcp.types
|
||||||
from fastmcp.client import Client, StreamableHttpTransport
|
from fastmcp.client import Client, StdioTransport, StreamableHttpTransport
|
||||||
|
|
||||||
from src.common.logger import get_logger
|
from src.common.logger import get_logger
|
||||||
|
|
||||||
@@ -169,11 +169,17 @@ class MCPClientManager:
|
|||||||
|
|
||||||
client = Client(transport, timeout=server_config.timeout)
|
client = Client(transport, timeout=server_config.timeout)
|
||||||
|
|
||||||
elif transport_type == "sse":
|
elif transport_type == "stdio":
|
||||||
from fastmcp.client import SSETransport
|
# stdio 传输:通过标准输入输出与本地进程通信
|
||||||
|
command = server_config.transport_config.get("command")
|
||||||
|
args = server_config.transport_config.get("args", [])
|
||||||
|
|
||||||
url = server_config.transport_config["url"]
|
if not command:
|
||||||
client = Client(SSETransport(url), timeout=server_config.timeout)
|
raise ValueError("stdio 传输需要提供 'command' 参数")
|
||||||
|
|
||||||
|
# 创建 stdio 传输
|
||||||
|
transport = StdioTransport(command, args)
|
||||||
|
client = Client(transport, timeout=server_config.timeout)
|
||||||
|
|
||||||
else:
|
else:
|
||||||
raise ValueError(f"不支持的传输类型: {transport_type}")
|
raise ValueError(f"不支持的传输类型: {transport_type}")
|
||||||
|
|||||||
Reference in New Issue
Block a user