数据同步

开发中

POST

http://127.0.0.1:20001http://127.0.0.1:20001/api/dataPush/start

请求参数

Body 参数application/json

示例

{
  "taskId": "user-message-sync",
  "taskName": "用户消息同步",
  "sourceType": "jdbc",
  "sourceConfig": {
    "url": "jdbc:mysql://localhost:3306/doc?useSSL=false&serverTimezone=UTC",
    "username": "root",
    "password": "123456"
  },
  "destinationType": "jdbc",
  "destinationConfig": {
    "url": "jdbc:mysql://localhost:3306/target?useSSL=false&serverTimezone=UTC",
    "username": "root",
    "password": "123456"
  },
  "syncConfig": {
    "batchSize": 5000,
    "minShards": 1,
    "maxShards": 10,
    "coordinatorType": "redis",
    "coordinatorConfig": {
      "host": "localhost",
      "port": 6379
    }
  },
  "sourceEntityClassName": "kd.data.web.entities.SourceMessage",
  "targetEntityClassName": "kd.data.web.entities.TargetMessage"
}

请求示例代码

Shell

JavaScript

Java

Swift

PHP

Python

HTTP

Objective-C

Ruby

OCaml

Dart

curl --location --request POST 'http://127.0.0.1:20001/api/dataPush/start' \
--header 'Content-Type: application/json' \
--data-raw '{
  "taskId": "user-message-sync",
  "taskName": "用户消息同步",
  "sourceType": "jdbc",
  "sourceConfig": {
    "url": "jdbc:mysql://localhost:3306/doc?useSSL=false&serverTimezone=UTC",
    "username": "root",
    "password": "123456"
  },
  "destinationType": "jdbc",
  "destinationConfig": {
    "url": "jdbc:mysql://localhost:3306/target?useSSL=false&serverTimezone=UTC",
    "username": "root",
    "password": "123456"
  },
  "syncConfig": {
    "batchSize": 5000,
    "minShards": 1,
    "maxShards": 10,
    "coordinatorType": "redis",
    "coordinatorConfig": {
      "host": "localhost",
      "port": 6379
    }
  },
  "sourceEntityClassName": "kd.data.web.entities.SourceMessage",
  "targetEntityClassName": "kd.data.web.entities.TargetMessage"
}'

返回响应

🟢200成功

application/json

Body

示例

{}

修改于 2025-07-30 02:04:32

监控