shared-sqs тестирование

Multi-tenant очередь, совместимая с AWS SQS API. Каждый тенант получает изолированное пространство очередей.

Подключение

Endpoint

https://sqs.containerk8s.dev.nubes.ru

Протокол

AWS SQS Query / JSON, подпись AWS Signature V4

Регион

us-east-1

Аутентификация

Access Key / Secret Key тенанта (выдаются в консоли /ui)

Консоль

/ui — веб-интерфейс (вход по токену Nubes)

Health

GET /health ● ok

Метрики

GET /metrics — Prometheus

Persistence

Managed Redis (realm iot-naeel)

Команды SQS API

Все команды отправляются на корень POST https://sqs.containerk8s.dev.nubes.ru/ с параметром Action.

Action	Описание
`CreateQueue`	Создать очередь
`ListQueues`	Список очередей тенанта
`GetQueueUrl`	URL очереди по имени
`GetQueueAttributes`	Атрибуты очереди
`SetQueueAttributes`	Изменить атрибуты очереди
`SendMessage`	Отправить сообщение
`SendMessageBatch`	Отправить до 10 сообщений разом
`ReceiveMessage`	Получить сообщения (long polling до 20с)
`DeleteMessage`	Удалить сообщение
`DeleteMessageBatch`	Удалить до 10 сообщений разом
`ChangeMessageVisibility`	Изменить таймаут видимости сообщения
`ChangeMessageVisibilityBatch`	Пакетно изменить таймаут видимости
`PurgeQueue`	Очистить очередь
`DeleteQueue`	Удалить очередь
`TagQueue`	Назначить теги очереди
`UntagQueue`	Снять теги с очереди
`ListQueueTags`	Список тегов очереди

Примеры (AWS CLI)

Ключи тенанта

export AWS_ACCESS_KEY_ID=<Access Key из /ui>
export AWS_SECRET_ACCESS_KEY=<Secret Key из /ui>

Создать очередь

aws sqs create-queue --queue-name demo \
  --endpoint-url https://sqs.containerk8s.dev.nubes.ru \
  --region us-east-1

Отправить сообщение (QueueUrl — из ответа create-queue)

aws sqs send-message --queue-url <QueueUrl> \
  --message-body "hello nubes" \
  --endpoint-url https://sqs.containerk8s.dev.nubes.ru \
  --region us-east-1

Получить и удалить сообщение

aws sqs receive-message --queue-url <QueueUrl> \
  --endpoint-url https://sqs.containerk8s.dev.nubes.ru --region us-east-1

aws sqs delete-message --queue-url <QueueUrl> \
  --receipt-handle <ReceiptHandle> \
  --endpoint-url https://sqs.containerk8s.dev.nubes.ru --region us-east-1