如何为celery的异步任务分配不同的worker?
- 内容介绍
- 文章标签
- 相关推荐
本文共计417个文字,预计阅读时间需要2分钟。
背景:之前所有的异步任务都由统一的worker来处理,存在一个问题,每次更新某个异步任务代码后,需要重启worker,否则会影响正在运行的任务。
问题:如果存在正在运行的任务,重启后会导致任务暂停,影响业务。
背景:
之前所有的异步任务都由统一的一个worker来消费,这样有个问题,每次更新某个异步任务代码后,需要重启worker,如果有在运行的异步任务,那面重启后就暂停了,影响业务。
所以想到把不通的任务分配到不通的worker,如果更新某个任务代码,重启对应worker即可,不会影响其他业务。
本文共计417个文字,预计阅读时间需要2分钟。
背景:之前所有的异步任务都由统一的worker来处理,存在一个问题,每次更新某个异步任务代码后,需要重启worker,否则会影响正在运行的任务。
问题:如果存在正在运行的任务,重启后会导致任务暂停,影响业务。
背景:
之前所有的异步任务都由统一的一个worker来消费,这样有个问题,每次更新某个异步任务代码后,需要重启worker,如果有在运行的异步任务,那面重启后就暂停了,影响业务。
所以想到把不通的任务分配到不通的worker,如果更新某个任务代码,重启对应worker即可,不会影响其他业务。

