import base64 | |
import os | |
from dotenv import load_dotenv | |
from openinference.instrumentation.smolagents import SmolagentsInstrumentor | |
from opentelemetry.exporter.otlp.proto.http.trace_exporter import ( | |
OTLPSpanExporter, | |
) | |
from opentelemetry.sdk.trace import TracerProvider | |
from opentelemetry.sdk.trace.export import SimpleSpanProcessor | |
load_dotenv() | |
LANGFUSE_PUBLIC_KEY = os.getenv("LANGFUSE_PUBLIC_KEY") | |
LANGFUSE_SECRET_KEY = os.getenv("LANGFUSE_SECRET_KEY") | |
LANGFUSE_AUTH = base64.b64encode( | |
f"{LANGFUSE_PUBLIC_KEY}:{LANGFUSE_SECRET_KEY}".encode() | |
).decode() | |
os.environ["OTEL_EXPORTER_OTLP_ENDPOINT"] = ( | |
"https://cloud.langfuse.com/api/public/otel" # EU data region | |
) | |
os.environ["OTEL_EXPORTER_OTLP_HEADERS"] = ( | |
f"Authorization=Basic {LANGFUSE_AUTH}" | |
) | |
def add_tracing(): | |
trace_provider = TracerProvider() | |
trace_provider.add_span_processor(SimpleSpanProcessor(OTLPSpanExporter())) | |
SmolagentsInstrumentor().instrument(tracer_provider=trace_provider) | |