首页 云数据库 OceanBase 参考指南 API参考指南 API目录 数据传输 CreateOmsOpenAPIProject - 创建数据同步项目

CreateOmsOpenAPIProject - 创建数据同步项目

创建数据同步项目。

调试

您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。

调试

授权信息

当前API暂无授权信息透出。

请求参数

名称类型必填描述示例值
WorkerGradeIdstring

传输实例的 ID。通常公有云上创建项目,需要先购买传输实例。

g_abcd
PageNumberinteger

页序号,分页查询时生效。

1
PageSizeinteger

页大小,分页查询时生效。

10
ProjectNamestring

项目名称。

test-l
LabelIdsarray

标签 ID 集合。

string

标签 ID。

abcd
SourceConfigobject

源端传输配置。

EndpointTypestring

数据源类型,包括 MYSQLMARIADBOB_MYSQLOB_MYSQL_CEOB_ORACLEORACLE、DB2_LUWKAFKAROCKETMQDATAHUBSYBASELOGPROXYADBDBP_OP_ROUTEDMSIDBTIDB

OB_MYSQL
EndpointIdstring

指定数据源 ID。

e_abcdefj
PartitionModestring

目标端为消息队列(Kafka/DataHub/RocketMQ)时,选择分区模式(包括 ONE、HASH 和 TABLE)。

HASH
Partitioninteger

目标端为消息队列(Kafka/DataHub/RocketMQ)时,如果 partitionMode 为 ONE 模式,该参数表示分区索引。

0
SerializerTypestring

目标端为消息队列(Kafka/DataHub/RocketMQ)时,选择文本序列化类型(Default、Canal、DataWorks、SharePlex 和 DefaultExtendColumnType)。

DEFAULT
TopicTypestring

目标端为 DataHub 时,投递消息所属 Topic 的类型(包括 Tuple 和 Blob)。

TUPLE
SequenceEnableboolean

目标端为 DataHub 时,该参数表示是否开启消息序列。

false
SequenceStartTimestamplong

目标端为 DataHub 时,如果开启消息序列,请设置序列起始时间。单位为秒级时间戳。

1656510473
ProducerGroupstring

目标端为 RocketMQ 时,指定投递消息的生产者组。

producer-group-1
MsgTagsstring

目标端为 RocketMQ 时,设置投递消息的 Tag(标签)。

tag1
EnableMsgTraceboolean

目标端为 RocketMQ 时,该参数表示是否开启消息追踪。

false
SendMsgTimeoutlong

目标端为 RocketMQ 时,设置单次投递消息的超时时间。

10
DestConfigobject

目标端传输配置。

EndpointTypestring

数据源类型,包括 MYSQLMARIADBOB_MYSQLOB_MYSQL_CEOB_ORACLEORACLEDB2_LUWKAFKAROCKETMQDATAHUBSYBASELOGPROXYADBDBP_OP_ROUTEDMSIDBTIDB

OB_MYSQL
EndpointIdstring

指定数据源 ID。

e_abcdefj
PartitionModestring

目标端为消息队列(Kafka/DataHub/RocketMQ)时,选择分区模式(包括 ONE、HASH 和 TABLE)。

HASH
Partitioninteger

目标端为消息队列(Kafka/DataHub/RocketMQ)时,如果 partitionMode 为 ONE 模式,该参数表示分区索引。

0
SerializerTypestring

目标端为消息队列(Kafka/DataHub/RocketMQ)时,选择文本序列化类型(包括 Default、Canal、DataWorks、SharePlex 和 DefaultExtendColumnType)。

DEFAULT
TopicTypestring

目标端为 DataHub 时,投递消息所属 Topic 的类型(包括 Tuple 和 Blob)。

TUPLE
SequenceEnableboolean

目标端为 DataHub 时,该参数表示是否开启消息序列。

false
SequenceStartTimestamplong

目标端为 DataHub 时,如果开启消息序列,请设置序列起始时间。单位为秒级时间戳。

1656510473
ProducerGroupstring

目标端为 RocketMQ 时,指定投递消息的生产者组。

producer-group-1
MsgTagsstring

目标端为 RocketMQ 时,设置投递消息的 Tag(标签)。

tag1
EnableMsgTraceboolean

目标端为 RocketMQ 时,该参数表示是否开启消息追踪。

false
SendMsgTimeoutlong

目标端为 RocketMQ 时,设置单次投递消息的超时时间。

10
TransferMappingobject

传输对象的映射关系。

Modestring

