SmoothMQ — это замена SQS, обеспечивающая гораздо более удобный интерфейс разработки. Он имеет функциональный пользовательский интерфейс, возможность наблюдения, отслеживания, планирования сообщений и ограничения скорости. SmoothMQ позволяет запускать частный экземпляр SQS в любом облаке.
Буду рад вашим отзывам о направлении этого проекта! https://forms.gle/m5iMjcA5Xvp685Yw8
SmoothMQ развертывается как единый двоичный файл и может использоваться любым существующим клиентом SQS.
Это запустит пользовательский интерфейс на :3000 и SQS-совместимый сервер на :3001 .
$ go run . server
Это работает с любым клиентом SQS на любом языке.
import boto3
# Simply change the endpoint_url
sqs = boto3 . client ( "sqs" , ..., endpoint_url = "http://localhost:3001" )
sqs . send_message ( QueueUrl = "..." , MessageBody = "hello world" )Сельдерей работает без проблем:
app = Celery ( "tasks" , broker_url = "sqs://...@localhost:3001" )Пользовательский интерфейс позволяет управлять очередями и искать отдельные сообщения.
