celery 取 rabbitmq 内消息时偶现 messages_unacknowledged
fxxkgw · 2016-05-27 12:14:27 +08:00 · 4055 次点击这是一个创建于 2890 天前的主题，其中的信息可能已经有所发展或是发生改变。
队列的压力很小， celery 的 worker 起了大概 30 个，实际使用时发现偶现 messages_unacknowledged ，而且出问题的消息全是这一种问题
方案用的是 django 架构，通过 djcelery 插件连接 celery 和 rabbitmq
有什么好的处理办法么？
#python manage.py celery inspect stats
"total": {
"back_management.tasks.app_entry": 1131,
#rabbitmqctl list_queues messages messages_unacknowledged
16 16
堆积了 16 个消息，全都是超时的。
所有的程序都在一台服务器，任务进程也一直存在，不理解这个unack是如何造成的。
方案用的是 django 架构，通过 djcelery 插件连接 celery 和 rabbitmq
有什么好的处理办法么？
#python manage.py celery inspect stats
"total": {
"back_management.tasks.app_entry": 1131,
#rabbitmqctl list_queues messages messages_unacknowledged
16 16
堆积了 16 个消息，全都是超时的。
所有的程序都在一台服务器，任务进程也一直存在，不理解这个unack是如何造成的。
 |
1
VicYu 2016-05-27 13:23:33 +08:00
pika 的链接断了
|
Select Language