View a markdown version of this page

Listar los recursos disponibles en una AgentCore puerta de enlace - Amazon Bedrock AgentCore

Listar los recursos disponibles en una AgentCore puerta de enlace

Para enumerar todos los recursos disponibles que proporciona una AgentCore puerta de enlace, realice una solicitud POST al punto final MCP de la puerta de enlace y especifique resources/list el método en el cuerpo de la solicitud:

POST /mcp HTTP/1.1 Host: ${GatewayEndpoint} Content-Type: application/json Authorization: ${Authorization header} ${RequestBody}

Reemplace los siguientes valores:

  • ${GatewayEndpoint}— La URL de la puerta de enlace, tal como se proporciona en la respuesta de la CreateGatewayAPI.

  • ${Authorization header}— Las credenciales de autorización del proveedor de identidad al configurar la autorización entrante.

  • ${RequestBody}— La carga útil JSON del cuerpo de la solicitud, tal como se especifica en Cómo enumerar los recursos del Model Context Protocol (MCP). Incluir resources/list como. method

nota

Para obtener una lista de los parámetros compatibles opcionalmenteresources/list, consulte el params objeto en el cuerpo de la solicitud en Recursos, en la documentación del Protocolo de contexto modelo. En la parte superior de la página, junto a la barra de búsqueda, puede seleccionar la versión del MCP cuya documentación desea ver. Asegúrese de que la versión sea compatible con Amazon Bedrock AgentCore.

La respuesta devuelve una lista de los recursos disponibles con sus URI, nombres, descripciones y tipos de MIME.

nota

A diferencia de las herramientas y las indicaciones, los URI de los recursos se devuelven sin un prefijo de nombre de destino. El URI original del servidor MCP se devuelve tal cual.

nota

Cuando varios destinos muestran el mismo URI de recurso, la puerta de enlace devuelve el recurso del destino con el valor más bajoresourcePriority.

importante

Los URI de los recursos los proporciona el servidor MCP de destino descendente y la puerta de enlace no los valida ni los desinfecta. Un servidor MCP malintencionado o comprometido podría devolver URIs que apunten a puntos finales internos (SSRF) o a rutas de sistemas de archivos locales (por ejemplo,). file:///etc/passwd Valide y desinfecte los URI de los recursos antes de seguirlos y no busque ni renderice automáticamente los URI de servidores MCP que no sean de confianza.

Ejemplos de código para enumerar los recursos

Para ver ejemplos de cómo enumerar los recursos disponibles en la puerta de enlace, seleccione uno de los siguientes métodos:

ejemplo
Python requests package
  1. import requests import json def list_resources(gateway_url, access_token): headers = { "Content-Type": "application/json", "Authorization": f"Bearer {access_token}" } payload = { "jsonrpc": "2.0", "id": "list-resources-request", "method": "resources/list" } response = requests.post(gateway_url, headers=headers, json=payload) return response.json() # Example usage gateway_url = "https://${GatewayEndpoint}/mcp" # Replace with your actual gateway endpoint access_token = "${AccessToken}" # Replace with your actual access token resources = list_resources(gateway_url, access_token) print(json.dumps(resources, indent=2))
MCP Client
  1. import asyncio from mcp import ClientSession from mcp.client.streamable_http import streamablehttp_client async def execute_mcp( url, token, headers=None ): default_headers = { "Authorization": f"Bearer {token}" } headers = {**default_headers, **(headers or {})} async with streamablehttp_client( url=url, headers=headers, ) as ( read_stream, write_stream, callA, ): async with ClientSession(read_stream, write_stream) as session: # 1. Perform initialization handshake print("Initializing MCP...") _init_response = await session.initialize() print(f"MCP Server Initialize successful! - {_init_response}") # 2. List available resources print("Listing resources...") cursor = True resources = [] while cursor: next_cursor = cursor if isinstance(cursor, bool): next_cursor = None list_resources_response = await session.list_resources(next_cursor) resources.extend(list_resources_response.resources) cursor = list_resources_response.nextCursor if resources: for resource in resources: print(f"{resource.uri} - {resource.name} ({resource.mimeType})") print(f"Total resources: {len(resources)}") async def main(): url = "https://${GatewayEndpoint}/mcp" token = "your_bearer_token_here" # Optional additional headers additional_headers = { "Content-Type": "application/json", } await execute_mcp( url=url, token=token, headers=additional_headers ) # Run the async function if __name__ == "__main__": asyncio.run(main())
Strands MCP Client
  1. # NOTE: Strands SDK resource support may vary. Use the MCP Client approach # above for the most reliable resources/list implementation. from strands.tools.mcp.mcp_client import MCPClient from mcp.client.streamable_http import streamablehttp_client def create_streamable_http_transport(mcp_url: str, access_token: str): return streamablehttp_client(mcp_url, headers={"Authorization": f"Bearer {access_token}"}) def run_agent(mcp_url: str, access_token: str): mcp_client = MCPClient(lambda: create_streamable_http_transport(mcp_url, access_token)) with mcp_client: result = mcp_client.list_resources_sync() print(f"Found the following resources: {[r.uri for r in result.resources]}") run_agent(<MCP URL>, <Access token>)
LangGraph MCP Client
  1. # NOTE: LangGraph MCP adapter resource support may vary. Use the MCP Client # approach above for the most reliable resources/list implementation. import asyncio from mcp import ClientSession from mcp.client.streamable_http import streamablehttp_client async def list_resources(url, token): headers = {"Authorization": f"Bearer {token}"} async with streamablehttp_client(url=url, headers=headers) as ( read_stream, write_stream, callA ): async with ClientSession(read_stream, write_stream) as session: await session.initialize() response = await session.list_resources() for resource in response.resources: print(f"{resource.uri} - {resource.name}") asyncio.run(list_resources("https://${GatewayEndpoint}/mcp", "${AccessToken}"))