-
Notifications
You must be signed in to change notification settings - Fork 1
liutaihua/hera
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
一个提供快速配置出一个可用的celery的框架
celery的revoke功能比较弱, revoked task的过期检查是很迟钝, 增强了revoke的时效性
>#### 功能:
1, 可以pause一个task, resume它(新增)
2, 可以手工revoke一个task(celery本身支持)
3, 支持以redis sentinel模式存储result
4, 支持和golang一起用
5, 按MVC的模式整理, 方便清晰
>#### 目录:
config: 主要配置是config.py, 一些不常用的celery在celeryconfig.py内
common.model: 封装了大概的celery task, 可以直接写on_failure, on_success, 方便直接使用
common.strategy: hacky的celery strategy, 如果有需要可以自己在里面干很多事情, pause目前是在里面实现的
common.sentinel: 一个支持redis sentinel模式的 celery result backend实现
common.hera_job: 一个继承了celery job的JOB 类某些方法覆盖, 可以自己在里面做不少事情
About
a celery framework
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published