python - django celery - 多处理

Question

我正在使用 Django celery 来满足我的项目需求。如何对使用单个工作人员的两个队列进行多处理？我不希望一个队列等待另一个队列中的任务完成。

请指教

Answer 1

为什么不直接使用concurrenc y of >1？像这样：

celeryd -c 5

这应该启动一个有 5 个进程的工作人员，这些进程可以并行处理事情。