Changement de file d'attente de messages
Ce guide décrit comment basculer la file d'attente de messages (MQ) d'un déploiement Milvus existant de Woodpecker vers une autre file d'attente de messages, en ligne et sans interruption de service.
Cette fonctionnalité n'est pas encore disponible et est susceptible d'être modifiée. Veuillez contacter le support Milvus si vous souhaitez la tester ou si vous avez des questions.
Prérequis
- La fonctionnalité de changement de file d’attente de messages est disponible dans Milvus 3.0 et les versions ultérieures. Mettez à niveau votre instance Milvus vers la version 3.0 ou une version ultérieure avant de l’utiliser — cette fonctionnalité n’est pas disponible dans les versions antérieures.
- L’instance fonctionne correctement.
Portée
Ce guide traite uniquement de la bascule entre Woodpecker et une autre file d’attente de messages. La bascule directe entre Pulsar et Kafka n’est pas couverte.
- Basculer entre RocksMQ et Woodpecker — Milvus autonome (Docker Compose)
- Basculer entre Pulsar et Woodpecker — Cluster Milvus (Helm / Milvus Operator)
- Basculer entre Kafka et Woodpecker — Cluster Milvus (Helm / Milvus Operator)
Déroulement général
- Assurez-vous que l’instance Milvus fonctionne correctement.
- Vérifiez le type de MQ source et le type de MQ cible.
- Intégrez les paramètres d’accès du MQ cible dans la configuration de Milvus sans modifier la valeur «
mqType». - Déclenchez la bascule en appelant l’API WAL alter sur MixCoord.
- Surveillez les journaux pour vérifier que la bascule s’est bien effectuée.
Avant la bascule, assurez-vous que le MQ cible ne contient pas de sujets portant les mêmes noms que ceux utilisés par l’instance Milvus actuelle. Ceci est particulièrement important si le MQ cible a déjà été utilisé par une autre instance Milvus, car des noms de sujets en conflit peuvent entraîner un comportement inattendu.
Matrice de prise en charge
| MQ source | MQ cible | Déploiement | Statut |
|---|---|---|---|
| RocksMQ | Woodpecker (local/MinIO) | Autonome (Docker Compose) | Prise en charge |
| Woodpecker (local/MinIO) | RocksMQ | Autonome (Docker Compose) | Pris en charge |
| Pulsar (intégré/externe) | Woodpecker (MinIO) | Cluster (Helm / Operator) | Pris en charge |
| Woodpecker (MinIO) | Pulsar (externe) | Cluster (Helm / Operator) | Pris en charge |
| Kafka (intégré/externe) | Woodpecker (MinIO) | Cluster (Helm / Operator) | Pris en charge |
| Woodpecker (MinIO) | Kafka (externe) | Cluster (Helm / Operator) | Pris en charge |
| Woodpecker MinIO | Woodpecker local (ou inversement) | n'importe lequel | Non pris en charge |
Évitez de changer de type de MQ à plusieurs reprises. Si vous devez tout de même effectuer un changement, veillez à nettoyer les données associées avant chaque changement — les données résiduelles peuvent entraîner un comportement inattendu.
