【问题标题】:Simple queue with Celery and RabbitMQ使用 Celery 和 RabbitMQ 的简单队列
【发布时间】:2011-05-08 08:07:56
【问题描述】:

我正在尝试实现一个一次执行一项任务的简单队列。使用 Celery 将任务从主线程中卸载并在 Celery 配置中设置 concurrency=1 可以正常工作,但我可能希望为其他任务使用更多并发工作人员。

有没有办法告诉 Celery 或 RabbitMQ 不要为一个任务使用多个并发工作人员(强制并发 = 1 除外)?我在文档中找不到任何内容,但也许这些工具不是为线性队列设计的?

谢谢!

【问题讨论】:

    标签: rabbitmq celery


    【解决方案1】:

    我认为您需要为每种类型的任务设置一个单独的队列。创建从每个队列消费的单独工作人员,并发设置为 1。

    【讨论】:

    • 是的,我目前正在这样做(并发=1)。关于创建多个工人的好点,我想这是解决这个问题的最佳方法。谢谢!
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2019-12-27
    • 2013-07-25
    • 2014-06-13
    • 1970-01-01
    • 1970-01-01
    • 2022-06-10
    • 1970-01-01
    相关资源
    最近更新 更多