feat(examples): migrate AI examples to OpenTelemetry instrumentation

Switch from PostHog direct SDK wrappers to OpenTelemetry auto-instrumentation
for all AI provider examples where OTel instrumentations are available.

Uses opentelemetry-instrumentation-openai-v2 for OpenAI-compatible providers,
opentelemetry-instrumentation-anthropic for Anthropic, opentelemetry-instrumentation-google-generativeai
for Gemini, opentelemetry-instrumentation-langchain for LangChain/LangGraph,
opentelemetry-instrumentation-llamaindex for LlamaIndex, and opentelemetry-instrumentation-crewai for CrewAI.

Author: richardsolomou

examples/example-ai-anthropic/chat.py

@@ -1,16 +1,29 @@
-"""Anthropic chat with tool calling, tracked by PostHog."""
+"""Anthropic chat with tool calling, tracked via OpenTelemetry."""
 
 import os
 import json
 import urllib.request
-from posthog import Posthog
-from posthog.ai.anthropic import Anthropic
+from opentelemetry import trace
+from opentelemetry.sdk.trace import TracerProvider
+from opentelemetry.sdk.trace.export import BatchSpanProcessor
+from opentelemetry.sdk.resources import Resource, SERVICE_NAME
+from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
+from opentelemetry.instrumentation.anthropic import AnthropicInstrumentor
 
-posthog = Posthog(
-    os.environ["POSTHOG_API_KEY"],
-    host=os.environ.get("POSTHOG_HOST", "https://us.i.posthog.com"),
+resource = Resource(attributes={SERVICE_NAME: "example-anthropic-app"})
+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']}"},
 )
-client = Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"], posthog_client=posthog)
+provider = TracerProvider(resource=resource)
+provider.add_span_processor(BatchSpanProcessor(exporter))
+trace.set_tracer_provider(provider)
+
+AnthropicInstrumentor().instrument()
+
+import anthropic
+
+client = anthropic.Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"])
 
 tools = [
     {
@@ -40,7 +53,6 @@ def get_weather(latitude: float, longitude: float, location_name: str) -> str:
 message = client.messages.create(
     model="claude-sonnet-4-5-20250929",
     max_tokens=1024,
-    posthog_distinct_id="example-user",
     tools=tools,
     messages=[{"role": "user", "content": "What's the weather like in San Francisco?"}],
 )
@@ -54,4 +66,4 @@ def get_weather(latitude: float, longitude: float, location_name: str) -> str:
         result = get_weather(**block.input)
         print(result)
 
-posthog.shutdown()
+provider.shutdown()

examples/example-ai-anthropic/extended_thinking.py

@@ -1,22 +1,34 @@
-"""Anthropic extended thinking, tracked by PostHog.
+"""Anthropic extended thinking, tracked via OpenTelemetry.
 
 Extended thinking lets Claude show its reasoning process before responding.
 """
 
 import os
-from posthog import Posthog
-from posthog.ai.anthropic import Anthropic
+from opentelemetry import trace
+from opentelemetry.sdk.trace import TracerProvider
+from opentelemetry.sdk.trace.export import BatchSpanProcessor
+from opentelemetry.sdk.resources import Resource, SERVICE_NAME
+from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
+from opentelemetry.instrumentation.anthropic import AnthropicInstrumentor
 
-posthog = Posthog(
-    os.environ["POSTHOG_API_KEY"],
-    host=os.environ.get("POSTHOG_HOST", "https://us.i.posthog.com"),
+resource = Resource(attributes={SERVICE_NAME: "example-anthropic-app"})
+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']}"},
 )
-client = Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"], posthog_client=posthog)
+provider = TracerProvider(resource=resource)
+provider.add_span_processor(BatchSpanProcessor(exporter))
+trace.set_tracer_provider(provider)
+
+AnthropicInstrumentor().instrument()
+
+import anthropic
+
+client = anthropic.Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"])
 
 message = client.messages.create(
     model="claude-sonnet-4-5-20250929",
     max_tokens=16000,
-    posthog_distinct_id="example-user",
     thinking={"type": "enabled", "budget_tokens": 10000},
     messages=[
         {
@@ -32,4 +44,4 @@
     elif block.type == "text":
         print(f"Answer: {block.text}")
 
-posthog.shutdown()
+provider.shutdown()

examples/example-ai-anthropic/pyproject.toml

@@ -3,6 +3,8 @@ name = "example-ai-anthropic"
 version = "0.1.0"
 requires-python = ">=3.10"
 dependencies = [
-    "posthog==7.9.12",
-    "anthropic==0.86.0",
+    "anthropic>=0.80.0",
+    "opentelemetry-instrumentation-anthropic>=0.24.0",
+    "opentelemetry-sdk>=1.30.0",
+    "opentelemetry-exporter-otlp-proto-http>=1.30.0",
 ]

examples/example-ai-anthropic/streaming.py

@@ -1,19 +1,31 @@
-"""Anthropic streaming chat, tracked by PostHog."""
+"""Anthropic streaming chat, tracked via OpenTelemetry."""
 
 import os
-from posthog import Posthog
-from posthog.ai.anthropic import Anthropic
+from opentelemetry import trace
+from opentelemetry.sdk.trace import TracerProvider
+from opentelemetry.sdk.trace.export import BatchSpanProcessor
+from opentelemetry.sdk.resources import Resource, SERVICE_NAME
+from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
+from opentelemetry.instrumentation.anthropic import AnthropicInstrumentor
 
-posthog = Posthog(
-    os.environ["POSTHOG_API_KEY"],
-    host=os.environ.get("POSTHOG_HOST", "https://us.i.posthog.com"),
+resource = Resource(attributes={SERVICE_NAME: "example-anthropic-app"})
+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']}"},
 )
-client = Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"], posthog_client=posthog)
+provider = TracerProvider(resource=resource)
+provider.add_span_processor(BatchSpanProcessor(exporter))
+trace.set_tracer_provider(provider)
+
+AnthropicInstrumentor().instrument()
+
+import anthropic
+
+client = anthropic.Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"])
 
 stream = client.messages.create(
     model="claude-sonnet-4-5-20250929",
     max_tokens=1024,
-    posthog_distinct_id="example-user",
     messages=[{"role": "user", "content": "Write a haiku about observability."}],
     stream=True,
 )
@@ -24,4 +36,4 @@
             print(event.delta.text, end="", flush=True)
 
 print()
-posthog.shutdown()
+provider.shutdown()