检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
CSV格式：支持对消息内容以CSV格式指定分隔符进行解析。 TEXT格式：将整条消息内容作为文本直接同步。 消费组ID：由用户指定，标识当前实时处理集成作业的消费组。 当迁移作业消费DMS Kafka集群某一Topic的消息后，在Kafka集群的“消费组管理”可以看到此处配置的消费组I
查询集群详情 功能介绍 查询集群详情接口。 调用方法 请参见如何调用API。 URI GET /v1.1/{project_id}/clusters/{cluster_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方法请参见项目ID和账号ID。
过大，单位为MB。 toJobConfig.duplicateFileOpType 否 枚举 重复文件处理方式，只有文件名和文件大小都相同才会判定为重复文件。重复文件支持以下处理方式： REPLACE：替换重复文件。 SKIP：跳过重复文件。 ABANDON：发现重复文件停止任务。
错误码，如DS.6000，请求处理失败。 error_msg String 错误信息。 data Object 返回的数据信息。 状态码： 401 表7 响应Body参数 参数 参数类型 描述 error_code String 错误码，如DS.6000，请求处理失败。 error_msg
源端为MySQL，目的端为DWS 本章节适用于配置实时处理集成作业的Mysql到DWS链路，期望将源端1个或多个Mysql实例的数据实时同步到目的端为DWS数据库的场景。 整库：适用于将1个源端为Mysql实例上的多个数据库表实时同步到1个目标端为DWS实例的多个库表。 分库分表
错误码，如DS.6000，请求处理失败。 error_msg String 错误信息。 data Object 返回的数据信息。 状态码： 401 表7 响应Body参数 参数 参数类型 描述 error_code String 错误码，如DS.6000，请求处理失败。 error_msg
错误码，如DS.6000，请求处理失败。 error_msg String 错误信息。 data Object 返回的数据信息。 状态码： 401 表14 响应Body参数 参数 参数类型 描述 error_code String 错误码，如DS.6000，请求处理失败。 error_msg
分库分表场景 源端配置。 Kafka配置。 数据格式：支持的数据格式。 目前支持JSON、CSV、TEXT格式。 消费组ID：由用户指定，标识当前实时处理集成作业的消费组。 当迁移作业消费DMS Kafka集群某一Topic的消息后，在Kafka集群的“消费组管理”可以看到此处配置的消费组I
查询集群详情信息 功能介绍 查询集群详情信息。 调用方法 请参见如何调用API。 URI GET /v1/{project_id}/service/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
错误码，如DS.6000，请求处理失败。 error_msg String 错误信息。 data Object 返回的数据信息。 状态码： 401 表7 响应Body参数 参数 参数类型 描述 error_code String 错误码，如DS.6000，请求处理失败。 error_msg
如何将一个空间的数据开发作业和数据连接迁移到另一空间？ 您需要通过导入导出功能，分别将旧空间的数据连接和作业数据导入到新空间内。 数据连接数据，需要在管理中心的资源迁移进行导入导出。具体操作请参考资源迁移。 作业数据，需要在数据开发中将作业导入导出。具体操作请参考导出导入作业。 父主题：
Request(); try { // 认证用的ak和sk编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； // 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境
错误码，如DQC.0000表示请求处理成功。 error_msg String 错误信息。 data Object 返回的数据信息。 状态码： 400 表4 响应Body参数 参数 参数类型 描述 error_code String 错误码，如DQC.0000表示请求处理成功。 error_msg
错误码，如DS.6000，请求处理失败。 error_msg String 错误信息。 data Object 返回的数据信息。 状态码： 401 表37 响应Body参数 参数 参数类型 描述 error_code String 错误码，如DS.6000，请求处理失败。 error_msg
生成一个新的Signer，输入AppKey和AppSecret。 // 认证用的ak和sk编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； // 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量SDK_AK和SDK_SK。
源端为MySQL，目的端为DMS Kafka 本章节适用于配置实时处理集成作业MySQL到DMS Kafka链路，期望将源端1个或多个Mysql实例的数据实时同步到目的端为DMS Kafka数据库的场景。 同步场景 整库：适用于将1个源端为Mysql实例上的多个数据库表实时同步到1个目标端为DMS
错误码，如DS.6000，请求处理失败。 error_msg String 错误信息。 data Object 返回的数据信息。 状态码： 401 表8 响应Body参数 参数 参数类型 描述 error_code String 错误码，如DS.6000，请求处理失败。 error_msg
源端为MySQL，目的端为MRS Hudi 本章节适用于配置实时处理集成作业MySQL到MRS Hudi链路，期望将源端1个或多个MySQL实例的数据实时同步到目的端为MRS Hudi数据库的场景。 MySql源端配置。 支持选择源端多库多表迁移。 DDL支持新增列。 Hudi目的端配置。
错误码，如DS.6000，请求处理失败。 error_msg String 错误信息。 data Object 返回的数据信息。 状态码： 401 表26 响应Body参数 参数 参数类型 描述 error_code String 错误码，如DS.6000，请求处理失败。 error_msg
源端为SQLServer，目的端为Hudi 该链路目前仅支持整库场景。 该链路目前需申请白名单后才能使用。如需使用该链路，请联系客服或技术支持人员。 前提条件 已开启SQLServer库、表的CDC（change data capture，就是增量实时同步）能力，详情请参见如下示例。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
