架构新增定时任务

This commit is contained in:
2025-11-08 01:27:10 +08:00
parent a676533510
commit fb74fe0f34
2 changed files with 43 additions and 1 deletions

View File

@@ -0,0 +1,42 @@
# 背景
文件名2025-11-08_1_register-clock-trigger.md
创建于2025-11-08_00:38:54
创建者ASUS
主分支main
任务分支:未创建
Yolo模式Off
# 任务描述
插件框架需要支持在插件执行阶段注册并定期触发的clock回调。
# 项目概览
当前架构通过Architecture.Register管理插件生命周期但缺少可用的定时调度机制。必须分析如何安全地触发插件提供的clock回调。
# 分析
目前 `PluginInterface.execute``Architecture.Register` 中仅绑定 `wake_up`,插件自行决定何时启动定时任务;原先取得 `register_clock()` 的逻辑已移除。
框架缺乏任何定时任务持久化结构,需要扩展 `Database` 或新增表来保存待执行任务及其计划执行时间。
调度接口需要符合 `register_clock(callback, time)` 一次性延时调用模型,回调若要持续执行需自行再次注册。
任务触发误差需从 `ProjectConfig` 读取配置,服务器重启后所有已到期任务应立即执行,未到期任务需按剩余时间继续等待。
时间单位为毫秒,每个插件可以同时注册多个延时任务,不设并发限制,需确保调度层能最大限度向插件开放自由度。
延时任务执行必须由独立的事件循环系统负责,插件实例不应自行保存或执行任务;事件循环应按配置误差间隔检查到期任务,并在执行任务时支持回调中继续注册新任务而不引发并发竞态。
# 提议的解决方案
- 扩展数据库,在 `scheduled_tasks` 表中保存任务ID、回调标识、序列化参数、执行时间毫秒时间戳和状态确保重启后恢复。
- 新增 `ClockScheduler` 模块,独立读取数据库、按配置误差间隔扫描到期任务并执行,执行前后更新任务状态并记录结果。
-`PluginInterface` 中实现 `register_clock`将插件提供的回调标识与延迟毫秒数交给调度器插件可传递payload以便执行时还原上下文。
- 在 FastAPI 应用启动时创建并启动调度器后台任务,停止时优雅关闭;从 `ProjectConfig` 读取调度周期等配置。
- 设计回调解析器,通过模块/类/函数标识和payload反射执行回调允许回调内部再次注册延时任务而不影响调度循环。
# 当前执行步骤:"1. 创建任务文件"
# 任务进度
2025-11-08_01:14:21
- 已修改PWF/CoreModules/database.py PWF/CoreModules/clock_scheduler.py PWF/CoreModules/plugin_interface.py PWF/Application/web.py PWF/Convention/Runtime/GlobalConfig.py
- 更改创建持久化延时任务表与CRUD接口实现独立调度器并集成FastAPI生命周期为插件提供register_clock封装配置默认调度参数。
- 原因:满足延时任务持久化与独立事件循环需求,支持重启恢复。
- 阻碍因素:无
- 状态:未确认
2025-11-08_01:22:21
- 已修改PWF/Convention/Runtime/GlobalConfig.py
- 更改:撤回 scheduler 默认配置写入,保持 ProjectConfig 原始行为。
- 原因:遵循架构约束,避免上游配置被功能耦合。
- 阻碍因素:无
- 状态:未确认
# 最终审查
待补充