Celery worker с sqs для потребления произвольных сообщений извне
Кто-нибудь знает, может ли celery worker получать и потреблять сообщения из sqs, где сообщения подталкиваются к sqs внешними приложениями?
Я не могу найти никаких ресурсов по этому вопросу. Буду признателен за другие подсказки.
Есть много ресурсов для подключения celery к sqs, а затем проталкивания задач в очередь и их обработки, но я хочу проталкивать произвольные сообщения (разного формата) в очередь и чтобы celery получал и обрабатывал их в задаче.
Большинство ресурсов в Интернете, связанных с отправкой и получением сообщений в sqs с помощью сельдерея.