Cambio della coda dei messaggi
Questa guida descrive come passare dalla coda dei messaggi (MQ) di un'istanza Milvus esistente da Woodpecker a un'altra coda dei messaggi, online e senza tempi di inattività.
Questa funzionalità è in fase di rilascio ed è soggetta a modifiche. Se desideri provarla o hai domande, contatta l'assistenza Milvus.
Prerequisiti
- La funzionalità "Cambio della coda dei messaggi" è disponibile in Milvus 3.0 e versioni successive. Aggiornare l'istanza di Milvus alla versione 3.0 o successiva prima di utilizzarla: la funzionalità non è disponibile nelle versioni precedenti.
- L’istanza è in esecuzione corretta.
Ambito
Questa guida tratta esclusivamente il passaggio da Woodpecker a un'altra coda di messaggi. Il passaggio diretto da Pulsar a Kafka non rientra nell'ambito di questa guida.
- Passaggio da RocksMQ a Woodpecker — Milvus Standalone (Docker Compose)
- Passaggio da Pulsar a Woodpecker — Cluster Milvus (Helm / Milvus Operator)
- Passaggio da Kafka a Woodpecker — Cluster Milvus (Helm / Milvus Operator)
Flusso di lavoro generale
- Assicurarsi che l’istanza di Milvus sia in esecuzione corretta.
- Verificare il tipo di MQ di origine e quello di destinazione.
- Inserire le impostazioni di accesso dell’MQ di destinazione nella configurazione di Milvus senza modificare il valore di "
mqType". - Avviare il passaggio chiamando l’API WAL alter su MixCoord.
- Monitorare i log per confermare che il passaggio sia stato completato.
Prima del passaggio, assicurarsi che l'MQ di destinazione non contenga argomenti con nomi identici a quelli utilizzati dall'istanza Milvus corrente. Ciò è particolarmente importante se l'MQ di destinazione è stato utilizzato da un'altra istanza Milvus, poiché nomi di argomenti in conflitto possono causare comportamenti imprevisti.
Matrice di supporto
| MQ di origine | MQ di destinazione | Distribuzione | Stato |
|---|---|---|---|
| RocksMQ | Woodpecker (locale/MinIO) | Autonomo (Docker Compose) | Supportato |
| Woodpecker (locale/MinIO) | RocksMQ | Autonomo (Docker Compose) | Supportato |
| Pulsar (integrato/esterno) | Woodpecker (MinIO) | Cluster (Helm / Operator) | Supportato |
| Woodpecker (MinIO) | Pulsar (esterno) | Cluster (Helm / Operator) | Supportato |
| Kafka (integrato/esterno) | Woodpecker (MinIO) | Cluster (Helm / Operator) | Supportato |
| Woodpecker (MinIO) | Kafka (esterno) | Cluster (Helm / Operator) | Supportato |
| Woodpecker MinIO | Woodpecker locale (o viceversa) | qualsiasi | Non supportato |
Evitare di passare ripetutamente da un tipo di MQ all'altro. Se è necessario effettuare il cambio, assicurarsi di ripulire i dati correlati prima di ogni passaggio: i dati residui potrebbero causare comportamenti imprevisti.