映射类型,包括 NORMALWHITE_AND_BLACK_LIST

NORMAL
Databasesobject []

传统映射(源端库表映射)列表信息,当且仅当 mode 为 NORMAL 时生效。

TenantNamestring

映射对象租户,源端为 OceanBase 时生效。

tenant
MappedNamestring

映射对象 DataBase,目标端为数据库时生效。

mapped_db
DatabaseIdstring

数据库的 ID。源端为逻辑数据源 IDB 时生效。

db_id1
DatabaseNamestring

数据库的名称。

db1
Tablesobject []

数据库中的表信息。

MappedNamestring

映射对象 Table/Topic。目标端为数据库时,该参数为映射表名。目标端为消息队列时,该参数为映射 Topic。

mapped_table
TableIdstring

表的 ID,源端为逻辑数据源 IDB 时生效。

table_id
TableNamestring

表的名称。

table
WhereClausestring

行过滤条件。

id > 1
FilterColumnsarray

过滤列列表,即指定同步哪些列。

string

过滤列。

col
ShardColumnsarray

分片键列列表,用于目标端为消息队列的场景。

string

分片键列。

col
AdbTableSchemaobject

ADB 表的 Schema。目标端为 ADB 时,额外配置信息,用于结构同步。

PrimaryKeysarray

主键列列表。

string

主键列。

pk
DistributedKeysarray

分布键列列表。

string

分布键列。

col
PartitionStatementstring

分区表达式。

PARTITION BY VALUE('id')
PartitionLifeCycleinteger

表的生命周期。

30
Typestring

包括 DATABASE 和 TABLE。

DATABASE
Typestring

包括 DATABASE 和 TABLE。

DATABASE
TransferStepConfigobject

传输步骤配置。

EnableStructSyncboolean

是否开启结构同步。

false
EnableFullSyncboolean

是否开启全量迁移。

false
EnableIncrSyncboolean

是否开启增量同步。

false
IncrSyncStepTransferConfigobject

增量同步步骤的配置。

StartTimestamplong

增量同步阶段时,请设置增量起始位点,单位为秒级时间戳。

1637568354
RecordTypeListarray

增量同步阶段时,同步的增量数据类型列表。

string

增量同步阶段时,同步的增量数据类型。

BIGINT
StoreLogKeptHourlong

有增量同步阶段,且增量日志拉取组件为 Store 时,日志的保存时间。

1
StoreTransactionEnabledboolean

有增量同步阶段,且增量日志拉取组件为 Store 时,是否开启事务内序号编排。

false
TransferStepTypestring

包括 STRUCT、FULL 和 INCR。

STRUCT
BusinessNamestring

业务系统标识(可选),投递消息的特定字段。

OMS_TEST

返回参数

名称类型描述示例值
object

OmsApiReturnResult

Successboolean

是否调用成功。

true
ErrorDetailobject

错误详情。

Codestring

错误码(新)。

CM-RESOAT111111
Levelstring

包括 CRITICAL、ERROR 和 WARN。

WARN
Messagestring

错误描述(新)。

A system error occurred.
Proposalstring

建议(新)。

Contact the administrator.
Codestring

错误码(旧)。

INNER_ERROR
Messagestring

错误描述(旧)。

A system error occurred.
Advicestring

建议(旧)。

Contact the administrator.
RequestIdstring

请求 ID。

XCVSADGDFSGDFGFDGFDGDFGDFGDFGDFGDSGDS
PageNumberinteger

页序号,分页查询时生效。

1
PageSizeinteger

页大小,分页查询时生效。

1
TotalCountlong

总数,分页查询时生效。

1
Coststring

请求耗时,单位为秒。

1
Datastring

是否创建成功。

abcdg

示例

正常返回示例

JSON格式

{
  "Success": true,
  "ErrorDetail": {
    "Code": "CM-RESOAT111111",
    "Level": "WARN",
    "Message": "A system error occurred.",
    "Proposal": "Contact the administrator."
  },
  "Code": "INNER_ERROR",
  "Message": "A system error occurred.",
  "Advice": "Contact the administrator.",
  "RequestId": "XCVSADGDFSGDFGFDGFDGDFGDFGDFGDFGDSGDS",
  "PageNumber": 1,
  "PageSize": 1,
  "TotalCount": 1,
  "Cost": "1",
  "Data": "abcdg"
}

错误码

访问错误中心查看更多错误码。

变更历史

变更时间变更内容概要操作
2022-08-19新增 OpenAPI
阿里云首页 云数据库 OceanBase 版 相关技术圈