芹菜停止加工

Question

在 rabbitmq 中大约有 90 万条消息的情况下，芹菜工人停止了处理任务。在杀死芹菜并再次运行它时，加工恢复了。兔子从未失去记忆。任何日志或状态中都没有可疑内容，但以下情况除外：

**

警告 ** 失忆症过载：{dump_log，write_threshold}

从/var/log/rabbitmq/rabbit.log.类似的症状之前也存在，大约有1.6m消息排队。

更多信息：

• 芹菜并发：4
• 安装内存：4GB
• 交换空间 8GB
• disk_free_limit(兔子(：8GB
• vm_memory_high_watermark： 2
• vm_memory_high_watermark_paging_ratio： 0.75

如何诊断工人停车的实际原因，如何防止其再次发生。

谢谢。

Answer 1

可能提交

/使用队列中的消息太快？

如果您不需要消息持久，并且只能将它们存储在内存中，它将显着提高 RabbitMQ 的性能。

http://docs.celeryproject.org/en/latest/userguide/optimizing.html#using-transient-queues