SmoothMQ es un reemplazo directo de SQS con una experiencia de desarrollador mucho más fluida. Tiene una interfaz de usuario funcional, observabilidad, seguimiento, programación de mensajes y limitación de velocidad. SmoothMQ le permite ejecutar una instancia SQS privada en cualquier nube.
¡Me encantaría recibir comentarios sobre la dirección de este proyecto! https://forms.gle/m5iMjcA5Xvp685Yw8
SmoothMQ se implementa como un binario único y puede ser utilizado por cualquier cliente SQS existente.
Esto ejecutará una interfaz de usuario en :3000
y un servidor compatible con SQS en :3001
.
$ go run . server
Esto funciona con cualquier cliente SQS en cualquier idioma.
import boto3
# Simply change the endpoint_url
sqs = boto3 . client ( "sqs" , ..., endpoint_url = "http://localhost:3001" )
sqs . send_message ( QueueUrl = "..." , MessageBody = "hello world" )
El apio funciona a la perfección:
app = Celery ( "tasks" , broker_url = "sqs://...@localhost:3001" )
La interfaz de usuario le permite administrar colas y buscar mensajes individuales.