У меня есть автоскал в AWS, который в основном делает:
- Запустить процесс Python
script.py
- Этот скрипт получает сообщения из очереди sqs для обработки
Мой автоматический вызов настроен на запуск / завершение экземпляра на основе количества доступных сообщений в очереди. Но иногда, когда я что-то обрабатываю на машинах и # моих сообщениях, мой автомасштабирующий триггер завершает работу экземпляров, поэтому я заканчиваю потерять сообщение в середине обработки.
Я начал пытаться обрабатывать сигналы, но, похоже, не работает.
Моя главная цель:
- Если я знаю, что мой экземпляр будет скоро завершен, я буду ждать завершения моих текущих процессов (я не получу никакого нового сообщения), а затем я посылаю сигнал "ОК" в AWS, чтобы закрыть экземпляр.
Есть ли способ архивировать это? Я не использую балансировку нагрузки, потому что я вручную получаю сообщения из очереди.