1
Aether 2019-11-06 15:49:00 +08:00
你就说一句”业务需求“?你的整个问题最应该详细说明逻辑的,不就是这几个字么……
|
3
locoz 2019-11-06 16:00:55 +08:00
前面业务相关的描述太简单了点...
执行死循环任务是指?消费者消费这个任务的时候会一直处于处理状态而不 ack ?还是说是同一个任务做完一次之后又扔回队列?这两种情况都是:如果生产者一直在发同样的任务,就会导致队列被塞爆。但如果生产者只发一次任务的话,不会怎么样,后者会更好监控状态一些而已。 |
4
littlespider89 2019-11-06 16:02:47 +08:00
上 kafka
|
5
GoLand 2019-11-06 16:04:02 +08:00
开个独立进程去拉队列里的消息,拉到消息就直接放进 celery 消费。不用担心进程不稳定,消费速度也没有瓶颈了。celery 不是你这么用的。
|