Как прослушать сообщения AWS SQS при запуске приложения Flask?

Question

У меня есть приложение Flask, которое должно выполнить некоторые операции с сообщениями, которые оно получает от AWS SQS. Я имитировал SQS, используя Docker контейнер и boto3 библиотеку.

Но я не могу понять, как начать получать сообщения, как только запускается Flask app.

Как лучше прослушивать сообщения из очереди SQS? Я попытался создать функцию просмотра, которая начинает прослушивать сообщения SQS при достижении определенной конечной точки. Но я не могу достичь конечной точки после запуска приложения фляги.

Пожалуйста, дайте мне знать, если есть какой-либо лучший подход для решения этой проблемы.

Answer 1

Один из подходов к этому (тот, который я предпочитаю) - запустить отдельный процесс, который прослушивает SQS и пересылает сообщения в приложение Flask через HTTP.

Другой подход заключается в запуске приложения Flask ислушатель SQS как отдельные потоки внутри одного процесса. Это выполнимо, но гораздо сложнее.