У меня есть реализация Celery в моем приложении Python.Я использую брокера SQS.Сообщения, поступающие в SQS, поступают из другого приложения через API send_message () Boto3.Теперь моя путаница заключается в том, как заставить Celery извлечь сообщение из SQS для обработки.Будет некоторая задача, которая будет работать в Celery, которая должна правильно обрабатывать сообщения от SQS.Мое требование похоже на Сообщения SQS потребителя сельдерея .
Насколько я понимаю, Сельдерей опрашивает SQS до тех пор, пока туда не приходят сообщения.Кто-нибудь может мне помочь с этим?