#rabbitmq #keda
Вопрос:
Я использую Keda, автоматический масштабатор на основе событий kubernetes, используя RabbitMQ.
У меня есть объект scaledjob, настроенный на одновременное выполнение максимум 30 заданий при просмотре myQueue.
pollingInterval: 10
successfulJobsHistoryLimit: 0
failedJobsHistoryLimit: 0
maxReplicaCount: 30
triggers:
- type: rabbitmq
metadata:
protocol: amqp
queueName: myQueue
mode: QueueLength
value: "1"
authenticationRef:
name: keda-trigger-auth-rabbitmq-conn
Когда в моем запросе около 300 сообщений, проблемы нет. У меня есть 30 запущенных заданий, пока я не достигну 0 сообщений.
Но проблема в том, что когда у меня в очереди 2 сообщения : 1 «Готово» и 1 «Распаковано», Keda не создаст дополнительную масштабируемую работу. Он ожидает обработки распакованных сообщений…
Как заставить его использовать как можно больше ресурсов