Cron 定时任务(网关调度器)

Cron 定时任务(网关调度器)

适用场景

在以下情况使用本页面:

  • 调度后台任务或唤醒
  • 连接应与心跳一起或 alongside 心跳运行的自动化
  • 在心跳和 cron 之间为定时任务做选择

Cron vs Heartbeat? 参见 Cron vs Heartbeat 了解何时使用每个的指导。

Cron 是网关的内置调度器。它持久化任务,在正确的时间唤醒 Agent,并可选择将输出投递回聊天。

如果您想要*“每天早上运行此任务”“在 20 分钟后提醒 Agent”*, cron 就是您需要的机制。

简而言之

  • Cron 在网关内部运行(不在模型内部)。
  • 任务持久化在 ~/.moltbot/cron/ 下,因此重启不会丢失调度。
  • 两种执行样式:
    • 主会话:排队一个系统事件,然后在下一次心跳时运行。
    • 隔离:在 cron:<jobId> 中运行专用的 Agent 轮次,可选择投递输出。
  • 唤醒是一等公民:任务可以请求"立即唤醒"与"下一次心跳"。

新手友好的概述

将 cron 任务视为:何时运行 + 做什么

  1. 选择调度

    • 一次性提醒 → schedule.kind = "at"(CLI:--at
    • 重复任务 → schedule.kind = "every"schedule.kind = "cron"
    • 如果您的 ISO 时间戳省略了时区,它将被视为 UTC
  2. 选择运行位置

    • sessionTarget: "main" → 在下一次心跳时使用主上下文运行。
    • sessionTarget: "isolated" → 在 cron:<jobId> 中运行专用的 Agent 轮次。
  3. 选择负载

    • 主会话 → payload.kind = "systemEvent"
    • 隔离会话 → payload.kind = "agentTurn"

可选:deleteAfterRun: true 在成功的一次性运行后从存储中删除任务。

概念

任务

一个 cron 任务是一个存储的记录,包含:

  • 一个调度(何时运行),
  • 一个负载(做什么),
  • 可选的投递(输出应发送到哪里)。
  • 可选的 Agent 绑定agentId):在特定 Agent 下运行任务;如果 缺失或未知,网关回退到默认 Agent。

任务通过稳定的 jobId 标识(由 CLI/网关 API 使用)。 在 Agent 工具调用中,jobId 是规范的;为了兼容性接受旧版 id。 任务可以通过 deleteAfterRun: true 在成功的一次性运行后自动删除。

调度

Cron 支持三种调度类型:

  • at:一次性时间戳(自纪元以来的毫秒数)。网关接受 ISO 8601 并强制转换为 UTC。
  • every:固定间隔(毫秒)。
  • cron:5 字段 cron 表达式,可选 IANA 时区。

Cron 表达式使用 croner。如果省略时区,则使用网关主机的本地时区。

主会话 vs 隔离执行

主会话任务(系统事件)

主任务排队一个系统事件并可选择唤醒心跳运行器。 它们必须使用 payload.kind = "systemEvent"

  • wakeMode: "next-heartbeat"(默认):事件等待下一次调度的心跳。
  • wakeMode: "now":事件触发立即心跳运行。

这是您想要正常心跳提示 + 主会话上下文时的最佳选择。 参见 Heartbeat

隔离任务(专用 cron 会话)

隔离任务在会话 cron:<jobId> 中运行专用的 Agent 轮次。

关键行为:

  • 提示前缀为 [cron:<jobId> <job name>] 以便跟踪。
  • 每次运行启动一个新的会话 id(没有先前的对话延续)。
  • 摘要发布到主会话(前缀 Cron,可配置)。
  • wakeMode: "now" 在发布摘要后触发立即心跳。
  • 如果 payload.deliver: true,输出投递到频道;否则保持内部。

对不应污染主聊天历史的嘈杂、频繁或"后台杂务"任务使用隔离任务。

负载形状(运行什么)

支持两种负载类型:

  • systemEvent:仅主会话,通过心跳提示路由。
  • agentTurn:仅隔离会话,运行专用的 Agent 轮次。

常见的 agentTurn 字段:

  • message:必需的文本提示。
  • model / thinking:可选覆盖(见下文)。
  • timeoutSeconds:可选超时覆盖。
  • delivertrue 将输出发送到频道目标。
  • channellast 或特定频道。
  • to:频道特定目标(电话/聊天/频道 id)。
  • bestEffortDeliver:如果投递失败,避免任务失败。

隔离选项(仅适用于 session=isolated):

  • postToMainPrefix(CLI:--post-prefix):主会话中系统事件的前缀。
  • postToMainModesummary(默认)或 full
  • postToMainMaxChars:当 postToMainMode=full 时的最大字符数(默认 8000)。

模型和思考覆盖

