Verwalten von CDC-Aufgaben

Eine CDC-Aufgabe (Capture Data Change) ermöglicht die Synchronisierung von Daten von einer Milvus-Quellinstanz zu einer Milvus-Zielinstanz. Sie überwacht die Betriebsprotokolle der Quelle und repliziert Datenänderungen wie Einfügungen, Löschungen und Indexoperationen in Echtzeit an das Ziel. Dies erleichtert die Disaster Recovery in Echtzeit oder den aktiv-aktiven Lastausgleich zwischen Milvus-Bereitstellungen.

Dieses Handbuch beschreibt die Verwaltung von CDC-Tasks, einschließlich Erstellung, Anhalten, Fortsetzen, Abrufen von Details, Auflisten und Löschen über HTTP-Anfragen.

Erstellen einer Aufgabe

Durch das Erstellen einer CDC-Aufgabe können Datenänderungsvorgänge im Quell-Milvus mit dem Ziel-Milvus synchronisiert werden.

So erstellen Sie eine CDC-Aufgabe:

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": "*"
      }
    ]
  }
}'

Ersetzen Sie localhost durch die IP-Adresse des Milvus-Zielservers.

Parameter:

• milvus_connect_param: Verbindungsparameter des Ziel-Milvus.

  • host: Hostname oder IP-Adresse des Milvus-Servers.

  • port: Portnummer, an der der Milvus-Server lauscht.

  • username: Benutzername für die Authentifizierung beim Milvus-Server.

  • password: Passwort für die Authentifizierung beim Milvus-Server.

  • enable_tls: Ob TLS/SSL-Verschlüsselung für die Verbindung verwendet werden soll.

  • connect_timeout: Timeout-Zeit in Sekunden für den Aufbau der Verbindung.

• sammlungs_infos: Zu synchronisierende Sammlungen. Derzeit wird nur ein Sternchen(*) unterstützt, da Milvus-CDC auf Clusterebene synchronisiert, nicht auf Ebene einzelner Sammlungen.

Erwartete Antwort:

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

Aufgaben auflisten

Um alle erstellten CDC-Aufgaben aufzulisten:

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

Ersetzen Sie localhost durch die IP-Adresse des Milvus-Zielservers.

Erwartete Antwort:

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

Anhalten einer Aufgabe

Um eine CDC-Aufgabe zu pausieren:

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

Ersetzen Sie localhost durch die IP-Adresse des Ziel-Milvus-Servers.

Parameter:

• task_id: ID der CDC-Aufgabe, die unterbrochen werden soll.

Erwartete Antwort:

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

Wiederaufnahme einer Aufgabe

Um eine angehaltene CDC-Aufgabe fortzusetzen:

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

Ersetzen Sie localhost durch die IP-Adresse des Milvus-Zielservers.

Parameter:

• task_id: ID der fortzusetzenden CDC-Aufgabe.

Erwartete Antwort:

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

Abrufen von Aufgabendetails

So rufen Sie die Details einer bestimmten CDC-Aufgabe ab:

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

Ersetzen Sie localhost durch die IP-Adresse des Milvus-Zielservers.

Parameter:

• task_id: ID der abzufragenden CDC-Aufgabe.

Erwartete Antwort:

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

Löschen einer Aufgabe

Um eine CDC-Aufgabe zu löschen:

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

Ersetzen Sie localhost durch die IP-Adresse des Milvus-Zielservers.

Parameter:

• task_id: ID der zu löschenden CDC-Aufgabe.

Erwartete Antwort:

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