Lumen エコシステム連携 開発中
Lumen はセマンティックレイヤーの可観測性ツールとして、下位では Kova 実行エンジンと Lurus API ゲートウェイに接続し、横では LangGraph と互換性を持ち、外部へは標準 OTel トレースを Grafana / Datadog にエクスポートします。
Kova
WAL 永続化基盤、マイクロ秒単位のクラッシュリカバリ。
LangGraph
1 行で Saver を置き換え。
Lurus API
Token 課金を自動で関連付け。
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" で検索）。