隔离任务(agentTurn)可以覆盖模型和思考级别:

  • model:提供商/模型字符串(例如,anthropic/claude-sonnet-4-20250514)或别名(例如,opus
  • thinking:思考级别(offminimallowmediumhighxhigh;仅 GPT-5.2 + Codex 模型)

注意:您也可以在主会话任务上设置 model,但它会更改共享的主会话模型。我们建议仅对隔离任务使用模型覆盖,以避免意外的上下文转移。

解析优先级:

  1. 任务负载覆盖(最高)
  2. Hook 特定默认值(例如,hooks.gmail.model
  3. Agent 配置默认值

投递(频道 + 目标)

隔离任务可以将输出投递到频道。任务负载可以指定:

  • channelwhatsapp / telegram / discord / slack / mattermost(插件) / signal / imessage / last
  • to:频道特定的接收者目标

如果省略 channelto,cron 可以回退到主会话的"最后一条路由"(Agent 最后回复的地方)。

投递注意事项:

  • 如果设置了 to,即使省略了 deliver,cron 也会自动投递 Agent 的最终输出。
  • 当您想要没有明确 to 的最后路由投递时,使用 deliver: true
  • 使用 deliver: false 使输出保持内部,即使存在 to

目标格式提醒:

  • Slack/Discord/Mattermost(插件)目标应使用显式前缀(例如 channel:<id>user:<id>)以避免歧义。
  • Telegram 主题应使用 :topic: 形式(见下文)。

Telegram 投递目标(主题 / 论坛线程)

Telegram 通过 message_thread_id 支持论坛主题。对于 cron 投递,您可以将主题/线程编码到 to 字段中:

  • -1001234567890(仅聊天 id)
  • -1001234567890:topic:123(首选:显式主题标记)
  • -1001234567890:123(简写:数字后缀)

也接受前缀目标如 telegram:... / telegram:group:...

  • telegram:group:-1001234567890:topic:123

存储和历史

  • 任务存储:~/.moltbot/cron/jobs.json(网关管理的 JSON)。
  • 运行历史:~/.moltbot/cron/runs/<jobId>.jsonl(JSONL,自动修剪)。
  • 覆盖存储路径:配置中的 cron.store

配置

{
  cron: {
    enabled: true, // 默认 true
    store: "~/.moltbot/cron/jobs.json",
    maxConcurrentRuns: 1 // 默认 1
  }
}

完全禁用 cron:

  • cron.enabled: false(配置)
  • MOLTBOT_SKIP_CRON=1(环境变量)

CLI 快速入门

一次性提醒(UTC ISO,成功后自动删除):

moltbot cron add \
  --name "发送提醒" \
  --at "2026-01-12T18:00:00Z" \
  --session main \
  --system-event "提醒:提交费用报告。" \
  --wake now \
  --delete-after-run

一次性提醒(主会话,立即唤醒):

moltbot cron add \
  --name "日历检查" \
  --at "20m" \
  --session main \
  --system-event "下一次心跳:检查日历。" \
  --wake now

重复隔离任务(投递到 WhatsApp):

moltbot cron add \
  --name "早间状态" \
  --cron "0 7 * * *" \
  --tz "America/Los_Angeles" \
  --session isolated \
  --message "总结今天的收件箱 + 日历。" \
  --deliver \
  --channel whatsapp \
  --to "+15551234567"

重复隔离任务(投递到 Telegram 主题):

moltbot cron add \
  --name "每晚摘要(主题)" \
  --cron "0 22 * * *" \
  --tz "America/Los_Angeles" \
  --session isolated \
  --message "总结今天;发送到每晚主题。" \
  --deliver \
  --channel telegram \
  --to "-1001234567890:topic:123"

具有模型和思考覆盖的隔离任务:

moltbot cron add \
  --name "深度分析" \
  --cron "0 6 * * 1" \
  --tz "America/Los_Angeles" \
  --session isolated \
  --message "项目进度的每周深度分析。" \
  --model "opus" \
  --thinking high \
  --deliver \
  --channel whatsapp \
  --to "+15551234567"

Agent 选择(多 Agent 设置):

# 将任务固定到 agent "ops"(如果该 agent 缺失则回退到默认)
moltbot cron add --name "Ops 扫描" --cron "0 6 * * *" --session isolated --message "检查 ops 队列" --agent ops

# 切换或清除现有任务上的 agent
moltbot cron edit <jobId> --agent ops
moltbot cron edit <jobId> --clear-agent

手动运行(调试):

moltbot cron run <jobId> --force

编辑现有任务(修补字段):

moltbot cron edit <jobId> \
  --message "更新的提示" \
  --model "opus" \
  --thinking low

运行历史:

moltbot cron runs --id <jobId> --limit 50

不创建任务的立即系统事件:

moltbot system event --mode now --text "下一次心跳:检查电池。"

网关 API 表面

  • cron.listcron.statuscron.addcron.updatecron.remove
  • cron.run(强制或到期)、cron.runs 对于没有任务的立即系统事件,使用 moltbot system event

故障排除

“什么都不运行”

  • 检查 cron 是否启用:cron.enabledMOLTBOT_SKIP_CRON
  • 检查网关是否持续运行(cron 在网关进程内运行)。
  • 对于 cron 调度:确认时区(--tz)与主机时区。

Telegram 投递到错误的地方

  • 对于论坛主题,使用 -100…:topic:<id> 以便明确和无歧义。
  • 如果您在日志或存储的"最后一条路由"目标中看到 telegram:... 前缀,那是正常的; cron 投递接受它们并仍然正确解析主题 ID。