1
开发阶段                              生产阶段
2
────────                              ────────
3
Lambda 写业务逻辑
4
    ↓
5
Graph/Chain 编排节点
6
    ↓
7
可视化（Mermaid）                     调试（Devops）
8
查看拓扑结构                          图形界面测试
9
    ↓
10
确认结构无误                          确认逻辑无误
11
    ↓
12
    提交代码 → 生产运行

1
Lambda 四种创建：
2
  InvokableLambda(fn)                     ← 最简
3
  InvokableLambdaWithOption(fn)           ← 需自定义参数
4
  AnyLambda(invoke, stream, collect, transform) ← 全模式
5
  ToList[T]()                             ← 类型转换 T→[]T
6

7
调试：devops.Init(ctx) → Chain/Graph.Compile → 图形界面测试
8
可视化：NewMermaidGenerator(dir) → Compile(WithGraphCompileCallbacks(gen))

1
Graph 内置节点：ChatModel、ToolsNode、ChatTemplate  ← 框架提供
2
Lambda 节点：    你写的任意函数                       ← 你自己提供

1
你需要什么？
2
│
3
├─ 最简单：ctx+input → output
4
│   └─→ compose.InvokableLambda(fn)
5
│
6
├─ 需要自定义参数
7
│   └─→ compose.InvokableLambdaWithOption(fn)
8
│
9
├─ 需要流式处理（Stream/Transform）
10
│   └─→ compose.AnyLambda(invoke, stream, collect, transform)
11
│
12
├─ 只做类型转换 T → []T
13
│   └─→ compose.ToList[T]()
14
│
15
└─ 解析 ChatModel 返回的 JSON
16
    └─→ compose.MessageParser(parser)

1
lambda := compose.InvokableLambda(
2
    func(ctx context.Context, input string) (output string, err error) {
3
        return strings.ToUpper(input), nil
4
    },
5
)

1
type Options struct { Field1 string }
2
type MyOption func(*Options)
3

4
lambda := compose.InvokableLambdaWithOption(
5
    func(ctx context.Context, input string, opts ...MyOption) (output string, err error) {
6
        o := &Options{}
7
        for _, opt := range opts { opt(o) }
8
        return "", nil
9
    },
10
)

1
lambda, _ := compose.AnyLambda(
2
    func(ctx context.Context, input string, opts ...MyOption) (output string, err error) { return "", nil },
3
    func(ctx context.Context, input string, opts ...MyOption) (output *schema.StreamReader[string], err error) { return nil, nil },
4
    func(ctx context.Context, input *schema.StreamReader[string], opts ...MyOption) (output string, err error) { return "", nil },
5
    func(ctx context.Context, input *schema.StreamReader[string], opts ...MyOption) (output *schema.StreamReader[string], err error) { return nil, nil },
6
)

1
// ChatModel 返回 *schema.Message，下游需要 []*schema.Message 时桥接
2
chain.AppendLambda(compose.ToList[*schema.Message]())

1
// Chain
2
chain := compose.NewChain[string, string]()
3
chain.AppendLambda(
4
    compose.InvokableLambda(func(ctx context.Context, input string) (string, error) {
5
        return input + " processed", nil
6
    }),
7
    compose.WithNodeName("step1"),
8
)
9

10
// Graph
11
graph := compose.NewGraph[string, *MyStruct]()
12
graph.AddLambdaNode("node1",
13
    compose.InvokableLambda(func(ctx context.Context, input string) (*MyStruct, error) {
14
        return &MyStruct{ID: 1}, nil
15
    }),
16
    compose.WithStatePreHandler(func(ctx context.Context, input string, state *myState) (string, error) {
17
        return input, nil  // 节点执行前读写 State
18
    }),
19
)

1
parser := schema.NewMessageJSONParser[*MyStruct](&schema.MessageJSONParseConfig{
2
    ParseFrom: schema.MessageParseFromContent,
3
})
4
parserLambda := compose.MessageParser(parser)
5

6
chain := compose.NewChain[*schema.Message, *MyStruct]()
7
chain.AppendLambda(parserLambda)

1
import (
2
    "github.com/cloudwego/eino-ext/devops"
3
    "os/signal"
4
    "syscall"
5
)
6

7
func main() {
8
    err := devops.Init(ctx)  // 1. 启动 HTTP 调试界面
9

10
    chain.RegisterSimpleChain(ctx)     // 2. 注册你的 Chain/Graph
11
    graph.RegisterSimpleGraph(ctx)
12

13
    sigs := make(chan os.Signal, 1)   // 3. 阻塞等待
14
    signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
15
    <-sigs
16
}

1
{
2
    "name": {
3
        "_value": "alice",
4
        "_eino_go_type": "string"
5
    },
6
    "score": {
7
        "_value": "99",
8
        "_eino_go_type": "int"
9
    }
10
}

1
import "github.com/cloudwego/eino-examples/devops/visualize"
2

3
gen := visualize.NewMermaidGenerator("output/dir")  // 指定输出目录
4

5
runner, _ := g.Compile(context.Background(),
6
    compose.WithGraphCompileCallbacks(gen),
7
    compose.WithGraphName("MyGraph"),
8
)

1
// Lambda
2
"github.com/cloudwego/eino/compose"  // InvokableLambda, AnyLambda, ToList, MessageParser
3
"github.com/cloudwego/eino/schema"   // NewMessageJSONParser, MessageParseFromContent
4

5
// 调试
6
"github.com/cloudwego/eino-ext/devops"  // Init
7

8
// 可视化
9
"github.com/cloudwego/eino-examples/devops/visualize"  // NewMermaidGenerator

1
Lambda:     InvokableLambda（ctx+T→T）→ AppendLambda / AddLambdaNode
2
调试:       devops.Init → Compile → 图形界面测试
3
可视化:     NewMermaidGenerator → WithGraphCompileCallbacks →  + .png
4
MessageParser:  ChatModel JSON 输出 → Go 结构体（类型安全处理）