Я использую докеризованный сельдерей 4.2 с Redis в качестве посредника и бэкэнда, обрабатывая данные из потока Twitter.
Иногда возникают прерывания, из-за которых задачи накапливаются в очереди. Даже при достаточной вычислительной мощности (памяти / ЦП) Celery, по-видимому, не может сократить это отставание с течением времени после исправления прерываний и перезапуска службы.
Есть ли варианты изменить это поведение в Celery? Является ли вероятная причина такого поведения узким местом в IO (например, чтение / запись в Redis?). Рад за любой ввод!