Gestionar tareas CDC

Una tarea de Captura de Cambio de Datos (CDC) permite la sincronización de datos desde una instancia Milvus de origen a una instancia Milvus de destino. Supervisa los registros de operaciones del origen y replica los cambios de datos, como inserciones, eliminaciones y operaciones de índice, en el destino en tiempo real. Esto facilita la recuperación ante desastres en tiempo real o el equilibrio de carga activo-activo entre despliegues Milvus.

Esta guía cubre cómo gestionar las tareas CDC, incluyendo la creación, pausa, reanudación, recuperación de detalles, listado y eliminación a través de peticiones HTTP.

Crear una tarea

La creación de una tarea CDC permite que las operaciones de cambio de datos en el Milvus de origen se sincronicen con el Milvus de destino.

Para crear una tarea CDC

curl -X POST http:_//localhost:8444/cdc \
-H "Content-Type: application/json" \
-d '{
  "request_type": "create",
  "request_data": {
    "milvus_connect_param": {
      "uri": "http://localhost:19530",
      "token":"root:Milvus",
      "connect_timeout": 10
    },
    "collection_infos": [
      {
        "name": "*"
      }
    ]
  }
}'

Sustituya localhost por la dirección IP del servidor Milvus de destino.

Parámetros:

• milvus_connect_param: Parámetros de conexión del Milvus de destino.

  • host: Nombre de host o dirección IP del servidor Milvus.

  • port: Número de puerto en el que escucha el servidor Milvus.

  • username: Nombre de usuario para autenticarse con el servidor Milvus.

  • password: Contraseña para autenticarse con el servidor Milvus.

  • enable_tls: Si desea utilizar el cifrado TLS/SSL para la conexión.

  • connect_timeout: Tiempo de espera en segundos para establecer la conexión.

• colección_infos: Colecciones a sincronizar. Actualmente, sólo se admite un asterisco(*), ya que Milvus-CDC sincroniza a nivel de clúster, no colecciones individuales.

Respuesta esperada:

{
  "code": 200,
  "data": {
    "task_id":"xxxx"
  }
}

Listar tareas

Para listar todas las tareas CDC creadas:

curl -X POST -H "Content-Type: application/json" -d '{
  "request_type": "list"
}' http://localhost:8444/cdc

Sustituya localhost por la dirección IP del servidor Milvus de destino.

Respuesta esperada:

{
  "code": 200,
  "data": {
    "tasks": [
      {
        "task_id": "xxxxx",
        "milvus_connect_param": {
          "uri":"http://localhost:19530",
          "connect_timeout": 10
        },
        "collection_infos": [
          {
            "name": "*"
          }
        ],
        "state": "Running"
      }
    ]
  }
}

Pausar una tarea

Para pausar una tarea CDC:

curl -X POST -H "Content-Type: application/json" -d '{
  "request_type":"pause",
  "request_data": {
    "task_id": "xxxx"
  }
}' http://localhost:8444/cdc

Sustituya localhost por la dirección IP del servidor Milvus de destino.

Parámetros:

• task_id: ID de la tarea CDC que se desea pausar.

Respuesta esperada:

{
  "code": 200,
  "data": {}
}

Reanudar una tarea

Para reanudar una tarea CDC en pausa:

curl -X POST -H "Content-Type: application/json" -d '{
  "request_type":"resume",
  "request_data": {
    "task_id": "xxxx"
  }
}' http://localhost:8444/cdc

Sustituya localhost por la dirección IP del servidor Milvus de destino.

Parámetros:

• task_id: ID de la tarea CDC que se va a reanudar.

Respuesta esperada:

{
  "code": 200,
  "data": {}
}

Recuperar detalles de la tarea

Para recuperar los detalles de una tarea CDC específica:

curl -X POST -H "Content-Type: application/json" -d '{
  "request_type":"get",
  "request_data": {
    "task_id": "xxxx"
  }
}' http://localhost:8444/cdc

Sustituya localhost por la dirección IP del servidor Milvus de destino.

Parámetros:

• task_id: ID de la tarea CDC a consultar.

Respuesta esperada:

{
  "code": 200,
  "data": {
    "Task": {
      "collection_infos": [
        {
          "name": "*"
        }
      ],
      "milvus_connect_param": {
        "connect_timeout": 10,
        "uri":"http://localhost:19530"
      },
      "state": "Running",
      "task_id": "xxxx"
    }
  }
}

Eliminar una tarea

Para eliminar una tarea CDC:

curl -X POST -H "Content-Type: application/json" -d '{
  "request_type":"delete",
  "request_data": {
    "task_id": "30d1e325df604ebb99e14c2a335a1421"
  }
}' http://localhost:8444/cdc

Sustituya localhost por la dirección IP del servidor Milvus de destino.

Parámetros:

• task_id: ID de la tarea CDC que desea eliminar.

Respuesta esperada:

{
  "code": 200,
  "data": {}
}