http example.

Author: lukeina2z

instrumentation-genai/opentelemetry-instrumentation-mcp/README.rst

@@ -16,12 +16,22 @@ Automatically enabled with:
 opentelemetry-instrument python your_mcp_app.py
 ```
 
-## Configuration
+## Examples
+
+See the `examples/` directory for complete working examples:
+
+- **simple-client-server**: stdio transport example with Jaeger integration
+- **http-transport**: HTTP/SSE transport example with console exporter
+
+## Supported Transports
+
+- **stdio**: Process-based communication (stdin/stdout)
+- **HTTP/SSE**: Network-based communication with Server-Sent Events
+
+Both transports are fully instrumented with automatic trace context propagation.
 
 ## Spans Created
 
-- **Client**: 
-  - Initialize: `mcp.initialize`
-  - List Tools: `mcp.list_tools`
-  - Call Tool: `mcp.call_tool.{tool_name}`
-- **Server**: `tools/initialize`, `tools/list`, `tools/{tool_name}`
+- **Client spans**: `mcp.client` with method-specific names (e.g., `tools/call add`)
+- **Server spans**: `mcp.server` with method-specific names
+- Distributed tracing via W3C trace context in message metadata

instrumentation-genai/opentelemetry-instrumentation-mcp/examples/http-transport/README.md

@@ -0,0 +1,84 @@
+# MCP HTTP Transport Example
+
+This example demonstrates OpenTelemetry instrumentation for MCP using HTTP transport with Server-Sent Events (SSE).
+
+## Running the Server
+
+### 1. Install Dependencies
+
+```bash
+cd server
+uv sync
+uv run opentelemetry-bootstrap -a install
+
+# Install MCP instrumentation library
+uv run pip install -e ../../../../opentelemetry-instrumentation-mcp
+```
+
+### 2. Start the Server
+
+```bash
+cd server
+
+OTEL_SERVICE_NAME=mcp-server-PyHttp \
+  OTEL_TRACES_EXPORTER=otlp \
+  OTEL_EXPORTER_OTLP_TRACES_ENDPOINT=http://xyz-jaeger-100:4317/v1/traces \
+  uv run opentelemetry-instrument python ./server.py
+```
+
+The server will start on `http://localhost:8000`.
+
+## Running the Client
+
+### 1. Install Dependencies
+
+```bash
+cd client
+uv sync
+uv run opentelemetry-bootstrap -a install
+
+# Install MCP instrumentation library
+uv run pip install -e ../../../../opentelemetry-instrumentation-mcp
+```
+
+### 2. Run the Client
+
+```bash
+cd client
+
+OTEL_SERVICE_NAME=mcp-client-PyHttp \
+  OTEL_TRACES_EXPORTER=otlp \
+  OTEL_EXPORTER_OTLP_TRACES_ENDPOINT=http://xyz-jaeger-100:4317/v1/traces \
+  uv run opentelemetry-instrument python ./client.py
+```
+
+## Jaeger Trace Visualization
+
+![MCP HTTP Transport Trace](mcphttp.png)
+
+
+## How It Works
+
+### Transport Layer
+
+- **Server**: Uses `mcp.server.sse` for HTTP transport with Server-Sent Events
+- **Client**: Uses `mcp.client.sse.sse_client()` to connect via HTTP
+- **Communication**: Real-time bidirectional communication over HTTP/SSE
+
+### Instrumentation
+
+The OpenTelemetry instrumentation automatically:
+
+1. **Traces all MCP operations**: Tool calls, resource reads, prompt handling, and session lifecycle
+2. **Injects W3C trace context**: Embeds trace context into MCP message metadata
+3. **Propagates context**: Maintains trace continuity across HTTP requests
+4. **Links spans**: Creates parent-child relationships between client and server operations
+
+## Transport Comparison
+
+| Feature | stdio Transport | HTTP/SSE Transport |
+|---------|----------------|--------------------|
+| Communication | Process-based (stdin/stdout) | Network-based (HTTP) |
+| Use Case | Local processes | Distributed systems |
+| Instrumentation | Fully supported | Fully supported |
+| Trace Propagation | W3C trace context | W3C trace context |

instrumentation-genai/opentelemetry-instrumentation-mcp/examples/http-transport/client/client.py

@@ -0,0 +1,41 @@
+#!/usr/bin/env python3
+"""MCP client with HTTP transport using SSE."""
+
+import asyncio
+
+from mcp import ClientSession
+from mcp.client.sse import sse_client
+from pydantic import AnyUrl
+
+from opentelemetry import trace
+
+
+async def main():
+    tracer = trace.get_tracer(__name__)
+
+    with tracer.start_as_current_span("mcp_http_client"):
+        # Connect to MCP server via HTTP
+        async with sse_client("http://localhost:8000/sse") as (read, write):
+            async with ClientSession(read, write) as session:
+                # Initialize
+                await session.initialize()
+
+                # List tools
+                tools = await session.list_tools()
+                print(f"Available tools: {[t.name for t in tools.tools]}")
+
+                # Call tool
+                result = await session.call_tool(
+                    "add", arguments={"a": 5, "b": 3}
+                )
+                print(f"add(5, 3) = {result.content}")
+
+                # Read resource
+                greeting = await session.read_resource(
+                    AnyUrl("greeting://World")
+                )
+                print(f"Greeting: {greeting}")
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

instrumentation-genai/opentelemetry-instrumentation-mcp/examples/http-transport/client/pyproject.toml

@@ -0,0 +1,13 @@
+[project]
+name = "mcp-http-client-example"
+version = "0.1.0"
+requires-python = ">=3.10"
+dependencies = [
+    "mcp>=1.8.1",
+    "opentelemetry-api>=1.37.0",
+    "opentelemetry-distro>=0.58b0",
+    "opentelemetry-exporter-otlp>=1.37.0",
+    "opentelemetry-instrumentation-mcp",
+    "opentelemetry-sdk",
+    "pip>=25.2",
+]