kake
基于tengo构建自己的task 系统
todo
- 任务系统的API开发设计
1.1 任务提交
1.2 任务分发
1.3 任务重新入队列(timeout, retask)
1.4 任务确认(状态上报)
1.7 任务状态确认(确认完毕任务之后)
组件: redis
- 任务系统的代理设计
- 任务提交代理
- 任务回调和任务状态的上报(需要配置任务地址, 任务类型等)
- 自动的上报log以及相关的trace
- 通过异步的方式模拟同步
组件: 任务系统API
- 任务系统的管理系统开发设计
- 前n秒内的ready的任务数
- 前n秒内的pending的任务数
- 任务迁移(完成)
- 任务统计(未完成的任务数, 已经完成的任务数, 正在运行的任务数)
- 最近一个小时的任务数
- 任务分页展示
- 任务Tree展示(通过一条任务的根, 然后得到所有的子任务)
- 任务重新执行, 把没有执行成功的任务 重新执行一遍
- 任务强制删除(输入任务ID, 那么删除该任务信息, 如果输入的是根任务ID,
那么删除所有的子任务)
组件: redis, mysql