Bedrock AgentCore Tracing

import os

from bedrock_agentcore.runtime import BedrockAgentCoreApp
from openinference.instrumentation.strands_agents import (
    StrandsAgentsToOpenInferenceProcessor,
)
from phoenix.otel import BatchSpanProcessor, HTTPSpanExporter, register
from strands import Agent
from strands.models.bedrock import BedrockModel

# register() reads PHOENIX_PROJECT_NAME, PHOENIX_COLLECTOR_ENDPOINT, and
# PHOENIX_API_KEY from the environment, and makes Phoenix the global tracer
# provider so Strands' internal tracer finds it.
tracer_provider = register()

# This processor rewrites Strands' native spans into OpenInference spans, so it
# must run before the Phoenix exporter that sends spans to your collector.
tracer_provider.add_span_processor(StrandsAgentsToOpenInferenceProcessor())
tracer_provider.add_span_processor(BatchSpanProcessor(HTTPSpanExporter()))

# AgentCore calls strands_agent_bedrock for every /invocations request.
app = BedrockAgentCoreApp()


@app.entrypoint
def strands_agent_bedrock(payload, context=None):
    agent = Agent(
        name="OceanAssistant",
        model=BedrockModel(
            model_id="us.anthropic.claude-sonnet-4-6",
            region_name=os.environ.get("AWS_REGION", "us-west-2"),
        ),
        system_prompt="Answer concisely in two sentences.",
    )
    response = agent(payload.get("prompt", ""))
    return response.message["content"][0]["text"]


if __name__ == "__main__":
    app.run()

import os

from bedrock_agentcore_starter_toolkit import Runtime
from boto3.session import Session

region = Session().region_name

agentcore_runtime = Runtime()

agentcore_runtime.configure(
    entrypoint="strands_claude.py",
    auto_create_execution_role=True,
    auto_create_ecr=True,
    requirements_file="requirements.txt",
    region=region,
    agent_name="strands_agentcore_phoenix_observability",
    memory_mode="NO_MEMORY",
    # Disable AgentCore's built-in OpenTelemetry, because strands_claude.py
    # registers its own Phoenix tracer provider.
    disable_otel=True,
)

# Pass the Phoenix settings to the deployed container as environment variables.
agentcore_runtime.launch(
    env_vars={
        "PHOENIX_COLLECTOR_ENDPOINT": os.environ["PHOENIX_COLLECTOR_ENDPOINT"],
        "PHOENIX_API_KEY": os.environ["PHOENIX_API_KEY"],
        "PHOENIX_PROJECT_NAME": os.environ["PHOENIX_PROJECT_NAME"],
        # AWS recommends this when you use a non-AWS observability backend,
        # so AgentCore doesn't also export to CloudWatch.
        "DISABLE_ADOT_OBSERVABILITY": "true",
    },
)

# invoke() posts to the AgentCore Runtime endpoint and returns the response.
result = agentcore_runtime.invoke(
    {"prompt": "Why is the ocean salty? Answer in two sentences."}
)
print(result)