任务中心

任务中心解决的是"这些能力如何按计划持续运行"。如果说 Workflow 回答怎么做、Agent 回答谁来做，那么任务中心回答的就是"什么时间、多久一次、结果发到哪里"。平台从此不只是接到指令才行动，而可以围绕运营目标长期、主动地工作。

功能定位

任务中心承载平台的长期运行能力，当前已经具备：

• 任务队列 + 调度 + 执行 + 恢复（任务播种）
• 基于 Agent 和基于 Workflow 的两类执行模式
• 一次性运行、周期性运行（定时任务）、批量运行

可以把它理解为 Flocks 内置的"轻量 SOAR 调度器"：把一条可用的 Workflow 或一个成熟的 Agent，拖进任务中心，配上"每小时 / 每日 / 每周"，就得到一条持续跑的数字员工。

操作步骤（WebUI）

步骤 1：确认已有可运行对象

任务中心的前提是存在一个可以跑的 Agent 或 Workflow。确保：

• 要跑的 Workflow 在 工作流列表 里，并且通过了单点 + 集成测试
• 或者要跑的 Agent 在 Agent 列表 里，并且已经手动验证过一次
• 模型、通道、工具等依赖都已就绪（参见 模型清单 和 通道配置）

步骤 2：进入任务中心

侧栏 AI 工作台 → 任务中心。页面显示：

• 所有已创建的任务
• 每条任务的执行模式（Agent / Workflow）
• 最近一次运行状态（成功 / 失败 / 运行中）
• 下次执行时间
• 近期产出

步骤 3：用自然语言在会话里创建

和 Agent / Workflow 一样，任务中心的创建走"语言生成"路径。在会话里告诉 Rex：

把刚才那条 NDR 告警研判工作流配成定时任务：
- 每小时执行一次
- 执行结果通过企微通道推送
- 目标群：值班运营群

或者更简单：

「帮我把设备巡检 Agent 配成每日 08:00 执行，结果发到飞书运营群」

步骤 4：Rex 自动创建任务

Rex 会：

1. 识别要调度的执行对象（Agent 还是 Workflow）
2. 解析调度周期（每小时 / 每日 HH:MM / 每周等）
3. 绑定输出通道和目标会话 ID
4. 在任务中心生成一条新任务

步骤 5：查看执行状态

进任务中心查看：

• 任务基本信息 — 名称、执行对象、调度周期、下次执行时间
• 执行历史 — 每次运行的起止时间、状态、耗时
• 产出 — 落盘到 Workspace 的 artifacts 目录（每次执行通常按日期/时间戳归档）
• 失败重试 — 平台会自动恢复，但连续失败时需要手动排查

步骤 6：调整或停用

可以直接告诉 Rex 调整任务：

「把告警研判任务改成每 30 分钟跑一次」

或在任务中心页面手动停用、启用、删除。

核心概念

两种执行模式

模式	特点	适合
基于 Agent	调用一个完整子 Agent 处理任务	过程灵活、步骤有弹性的工作（如巡检、研判）
基于 Workflow	按固定剧本走节点	步骤稳定、输入输出 schema 明确的工作（如批量告警清洗）

选择原则和 Workflow vs Agent 的选择一致：流程越固定越偏 Workflow，越需要临场决策越偏 Agent。

任务调度和恢复

平台内置任务队列和恢复能力，即使重启也能继续处理（任务播种）。一般情况下用户无需关心底层机制；只有在排查"任务为什么没跑"时才需要到 运维与排障 确认 flocks status 和 backend 日志。

与通道的衔接

任务产出通常需要通道外发。确保：

• 通道已配置（参见 通信配置）
• 多群场景显式指定 session ID（参见 企业微信 · 多群消息与 session ID 或 钉钉、飞书 对应章节）

真实案例走读：NDR 告警研判每小时任务

参考场景：告警研判

一次性运行（会话里）

用户在会话里输入：

「从 TDP 抓 5 条最新告警，逐条做研判，JSON 产出，摘要发企微值班群」

Rex 依次：

1. 调浏览器工具抓取原始告警 → 落盘到 Workspace 3-28/alerts.json
2. 委派告警分析子 Agent 逐条研判
3. 输出结构化 JSON 和文本摘要
4. 调企微通道推送摘要到值班群

转任务中心

同一会话继续：

「把这套巡检研判过程配成定时任务，每小时执行一次，结果发企微」

Rex 在任务中心创建：

• 启动方式：每小时
• 执行对象：之前跑通的告警研判链路（或其固化成的 Workflow）
• 通道：企微值班群

持续运营效果

从此不再需要人工手动触发。每小时平台自动：

• 抓最新一批告警
• 研判并落盘 JSON
• 摘要推送企微群

这是典型的"做一次 → 常态化"升级路径，也是任务中心最高频的使用方式。

常见问题

任务没有按时执行怎么办？

按下列顺序排查：

1. flocks status 确认服务在线
2. 任务中心页面查看任务状态是否被误停用
3. 查看最近一次执行结果和错误信息
4. 检查依赖：默认模型是否可用、通道是否能连通、工具是否正常
5. 必要时看 ~/.flocks/logs/backend.log（见 运维与排障）

任务产出在哪里？

通常在 Workspace 的 artifacts/ 下。如果任务执行的是 Workflow，会按 Workflow 的产出约定存放；如果执行的是 Agent，Agent 通常会自己选定输出文件位置并写入。

一个任务挂了会影响其他任务吗？

任务之间独立调度。但若某个任务大量失败，会在日志里留下错误，建议连续失败时手动停用避免无效重试。

任务能手动触发一次吗？

可以。任务中心通常支持 "立即运行一次" 按钮，或者直接在会话里对 Rex 说"帮我手动跑一次 [任务名]"。

能不能让任务运行失败时自动通知我？

可以。在创建任务时显式告诉 Rex："如果执行失败，把错误摘要发到 XXX 群"——任务配置里会包含失败通道回调。

相关模块

• Workflow 工作流 — 周期任务最常见的执行对象
• Agent 智能体 — 当任务步骤较灵活时的执行对象
• Workspace — 任务产物的落盘位置
• 通信配置 — 任务结果的外发通道
• 运维与排障 — 定时任务的监控与排障
• 场景案例 · 告警研判 — 最典型的任务中心落地
• 场景案例 · 互联网资产测绘 — 资产 diff 任务