1. 接口描述
接口请求域名: dts.tencentcloudapi.com 。
本接口(ConfigureSubscribeJob)用于配置数据订阅实例。
默认接口请求频率限制:20次/秒。
推荐使用 API Explorer
点击调试
API Explorer 提供了在线调用、签名验证、SDK 代码生成和快速检索接口等能力。您可查看每次调用的请求内容和返回结果以及自动生成 SDK 调用示例。
2. 输入参数
以下请求参数列表仅列出了接口请求参数和部分公共参数,完整公共参数列表见 公共请求参数。
参数名称 | 必选 | 类型 | 描述 |
---|---|---|---|
Action | 是 | String | 公共参数,本接口取值:ConfigureSubscribeJob。 |
Version | 是 | String | 公共参数,本接口取值:2021-12-06。 |
Region | 是 | String | 公共参数,详见产品支持的 地域列表。 |
SubscribeId | 是 | String | 数据订阅实例的 ID 示例值:subs-xxxxxx |
SubscribeMode | 是 | String | 数据订阅的类型,当 DatabaseType 不为 mongodb 时,枚举值为:all-全实例更新;dml-数据更新;ddl-结构更新;dmlAndDdl-数据更新+结构更新。当 DatabaseType 为 mongodb 时,枚举值为 all-全实例更新;database-订阅单库;collection-订阅单集合 示例值:dmlAndDdl |
AccessType | 是 | String | 源数据库接入类型,如:extranet(公网)、vpncloud(vpn接入)、dcg(专线接入)、ccn(云联网)、cdb(云数据库)、cvm(云服务器自建)、intranet(自研上云)、vpc(私有网络vpc)。注意具体可选值依赖当前链路支持能力 示例值:cdb |
Endpoints.N | 是 | Array of EndpointItem | 数据库节点信息 |
KafkaConfig | 是 | SubscribeKafkaConfig | Kafka配置 |
SubscribeObjects.N | 否 | Array of SubscribeObject | 订阅的数据库表信息,当 SubscribeMode 不为 all和ddl 时,SubscribeObjects 为必选参数 |
Protocol | 否 | String | 订阅数据格式,如:protobuf、json、avro。注意具体可选值依赖当前链路支持能力,数据格式详情参考官网的消费demo文档 示例值:protobuf |
PipelineInfo.N | 否 | Array of PipelineInfo | mongo选填参数:输出聚合设置。 |
ExtraAttr.N | 否 | Array of KeyValuePairOption | 为业务添加的额外信息。参数名作key,参数值作value。 mysql选填参数:ProcessXA-是否处理XA事务,填true处理,不填或填其他值不处理。 mongo选填参数:SubscribeType-订阅类型,目前只支持changeStream,不填也是默认changeStream。 其他业务暂没有可选参数。 |
3. 输出参数
参数名称 | 类型 | 描述 |
---|---|---|
RequestId | String | 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 |
4. 示例
示例1 配置订阅
配置订阅一个cdb整实例的任务,其中db1.table1的数据根据id列值投递到不同的kafka分区,其他的数据根据表名投递
输入示例
POST / HTTP/1.1
Host: dts.tencentcloudapi.com
Content-Type: application/json
X-TC-Action: ConfigureSubscribeJob
<公共请求参数>
{
"SubscribeMode": "all",
"SubscribeId": "subs-5ft0e2nrc0",
"KafkaConfig": {
"DistributeRules": [
{
"DbPattern": "db1",
"RuleType": "cols",
"TablePattern": "table1",
"Columns": [
"id"
]
}
],
"NumberOfPartitions": 8,
"DefaultRuleType": "table"
},
"AccessType": "cdb",
"Protocol": "json",
"Endpoints": [
{
"InstanceId": "cdb-kdxona7h",
"DatabaseRegion": "ap-guangzhou",
"EncryptConn": "Encrypted",
"User": "root",
"Password": "******"
}
],
"ExtraAttr": [
{
"Value": "true",
"Key": "ProcessXA"
}
]
}
输出示例
{
"Response": {
"RequestId": "abc"
}
}
5. 开发者资源
腾讯云 API 平台
腾讯云 API 平台 是综合 API 文档、错误码、API Explorer 及 SDK 等资源的统一查询平台,方便您从同一入口查询及使用腾讯云提供的所有 API 服务。
API Inspector
用户可通过 API Inspector 查看控制台每一步操作关联的 API 调用情况,并自动生成各语言版本的 API 代码,也可前往 API Explorer 进行在线调试。
SDK
云 API 3.0 提供了配套的开发工具集(SDK),支持多种编程语言,能更方便的调用 API。
- Tencent Cloud SDK 3.0 for Python: GitHub Gitee
- Tencent Cloud SDK 3.0 for Java: GitHub Gitee
- Tencent Cloud SDK 3.0 for PHP: GitHub Gitee
- Tencent Cloud SDK 3.0 for Go: GitHub Gitee
- Tencent Cloud SDK 3.0 for Node.js: GitHub Gitee
- Tencent Cloud SDK 3.0 for .NET: GitHub Gitee
- Tencent Cloud SDK 3.0 for C++: GitHub Gitee
- Tencent Cloud SDK 3.0 for Ruby: GitHub Gitee
命令行工具
6. 错误码
以下仅列出了接口业务逻辑相关的错误码,其他错误码详见 公共错误码。
错误码 | 描述 |
---|---|
AuthFailure | CAM签名/鉴权错误。 |
AuthFailure.AuthFailureError | 认证失败。 |
FailedOperation | 操作失败。 |
FailedOperation.FailedOperationError | 操作失败。 |
InternalError | 内部错误。 |
InternalError.InternalErrorError | 内部错误。 |
InternalError.UnknownError | 未知的内部错误。 |
InvalidParameter | 参数错误。 |
InvalidParameter.ControllerNotFoundError | 异常错误导致当前接口未注册。 |
InvalidParameter.InvalidParameterError | 参数无效。 |
InvalidParameterValue | 参数取值错误。 |
InvalidParameterValue.InvalidParameterValueError | 非法参数。 |
OperationDenied | 操作被拒绝。 |
OperationDenied.OperationDeniedError | 操作被拒绝。 |
ResourceNotFound | 资源不存在。 |
ResourceNotFound.ResourceNotFoundError | 资源未找到。 |
UnauthorizedOperation | 未授权操作。 |
UnauthorizedOperation.UnauthorizedOperationError | 未授权的操作。 |
UnsupportedOperation | 操作不支持。 |
UnsupportedOperation.UnsupportedOperationError | 不支持的操作。 |