Mengelola Tugas CDC

Tugas Capture Data Change (CDC) memungkinkan sinkronisasi data dari instance Milvus sumber ke instance Milvus target. Tugas ini memonitor log operasi dari sumber dan mereplikasi perubahan data seperti penyisipan, penghapusan, dan operasi indeks ke target secara real-time. Hal ini memfasilitasi pemulihan bencana secara real-time atau penyeimbangan beban aktif-aktif di antara penerapan Milvus.

Panduan ini mencakup cara mengelola tugas CDC, termasuk membuat, menjeda, melanjutkan, mengambil detail, mencantumkan, dan menghapus melalui permintaan HTTP.

Membuat tugas

Membuat tugas CDC memungkinkan operasi perubahan data di Milvus sumber disinkronkan ke Milvus target.

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

Ganti localhost dengan alamat IP server Milvus target.

Parameter:

• milvus_connect_param: Parameter koneksi Milvus target.

  • host: Nama host atau alamat IP server Milvus.

  • port: Nomor port yang didengarkan oleh server Milvus.

  • username: Nama pengguna untuk mengautentikasi dengan server Milvus.

  • password: Kata sandi untuk mengautentikasi dengan server Milvus.

  • enable_tls: Apakah akan menggunakan enkripsi TLS/SSL untuk koneksi.

  • connect_timeout: Periode batas waktu dalam detik untuk membangun koneksi.

• collection_infos: Koleksi yang akan disinkronkan. Saat ini, hanya tanda bintang(*) yang didukung, karena Milvus-CDC melakukan sinkronisasi di tingkat kluster, bukan koleksi individual.

Tanggapan yang diharapkan:

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

Membuat daftar tugas

Untuk mencantumkan semua tugas CDC yang dibuat:

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

Ganti localhost dengan alamat IP server Milvus target.

Tanggapan yang diharapkan:

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

Menjeda tugas

Untuk menjeda tugas CDC:

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

Ganti localhost dengan alamat IP server Milvus target.

Parameter:

• task_id: ID tugas CDC yang akan dijeda.

Respons yang diharapkan:

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

Melanjutkan tugas

Untuk melanjutkan tugas CDC yang dijeda:

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

Ganti localhost dengan alamat IP server Milvus target.

Parameter:

• task_id: ID tugas CDC yang akan dilanjutkan.

Respons yang diharapkan:

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

Mengambil detail tugas

Untuk mengambil detail tugas CDC tertentu:

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

Ganti localhost dengan alamat IP server Milvus target.

Parameter

• task_id: ID tugas CDC yang akan ditanyakan.

Respons yang diharapkan:

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

Menghapus tugas

Untuk menghapus tugas CDC:

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

Ganti localhost dengan alamat IP server Milvus target.

Parameter:

• task_id: ID tugas CDC yang akan dihapus.

Tanggapan yang diharapkan:

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