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": {}
}