examples: reorganize samples and collectors; remove azure monitor from most; add enhanced_travel_planner and trace_collectors; update README

Author: nagkumar91

instrumentation-genai/opentelemetry-instrumentation-openai-agents/examples/README.md

@@ -4,9 +4,12 @@ This directory contains examples of how to use the OpenAI Agents instrumentation
 
 ## Files
 
-- `quickstart.py` - Minimal OpenTelemetry setup and OpenAI chat sample using `OpenAIAgentsInstrumentor`
-- `basic_usage.py` - Basic example showing how to enable and use the instrumentation
-- `.env.example` - Example environment variables configuration
+- `quickstart.py` - Minimal OpenTelemetry setup and OpenAI chat sample.
+- `basic_usage.py` - Tool-calling airline demo (no Azure Monitor).
+- `mcp_hotel_capture_all.py` - MCP HTTP hotel finder sample (no Azure Monitor).
+- `enhanced_travel_planner.py` - Complex orchestration travel planner (console exporter).
+- `trace_collectors.py` - Showcase of Console, OTLP gRPC/HTTP, and Azure Monitor exporters.
+- `.env.example` - Example environment variables configuration.
 
 ## Basic Usage
 
@@ -27,10 +30,7 @@ This directory contains examples of how to use the OpenAI Agents instrumentation
 
 ## Configuration
 
-The instrumentation can be configured using environment variables:
-
-- `OTEL_INSTRUMENTATION_OPENAI_AGENTS_CAPTURE_CONTENT` - Enable/disable content capture (default: false)
-- `OTEL_INSTRUMENTATION_OPENAI_AGENTS_CAPTURE_METRICS` - Enable/disable metrics collection (default: true)
+Content, metrics, and events are captured by default.
 
 ## Integration with Agent Frameworks
 

instrumentation-genai/opentelemetry-instrumentation-openai-agents/examples/basic_usage.py

@@ -23,7 +23,6 @@
     trace,
 )
 from agents.extensions.handoff_prompt import RECOMMENDED_PROMPT_PREFIX
-from azure.monitor.opentelemetry import configure_azure_monitor
 from dotenv import load_dotenv
 from openai import AsyncAzureOpenAI
 from pydantic import BaseModel
@@ -34,9 +33,6 @@
 
 load_dotenv()
 
-configure_azure_monitor(
-    connection_string=os.environ["APPLICATION_INSIGHTS_CONNECTION_STRING"]
-)
 
 OpenAIAgentsInstrumentor().instrument()
 

instrumentation-genai/opentelemetry-instrumentation-openai-agents/examples/openai_agents_multi_agent_travel/enhanced.py renamed to instrumentation-genai/opentelemetry-instrumentation-openai-agents/examples/enhanced_travel_planner.py

@@ -9,6 +9,19 @@
 from typing import Any, Dict, List, Optional
 from uuid import uuid4
 
+# Azure Monitor exporter removed for this sample
+from agents import (
+    Agent,
+    HandoffInputData,
+    OpenAIChatCompletionsModel,
+    Runner,
+    function_tool,
+    handoff,
+)
+from agents import (
+    trace as agents_trace,
+)
+from agents.extensions import handoff_filters
 from dotenv import load_dotenv
 from openai import AsyncAzureOpenAI, AsyncOpenAI
 from pydantic import BaseModel, Field
@@ -27,24 +40,6 @@
     ConsoleSpanExporter,
 )
 
-try:
-    from azure.monitor.opentelemetry.exporter import AzureMonitorTraceExporter
-except ImportError:
-    AzureMonitorTraceExporter = None
-
-from agents import (
-    Agent,
-    HandoffInputData,
-    OpenAIChatCompletionsModel,
-    Runner,
-    function_tool,
-    handoff,
-)
-from agents import (
-    trace as agents_trace,
-)
-from agents.extensions import handoff_filters
-
 TRACER = trace.get_tracer(__name__)
 
 # Agent metadata constants
@@ -112,10 +107,6 @@ class CompleteTravelPlan(BaseModel):
 
 def _configure_otel(session_id: str) -> GenAISemanticProcessor:
     """Configure OpenTelemetry with GenAI semantic processor."""
