Lobster
Lobster 是一个工作流 Shell,允许 OpenClaw 将多步骤工具序列作为单一确定性操作运行,并具有明确的批准检查点。
Lobster 是位于独立后台工作之上的一个创作层。对于单个任务之上的流程编排,请参阅 Task Flow (openclaw tasks flow)。有关任务活动账本,请参阅 openclaw tasks。
你的助手可以构建管理自身的工具。请求一个工作流,30 分钟后你就会得到一个 CLI 和作为一次调用运行的管道。Lobster 是缺失的那一块:确定性管道、明确的批准和可恢复的状态。
如今,复杂的工作流需要多次来回的工具调用。每次调用都会消耗 token,而 LLM 必须编排每一个步骤。Lobster 将这种编排移入类型化运行时:
- 一次调用代替多次:OpenClaw 运行一次 Lobster 工具调用并获得结构化结果。
- 内置批准:副作用(发送电子邮件、发布评论)会暂停工作流,直到被明确批准。
- 可恢复:暂停的工作流返回一个 token;批准并恢复而无需重新运行所有内容。
Why a DSL instead of plain programs?
Section titled “Why a DSL instead of plain programs?”Lobster 故意设计得很小。目标不是“一种新语言”,而是一个可预测的、AI 友好的管道规范,具有一流的批准和恢复 token。
- 内置批准/恢复功能:普通程序可以提示人工,但在不自行发明该运行时的情况下,它无法使用持久化令牌 暂停并恢复。
- 确定性与可审计性:流水线即数据,因此易于记录、比较差异、重放和审查。
- 受约束的 AI 表面:微小的语法 + JSON 管道减少了“创造性”代码路径,并使验证变得现实可行。
- 内置安全策略:超时、输出上限、沙箱检查和允许列表由运行时强制执行,而不是由每个脚本强制执行。
- 仍然可编程:每个步骤都可以调用任何 CLI 或脚本。如果您想要 JS/TS,可以从代码生成 CLI
.lobster文件。
How it works
Section titled “How it works”OpenClaw 使用嵌入式运行器 进程内 运行 Lobster 工作流。不会生成外部 CLI 子进程;工作流引擎在网关进程内执行并直接返回 JSON 信封。
如果流水线因批准而暂停,工具会返回一个 OpenClawLobsterCLIresumeToken 以便您稍后继续。
模式:小型 CLI + JSON 管道 + 批准
Section titled “模式:小型 CLI + JSON 管道 + 批准”构建能够处理 JSON 的微小命令,然后将它们链接到单个 Lobster 调用中。(下面的示例命令名称 - 替换为您自己的名称。)
inbox list --jsoninbox categorize --jsoninbox 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}如果管道请求批准,请使用令牌恢复:
{ "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)
Section titled “仅 JSON 的 LLM 步骤 (llm-task)”对于需要 结构化 LLM 步骤 的工作流,请启用可选的
LLMllm-taskLobster 插件工具并从 Lobster 调用它。这保持了工作流的
确定性,同时仍允许您使用模型进行分类/摘要/起草。
启用该工具:
{ "plugins": { "entries": { "llm-task": { "enabled": true } } }, "agents": { "list": [ { "id": "main", "tools": { "alsoAllow": ["llm-task"] } } ] }}重要限制:嵌入式 Lobster 与 Lobsteropenclaw.invoke 的对比
Section titled “重要限制:嵌入式 Lobster 与 Lobsteropenclaw.invoke 的对比”捆绑的 Lobster 插件在网关内部 进程内 运行工作流。在该嵌入式模式下,Lobsteropenclaw.invokeOpenClawCLI 不会 自动继承网关 URL/身份验证上下文用于嵌套的 OpenClaw CLI 工具调用。
这意味着此模式目前在嵌入式运行器中不可靠:
openclaw.invoke --tool llm-task --action json --args-json '{ ... }'仅在 LobsterCLIopenclaw.invoke 已配置正确网关/身份验证上下文的环境中运行独立 Lobster CLI 时,才使用以下示例。
在独立的 Lobster CLI 管道中使用它:
openclaw.invoke --tool llm-task --action json --args-json '{ "prompt": "Given the input email, return intent and draft.", "thinking": "low", "input": { "subject": "Hello", "body": "Can you help?" }, "schema": { "type": "object", "properties": { "intent": { "type": "string" }, "draft": { "type": "string" } }, "required": ["intent", "draft"], "additionalProperties": false }}'如果您今天正在使用嵌入式 Lobster 插件,建议优先选择:
- 在 Lobster 外部直接调用
llm-taskLobster 工具,或者 - 在 Lobster 管道内部使用非
openclaw.invokeLobster 步骤,直到添加受支持的嵌入式桥接。
有关详细信息和配置选项,请参阅 LLM Task。
Lobster 可以运行包含 Lobstername、args、steps、env、condition 和 approvalOpenClaw 字段的 YAML/JSON 工作流文件。在 OpenClaw 工具调用中,将 pipeline 设置为文件路径。
name: inbox-triageargs: 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
Section titled “安装 Lobster”打包的 Lobster 工作流在进程中运行;不需要单独的 LobsterlobsterLobster 二进制文件。嵌入式运行器随 Lobster 插件一起提供。
如果您需要独立的 Lobster CLI 进行开发或外部管道,请从 Lobster repo 安装,并确保 lobster 在 PATH 上。
Lobster 是一个可选的插件工具(默认未启用)。
推荐(累加,安全):
{ "tools": { "alsoAllow": ["lobster"] }}或针对每个代理:
{ "agents": { "list": [ { "id": "main", "tools": { "alsoAllow": ["lobster"] } } ] }}除非你打算在限制性允许列表模式下运行,否则请避免使用 tools.allow: ["lobster"]。
示例:邮件分流
Section titled “示例:邮件分流”不使用 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}一个工作流。确定性。安全。
在工具模式下运行管道。
{ "action": "run", "pipeline": "gog.gmail.search --query 'newer_than:1d' | email.triage", "cwd": "workspace", "timeoutMs": 30000, "maxStdoutBytes": 512000}使用参数运行工作流文件:
{ "action": "run", "pipeline": "/path/to/inbox-triage.lobster", "argsJson": "{\"tag\":\"family\"}"}resume
Section titled “resume”在批准后继续已停止的工作流。
{ "action": "resume", "token": "<resumeToken>", "approve": true}cwd:管道的相对工作目录(必须保持在网关工作目录内)。timeoutMs:如果工作流超过此持续时间,则中止(默认值:20000)。maxStdoutBytes:如果输出超过此大小,则中止工作流(默认值: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 粘合代码。恢复令牌现在很紧凑:Lobster 在其状态目录下存储工作流恢复状态,并返回一个小的令牌键。
OpenProse
Section titled “OpenProse”OpenProse 与 Lobster 搭配得很好:使用 OpenProseLobster/proseLobsterLobster 来编排多智能体准备,然后运行 Lobster 管道进行确定性审批。如果 Prose 程序需要 Lobster,请通过 tools.subagents.toolsOpenProse 为子智能体允许 lobster 工具。参见 OpenProse。
- 仅限本地进程内 - 工作流在网关进程内执行;插件本身不进行网络调用。
- 无密钥 - Lobster 不管理 OAuth;它调用执行此操作的 OpenClaw 工具。
- 感知沙箱 - 当工具上下文处于沙箱隔离状态时禁用。
- 强化防护 - 由嵌入式运行器强制执行超时和输出限制。
lobster timed out→ 增加timeoutMs,或拆分长管道。lobster output exceeded maxStdoutBytes→ 提高maxStdoutBytes或减小输出大小。lobster returned invalid JSON→ 确保管道在工具模式下运行,并且仅打印 JSON。lobster failed→ 检查网关日志以获取嵌入式运行器的错误详细信息。
案例研究:社区工作流
Section titled “案例研究:社区工作流”一个公开示例:管理三个 Markdown 保险库(个人、合作伙伴、共享)的“第二大脑” CLI + Lobster 管道。CLI 输出 JSON 用于统计、收件箱列表和陈旧扫描;Lobster 将这些命令链接到工作流中,如 CLILobsterCLILobsterweekly-review、inbox-triage、memory-consolidation 和 shared-task-sync,每个都有审批门。AI 在可用时处理判断(分类),在不可用时回退到确定性规则。