В настоящее время я работаю над приложением распределенной обработки, написанным на Python, который использует Amazon SQS.
Какой самый Pythonic способ правильно создать и разместить потребителя очереди в Python, который:
- является надежным: если есть проблема и потребитель завершает работу, должен быть выполнен некоторый реактивный код и обработка должна перезапуститься
- повторно использует код: должно быть несколько пакетов, чтобы помочь с этим, и было бы здорово не изобретать колесо :))
Заранее спасибо!