读完这篇你会知道

• devops.Init 怎么在进程内起一个调试 HTTP 服务
• 全局编译回调如何自动捕获所有已编译的图
• 五个主要 API 端点：从拓扑查询到流式执行
• 从任意节点开始运行：BuildDevGraph 的子图重建逻辑
• NodeDebugState每个节点的输入、输出、耗时、Token 消耗
• any 类型输入的特殊 JSON 格式
• AppendType 注册自定义类型

一、问题：图跑不对，怎么定位？

User Pain Point：

• 业务代码难以改动：每次要定位错误都得手动加断点或打印日志。
• 日志只给出结果，缺乏中间状态追踪。
• 复现特定分支需多次修改入口参数或重新启动。

Eino Dev 的思路是进程旁挂一个 HTTP 服务。浏览器/插件直接连上来,任意选一个节点作为起点,填入 mock 数据,按节点顺序看执行结果。这样就能快速定位数据在哪个跳转处出现偏差。

二、三步接入

• "如何在现有项目里无缝加入调试功能？"
• "是否需要改动注册流程或者担心影响正常编译？"

import "github.com/cloudwego/eino-ext/devops"

func main {
ctx := context.Background
// 启动调试服务（默认 .:)
if err := devops.Init;err，= nil {
log.Fatalf
}
// 正常注册图
graph.RegisterSimpleGraph
graph.RegisterSimpleStateGraph
chain.RegisterSimpleChain
// 阻塞直到退出
}

提示： Init 返回后 HTTP 服务已在后台运行；后续所有 Compile 调用都会被拦截并存入内存。

自定义监听地址：

devops.Init(ctx,devops.WithDevServerIP。// 允许外部访问
devops.WithDevServerPort,)

三、底层机制：全局编译回调

• "为什么所有图都能被捕获而不用手工收集？"
• "

// devops/internal/apihandler/debug.gocompose.InitGraphCompileCallbacks(compose.GraphCompileCallback{ service.NewGlobalDevGraphCompileCallback。 })

This callback implements same interface as Mermaid generator but stores graph info in memory instead of writing files.

从关键流程来看，

• {@link GraphCompileCallback.OnFinish} 收集所有节点、边、分支及其类型信息。
• devops.Init 在全局回调里插入 listener，以零侵入方式捕获图结构。
• BuildDevGraph 在运行时动态裁剪子图，以满足任意起始点需求。
• SSE 推送 {@link NodeDebugState} 给前端，实现实时监控。
• any 类型通过带类型标注 JSON 与 AppendType 支持自定义结构体。
• StateGraph 的 state handler 可直接观测状态快照。
• InputTypes 接口列出可用 Go 类型，为表单生成提供依据。
• Graphs/{id}/canvas 提供拓扑渲染供前端交互使用。
• threads/{tid}/stream 开启流式执行，用于按需触发和观察节点执行过程。
• Ping 用于健康检查和快速确认服务可用性。
• LogId 为每次 debug session 标识，可追踪日志记录与分析历史执行轨迹。

完整请求示例这方面，

{
"from_node": "node_2","input": {
"content": "hello"
}。"log_id": "debug-20260809"
}

四、五个主要 API

GET /eino/devops/ping

GET /eino/devops/debug/v1/input_types

GET /eino/devops/debug/v1/graphs/{id}/canvas

POST /eino/devops/debug/v1/graphs/{id}/threads/{tid}/stream

。

---