refactor(examples): use PostHogSpanProcessor instead of raw OTLP exporter

Adopt the new PostHogSpanProcessor API from #494 across all OTEL examples.
Drops the manual SimpleSpanProcessor + OTLPSpanExporter wiring in favor of
the higher-level processor that handles batching and AI span filtering.

Each example now depends on posthog[otel] via a uv path source so it
resolves against the workspace checkout while #494 is unreleased.

Author: richardsolomou

examples/example-ai-anthropic/chat.py

@@ -5,9 +5,8 @@
 import urllib.request
 from opentelemetry import trace
 from opentelemetry.sdk.trace import TracerProvider
-from opentelemetry.sdk.trace.export import SimpleSpanProcessor
 from opentelemetry.sdk.resources import Resource, SERVICE_NAME
-from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
+from posthog.ai.otel import PostHogSpanProcessor
 from opentelemetry.instrumentation.anthropic import AnthropicInstrumentor
 
 resource = Resource(
@@ -18,12 +17,13 @@
         "conversation_id": "abc-123",
     }
 )
-exporter = OTLPSpanExporter(
-    endpoint=f"{os.environ.get('POSTHOG_HOST', 'https://us.i.posthog.com')}/i/v0/ai/otel",
-    headers={"Authorization": f"Bearer {os.environ['POSTHOG_API_KEY']}"},
-)
 provider = TracerProvider(resource=resource)
-provider.add_span_processor(SimpleSpanProcessor(exporter))
+provider.add_span_processor(
+    PostHogSpanProcessor(
+        api_key=os.environ["POSTHOG_API_KEY"],
+        host=os.environ.get("POSTHOG_HOST", "https://us.i.posthog.com"),
+    )
+)
 trace.set_tracer_provider(provider)
 
 AnthropicInstrumentor().instrument()

examples/example-ai-anthropic/extended_thinking.py

@@ -6,9 +6,8 @@
 import os
 from opentelemetry import trace
 from opentelemetry.sdk.trace import TracerProvider
-from opentelemetry.sdk.trace.export import SimpleSpanProcessor
 from opentelemetry.sdk.resources import Resource, SERVICE_NAME
-from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
+from posthog.ai.otel import PostHogSpanProcessor
 from opentelemetry.instrumentation.anthropic import AnthropicInstrumentor
 
 resource = Resource(
@@ -19,12 +18,13 @@
         "conversation_id": "abc-123",
     }
 )
-exporter = OTLPSpanExporter(
-    endpoint=f"{os.environ.get('POSTHOG_HOST', 'https://us.i.posthog.com')}/i/v0/ai/otel",
-    headers={"Authorization": f"Bearer {os.environ['POSTHOG_API_KEY']}"},
-)
 provider = TracerProvider(resource=resource)
-provider.add_span_processor(SimpleSpanProcessor(exporter))
+provider.add_span_processor(
+    PostHogSpanProcessor(
+        api_key=os.environ["POSTHOG_API_KEY"],
+        host=os.environ.get("POSTHOG_HOST", "https://us.i.posthog.com"),
+    )
+)
 trace.set_tracer_provider(provider)
 
 AnthropicInstrumentor().instrument()

examples/example-ai-anthropic/pyproject.toml

@@ -6,5 +6,8 @@ dependencies = [
     "anthropic>=0.80.0",
     "opentelemetry-instrumentation-anthropic>=0.24.0",
     "opentelemetry-sdk>=1.30.0",
-    "opentelemetry-exporter-otlp-proto-http>=1.30.0",
+    "posthog[otel]>=7.11.0",
 ]
+
+[tool.uv.sources]
+posthog = { path = "../.." }

examples/example-ai-anthropic/streaming.py

@@ -3,9 +3,8 @@
 import os
 from opentelemetry import trace
 from opentelemetry.sdk.trace import TracerProvider
-from opentelemetry.sdk.trace.export import SimpleSpanProcessor
 from opentelemetry.sdk.resources import Resource, SERVICE_NAME
-from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
+from posthog.ai.otel import PostHogSpanProcessor
 from opentelemetry.instrumentation.anthropic import AnthropicInstrumentor
 
 resource = Resource(
@@ -16,12 +15,13 @@
         "conversation_id": "abc-123",
     }
 )
-exporter = OTLPSpanExporter(
-    endpoint=f"{os.environ.get('POSTHOG_HOST', 'https://us.i.posthog.com')}/i/v0/ai/otel",
-    headers={"Authorization": f"Bearer {os.environ['POSTHOG_API_KEY']}"},
-)
 provider = TracerProvider(resource=resource)
-provider.add_span_processor(SimpleSpanProcessor(exporter))
+provider.add_span_processor(
+    PostHogSpanProcessor(
+        api_key=os.environ["POSTHOG_API_KEY"],
+        host=os.environ.get("POSTHOG_HOST", "https://us.i.posthog.com"),
+    )
+)
 trace.set_tracer_provider(provider)
 
 AnthropicInstrumentor().instrument()

examples/example-ai-anthropic/uv.lock

@@ -4,9 +4,8 @@
 import asyncio
 from opentelemetry import trace
 from opentelemetry.sdk.trace import TracerProvider
-from opentelemetry.sdk.trace.export import SimpleSpanProcessor
 from opentelemetry.sdk.resources import Resource, SERVICE_NAME
-from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
+from posthog.ai.otel import PostHogSpanProcessor
 from opentelemetry.instrumentation.openai_v2 import OpenAIInstrumentor
 
 resource = Resource(
@@ -17,12 +16,13 @@
         "conversation_id": "abc-123",
     }
 )
-exporter = OTLPSpanExporter(
-    endpoint=f"{os.environ.get('POSTHOG_HOST', 'https://us.i.posthog.com')}/i/v0/ai/otel",
-    headers={"Authorization": f"Bearer {os.environ['POSTHOG_API_KEY']}"},
-)
 provider = TracerProvider(resource=resource)
-provider.add_span_processor(SimpleSpanProcessor(exporter))
+provider.add_span_processor(
+    PostHogSpanProcessor(
+        api_key=os.environ["POSTHOG_API_KEY"],
+        host=os.environ.get("POSTHOG_HOST", "https://us.i.posthog.com"),
+    )
+)
 trace.set_tracer_provider(provider)
 
 OpenAIInstrumentor().instrument()

examples/example-ai-autogen/agent.py

@@ -8,5 +8,8 @@ dependencies = [
     "openai>=1.0.0",
     "opentelemetry-instrumentation-openai-v2>=2.0b0",
     "opentelemetry-sdk>=1.30.0",
-    "opentelemetry-exporter-otlp-proto-http>=1.30.0",
+    "posthog[otel]>=7.11.0",
 ]
+
+[tool.uv.sources]
+posthog = { path = "../.." }