Lumen 生态集成 开发中
Lumen 作为语义层可观测性工具,向下接 Kova 执行引擎与 Lurus API 网关,向旁兼容 LangGraph,向外导出标准 OTel 链路到 Grafana / Datadog。
与 Kova
Kova 负责底层 WAL 状态持久化与微秒级崩溃恢复,Lumen 负责语义层 Trace 标注与成本统计。
python
from lumen_ai import LumenCheckpointer
from kova import KovaClient
kova = KovaClient("kova://prod")
graph.compile(checkpointer=LumenCheckpointer(kova_client=kova))与 LangGraph
直接替换 Saver(API 完全兼容 BaseCheckpointSaver):
diff
- from langgraph.checkpoint.sqlite import SqliteSaver
+ from lumen_ai import LumenCheckpointer
- graph = wf.compile(checkpointer=SqliteSaver.from_conn_string(":memory:"))
+ graph = wf.compile(checkpointer=LumenCheckpointer())与 Lurus API
经 Lurus API 调 LLM 时,Token 计费和耗时自动关联到 Lumen Trace:
python
from openai import OpenAI
from lumen_ai import LumenTracer
client = OpenAI(base_url="https://hub.lurus.cn/v1", api_key="sk-...")
tracer = LumenTracer()
with tracer.span("classify"):
resp = client.chat.completions.create(...)
# 调用自动记录,鹿贝消费可追溯OpenTelemetry
导出为 OTel Trace:LumenTracer(exporters=[to_otlp("http://otel-collector:4317")])(from lumen_ai.otel import to_otlp)。
Grafana / Datadog
链路如下,Lumen SDK 以 OTLP 协议把 Trace 推给 OTel Collector,再分发到 Grafana Tempo 或 Datadog APM:
graph LR
A[Lumen SDK] -->|OTLP| B[OTel Collector]
B --> C[Grafana Tempo]
B --> D[Datadog APM]Grafana 仪表盘模板见 Lurus 官方模板库(搜 "Lumen Dashboard")。