Langfuse

curl https://opendunes.com/v1/observability/destinations \
  -H "Authorization: Bearer $OPENDUNES_MANAGEMENT_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Langfuse",
    "type": "langfuse",
    "config": { "publicKey": "pk-lf-…", "secretKey": "sk-lf-…" }
  }'

import os
from openai import OpenAI
from langfuse import Langfuse
from langfuse.decorators import observe, langfuse_context

langfuse = Langfuse(
    public_key=os.environ["LANGFUSE_PUBLIC_KEY"],
    secret_key=os.environ["LANGFUSE_SECRET_KEY"],
    host=os.environ.get("LANGFUSE_HOST", "https://cloud.langfuse.com"),
)

client = OpenAI(
    base_url="https://opendunes.com/v1",
    api_key=os.environ["OPENDUNES_API_KEY"],
)

@observe(as_type="generation")
def ask(prompt: str, model: str = "anthropic/claude-sonnet-5") -> str:
    langfuse_context.update_current_observation(
        model=model,
        input=prompt,
    )

    resp = client.chat.completions.create(
        model=model,
        messages=[{"role": "user", "content": prompt}],
    )

    text = resp.choices[0].message.content

    langfuse_context.update_current_observation(
        output=text,
        usage={
            "input": resp.usage.prompt_tokens,
            "output": resp.usage.completion_tokens,
        },
    )

    return text

result = ask("What are the official languages of Algeria?")
print(result)

langfuse.flush()

import OpenAI from "openai";
import { Langfuse } from "langfuse";

const langfuse = new Langfuse({
  publicKey: process.env.LANGFUSE_PUBLIC_KEY!,
  secretKey: process.env.LANGFUSE_SECRET_KEY!,
});

const client = new OpenAI({
  baseURL: "https://opendunes.com/v1",
  apiKey: process.env.OPENDUNES_API_KEY,
});

const trace = langfuse.trace({ name: "chat" });
const generation = trace.generation({
  name: "completion",
  model: "google/gemini-2.5-pro",
  input: [{ role: "user", content: "What is Tamazight?" }],
});

const resp = await client.chat.completions.create({
  model: "google/gemini-2.5-pro",
  messages: [{ role: "user", content: "What is Tamazight?" }],
});

generation.end({
  output: resp.choices[0].message.content,
  usage: {
    input: resp.usage?.prompt_tokens,
    output: resp.usage?.completion_tokens,
  },
});

await langfuse.flushAsync();