SmoothMQ est un remplacement immédiat de SQS avec une expérience de développement beaucoup plus fluide. Il dispose d'une interface utilisateur fonctionnelle, d'observabilité, de traçage, de planification de messages et de limitation de débit. SmoothMQ vous permet d'exécuter une instance SQS privée sur n'importe quel cloud.
J'aimerais avoir vos retours sur l'orientation de ce projet ! https://forms.gle/m5iMjcA5Xvp685Yw8
SmoothMQ se déploie en tant que binaire unique et peut être utilisé par n'importe quel client SQS existant.
Cela exécutera une interface utilisateur sur :3000
et un serveur compatible SQS sur :3001
.
$ go run . server
Cela fonctionne avec n'importe quel client SQS dans n'importe quelle langue.
import boto3
# Simply change the endpoint_url
sqs = boto3 . client ( "sqs" , ..., endpoint_url = "http://localhost:3001" )
sqs . send_message ( QueueUrl = "..." , MessageBody = "hello world" )
Le céleri fonctionne parfaitement :
app = Celery ( "tasks" , broker_url = "sqs://...@localhost:3001" )
L'interface utilisateur vous permet de gérer les files d'attente et de rechercher des messages individuels.