Lobster
OpenClaw 的类型化工作流运行时,具有可恢复的审批关卡。
Lobster 是一个工作流 shell,让 OpenClaw 将多步骤工具序列作为单个确定性操作运行,并具有明确的审批检查点。
简介
您的助手可以构建管理自身的工具。请求一个工作流,30 分钟后您就拥有了一个 CLI 和作为单次调用运行的管道。Lobster 是缺失的部分:确定性管道、明确审批和可恢复状态。
为什么
如今,复杂的工作流需要多次来回工具调用。每次调用都消耗 token,LLM 必须编排每一步。Lobster 将这种编排移入类型化运行时:
- 一次调用代替多次:OpenClaw 运行一次 Lobster 工具调用并获得结构化结果。
- 内置审批:副作用(发送邮件、发布评论)会暂停工作流,直到明确批准。
- 可恢复:暂停的工作流返回一个 token;批准并恢复,无需重新运行所有内容。
为什么用 DSL 而不是普通程序?
Lobster 故意设计得很小。目标不是"一种新语言",而是一个可预测的、AI 友好的管道规范,具有一流的审批和恢复 token。
- 内置审批/恢复:普通程序可以提示人类,但它无法在没有您自己发明该运行时的情况下使用持久 token _暂停和恢复_。
- 确定性 + 可审计性:管道是数据,因此易于记录、比较、重放和审查。
- AI 的受限界面:小型语法 + JSON 管道减少了"创造性"代码路径,使验证变得现实。
- 内置安全策略:超时、输出上限、沙箱检查和允许列表由运行时强制执行,而不是每个脚本。
- ''仍可编程'':每一步都可以调用任何 CLI 或脚本。如果您想要 JS/TS,可以从代码生成 ''.lobster'' 文件。
工作原理
OpenClaw 在''工具模式''下启动本地 ''lobster'' CLI,并从 stdout 解析 JSON 信封。
如果管道暂停等待审批,工具会返回一个 ''resumeToken'',以便您稍后继续。
模式:小型 CLI + JSON 管道 + 审批
构建使用 JSON 通信的小型命令,然后将它们链接成单个 Lobster 调用。(下面的示例命令名称 — 替换为您自己的。)
inbox list --json inbox categorize --json inbox apply --json
{
"action": "run",
"pipeline": "exec --json --shell 'inbox list --json' | exec --stdin json --shell 'inbox categorize --json' | exec --stdin json --shell 'inbox apply --json' | approve --preview-from-stdin --limit 5 --prompt 'Apply changes?'",
"timeoutMs": 30000
}如果管道请求审批,使用 token 恢复:
{
"action": "resume",
"token": "<resumeToken>",
"approve": true
}AI 触发工作流;Lobster 执行步骤。审批关卡使副作用明确且可审计。
示例:将输入项映射到工具调用:
gog.gmail.search --query 'newer_than:1d' | openclaw.invoke --tool message --action send --each --item-key message --args-json '{"provider":"telegram","to":"..."}'仅 JSON 的 LLM 步骤 (llm-task)
对于需要结构化 LLM 步骤的工作流,启用可选的
''llm-task'' 插件工具并从 Lobster 调用它。这使工作流保持
确定性,同时仍允许您使用模型进行分类/总结/起草。
启用该工具:
{
"plugins": {
"entries": {
"llm-task": { "enabled": true }
}
},
"agents": {
"list": [
{
"id": "main",
"tools": { "allow": ["llm-task"] }
}
]
}
}在管道中使用它:
openclaw.invoke --tool llm-task --action json --args-json '{
"prompt": "Given the input email, return intent and draft.",
"input": { "subject": "Hello", "body": "Can you help?" },
"schema": {
"type": "object",
"properties": {
"intent": { "type": "string" },
"draft": { "type": "string" }
},
"required": ["intent", "draft"],
"additionalProperties": false
}
}'有关详细信息和配置选项,请参阅 ''LLM Task''。
工作流文件 (.lobster)
Lobster 可以运行包含 ''name''、''args''、''steps''、''env''、''condition'' 和 ''approval'' 字段的 YAML/JSON 工作流文件。在 OpenClaw 工具调用中,将 ''pipeline'' 设置为文件路径。
name: inbox-triage
args:
tag:
default: "family"
steps:
- id: collect
command: inbox list --json
- id: categorize
command: inbox categorize --json
stdin: $collect.stdout
- id: approve
command: inbox apply --approve
stdin: $categorize.stdout
approval: required
- id: execute
command: inbox apply --execute
stdin: $categorize.stdout
condition: $approve.approved注意:
- ''stdin: $step.stdout'' 和 ''stdin: $step.json'' 传递前一步的输出。
- ''condition''(或 ''when'')可以根据 ''$step.approved'' 控制步骤。
安装 Lobster
在运行 OpenClaw Gateway 的''同一主机''上安装 Lobster CLI(参见 ''Lobster 仓库''),并确保 ''lobster'' 在 ''PATH'' 中。
如果您想使用自定义二进制位置,请在工具调用中传递''绝对'' ''lobsterPath''。
启用工具
Lobster 是一个可选插件工具(默认不启用)。
推荐(添加式,安全):
{
"tools": {
"alsoAllow": ["lobster"]
}
}或按代理:
{
"agents": {
"list": [
{
"id": "main",
"tools": {
"alsoAllow": ["lobster"]
}
}
]
}
}避免使用 ''tools.allow: ["lobster"]'',除非您打算在限制性允许列表模式下运行。
注意:允许列表对于可选插件是选择性的。如果您的允许列表只命名
插件工具(如 ''lobster''),OpenClaw 会保持核心工具启用。要限制核心
工具,请在允许列表中包含您想要的核心工具或组。
示例:邮件分类
没有 Lobster:
User: "Check my email and draft replies" → openclaw calls gmail.list → LLM summarizes → User: "draft replies to #2 and #5" → LLM drafts → User: "send #2" → openclaw calls gmail.send (repeat daily, no memory of what was triaged)
使用 Lobster:
{
"action": "run",
"pipeline": "email.triage --limit 20",
"timeoutMs": 30000
}返回 JSON 信封(截断):
{
"ok": true,
"status": "needs_approval",
"output": [{ "summary": "5 need replies, 2 need action" }],
"requiresApproval": {
"type": "approval_request",
"prompt": "Send 2 draft replies?",
"items": [],
"resumeToken": "..."
}
}用户批准 → 恢复:
{
"action": "resume",
"token": "<resumeToken>",
"approve": true
}一个工作流。确定性。安全。
工具参数
#
`run`
在工具模式下运行管道。
{
"action": "run",
"pipeline": "gog.gmail.search --query 'newer_than:1d' | email.triage",
"cwd": "/path/to/workspace",
"timeoutMs": 30000,
"maxStdoutBytes": 512000
}使用参数运行工作流文件:
{
"action": "run",
"pipeline": "/path/to/inbox-triage.lobster",
"argsJson": "{"tag":"family"}"
}#
`resume`
审批后继续暂停的工作流。
{
"action": "resume",
"token": "<resumeToken>",
"approve": true
}#
可选输入
- ''lobsterPath'':Lobster 二进制文件的绝对路径(省略则使用 ''PATH'')。
- ''cwd'':管道的工作目录(默认为当前进程工作目录)。
- ''timeoutMs'':如果超过此持续时间则终止子进程(默认:20000)。
- ''maxStdoutBytes'':如果 stdout 超过此大小则终止子进程(默认:512000)。
- ''argsJson'':传递给 ''lobster run --args-json'' 的 JSON 字符串(仅限工作流文件)。
输出信封
Lobster 返回具有三种状态之一的 JSON 信封:
- ''ok'' → 成功完成
- ''needs_approval'' → 已暂停;需要 ''requiresApproval.resumeToken'' 才能恢复
- ''cancelled'' → 明确拒绝或取消
工具在 ''content''(格式化 JSON)和 ''details''(原始对象)中都显示信封。
审批
如果存在 ''requiresApproval'',检查提示并决定:
- ''approve: true'' → 恢复并继续副作用
- ''approve: false'' → 取消并完成工作流
使用 ''approve --preview-from-stdin --limit N'' 将 JSON 预览附加到审批请求,无需自定义 jq/heredoc 胶水。恢复 token 现在是紧凑的:Lobster 在其状态目录下存储工作流恢复状态,并返回一个小的 token 密钥。
OpenProse
OpenProse 与 Lobster 配合良好:使用 ''/prose'' 编排多代理准备,然后运行 Lobster 管道进行确定性审批。如果 Prose 程序需要 Lobster,请通过 ''tools.subagents.tools'' 为子代理允许 ''tools.subagents.tools'' 工具。参见 ''OpenProse''。
安全性
- 仅本地子进程 — 插件本身不进行网络调用。
- 无密钥 — Lobster 不管理 OAuth;它调用管理 OAuth 的 OpenClaw 工具。
- 沙箱感知 — 当工具上下文被沙箱化时禁用。
- ''加固'' — 如果指定,''lobsterPath'' 必须是绝对路径;强制执行超时和输出上限。
故障排除
- ''''lobster subprocess timed out'''' → 增加 ''timeoutMs'',或拆分长管道。
- ''''lobster output exceeded maxStdoutBytes'''' → 提高 ''maxStdoutBytes'' 或减少输出大小。
- ''''lobster returned invalid JSON'''' → 确保管道在工具模式下运行并仅打印 JSON。
- ''''lobster failed (code …)'''' → 在终端中运行相同的管道以检查 stderr。
了解更多
#