Celery 4.4.0、django 和flower:Celery worker 接收到已经被其他 worker 执行的任务它没有执行但添加到处理中

问题描述

我已经设置:

姜戈: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 (将#修改为@)