RabbitMQ 中的 celeryev 队列变得非常大 [英] celeryev Queue in RabbitMQ Becomes Very Large

问题描述

我在rabbitmq 上使用芹菜.我一直在向队列发送数千条消息，它们正在成功处理，一切正常.然而，几个rabbitmq队列中的消息数量正在增长相当大(队列中有数十万个项目).队列被命名为 celeryev.[...](见下面的截图).这是适当的行为吗?这些队列的目的是什么，不应该定期清除它们吗?有没有办法更频繁地清除它们，我认为它们占用了相当多的磁盘空间.

I am using celery on rabbitmq. I have been sending thousands of messages to the queue and they are being processed successfully and everything is working just fine. However, the number of messages in several rabbitmq queues are growing quite large (hundreds of thousands of items in the queue). The queues are named celeryev.[...] (see screenshot below). Is this appropriate behavior? What is the purpose of these queues and shouldn't they be regularly purged? Is there a way to purge them more regularly, I think they are taking up quite a bit of disk space.

推荐答案

您可以使用 CELERY_EVENT_QUEUE_TTL celery 选项(仅适用于 amqp)，它将设置消息的过期时间，之后它将从队列中删除.

You can use the CELERY_EVENT_QUEUE_TTL celery option (only working with amqp), that will set the message expiry time, after which it will be deleted from the queue.

这篇关于RabbitMQ 中的 celeryev 队列变得非常大的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！