订阅任务
订阅任务在时间到达或 Redis 主题收到新消息时运行已发布工作流。一个任务支持多个来源,任意来源触发一次运行。
创建任务
- 打开项目侧栏「应用」中的「订阅任务」,点击「创建任务」。
- 填写名称,选择已发布工作流。
- 添加时间或 Redis 来源。时间来源填写 Cron 和时区,Redis 来源选择本项目主题。
- 配置输入。Redis 默认读取
payload对象字段,也支持属性路径;标量或数组需指定目标字段。固定输入覆盖同名字段。 - 按需添加看门狗,选择观察来源、周期和兜底输入。
- 保存并启用,在任务记录中查看排队、运行、成功、失败和待处理状态。
主题每次显式发布消息会触发,缓存 Key 增删改不会触发。托管订阅从创建后的消息开始接收,暂停保留积压,恢复后补收。
若保存后显示「订阅未就绪」,配置已经保留。等待服务恢复和就绪后再发布消息,不要重复创建任务。
看门狗与恢复
周期内有有效触发则跳过兜底,没有则兜底一次。普通消息仍逐条触发,不会因本周期已经执行而忽略。可以选择受理即满足或执行成功才满足;无效输入、手动运行和兜底不满足。截止前有积压可等待有限宽限期,也可立即决定兜底。
新任务默认串行、停机错过时间合并补一次。旧任务保留 Cron、时区、ID、日志和恢复行为,可以逐步添加 Redis 来源和看门狗。
旧时间任务可以由后台计划任务身份执行。没有触发用户时,记录保留任务和原付款团队,不把所有者记为触发用户;有用户触发时保留真实用户。
暂停停止新派发,已开始工作流继续执行,积压保留;暂停期间不能手动运行。恢复后重新开始时间和看门狗周期,Redis继续补收。编辑只影响后续受理事件,已受理事件保留原版本和输入。
结果未知的运行会占用串行任务。通过运行记录进入原运行,恢复中断运行或取消;后台确认实际终态后继续执行后续事件。
结果待确认表示系统尚不能确定结果。串行任务会等待它,请查看运行记录,不要直接当作失败重复提交。
实时更新
列表与已打开的记录由真实事件更新,不定时刷新。后台更新会保留列表和编辑草稿。连接恢复后自动同步一次;也可以手动刷新。
管理与记录
管理员可以管理和手动运行,可读成员可以查看。编辑冲突时刷新后重新保存。
Redis托管消费者自动领取和确认,不能人工操作。已处理代表交给任务队列,工作流结果请看任务记录。删除任务后系统交接旧消费者积压并退出订阅。
订阅已就绪表示主题连接已建立。消息进入队列后,仍需在任务记录中确认执行成功;排队状态不表示工作流已经完成。
升级后的任务在订阅任务界面修改。重新发布工作流保留原绑定,需要在订阅任务中明确选择新版本。