python - celery+rabbitmq异步任务，队列消息一直增加

问题描述

celery 配合 rabbitmq 进行异步任务时，发现 rabbitmq 里消息的数量是一直增加的，但是这些消息其实也已经被 task 处理掉.

查看 rabbimtq 自带的后台，发现 Queued messages 里面，ready 和 total 的数量都达到了 5000 多，unacknowledged 的值为 0。不过实际在工作的时候，unacknowledged 的值会变化的，但是最后会变成 0 celery 的配置也没有特殊的地方，就只设置了如下的内容 CELERY_IMPORTS = (’testtasks’,) BROKER_URL = ’amqp://guest:guest@localhost:5672//’ CELERY_RESULT_BACKEND = ’amqp://’

然后看系统的资源，erl 的进程内存比较大，大概暂用了 300 多 M 是我这边 celery 的配置有问题么？

问题解答

已经解决了，升级了 rabbitmq 到 3.3 以上版本就可以了。 之前用的是 rabbitmq 3.1 的版本，然后 celery 是 3.1 的版本

真正解决问题的方法是，在task里增加一个ignore_result=True属性，如下@app.task(ignore_result=True)