python - 减少芹菜队列中的积压

Question

我正在使用带有 Redis 作为代理和后端的 dockerized celery 4.2，处理来自 Twitter 流的数据。

有时会有中断导致任务堆积在队列中。即使有足够的处理能力（内存/CPU），在修复中断并重新启动服务后，celery 似乎也无法随着时间的推移减少这种积压。

是否有任何选项可以改变 Celery 中的这种行为？这种行为的可能原因是 IO 中的瓶颈（例如读/写到 Redis？）。对任何类型的输入都很高兴！