Горизонтальное масштабирование на основе количества событий, опубликованных на сервере NATS

Question

Я новичок как в Nats, так и в Kubernetes. Я создал консольное приложение python, которое подписано на nats-server и заключено в pod с объектом Deployment в Kubernetes. Теперь я хочу автоматически масштабировать модуль в зависимости от количества событий, опубликованных в nats-server для этого клиента python. Как я могу это сделать? кто-нибудь может дать мне идею?

Заранее спасибо.

Answer 1

Вы можете использовать автомасштабирование Keda. Keda - это проект CNCF, который может масштабировать ваши развертывания на основе различных служб потоковой передачи / очереди, для NATS реализован автомасштабирование: https://keda.sh/docs/1.5/scalers/nats-streaming/

Я использовал автомасштабирование Keda с rabbitmq и работает как шарм.