检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
义文件。 导入文件后,ROMA Connect支持在线预览和修改导入的文件内容。 单击“导入”,导入后端。 界面右侧显示导入结果,“success”字段中包含了导入成功的后端,“failure”字段中包含了导入失败的后端、错误码和错误信息。 导出自定义后端 登录ROMA Conn
xml”、“hdfs-site.xml”文件。 生成MRS HBase配置文件。 将上述获取到的文件放到一个新的目录下,并打包成zip文件,所有文件位于zip文件的根目录下。 文件名只能由英文字母或数字组成,长度不超过255个字符。 文件大小不超过2MB。 父主题: 获取数据源配置文件
调度时间、取数时间、数据量、各阶段耗时、数据源读取耗时、系统处理耗时和统计周期等。 操作日志:指任务的管理操作记录,包括创建、更新、删除、启动、停止等操作。 查看调度信息 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“数据集成
LINK > 规则引擎”。 导出规则。 导出指定规则:勾选您想要导出的规则,然后单击“导出”,导出规则文件到本地。 导出所有规则:单击“导出所有规则”,导出所有规则文件到本地。 规则导入文件说明 规则的导入文件内容要求见表1。 表1 规则导入文件内容说明 列名 描述 取值要求 Name
KafkaProducer类说明 路径 com.roma.apic.livedata.client.v1.KafkaProducer 说明 生产Kafka消息。 使用示例 importClass(com.roma.apic.livedata.client.v1.KafkaProducer);
CipherUtils类说明 路径 com.huawei.livedata.lambdaservice.security.CipherUtils 说明 解密密码箱中密码的key值。 在获取解密密码箱中普通密码的key值时,注意敏感信息保护,避免敏感信息泄露。 方法列表 返回类型 方法和说明
status_code Integer mock后端自定义状态码: "200": "OK", "201": "Created", "202": "Accepted", "203": "NonAuthoritativeInformation", "204": "NoContent", "205":
str) 使用驼峰式大小写转换str中的单词,删除所有空格,并将除第一个单词外的每个单词的首字母转换为大写。 dasherize(string str) 使用kebab-case转换str中的单词,将str中的所有字母转换为小写,将所有空格转换为连字符(-)。 capitalize(string
您需要为目标端字段选择对应的源端字段。 单击“保存”,完成数据集成任务的创建。 在“任务管理”页面,在刚创建的数据集成任务右侧单击“启动”,启动任务。 父主题: 传统停车场管理系统数字化改造
realtime (实时) timing (定时) 最小长度:1 最大长度:10 status String 任务状态。 stop (停止\未启动) running (运行中) 最小值:0 最大值:1 project_id String 项目ID。 最小长度:1 最大长度:64 source_datasource_id
/{project_id}/link/instances/{instance_id}/devices 响应示例 状态码: 200 OK(如果所有地址返回"--",表示所有节点部署了独占模式的协议插件,无法使用MQTT或CoAP协议;如果CoAP链接地址返回"--",表示需要先配置外接ELB。) {
此配置项仅在创建任务后,重新“编辑”任务才可见。 启动组合任务时,如果有新添加到任务中的表映射,此开关用于如下控制: 启用此开关,则任务会先全量同步新增表的存量数据,全量同步结束后接着增量同步。 禁用此开关,则任务不会同步新增表的存量数据,只会同步任务启动后的增量数据。 配置映射关系,即源端和目标端的数据源信息。
消费组管理 查询指定消费组信息 查询所有消费组 重置消费组消费进度到指定位置 批量删除Group 父主题: 消息集成API
设备分组管理 创建设备分组 查询所有设备分组 删除设备分组 查询设备分组详情 修改设备分组 批量添加设备到设备分组 删除设备分组内的设备 父主题: 设备集成API
APIC通过客户端请求中的Cache-Control请求头来处理缓存,默认拒绝所有客户端带Cache-Control头的请求。 all:允许所有客户端带Cache-Control头的请求。 off:拒绝所有客户端带Cache-Control头的请求。 apps:允许appId(凭据ID)取值在datas列表中的客户端。
VPC通道管理-项目级 查询项目下所有实例的VPC通道列表 项目下创建VPC通道 项目下批量修改VPC通道 项目下同步VPC通道 父主题: 服务集成API
"隔开)。 最小长度:0 最大长度:256 ak String Access Key ID。 数据源为OBS,DIS类型时需要配置。 最小长度:0 最大长度:256 sk String Secret Access Key。 数据源为OBS,DIS类型时需要配置。 最小长度:0 最大长度:256
String 项目ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 [数组元素] 否 Array of strings 所有需要删除的消费组ID。 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 failed_groups Array of
配置Oracle CDC(LogMiner) 概述 CDC(Change Data Capture),即数据变更抓取,通过为源端数据源开启CDC,ROMA Connect可实现数据源的实时数据同步以及数据表的物理删除同步。 ROMA Connect支持Oracle的XStream
e表示非持久化。 autoDelete表示是否自动删除,true表示自动删除。自动删除的前提是至少有一个队列或者交换器与该交换器绑定,之后所有与该交换器绑定的队列或者交换器都会解绑。 internal表示是否为内置交换器,true表示是内置的交换器。客户端程序无法直接发送消息到这