Redis同步

September 26, 2022About 4 min

Redis同步

SDK类名:/active/Redis;

新建

SDK方法名:createRedisRule

URL

/redis/rule

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
rule_nameString
src_db_uuidString
tgt_db_uuidString
tgt_typeStringsqlserver
map_typeStringdb
configObject
  start_rule_nowNumber1
  table_mapString
  full_syncNumber0
  incre_syncNumber1
  kafkaObject
    binary_codeStringhex
  kafka_time_outString
  part_load_balanceString
  kafka_message_encodingString
  dbmap_topicString
  db_user_mapString
kafkaObject
sync_modeString是否全量同步

Response

名称类型必选简介Mock初始值Mock规则

修改

SDK方法名:modifyRedisRule

URL

/redis/rule/:rule_uuid([A-F0-9-]+)

Method

PUT

Request

名称类型必选简介Mock初始值Mock规则
rule_nameString
src_db_uuidString
tgt_db_uuidString
tgt_typeStringsqlserver
map_typeStringdb
configObject
  start_rule_nowNumber1
  table_mapString
  full_syncNumber0
  incre_syncNumber
  kafkaObject二进制数据编码方式
    binary_codeString
  kafka_time_outString12000
  part_load_balanceString分区均衡策略
  kafka_message_encodingStringutf-8

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageStringsuccess

删除

SDK方法名:deleteRedisRule

URL

/redis/rule

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidsArray
forceStringtrue

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageStringsuccess

启/停/重新同步/继续

SDK方法名:{operate}RedisRules

URL

/redis/rule/operate

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
operateStringresume | stoprestart
uuidsString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageStringsuccess

规则-状态

SDK方法名:listRedisStatus

URL

/redis/rule/status

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
uuidsArray

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  info_listArray2
    rule_uuidArray["6FBC9EB9-A10A-E226-9F2B-A77B3CF1D337","3BF809AF-4A2E-DD28-072E-530D33BAC189"]+1
    export_stateObject
      statusStringACTIVE_RULE_DUMP
      progressString66
    load_stateObject
      statusStringACTIVE_RULE_ABNORMAL
      error_codeNumber-4014
    track_stateObject
      statusStringACTIVE_RULE_STOP
      error_codeNumber-4014

日志

SDK方法名:listRedisRuleLog

URL

/redis/rule/log

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber0
limitNumber10
date_startString
date_endString
typeNumber1
module_typeNumber1
query_typeNumber1
rule_uuidString@guid

Response

名称类型必选简介Mock初始值Mock规则
msgString
dataObject
  codeNumber0
  messageStringDelete success
  info_listArray
    create_timeString2019-08-09 17:29:43
    detailStringFull Sync done, elapsed time: 24 sec'
    flagNumber1
    log_levelString2
    log_typeString装载
    uuidString@uuid
retNumber200

列表

SDK方法名:listRedisRule

URL

/redis/rule

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
pageNumber1
limitNumber10
search_fieldString
search_valueString
group_uuidString
where_argsObject
  rule_uuidString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  totalNumber5
  info_listArray2
    rule_uuidArray["6FBC9EB9-A10A-E226-9F2B-A77B3CF1D337","3BF809AF-4A2E-DD28-072E-530D33BAC189"]+1
    rule_nameArray["Ronald Lopez","Melissa Brown"]+1
    src_db_uuidString
    tgt_db_uuidString
    tgt_typeStringkafka
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    tgt_db_nameStringbei
    map_typeStringdatabase
    configObject
      start_rule_nowNumber1
      table_mapString
      full_syncNumber1
      incre_syncNumber1
      full_sync_modeString
      db_user_mapObject
      dbmap_topicString
      row_map_modeString
      kafka_time_outString
      part_load_balanceString
      kafka_message_encodingString
    src_db_nameString1111
    is_biz_adminNumber1
    can_delNumber1
    can_opNumber1
    can_upNumber1
    rule_typeNumber40
  messageString
  codeNumber0

获取单个规则

SDK方法名:describeRedisRule;

URL

/redis/rule/:rule_uuid([A-F0-9-]+)

Method

GET

Request

名称类型必选简介Mock初始值Mock规则

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageStringsuccess
  codeNumber0
  mongo_ruleObject
    rule_nameStringtest
    src_db_uuidString7B1BE386-4CB1-86AA-D39D-B644C2EADD57
    tgt_db_uuidStringCD52E44B-D25A-4CE3-126F-6F5A460731E4
    tgt_typeStringkafka
    map_typeStringdb
    configObject
      table_mapString'[{"src_user":"11","src_table":"22","dst_user":"11","dst_table":"22","column":[]}]'
      start_rule_nowNumber1
      full_syncNumber
      incre_syncNumber
      kafkaObject
      kafka_time_outString
      part_load_balanceString
      kafka_message_encodingString
      dbmap_topicString
      db_user_mapString
    rule_uuidString
Last update: 9/26/2022, 4:20:20 PM
Contributors: ganl