SmoothMQ é um substituto imediato para SQS com uma experiência de desenvolvedor muito mais suave. Possui uma UI funcional, observabilidade, rastreamento, agendamento de mensagens e limitação de taxa. SmoothMQ permite executar uma instância privada do SQS em qualquer nuvem.
Eu adoraria seu feedback sobre a direção deste projeto! https://forms.gle/m5iMjcA5Xvp685Yw8
SmoothMQ é implantado como um binário único e pode ser usado por qualquer cliente SQS existente.
Isso executará uma UI em :3000
e um servidor compatível com SQS em :3001
.
$ go run . server
Isso funciona com qualquer cliente SQS em qualquer idioma.
import boto3
# Simply change the endpoint_url
sqs = boto3 . client ( "sqs" , ..., endpoint_url = "http://localhost:3001" )
sqs . send_message ( QueueUrl = "..." , MessageBody = "hello world" )
O aipo funciona perfeitamente:
app = Celery ( "tasks" , broker_url = "sqs://...@localhost:3001" )
A IU permite gerenciar filas e pesquisar mensagens individuais.