У меня возникла проблема с уменьшением количества сервисов Fargate.Автоматическое масштабирование службы основано на возрасте сообщений SQS, поэтому оно уменьшается при отсутствии старых сообщений.
Проблема в том, что некоторые контейнеры, которые завершаются, все еще обрабатывают сообщения SQS в этой точке, что приводит к зависанию очереди SQS FIFO до тех пор, пока не пройдет visibilityTimeout для сообщения.
С thisredis thread Я предполагаю, что не было такого варианта год назад.Это все еще так, или, может быть, нашел хороший обходной путь?
Я использую Celery (Python) для приема сообщений SQS.Так как это длительные задачи (1-2 минуты), у меня довольно большой тайм-аут видимости, который создает большую задержку, если есть случай, когда работающий контейнер был отрезан.
Я не могу использовать лямбда-функции, потому что размер контейнера больше 1 ГБ
Любая помощь будет принята:)