MCP (Model Context Protocol)

1
import os
2
import asyncio
3
from dotenv import load_dotenv
4
5
load_dotenv()
6
7
from respan import Respan
8
from respan_instrumentation_openinference import OpenInferenceInstrumentor
9
from openinference_instrumentation_mcp import MCPInstrumentor
10
from mcp import ClientSession, StdioServerParameters
11
from mcp.client.stdio import stdio_client
12
13
# Initialize Respan with MCP instrumentation
14
respan = Respan(
15
    instrumentations=[
16
        OpenInferenceInstrumentor(instrumentor=MCPInstrumentor())
17
    ]
18
)
19
20
async def main():
21
    # Connect to an MCP server
22
    server_params = StdioServerParameters(
23
        command="python",
24
        args=["your_mcp_server.py"],
25
    )
26
27
    async with stdio_client(server_params) as (read, write):
28
        async with ClientSession(read, write) as session:
29
            await session.initialize()
30
31
            # List available tools
32
            tools = await session.list_tools()
33
            print(f"Available tools: {[t.name for t in tools.tools]}")
34
35
            # Call a tool
36
            result = await session.call_tool("your_tool", arguments={"query": "hello"})
37
            print(result)
38
39
    respan.flush()
40
41
asyncio.run(main())