APM

# OpenTelemetry로 APM 트레이싱 구현 (Python/FastAPI)
from opentelemetry import trace
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import BatchSpanProcessor
from opentelemetry.exporter.otlp.proto.grpc.trace_exporter import OTLPSpanExporter
from opentelemetry.instrumentation.fastapi import FastAPIInstrumentor
from opentelemetry.instrumentation.requests import RequestsInstrumentor
from fastapi import FastAPI
import requests

# 트레이서 설정
provider = TracerProvider()
processor = BatchSpanProcessor(OTLPSpanExporter(endpoint="http://otel-collector:4317"))
provider.add_span_processor(processor)
trace.set_tracer_provider(provider)

tracer = trace.get_tracer(__name__)

app = FastAPI()

# FastAPI 자동 계측
FastAPIInstrumentor.instrument_app(app)
RequestsInstrumentor().instrument()

@app.get("/api/orders/{order_id}")
async def get_order(order_id: str):
    # 커스텀 스팬으로 세부 구간 측정
    with tracer.start_as_current_span("fetch_order_details") as span:
        span.set_attribute("order.id", order_id)

        # DB 조회 (자동 계측됨)
        order = await fetch_from_db(order_id)

        # 외부 API 호출 추적
        with tracer.start_as_current_span("call_payment_service"):
            payment = requests.get(f"http://payment-svc/orders/{order_id}")

        span.set_attribute("order.total", order["total"])
        return {"order": order, "payment": payment.json()}