@@ -74,7 +74,7 @@ def get_mcp_servers_by_page(self, page_no: int, page_size: int) -> list[McpServe
74
74
jsonObj = json .loads (response .content .decode ("utf-8" ))
75
75
data = jsonObj ['data' ]
76
76
for mcp_server_dict in data ['pageItems' ]:
77
- if mcp_server_dict ["enabled" ]:
77
+ if mcp_server_dict ["enabled" ] and ( mcp_server_dict [ "protocol" ] == "mcp-sse" or mcp_server_dict [ "protocol" ] == "stdio" ) :
78
78
mcp_name = mcp_server_dict ["name" ]
79
79
mcpServer = self .get_mcp_server_by_name (mcp_name )
80
80
@@ -83,6 +83,7 @@ def get_mcp_servers_by_page(self, page_no: int, page_size: int) -> list[McpServe
83
83
mcpServers .append (mcpServer )
84
84
return mcpServers
85
85
except Exception as e :
86
+ NacosMcpRouteLogger .get_logger ().warning ("failed to get mcp server list" , exc_info = e )
86
87
return mcpServers
87
88
88
89
def get_mcp_servers (self ) -> list [McpServer ]:
@@ -98,7 +99,7 @@ def get_mcp_servers(self) -> list[McpServer]:
98
99
response = httpx .get (url , headers = headers )
99
100
if response .status_code != 200 :
100
101
NacosMcpRouteLogger .get_logger ().warning (
101
- "failed to get mcp server list, url {}, response {}" .format (url , response .content ))
102
+ "failed to get mcp server list, url {}, response {}" .format (url , response .content . decode ( "utf-8" ) ))
102
103
return []
103
104
104
105
jsonObj = json .loads (response .content .decode ("utf-8" ))
0 commit comments