检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
开发规范 开发建议 数据集成开发建议: ROMA Connect仅对连接器的RESTful接口做了规范定义,具体连接器对数据源的读写功能以及RESTful接口均需要您自行开发,您可以自行选择开发语言进行连接器开发。
父主题: 数据集成普通任务
不同实例的数据源ID不可以相同,如含有相同ID的数据源,请选择覆盖导入。 当选择“覆盖导入”时,根据是否需要覆盖环境配置选择“覆盖”或“不覆盖”。 覆盖:当导入的数据源存在同名数据源时,选择更新数据源。 不覆盖:当导入的数据源存在同名数据源时,不做更新。 输入前缀。
父主题: 数据集成组合任务
更新数据 填写更新操作中目标字段的值(注意值要用英文单引号包住)。 WHERE条件 配置要更新数据的条件值(注意值要用英文单引号包住)。 表4 同步数据 参数 说明 表名 选择或者填写数据库中要同步数据的表名。 清空表 每次同步数据,是否先清空表。
最小长度:1 最大长度:64 source_app_id String 源端数据源所属集成应用ID。 最小长度:1 最大长度:64 target_app_id String 目标端数据源所属集成应用ID。
最小长度:1 最大长度:64 target_app_id 否 String 目标端数据源所属集成应用ID。 最小长度:1 最大长度:64 响应参数 状态码: 200 表4 响应Body参数 参数 参数类型 描述 task_id String 任务ID, 可为空。
父主题: 开放数据API
开发说明 开发场景 开发规范 父主题: 数据集成开发指导
接入数据源 调用“创建数据源”接口,接入需要开放数据的数据库,并获取返回的数据源ID。此处以MySQL数据库为例进行说明,其他类型数据库请参考接口的参数说明。
更新数据 填写更新操作中目标字段的值(注意值要用英文单引号包住)。 WHERE条件 配置要更新数据的条件值(注意值要用英文单引号包住)。 表5 同步数据 参数 说明 表名 选择或者填写数据库中要同步数据的表名。 清空表 每次同步数据,是否先清空表。
资源规划 完成本实践所需的资源: 表1 资源规划 资源 资源说明 数量 MySQL 2核 4GB 1 Oracle 2核 4GB 1 新版ROMA Connect实例 配额设置为组合应用,2RCU 1 父主题: 定时同步MySQL中的数据到Oracle
extend_meta_data 否 List<MetaData> 源端数据源元数据配置信息的拓展信息。 source_meta_data 否 List<MetaData> 源端数据源元数据配置信息。
查看某个API的调用统计,包括“请求次数”、“调用延时”、“数据流量”和“出错统计”。 选择“集成应用”和“API”,筛选要查看统计数据的API,并可以选择要查看数据的时间段范围。 近1小时数据每2分钟刷新一次。 近6小时数据每2小时刷新一次。 近一天数据每2小时刷新一次。
父主题: 获取数据源配置文件
父主题: 开放数据API
最小长度:2 最大长度:512 请求示例 为指定数据集成任务创建调度计划,不使用Cron表达式,执行间隔为每天一次 { "use_quartz_cron" : false, "remark" : "123", "start_datetime" : "2020-11-14T07
最小长度:2 最大长度:512 请求示例 修改指定数据集成组合任务,操作类型修改为插入和更新,并同步已有数据 { "description" : "test" } 响应示例 状态码: 400 Bad Request { "error_code" : "FDI.3150",
FDI任务失败,修改问题后任务写入仍然报错 原因分析 Writer端写入数据时,先从Kafka通道的topic中消费数据,成功入库后才将消费偏移量提交给Kafka。如果写入数据时发生异常,将不会提交消费偏移量,等待修复问题后,重启任务,可以重新消费并处理未成功入库的数据。
删除指定任务 功能介绍 通过任务ID删除指定任务。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI DELETE /v2/{project_id}/fdi/instances