芹菜 + RabbitMQ,一些 AMQP 临时队列不会过期
我有一个 celery +rabbitmq 设置和一个繁忙的 django 站点,在 celery 设置中我有这个配置:
CELERY_RESULT_BACKEND = "amqp"
CELERY_AMQP_TASK_RESULT_EXPIRES = 5
我正在使用“watch”命令监视队列,我观察到的是临时队列在几秒钟后被删除,有一些队列(相同的guid)被删除不会被删除,并且无论使用了多少工作人员,列表都会缓慢增长。
django站点确实每秒生成大约60个任务,接受各种信息并使用任务来消化信息。整个设置运行在具有充足 RAM 的 16 核 cpu 服务器上。这仍然是由性能问题或芹菜错误引起的吗?
干杯
詹姆斯
I have a celery + rabbitmq setup with a busy django site, in the celery setting I have this config:
CELERY_RESULT_BACKEND = "amqp"
CELERY_AMQP_TASK_RESULT_EXPIRES = 5
I am monitoring the queues with the "watch" command, what I have observed is whilst most of the temporary queues get deleled after a few seconds, there are some queues (same guid) did not get deleted, and the list grows slowly, regardless how many workers used.
The django site does generate about 60 tasks per second, accepts various information and use the tasks to digest information. The whole setup runs on a 16 core cpu server with plenty of RAM. Would this still caused by performance issue or a celery bug?
Cheers
James
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论