mirror of
https://github.com/open-webui/open-webui
synced 2025-06-26 18:26:48 +00:00
49 lines
1.7 KiB
Python
49 lines
1.7 KiB
Python
from fastapi import FastAPI
|
|
from opentelemetry import trace
|
|
from opentelemetry.exporter.otlp.proto.grpc.trace_exporter import OTLPSpanExporter
|
|
from opentelemetry.sdk.resources import SERVICE_NAME, Resource
|
|
from opentelemetry.sdk.trace import TracerProvider
|
|
from sqlalchemy import Engine
|
|
from base64 import b64encode
|
|
|
|
from open_webui.utils.telemetry.exporters import LazyBatchSpanProcessor
|
|
from open_webui.utils.telemetry.instrumentors import Instrumentor
|
|
from open_webui.utils.telemetry.metrics import setup_metrics
|
|
from open_webui.env import (
|
|
OTEL_SERVICE_NAME,
|
|
OTEL_EXPORTER_OTLP_ENDPOINT,
|
|
OTEL_EXPORTER_OTLP_INSECURE,
|
|
ENABLE_OTEL_METRICS,
|
|
OTEL_BASIC_AUTH_USERNAME,
|
|
OTEL_BASIC_AUTH_PASSWORD,
|
|
)
|
|
|
|
|
|
def setup(app: FastAPI, db_engine: Engine):
|
|
# set up trace
|
|
trace.set_tracer_provider(
|
|
TracerProvider(
|
|
resource=Resource.create(attributes={SERVICE_NAME: OTEL_SERVICE_NAME})
|
|
)
|
|
)
|
|
|
|
# Add basic auth header only if both username and password are not empty
|
|
headers = []
|
|
if OTEL_BASIC_AUTH_USERNAME and OTEL_BASIC_AUTH_PASSWORD:
|
|
auth_string = f"{OTEL_BASIC_AUTH_USERNAME}:{OTEL_BASIC_AUTH_PASSWORD}"
|
|
auth_header = b64encode(auth_string.encode()).decode()
|
|
headers = [("authorization", f"Basic {auth_header}")]
|
|
|
|
# otlp export
|
|
exporter = OTLPSpanExporter(
|
|
endpoint=OTEL_EXPORTER_OTLP_ENDPOINT,
|
|
insecure=OTEL_EXPORTER_OTLP_INSECURE,
|
|
headers=headers,
|
|
)
|
|
trace.get_tracer_provider().add_span_processor(LazyBatchSpanProcessor(exporter))
|
|
Instrumentor(app=app, db_engine=db_engine).instrument()
|
|
|
|
# set up metrics only if enabled
|
|
if ENABLE_OTEL_METRICS:
|
|
setup_metrics(app)
|