mirror of
https://github.com/open-webui/open-webui
synced 2025-06-22 18:07:17 +00:00
Merge 4eb9597bb0
into aef0ad2d10
This commit is contained in:
commit
aacc404af4
@ -542,6 +542,7 @@ AUDIT_EXCLUDED_PATHS = [path.lstrip("/") for path in AUDIT_EXCLUDED_PATHS]
|
|||||||
####################################
|
####################################
|
||||||
|
|
||||||
ENABLE_OTEL = os.environ.get("ENABLE_OTEL", "False").lower() == "true"
|
ENABLE_OTEL = os.environ.get("ENABLE_OTEL", "False").lower() == "true"
|
||||||
|
USE_OTEL_HTTP_EXPORTER = os.environ.get("USE_OTEL_HTTP_EXPORTER", "False").lower() == "true"
|
||||||
ENABLE_OTEL_METRICS = os.environ.get("ENABLE_OTEL_METRICS", "False").lower() == "true"
|
ENABLE_OTEL_METRICS = os.environ.get("ENABLE_OTEL_METRICS", "False").lower() == "true"
|
||||||
OTEL_EXPORTER_OTLP_ENDPOINT = os.environ.get(
|
OTEL_EXPORTER_OTLP_ENDPOINT = os.environ.get(
|
||||||
"OTEL_EXPORTER_OTLP_ENDPOINT", "http://localhost:4317"
|
"OTEL_EXPORTER_OTLP_ENDPOINT", "http://localhost:4317"
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
from fastapi import FastAPI
|
from fastapi import FastAPI
|
||||||
from opentelemetry import trace
|
from opentelemetry import trace
|
||||||
from opentelemetry.exporter.otlp.proto.grpc.trace_exporter import OTLPSpanExporter
|
from opentelemetry.exporter.otlp.proto.grpc.trace_exporter import OTLPSpanExporter
|
||||||
|
from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter as HttpOTLPSpanExporter
|
||||||
from opentelemetry.sdk.resources import SERVICE_NAME, Resource
|
from opentelemetry.sdk.resources import SERVICE_NAME, Resource
|
||||||
from opentelemetry.sdk.trace import TracerProvider
|
from opentelemetry.sdk.trace import TracerProvider
|
||||||
from sqlalchemy import Engine
|
from sqlalchemy import Engine
|
||||||
@ -14,6 +15,7 @@ from open_webui.env import (
|
|||||||
OTEL_EXPORTER_OTLP_ENDPOINT,
|
OTEL_EXPORTER_OTLP_ENDPOINT,
|
||||||
OTEL_EXPORTER_OTLP_INSECURE,
|
OTEL_EXPORTER_OTLP_INSECURE,
|
||||||
ENABLE_OTEL_METRICS,
|
ENABLE_OTEL_METRICS,
|
||||||
|
USE_OTEL_HTTP_EXPORTER,
|
||||||
OTEL_BASIC_AUTH_USERNAME,
|
OTEL_BASIC_AUTH_USERNAME,
|
||||||
OTEL_BASIC_AUTH_PASSWORD,
|
OTEL_BASIC_AUTH_PASSWORD,
|
||||||
)
|
)
|
||||||
@ -35,11 +37,18 @@ def setup(app: FastAPI, db_engine: Engine):
|
|||||||
headers = [("authorization", f"Basic {auth_header}")]
|
headers = [("authorization", f"Basic {auth_header}")]
|
||||||
|
|
||||||
# otlp export
|
# otlp export
|
||||||
exporter = OTLPSpanExporter(
|
if USE_OTEL_HTTP_EXPORTER:
|
||||||
endpoint=OTEL_EXPORTER_OTLP_ENDPOINT,
|
exporter = HttpOTLPSpanExporter(
|
||||||
insecure=OTEL_EXPORTER_OTLP_INSECURE,
|
endpoint=OTEL_EXPORTER_OTLP_ENDPOINT,
|
||||||
headers=headers,
|
insecure=OTEL_EXPORTER_OTLP_INSECURE,
|
||||||
)
|
headers=headers,
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
exporter = OTLPSpanExporter(
|
||||||
|
endpoint=OTEL_EXPORTER_OTLP_ENDPOINT,
|
||||||
|
insecure=OTEL_EXPORTER_OTLP_INSECURE,
|
||||||
|
headers=headers,
|
||||||
|
)
|
||||||
trace.get_tracer_provider().add_span_processor(LazyBatchSpanProcessor(exporter))
|
trace.get_tracer_provider().add_span_processor(LazyBatchSpanProcessor(exporter))
|
||||||
Instrumentor(app=app, db_engine=db_engine).instrument()
|
Instrumentor(app=app, db_engine=db_engine).instrument()
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user