In Kubernetes, wie kann ich basierend auf der Größe einer Warteschlange automatisch skalieren?

Question

Angenommen, ich habe eine RabbitMQ-Instanz und eine Gruppe von Pods, die Nachrichten von RabbitMQ auswählen und verarbeiten. Wie führe ich Kubernetes dazu, die Anzahl der Pods zu erhöhen, wenn die Größe der Warteschlange zunimmt?

(Ich erwähne RabbitMQ, aber das ist nur ein Beispiel. Ihre Lieblings-Message Queue-Software oder Load-Balancer Auswahl, wenn Sie möchten.)

Answer 1

Sie können eine sehr einfache Steuerung schreiben, die die Größe der Warteschlange für Ihre speziellen Uhren Anwendung und ändert dann die Anzahl der gewünschten Replikate Ihres Replikations-Controllers/Replikat-Sets/Deployment.

Die integrierte horizontale Pod-Auto-Skalierung erhält bald Unterstützung für benutzerdefinierte Metriken, aber bis dahin ist es ziemlich einfach, selbst zu programmieren.

Answer 2

Die Top-Level-Lösung ist ganz einfach:

einen separaten Behälter aufstellen, die Warteschlange verbunden ist, und verwendet die Kubernetes API, um die Einsätze zu skalieren.

Es gibt einige Lösungen für dieses Problem bereits, aber sie sehen aber nicht, wie sie aktiv gepflegt und Produktion bereit sind, aber helfen könnten:

• https://github.com/mbogus/kube-amqp-autoscale
• https://github.com/mbogus/docker-kube-amqp-autoscale
• https://github.com/onfido/k8s-rabbit-pod-autoscaler