-    conn = os.getenv("APPLICATIONINSIGHTS_CONNECTION_STRING") or os.getenv(
-        "APPLICATION_INSIGHTS_CONNECTION_STRING"
-    )
-
     resource = Resource.create(
         {
             "service.name": "openai-agents-enhanced-travel-planner",
@@ -129,15 +120,7 @@ def _configure_otel(session_id: str) -> GenAISemanticProcessor:
     )
 
     tp = TracerProvider(resource=resource)
-
-    if conn and AzureMonitorTraceExporter:
-        tp.add_span_processor(
-            BatchSpanProcessor(
-                AzureMonitorTraceExporter.from_connection_string(conn)
-            )
-        )
-    else:
-        tp.add_span_processor(BatchSpanProcessor(ConsoleSpanExporter()))
+    tp.add_span_processor(BatchSpanProcessor(ConsoleSpanExporter()))
 
     trace.set_tracer_provider(tp)
 
@@ -166,31 +149,19 @@ def _configure_otel(session_id: str) -> GenAISemanticProcessor:
         tracer=tracer,
         event_logger=None,
         system_name=provider,
-        include_sensitive_data=os.getenv(
-            "OTEL_GENAI_INCLUDE_SENSITIVE", "false"
-        ).lower()
-        == "true",
+        include_sensitive_data=True,
         base_url=base_url,
-        emit_legacy=os.getenv("OTEL_GENAI_EMIT_LEGACY", "false").lower()
-        == "true",
-        agent_name=os.getenv("OTEL_GENAI_AGENT_NAME", AGENT_SYSTEM_NAME),
-        agent_id=os.getenv("OTEL_GENAI_AGENT_ID", agent_id),
-        agent_description=os.getenv(
-            "OTEL_GENAI_AGENT_DESCRIPTION",
-            "Multi-agent travel planning system with 6 specialized agents: Travel Coordinator, Flight Specialist, Hotel Specialist, Activity Specialist, Budget Analyst, and Plan Synthesizer",
+        emit_legacy=False,
+        agent_name=AGENT_SYSTEM_NAME,
+        agent_id=agent_id,
+        agent_description=(
+            "Multi-agent travel planning system with specialized agents: "
+            "Coordinator, Flight Specialist, Hotel Specialist, Activity Specialist, Budget Analyst, and Plan Synthesizer"
         ),
         server_address=None,
         server_port=None,
     )
 
-    if os.getenv("ENABLE_GENAI_CAPTURE_ALL", "false").lower() == "true":
-        os.environ["OTEL_GENAI_CAPTURE_SYSTEM_INSTRUCTIONS"] = "true"
-        os.environ["OTEL_GENAI_CAPTURE_MESSAGES"] = "true"
-        os.environ["OTEL_GENAI_CAPTURE_TOOL_DEFINITIONS"] = "true"
-
-    if os.getenv("OTEL_GENAI_METRICS_ENABLED", "true").lower() == "true":
-        os.environ["OTEL_GENAI_METRICS_ENABLED"] = "true"
-
     return genai_processor
 
 

instrumentation-genai/opentelemetry-instrumentation-openai-agents/examples/mcp_hotel_capture_all.py

@@ -7,7 +7,6 @@
 import os
 from dataclasses import dataclass
 from typing import Callable
-from urllib.parse import urlparse
 
 import azure.identity
 import openai
@@ -48,34 +47,8 @@ class _ApiConfig:
 
 
 def _set_capture_env(provider: str, base_url: str) -> None:
-    """Enable all GenAI capture toggles before instrumentation hooks."""
-
-    capture_defaults = {
-        "OTEL_INSTRUMENTATION_OPENAI_AGENTS_CAPTURE_CONTENT": "true",
-        "OTEL_INSTRUMENTATION_OPENAI_AGENTS_CAPTURE_METRICS": "true",
-        "OTEL_GENAI_CAPTURE_MESSAGES": "true",
-        "OTEL_GENAI_CAPTURE_SYSTEM_INSTRUCTIONS": "true",
-        "OTEL_GENAI_CAPTURE_TOOL_DEFINITIONS": "true",
-        "OTEL_GENAI_EMIT_OPERATION_DETAILS": "true",
-        "OTEL_GENAI_AGENT_NAME": os.getenv(
-            "OTEL_GENAI_AGENT_NAME", "MCP Hotel Assistant"
-        ),
-        "OTEL_GENAI_AGENT_DESCRIPTION": os.getenv(
-            "OTEL_GENAI_AGENT_DESCRIPTION",
-            "Agent orchestrator that uses MCP to find hotels matching user criteria",
-        ),
-        "OTEL_GENAI_AGENT_ID": os.getenv(
-            "OTEL_GENAI_AGENT_ID", "mcp-hotel-assistant"
-        ),
-    }
-    for env_key, value in capture_defaults.items():
-        os.environ.setdefault(env_key, value)
-
-    parsed = urlparse(base_url)
-    if parsed.hostname:
-        os.environ.setdefault("OTEL_GENAI_SERVER_ADDRESS", parsed.hostname)
-    if parsed.port:
-        os.environ.setdefault("OTEL_GENAI_SERVER_PORT", str(parsed.port))
+    """Deprecated: capture is always on; keep for backward compatibility."""
+    return
 
 
 def _resolve_api_config() -> _ApiConfig:
@@ -126,70 +99,24 @@ def _build_client() -> openai.AsyncAzureOpenAI:
             provider="azure.ai.openai",
         )
 
