问题描述
我已经设置:
姜戈:3.1.3 Django_celery_result: 1.1.0 芹菜:4.4.0 amqp:2.5.2 芹菜花:最新 CELERY_RESULT_BACKEND= Django python db
我已经开始了 10 个不同的芹菜工人。
当提交任务时,芹菜工人会收到它。其中一名工人拿起它并开始处理它,其他工人也收到/接受它,这导致芹菜花的进程数增加。所有这些工作人员都在不断重试,从而导致大量的进程数。对于 3 个任务,进程数为:40+。
当一个worker已经在执行任务时,我们如何确保其他worker不会重试。
这适用于从 manage.py celery worker 执行的 celery 3.x 版本。但是芹菜版本的问题:4.4.0。
如果需要更多详细信息,请告诉我。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)