Google ADK

# Google ADK
pip install google-adk

# OpenTelemetry packages
pip install opentelemetry-sdk opentelemetry-exporter-otlp

# OpenInference instrumentation for ADK (if available)
pip install openinference-instrumentation-google-adk

<!-- For Maven -->
<dependency>
    <groupId>com.google.ai</groupId>
    <artifactId>google-adk</artifactId>
    <version>latest</version>
</dependency>

// For Gradle
implementation 'com.google.ai:google-adk:latest'

export OTEL_EXPORTER_OTLP_ENDPOINT="https://api.orq.ai/v2/otel"
export OTEL_EXPORTER_OTLP_HEADERS="Authorization=Bearer <ORQ_API_KEY>"
export OTEL_RESOURCE_ATTRIBUTES="service.name=google-adk-app,service.version=1.0.0"
export GOOGLE_API_KEY="your-google-api-key"

$env:OTEL_EXPORTER_OTLP_ENDPOINT = "https://api.orq.ai/v2/otel"
$env:OTEL_EXPORTER_OTLP_HEADERS = "Authorization=Bearer <ORQ_API_KEY>"
$env:OTEL_RESOURCE_ATTRIBUTES = "service.name=google-adk-app,service.version=1.0.0"
$env:GOOGLE_API_KEY = "your-google-api-key"

OTEL_EXPORTER_OTLP_ENDPOINT=https://api.orq.ai/v2/otel
OTEL_EXPORTER_OTLP_HEADERS=Authorization=Bearer <ORQ_API_KEY>
OTEL_RESOURCE_ATTRIBUTES=service.name=google-adk-app,service.version=1.0.0
GOOGLE_API_KEY=your-google-api-key

from openinference.instrumentation.google_adk import GoogleADKInstrumentor
from opentelemetry import trace
from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import BatchSpanProcessor

provider = TracerProvider()
provider.add_span_processor(BatchSpanProcessor(OTLPSpanExporter()))
trace.set_tracer_provider(provider)

# Instrument Google ADK
GoogleADKInstrumentor().instrument()

# Now use ADK normally - all agent operations will be traced
import google.adk as adk
from google.adk.runners import Runner
from google.adk.sessions import InMemorySessionService
from google.genai import types
import asyncio


def get_weather(location: str) -> str:
    """Return current weather for a location."""
    return f"Sunny in {location}, 22C"


async def main():
    # Create an agent with a tool
    agent = adk.Agent(
        name="Helper",
        instruction="Use the provided tool to answer questions briefly.",
        model="gemini-2.5-flash",
        tools=[get_weather],
    )

    # Create session and runner
    session_service = InMemorySessionService()
    runner = Runner(
        agent=agent,
        app_name="simple-helper",
        session_service=session_service
    )

    # Create a session (await the async call)
    session = await session_service.create_session(
        app_name="simple-helper",
        user_id="user1"
    )

    # Simple one-shot example
    question = "What's the weather in Paris?"
    content = types.Content(role='user', parts=[types.Part(text=question)])

    # Run the agent (this is also async)
    events = runner.run_async(
        user_id="user1",
        session_id=session.id,
        new_message=content
    )

    # Get the response
    async for event in events:
        if event.is_final_response():
            response = event.content.parts[0].text
            print(f"Q: {question}")
            print(f"A: {response}")

# Run the async main function
if __name__ == "__main__":
    try:
        asyncio.run(main())
    finally:
        provider.force_flush()
        provider.shutdown()