SmoothMQ は、よりスムーズな開発者エクスペリエンスを備えた SQS のドロップイン代替品です。機能的な UI、可観測性、トレース、メッセージ スケジューリング、およびレート制限を備えています。 SmoothMQ を使用すると、任意のクラウド上でプライベート SQS インスタンスを実行できます。
このプロジェクトの方向性についてのフィードバックをお待ちしています。 https://forms.gle/m5iMjcA5Xvp685Yw8
SmoothMQ は単一の go バイナリとしてデプロイされ、既存の SQS クライアントで使用できます。
これにより、 :3000
で UI が実行され、 :3001
で SQS 互換サーバーが実行されます。
$ 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" )
UI を使用すると、キューを管理し、個々のメッセージを検索できます。