Lobster
适用范围
在以下情况使用本页面:
- 您想要确定性的多步骤工作流程和明确的批准
- 您需要在不重新运行早期步骤的情况下恢复工作流
Lobster 是一个工作流 shell,允许 Moltbot 将多步骤工具序列作为单个确定性操作运行,并具有明确的批准检查点。
钩子
您的助手可以构建管理自身的工具。请求一个工作流,30 分钟后您就有了一个 CLI 以及作为一次调用的管道。Lobster 是缺失的部分:确定性管道、明确的批准和可恢复的状态。
为什么
今天,复杂的工作流需要许多来回的工具调用。每次调用都会消耗令牌,LLM 必须协调每个步骤。Lobster 将这种协调转移到类型化运行时:
- 一次调用而不是多次:Moltbot 运行一次 Lobster 工具调用并获得结构化结果。
- 内置批准:副作用(发送电子邮件、发布评论)暂停工作流,直到明确批准。
- 可恢复:暂停的工作流返回令牌;批准并恢复而无需重新运行所有内容。
为什么使用 DSL 而不是普通程序?
Lobster 故意很小。目标不是"一种新语言",而是一个可预测的、AI 友好的管道规范,具有一流的批准和恢复令牌。
- 内置批准/恢复:普通程序可以提示人类,但它不能暂停和恢复并具有持久的令牌,除非您自己发明该运行时。
- 确定性 + 可审计性:管道是数据,因此它们易于记录、差异、重放和审查。
- 约束的 AI 表面:微小的语法 + JSON 管道减少了"创造性"代码路径,并使验证成为现实。
- 内置安全策略:超时、输出上限、沙箱检查和允许列表由运行时强制执行,而不是每个脚本。
- 仍然可编程:每个步骤都可以调用任何 CLI 或脚本。如果您想要 JS/TS,请从代码生成
.lobster文件。
它如何工作
Moltbot 在工具模式中启动本地 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' \
| clawd.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"] }
}
]
}
}在管道中使用它:
clawd.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 工作流文件。在 Moltbot 工具调用中,将 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
在运行 Moltbot 网关的同一主机上安装 Lobster CLI(参见 Lobster 仓库),并确保 lobster 在 PATH 上。
如果您想使用自定义二进制位置,请在工具调用中传递绝对 lobsterPath。
启用工具
Lobster 是一个可选的插件工具(默认未启用)。按代理允许:
{
"agents": {
"list": [
{
"id": "main",
"tools": {
"allow": ["lobster"]
}
}
]
}
}如果每个代理都应该看到它,您也可以通过 tools.allow 全局允许它。
注意:允许列表对于可选插件是选择加入的。如果您的允许列表仅命名
插件工具(如 lobster),Moltbot 保持核心工具启用。要限制核心
工具,在允许列表中也包括您想要的核心工具或组。
示例:电子邮件分类
没有 Lobster:
User: "Check my email and draft replies"
→ clawd calls gmail.list
→ LLM summarizes
→ User: "draft replies to #2 and #5"
→ LLM drafts
→ User: "send #2"
→ clawd calls 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 的 clawd 工具。
- 沙箱感知 — 当工具上下文是沙箱时禁用。
- 加固 — 如果指定,
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-review、inbox-triage、memory-consolidation 和 shared-task-sync,每个都有批准门。AI 在可用时处理判断(分类),在不可用时回退到确定性规则。
- 线程:https://x.com/plattenschieber/status/2014508656335770033
- 仓库:https://github.com/bloomedai/brain-cli