feat(examples): migrate AI examples to OpenTelemetry instrumentation

examples/example-ai-anthropic/chat.py

@@ -1,16 +1,36 @@
-"""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.resources import Resource, SERVICE_NAME
+from posthog.ai.otel import PostHogSpanProcessor
+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",
+        "posthog.distinct_id": "example-user",
+        "foo": "bar",
+        "conversation_id": "abc-123",
+    }
+)
+provider = TracerProvider(resource=resource)
+provider.add_span_processor(
+    PostHogSpanProcessor(
+        api_key=os.environ["POSTHOG_API_KEY"],
+        host=os.environ.get("POSTHOG_HOST", "https://us.i.posthog.com"),
+    )
 )
-client = Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"], posthog_client=posthog)
+trace.set_tracer_provider(provider)
+
+AnthropicInstrumentor().instrument()
+
+import anthropic  # noqa: E402
+
+client = anthropic.Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"])
 
 tools = [
     {
@@ -40,7 +60,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?"}],
 )
@@ -53,5 +72,3 @@ def get_weather(latitude: float, longitude: float, location_name: str) -> str:
     elif block.type == "tool_use":
         result = get_weather(**block.input)
         print(result)
-
-posthog.shutdown()

examples/example-ai-anthropic/extended_thinking.py

@@ -1,22 +1,41 @@
-"""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.resources import Resource, SERVICE_NAME
+from posthog.ai.otel import PostHogSpanProcessor
+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",
+        "posthog.distinct_id": "example-user",
+        "foo": "bar",
+        "conversation_id": "abc-123",
+    }
 )
-client = Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"], posthog_client=posthog)
+provider = TracerProvider(resource=resource)
+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()
+
+import anthropic  # noqa: E402
+
+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=[
         {
@@ -31,5 +50,3 @@
         print(f"Thinking: {block.thinking}\n")
     elif block.type == "text":
         print(f"Answer: {block.text}")
-
-posthog.shutdown()

examples/example-ai-anthropic/pyproject.toml

@@ -3,6 +3,11 @@ 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",
+    "posthog[otel]>=7.11.0",
 ]
+
+[tool.uv.sources]
+posthog = { path = "../.." }

examples/example-ai-anthropic/streaming.py

@@ -1,19 +1,38 @@
-"""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.resources import Resource, SERVICE_NAME
+from posthog.ai.otel import PostHogSpanProcessor
+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",
+        "posthog.distinct_id": "example-user",
+        "foo": "bar",
+        "conversation_id": "abc-123",
+    }
 )
-client = Anthropic(api_key=os.environ["ANTHROPIC_API_KEY"], posthog_client=posthog)
+provider = TracerProvider(resource=resource)
+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()
+
+import anthropic  # noqa: E402
+
+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 +43,3 @@
             print(event.delta.text, end="", flush=True)
 
 print()
-posthog.shutdown()