-    if host == "ollama":
-        base_url = os.getenv(
-            "OLLAMA_BASE_URL", "http://localhost:11434/v1"
-        ).rstrip("/")
-        model_name = os.getenv("OLLAMA_MODEL", "llama3.1:latest")
-        api_key = os.getenv("OLLAMA_API_KEY", "none")
-
-        def _build_client() -> openai.AsyncOpenAI:
-            return openai.AsyncOpenAI(base_url=base_url, api_key=api_key)
-
-        return _ApiConfig(
-            build_client=_build_client,
-            model_name=model_name,
-            base_url=base_url,
-            provider="self.hosted",
-        )
+    # Removed ollama path to simplify sample
 
     raise ValueError(f"Unsupported API_HOST '{host}'")
 
 
 def _configure_otel() -> None:
-    """Configure the tracer provider and exporters."""
-
-    conn = os.getenv("APPLICATION_INSIGHTS_CONNECTION_STRING")
+    """Configure tracer provider with console exporter (no Azure Monitor)."""
     resource = Resource.create(
         {
             "service.name": "mcp-hotel-finder-service",
             "service.namespace": "mcp-orchestration",
             "service.version": os.getenv("SERVICE_VERSION", "1.0.0"),
         }
     )
-
     tracer_provider = TracerProvider(resource=resource)
-
-    if conn:
-        try:
-            from azure.monitor.opentelemetry.exporter import (  # type: ignore import-not-found
-                AzureMonitorTraceExporter,
-            )
-        except ImportError:  # pragma: no cover - optional dependency
-            print(
-                "Warning: Azure Monitor exporter not installed. "
-                "Install with: pip install azure-monitor-opentelemetry-exporter",
-            )
-            tracer_provider.add_span_processor(
-                BatchSpanProcessor(ConsoleSpanExporter())
-            )
-        else:
-            tracer_provider.add_span_processor(
-                BatchSpanProcessor(
-                    AzureMonitorTraceExporter.from_connection_string(conn)
-                )
-            )
-            print("[otel] Azure Monitor trace exporter configured")
-    else:
-        tracer_provider.add_span_processor(
-            BatchSpanProcessor(ConsoleSpanExporter())
-        )
-        print("[otel] Console span exporter configured")
-        print(
-            "[otel] Set APPLICATION_INSIGHTS_CONNECTION_STRING to export to "
-            "Application Insights instead of the console",
-        )
-
+    tracer_provider.add_span_processor(
+        BatchSpanProcessor(ConsoleSpanExporter())
+    )
     trace.set_tracer_provider(tracer_provider)