Celery参数详解、配置参数

限制任务的执行频率
下面这个就是限制tasks模块下的add函数，每秒钟只能执行10次
CELERY_ANNOTATIONS = {'tasks.add':{'rate_limit':'10/s'}}
或者限制所有的任务的刷新频率
CELERY_ANNOTATIONS = {'*':{'rate_limit':'10/s'}}
也可以设置如果任务执行失败后调用的函数

def my_on_failure(self,exc,task_id,args,kwargs,einfo):
    print('task failed')
 
CELERY_ANNOTATIONS = {'*':{'on_failure':my_on_failure}

原文

https://blog.csdn.net/u012206617/article/details/106495425

https://www.cnblogs.com/xiao-xue-di/p/15878546.html

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容