检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
最大长度：64 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 响应参数 状态码： 400 表3 响应Body参数
具体如下表所示。接入数据源后，单击数据源名称可以查看数据源详情，数据源详情中可查看数据源相关的任务信息。 ROMA Connect数据集成适用于异构数据源之间的数据类型转换和按需集成。对于业界主流数据库之间的数据迁移、同步场景，建议使用数据复制服务DRS；对于关系型数据库、大数据
oracle：oracle数据源类型 mysql：mysql数据源类型 mongodb：mongodb数据源类型 redis：redis数据源类型 postgresql：postgresql/opengauss数据源类型 hive：hive数据源类型 mssql：sqlserver数据源类型 sql
接入Kafka数据源 接入MySQL数据源 接入MongoDB数据源 接入MQS数据源 接入MRS Hive数据源 接入MRS HDFS数据源 接入MRS HBase数据源 接入MRS Kafka数据源 接入OBS数据源 接入Oracle数据源 接入PostgreSQL数据源 接入Redis数据源
oracle：oracle数据源类型 mysql：mysql数据源类型 mongodb：mongodb数据源类型 redis：redis数据源类型 postgresql：postgresql/opengauss数据源类型 hive：hive数据源类型 mssql：sqlserver数据源类型 sql
-Subject-Token的值）。 表3 请求Body参数 参数 是否必选 参数类型 描述 apps 是 Array of apps objects 应用列表。 tasks 是 Array of tasks objects 任务列表。 表4 apps 参数 是否必选 参数类型 描述
仅当“连接模式”选择“专业”时需要配置。 填写PostgreSQL数据库的JDBC格式连接串，例如：jdbc:postgresql://{hostname}:{port}/{dbname}。 {hostname}为数据库的连接地址。 {port}为数据库的连接端口号。 {dbname}为要接入的数据库名。 用户名
包住）。 表5 同步数据 参数 说明 表名 选择或者填写数据库中要同步数据的表名。 清空表 每次同步数据，是否先清空表。 表6 删除记录 参数 说明 表名 选择或者填写数据库中要删除数据的表名。 WHERE条件 配置要删除数据的条件值（注意值要用英文单引号包住）。 表7 自定义SQL
oracle：oracle数据源类型 mysql：mysql数据源类型 mongodb：mongodb数据源类型 redis：redis数据源类型 postgresql：postgresql/opengauss数据源类型 hive：hive数据源类型 mssql：sqlserver数据源类型 sql
选择Topic所属的集成应用。 权限 为Topic所属的集成应用选择对Topic的操作权限。 发布+订阅：表示支持对Topic发布消息和订阅消息。 发布：表示仅支持对Topic发布消息。 订阅：表示仅支持对Topic订阅消息。 分区数 设置Topic的分区数，合理设置分区数量，可以提升消息生产与消费的并发性能。
-Subject-Token的值）。 表3 请求Body参数 参数 是否必选 参数类型 描述 apps 是 Array of apps objects 应用列表。 tasks 是 Array of tasks objects 任务列表。 表4 apps 参数 是否必选 参数类型 描述
}/assets/import 表1 路径参数 参数 是否必选 参数类型 描述 instance_id 是 String 实例ID。 project_id 是 String 项目ID，获取方式请参见API参考的“附录 > 获取项目ID”章节。 表2 Query参数 参数 是否必选
若数据源分组选择BIGDATA，即可选HIVE/FIHIVE；若数据源分组选择DB，即可选MYSQL/GAUSSDB/GAUSSDB_T/ORACLE/SQLSERVER/POSTGRESQL/DAMENG；若数据源组选择FILE，即可选EXCEL/SWAGGER/FILE_SYSTEM
2014、2019、2022 消息集成 消息集成支持的消息类型如表3所示。 表3 消息集成支持的消息类型 消息类型 支持的版本 Kafka 1.1.0、2.7 设备集成 设备集成支持设备使用的接入协议信息如表4所示。 表4 设备集成支持的接入协议 消息类型 支持的版本 MQTT 3
Jira Software 定时器 ArtemisMQ RabbitMQ 事件网格 QQ邮箱 IBM MQ Kafka MySQL Oracle PostgreSQL Sql Server 父主题： 连接器
做处理。例如，SELECT service，abs(temperature)，用到了abs(number)函数，具体条件表达式请见表5。 表5 SQL函数列表 函数名 函数说明 abs(number) 返回绝对值。 sin(n) 返回n值的正弦。 cos(number) 返回number值的余弦。
创建数据集成任务（组合任务） 配置Oracle CDC（LogMiner） 配置Oracle CDC（XStream） 配置MySQL CDC（Binlog） 配置SQL Server CDC 创建组合任务 父主题： 数据集成指导
在数据集成任务左侧勾选上要启动的任务，单击任务列表上方的“启动”，启动任务。任务启动成功后，“任务状态”变为“启动”。 手工调度任务，手工调度任务前，需确保“任务状态”为“停止”状态。 单击数据集成任务右侧的“更多 > 手工调度”，手工调度任务。 定时任务：手工调度任务后，任务仅执行一次，“任务状态”依然为“停止”。
strings 绑定的API编码列表。 数组长度：1 - 500 响应参数 状态码： 201 表4 响应Body参数 参数 参数类型 描述 attached_plugins Array of PluginApiAttachInfo objects 绑定插件信息列表。 表5 PluginApiAttachInfo
en的值）。 表3 请求Body参数 参数 是否必选 参数类型 描述 env_id 是 String 绑定API的环境编码。 plugin_ids 是 Array of strings 绑定的插件编码列表。 数组长度：1 - 500 响应参数 状态码： 201 表4 响应Body参数
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
