- python-celery+rabbitmq异步任务,队列消息一直增加
-
聚码交流
-
0
0

- yhuxAvNbtxUM
0000-00-00 00:00:00
- 回帖
celery配合rabbitmq进行异步任务时,发现rabbitmq里消息的数量是一直增加的,但是这些消息其实也已经被task处理掉.查看rabbimtq自带的后台,发现Queuedmessages里面,ready和total的数量都达到了5000多,unacknowledged的值为0。不过实际在工作的时候,unacknowledged的值会变化的,但是最后会变成0celery的配置也没有特殊的地方,就只设置了如下的内容CELERY_IMPORTS=('testtasks',)BROKER_URL='amqp://guest:guest@localhost:5672//'CELERY_RESULT_BACKEND='amqp://'然后看系统的资源,erl的进程内存比较大,大概暂用了300多M是我这边celery的配置有问题么?