Jaeger

# Python Flask + OpenTelemetry로 Jaeger 연동
from flask import Flask
from opentelemetry import trace
from opentelemetry.exporter.jaeger.thrift import JaegerExporter
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import BatchSpanProcessor
from opentelemetry.instrumentation.flask import FlaskInstrumentor
from opentelemetry.instrumentation.requests import RequestsInstrumentor

# Tracer 설정
trace.set_tracer_provider(TracerProvider())
tracer = trace.get_tracer(__name__)

# Jaeger Exporter 설정
jaeger_exporter = JaegerExporter(
    agent_host_name="jaeger-agent.observability.svc",
    agent_port=6831,
)

# BatchSpanProcessor로 효율적인 전송
trace.get_tracer_provider().add_span_processor(
    BatchSpanProcessor(jaeger_exporter)
)

app = Flask(__name__)

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

@app.route("/order/")
def get_order(order_id):
    # 커스텀 Span 생성
    with tracer.start_as_current_span("fetch_order_details") as span:
        span.set_attribute("order.id", order_id)

        # 다른 서비스 호출 (자동으로 trace context 전파)
        order = fetch_from_order_service(order_id)

        with tracer.start_as_current_span("enrich_with_user_data"):
            user = fetch_user_info(order["user_id"])
            order["user"] = user

        return order