检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
SapRfcConfig类说明 路径 com.roma.apic.livedata.config.v1.SapRfcConfig extends java.util.Properties 说明 与SapRfcClient配合使用,对sap客户端进行配置。 方法列表 返回类型 方法和说明
自定义数据源开发示例(实时任务) 操作场景 对于实时数据源,当前自定义连接器不支持直接接入,只能通过消息中转的方式进行接入。本章节以MQS数据源类型为例进行开发,示例使用Java语言进行开发,Demo代码参考RealtimeConnector.rar。 前提条件 准备装有1.8及以上版本JDK的Linux服务器。
DWS变成只读状态导致FDI任务运行失败 原因分析 在DWS磁盘空间达到阈值,例如80%,或者某些大数据量的表存在数据倾斜时,DWS集群会变为只读状态。从FDI侧来看,在某个时间点,所有访问DWS的任务均异常停止。 解决方案 处理DWS只读状态问题,恢复数据库服务后,如果FDI的
配置设备数据转发MQS 概述 ROMA Connect不会直接存储设备上报的数据,用户需要通过配置数据转发规则,把设备数据转发到其他服务进行存储。本实践中,把设备数据转发到ROMA Connect的消息集成MQS。 操作步骤 创建用于存储设备数据的消息Topic。 在左侧的导航栏选择“消息集成
设备接入ROMA Connect 概述 停车场的车位感应设备通过集成开源MQTT客户端接入ROMA Connect,实现车位状态信息的上报。 操作步骤 获取MQTT客户端。 根据您所使用的编程语言获取3.1或3.1.1版本的Eclipse paho MQTT Client。 获取设备的接入信息。
开发自定义认证 创建用于前端认证的函数后端 通过自定义后端开发自定义认证函数,然后调用该函数进行访问认证,实现自定义认证。 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 创建集成应用。 在左侧的导航栏选择“集成应用”,单击页面右上角的“创建集成应用”。
查询客户端应用关联的应用配额 功能介绍 查看指定客户端应用关联的应用配额。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/
查询产品列表 功能介绍 通过调用API获取产品的信息。 URI GET /v1/{project_id}/link/instances/{instance_id}/products 表1 参数说明 参数 类型 是否必填 说明 project_id string 是 租户每个区域对应的项目ID。
CacheUtils类说明 路径 com.huawei.livedata.lambdaservice.util.CacheUtils 说明 提供缓存的存储和查询功能。 使用示例 在使用CacheUtils之前,需要new一个新对象方可调用。 CacheUtils的get方法只允许使用白名单里的几项作为键:
JWTUtils类说明 路径 com.huawei.livedata.util.JWTUtils 说明 提供sha256签名。 方法列表 返回类型 方法和说明 static String createToken(String appId, String appKey, String
AesUtils类说明 路径 com.roma.apic.livedata.common.v1.AesUtils 说明 提供AES加解密方法。 使用示例 加密示例 importClass(com.roma.apic.livedata.common.v1.AesUtils); function
配置Oracle CDC(XStream) 概述 CDC(Change Data Capture),即数据变更抓取,通过为源端数据源开启CDC,ROMA Connect可实现数据源的实时数据同步以及数据表的物理删除同步。 ROMA Connect支持Oracle的XStream和
配置Oracle CDC(LogMiner) 概述 CDC(Change Data Capture),即数据变更抓取,通过为源端数据源开启CDC,ROMA Connect可实现数据源的实时数据同步以及数据表的物理删除同步。 ROMA Connect支持Oracle的XStream
MRS Hive写入时数据全部写在第一个字段里 原因分析 建表时没有使用列分隔符。 解决方案 在数据库中执行以下命令设置分隔符: alter table 表名set serdeproperties('field.delim'='分隔符') 父主题: 数据集成任务
创建自定义认证 功能介绍 创建自定义认证 URI POST /v1/{project_id}/apic/instances/{instance_id}/authorizers 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见API参考的“附录
创建后端API脚本 功能介绍 在某个实例中创建后端API脚本。 URI POST /v1/{project_id}/apic/instances/{instance_id}/livedata-scripts 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是
删除后端API 功能介绍 在某个实例中删除后端API。 URI DELETE /v1/{project_id}/apic/instances/{instance_id}/livedata-apis/{ld_api_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id
Kafka集到Mysql目标端报“cannot find record mapping field”错误 原因分析 查看任务mapping配置,源端字段类型的长度超出目标端字段类型的长度限制,或者配置的映射字段中某个字段在源端的数据中不存在。 解决方案 检查字段映射配置的字段类型
Mysql到Mysql时源端报“Illegal mix of collations for operation 'UNION'”错误 原因分析 从源端数据源视图中查看,视图定义语句使用了union,但是union两边字段编码不一致,须统一编码。 解决方案 建议使用CONVERT转换为统一编码,如:CONVERT
配置索引生命周期策略(可选) ElasticSearch存储的数据,默认未设置过期时间,用户可根据磁盘空间情况,为ElasticSearch数据设置索引生命周期策略。 创建生命周期策略 登录Kibana可视化界面。 访问地址:IP:Port 其中,IP为ELK所部署服务器的IP;