Gerenciar tarefas CDC

Uma tarefa de Captura de Alteração de Dados (CDC) permite a sincronização de dados de uma instância Milvus de origem para uma instância Milvus de destino. Monitoriza os registos de operações da origem e replica as alterações de dados, tais como inserções, eliminações e operações de índice, para o destino em tempo real. Isso facilita a recuperação de desastres em tempo real ou o balanceamento de carga ativo-ativo entre as implantações do Milvus.

Este guia aborda a forma de gerir tarefas CDC, incluindo a criação, pausa, retoma, recuperação de detalhes, listagem e eliminação através de pedidos HTTP.

Criar uma tarefa

A criação de uma tarefa CDC permite que as operações de alteração de dados no Milvus de origem sejam sincronizadas com o Milvus de destino.

Para criar uma tarefa 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": "*"
      }
    ]
  }
}'

Substituir localhost pelo endereço IP do servidor Milvus de destino.

Parâmetros:

• milvus_connect_param: Parâmetros de conexão do Milvus de destino.

  • host: Nome do host ou endereço IP do servidor Milvus.

  • port: Número da porta em que o servidor Milvus escuta.

  • username: Nome de utilizador para se autenticar no servidor Milvus.

  • password: Palavra-passe para se autenticar no servidor Milvus.

  • enable_tls: Se deve ser utilizada a encriptação TLS/SSL para a ligação.

  • connect_timeout: Tempo de espera em segundos para estabelecer a ligação.

• collection_infos: Colecções a sincronizar. Atualmente, apenas é suportado um asterisco(*), uma vez que o Milvus-CDC sincroniza ao nível do cluster e não das colecções individuais.

Resposta esperada:

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

Listar tarefas

Para listar todas as tarefas CDC criadas:

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

Substitua localhost pelo endereço IP do servidor Milvus de destino.

Resposta esperada:

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

Pausar uma tarefa

Para pausar uma tarefa do CDC:

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

Substitua localhost pelo endereço IP do servidor Milvus de destino.

Parâmetros:

• task_id: ID da tarefa CDC a ser pausada.

Resposta esperada:

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

Retomar uma tarefa

Para retomar uma tarefa CDC em pausa:

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

Substituir localhost pelo endereço IP do servidor Milvus de destino.

Parâmetros:

• task_id: ID da tarefa CDC a ser retomada.

Resposta esperada:

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

Recuperar detalhes da tarefa

Para obter os detalhes de uma tarefa CDC específica:

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

Substituir localhost pelo endereço IP do servidor Milvus de destino.

Parâmetros:

• task_id: ID da tarefa do CDC a ser consultada.

Resposta esperada:

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

Eliminar uma tarefa

Para eliminar uma tarefa CDC:

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

Substituir localhost pelo endereço IP do servidor Milvus de destino.

Parâmetros:

• task_id: ID da tarefa CDC a ser excluída.

Resposta esperada:

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