Cambiar el tipo de MQ para Milvus Cluster

Este tema describe cómo cambiar el tipo de cola de mensajes (MQ) para un despliegue de clúster Milvus existente. Milvus admite el cambio de MQ en línea entre Pulsar, Kafka y Woodpecker sin tiempo de inactividad.

Requisitos previos

• Una instancia de clúster Milvus en ejecución instalada a través de Milvus Operator o Helm.
• La instancia de Milvus se ha actualizado a la última versión compatible con esta función Switch MQ.

Cambiar de Pulsar/Kafka a Woodpecker (MinIO)

Siga estos pasos para cambiar el tipo de MQ de Pulsar o Kafka a Woodpecker con almacenamiento MinIO.

Paso 1: Compruebe que la instancia de Milvus se está ejecutando

Antes de cambiar, asegúrese de que su instancia de clúster Milvus está funcionando correctamente. Puede comprobarlo creando una colección de prueba, insertando datos y ejecutando una consulta.

Paso 2: (Opcional) Verificar la configuración de Woodpecker

La configuración predeterminada de Milvus ya establece el tipo de almacenamiento de Woodpecker en MinIO, por lo que no se requiere ninguna configuración adicional en la mayoría de los casos.

Sin embargo, si ha personalizado previamente la configuración de Woodpecker, debe asegurarse de que woodpecker.storage.type está establecido en minio. Actualice la configuración de Milvus sin cambiar el valor de mqType:

woodpecker:
  storage:
    type: minio

• Para Helm, consulte Configurar Milvus con cartas Helm para obtener instrucciones sobre cómo actualizar la configuración.
• Para Milvus Operator, consulte Configurar Milvus con Milvus Operator para obtener instrucciones sobre cómo actualizar la configuración.

Paso 3: Ejecutar el cambio MQ

Ejecute el siguiente comando para activar el cambio a Woodpecker:

curl -X POST http://<mixcoord_addr>:9091/management/wal/alter \
  -H "Content-Type: application/json" \
  -d '{"target_wal_name": "woodpecker"}'

Paso 4: Verifique que el cambio se ha completado

El proceso de cambio se completa automáticamente. Controle los registros de Milvus en busca de los siguientes mensajes clave para confirmar que el cambio ha finalizado:

WAL switch success: <MQ1> switch to <MQ2> finish, re-opening required
AlterWAL broadcast message acknowledged by all vchannels
successfully updated mq.type configuration in etcd

Cambio de Woodpecker (MinIO) a Pulsar o Kafka

Siga estos pasos para cambiar el tipo de MQ de Woodpecker a Pulsar o Kafka.

Paso 1: Compruebe que la instancia de Milvus se está ejecutando

Antes de cambiar, asegúrese de que su instancia de clúster Milvus está funcionando correctamente.

Paso 2: Configurar el MQ de destino

Antes de activar el cambio, debe asegurarse de que el servicio MQ de destino (Pulsar o Kafka) está disponible y de que su configuración de acceso está integrada en la configuración de Milvus.

Opción A: Pulsar/Kafka interno (incluido con Helm)

Si está utilizando el paquete Pulsar o Kafka desplegado por Helm, actualice su versión de Helm para habilitar el servicio MQ de destino y deshabilitar Woodpecker. La bandera streaming.enabled=true es necesaria para habilitar el Nodo de Streaming, que es un prerrequisito para la característica Switch MQ. Por ejemplo, para cambiar a Pulsar:

helm upgrade -i my-release milvus/milvus \
  --set pulsarv3.enabled=true \
  --set woodpecker.enabled=false \
  --set streaming.enabled=true \
  -f values.yaml

Después de la actualización, compruebe que la configuración de acceso MQ de destino se ha convertido en la configuración de Milvus. Por ejemplo, para Pulsar:

pulsar:
  address: <pulsar-proxy-address>
  port: 6650

Opción B: Pulsar/Kafka interno (gestionado por Milvus Operator)

Si está utilizando Milvus Operator, actualice el recurso personalizado Milvus para incluir la configuración de acceso MQ de destino. Consulte Configurar Milvus con Milvus Operator para obtener detalles sobre la actualización de la configuración de Milvus.

Opción C: Pulsar/Kafka externo

Si está utilizando un servicio Pulsar o Kafka externo, no necesita cambiar mqType. Simplemente añada la configuración de acceso MQ externo a su values.yaml y reinicie la instancia de Milvus para renderizar la configuración.

Paso 3: Ejecutar el conmutador MQ

Ejecute el siguiente comando para activar el cambio a Pulsar (sustituya pulsar por kafka si cambia a Kafka):

curl -X POST http://<mixcoord_addr>:9091/management/wal/alter \
  -H "Content-Type: application/json" \
  -d '{"target_wal_name": "pulsar"}'

Paso 4: Compruebe que el cambio se ha completado

El proceso de cambio se completa automáticamente. Supervise los registros de Milvus en busca de los siguientes mensajes clave para confirmar que el cambio ha finalizado:

WAL switch success: <MQ1> switch to <MQ2> finish, re-opening required
AlterWAL broadcast message acknowledged by all vchannels
successfully updated mq.type configuration in etcd