跳转到主要内容

Lobster

Lobster 是一个工作流外壳,让 OpenClaw 能够将多步骤工具序列作为单个确定性操作运行,并带有显式审批检查点。

亮点

你的助手可以构建管理自身的工具。请求一个工作流,30 分钟后你就能得到一个 CLI 加上作为单次调用运行的流水线。Lobster 就是缺失的那块拼图:确定性流水线、显式审批和可恢复状态。

为什么需要 Lobster

如今,复杂的工作流需要大量来回的工具调用。每次调用都消耗 token,而 LLM 必须编排每一个步骤。Lobster 将这种编排移入类型化运行时:
  • 一次调用代替多次:OpenClaw 运行一次 Lobster 工具调用即可获得结构化结果。
  • 内置审批:副作用(发送邮件、发布评论)会暂停工作流,直到获得显式批准。
  • 可恢复:暂停的工作流返回一个令牌;批准后可恢复执行,无需重新运行所有步骤。

为什么用 DSL 而不是普通程序?

Lobster 刻意保持小巧。目标不是”一门新语言”,而是一个可预测的、AI 友好的流水线规范,内置一等公民级别的审批和恢复令牌。
  • 审批/恢复是内置的:普通程序可以提示用户,但如果不自行发明运行时,它无法暂停并通过持久令牌恢复
  • 确定性 + 可审计性:流水线就是数据,因此易于记录、比较、重放和审查。
  • 为 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
}
如果流水线请求审批,使用令牌恢复:
{
  "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 可以运行包含 nameargsstepsenvconditionapproval 字段的 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.stdoutstdin: $step.json 传递前一步骤的输出。
  • condition(或 when)可以基于 $step.approved 来控制步骤执行。

安装 Lobster

在运行 OpenClaw Gateway网关的同一主机上安装 Lobster CLI(参见 Lobster 仓库),并确保 lobsterPATH 中。 如果你想使用自定义二进制文件位置,请在工具调用中传入绝对路径 lobsterPath

启用工具

Lobster 是一个可选插件工具(默认未启用)。 推荐方式(增量添加,安全):
{
  "tools": {
    "alsoAllow": ["lobster"]
  }
}
或按智能体配置:
{
  "agents": {
    "list": [
      {
        "id": "main",
        "tools": {
          "alsoAllow": ["lobster"]
        }
      }
    ]
  }
}
避免使用 tools.allow: ["lobster"],除非你打算以严格允许列表模式运行。 注意:允许列表对可选插件是选择性加入的。如果你的允许列表只包含 插件工具(如 lobster),OpenClaw 会保持核心工具启用。要限制核心 工具,请在允许列表中同时包含你需要的核心工具或工具组。

示例:邮件分类

不使用 Lobster:
用户:"检查我的邮件并起草回复"
→ openclaw 调用 gmail.list
→ LLM 进行摘要
→ 用户:"给 #2 和 #5 起草回复"
→ LLM 起草
→ 用户:"发送 #2"
→ openclaw 调用 gmail.send
(每天重复,不记得之前分类了什么)
使用 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 粘合代码。恢复令牌现在更加紧凑:Lobster 将工作流恢复状态存储在其状态目录下,并返回一个小型令牌密钥。

OpenProse

OpenProse 与 Lobster 配合良好:使用 /prose 编排多智能体准备工作,然后运行 Lobster 流水线进行确定性审批。如果 Prose 程序需要 Lobster,可通过 tools.subagents.tools 为子智能体允许 lobster 工具。参见 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。

了解更多

案例研究:社区工作流

一个公开示例:一个”第二大脑” CLI + Lobster 流水线,管理三个 Markdown 库(个人、伴侣、共享)。CLI 输出 JSON 格式的统计数据、收件箱列表和过期扫描;Lobster 将这些命令串联成工作流,如 weekly-reviewinbox-triagememory-consolidationshared-task-sync,每个都带有审批门控。AI 在可用时处理判断(分类),不可用时回退到确定性规则。