CDCタスクの管理

データ変更キャプチャ(CDC)タスクはソースMilvusインスタンスからターゲットMilvusインスタンスへのデータ同期を可能にします。ソースからの操作ログを監視し、挿入、削除、インデックス操作などのデータ変更をリアルタイムでターゲットにレプリケートします。これにより、リアルタイムのディザスタリカバリやMilvusデプロイメント間のアクティブ-アクティブ負荷分散が容易になります。

このガイドでは、HTTPリクエストによるCDCタスクの作成、一時停止、再開、詳細の取得、一覧表示、削除などの管理方法について説明します。

タスクの作成

CDCタスクを作成することで、ソースMilvusのデータ変更操作をターゲットMilvusに同期させることができます。

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

localhostをターゲットMilvusサーバーのIPアドレスに置き換えます。

パラメータ

• milvus_connect_param: ターゲットMilvusの接続パラメータ。

  • host: Milvusサーバのホスト名またはIPアドレス。

  • port：Milvusサーバがリッスンするポート番号。

  • username: Milvusサーバと認証するためのユーザ名.

  • password: Milvusサーバで認証するためのパスワード。

  • enable_tls：接続に TLS/SSL 暗号化を使用するかどうか。

  • connect_timeout：接続確立のタイムアウト時間(秒)

• collection_infos：同期するコレクション。Milvus-CDCは個々のコレクションではなくクラスタレベルで同期するため、現在のところアスタリスク(*)のみがサポートされています。

期待される応答

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

タスクのリスト

作成されたすべてのCDCタスクをリストする：

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

localhostをターゲットMilvusサーバのIPアドレスに置き換えてください。

期待される応答

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

タスクの一時停止

CDCタスクを一時停止するには

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

localhostをターゲットMilvusサーバーのIPアドレスに置き換える。

パラメータ

• task_id：一時停止するCDCタスクのID。

期待される応答

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

タスクの再開

一時停止したCDCタスクを再開するには

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

localhostをターゲットMilvusサーバのIPアドレスに置き換える。

パラメータ

• task_id：再開するCDCタスクのID。

期待される応答

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

タスクの詳細の取得

特定のCDCタスクの詳細を取得する：

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

localhostを対象のMilvusサーバのIPアドレスに置き換える。

パラメータ

• task_id：問い合わせるCDCタスクのID。

期待される応答

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

タスクの削除

CDCタスクを削除するには

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

localhostを対象のMilvusサーバのIPアドレスに置き換える。

パラメータ

• task_id：削除するCDCタスクのID。

期待される応答

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