检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
消息存储空间 实例的MQS消息存储空间信息,包括存储类型和存储空间使用率(百分比)。 MQS基本信息 实例的MQS的基本配置信息。 对应Kafka引擎类型,您可以根据实际需要修改“容量阈值策略”。 连接地址 实例的相关对接地址,包括: ROMA Connect连接地址 设备集成LINK连接地址
数据API调用存储过程时,参数可通过后端服务请求的Headers、Parameters或者Body传递,参数名的语法为:{参数名}.{数据类型}.{传输类型}。 数据类型包括String和int。 传输类型指入参或出参声明,入参使用in,出参使用out。 数据API中调用存储过程的执行语句示例: call sb_test(${nname
为Topic所属的集成应用添加消息发布和订阅标签,一般业务场景下无需添加,仅用于特殊业务场景。 添加标签后,客户端向Topic发布和订阅消息时需同时传输标签信息。如果有多个标签,则客户端传输的标签需为Topic包含标签的子集。 敏感字段 填写Topic的消息敏感字段。若向Topic生成的消息中包含敏感字段,则包含敏感字段的整条消息内容会被屏蔽。
is_parse 否 Boolean 是否解析。 如果选择了是,则不会透传数据。 如果选择了否,则会透传数据。 透传,即透明传输(pass-through),指的是将传输的内容由源端传输到目标端,不对数据内容做任何改变。 默认为true, 与source_meta_data值配对使用。 path
目标端。 不同数据源所支持的数据集成模式有所不同,具体请参考表1。 是否解析 选择是否透传数据。透传,即透明传输(pass-through),指的是将传输的内容由源端传输到目标端,不对数据内容做任何改变。 是:不会透传数据。 否:则会透传数据。 使用QuartZ Cron表达式 选择是否使用QuartZ
与服务器层面的异常重启或者掉电,使用消息确认(ACK)机制解决消息传输过程中遇到的异常。 考虑到网络异常等极端情况,用户除了做好消息生产与消费的确认,还需要配合ROMA Connect完成消息发送与消费的重复传输设计。 当无法确认消息是否已发送成功,生产者需要将消息重复发送给ROMA
kafka.common.security.plain.PlainLoginModule required \ username="**********" \ password="**********"; sasl.mechanism=PLAIN security.protocol=SASL_SSL
否停止整个任务。 输入方式 选择组件的输入方式。 API表单参数:表示通过API表单的方式来提交目标文件信息。 文本输入:表示直接通过文件传输服务器(如:FTP)方式来提交目标文件信息。 API表单参数 仅当“输入方式”选择“API表单参数”时需要配置。 获取上一节点传递的文件信
、设备客户端ID、具有订阅权限的Topic、发送控制消息的API的访问地址、访问端口、消息内容。 public static void main(String[] args) { // 示例仅用作测试或示意,API认证的appKey为敏感信息,请勿硬编码使用
executes failed.Writer data to kafka failed”错误 原因分析 目标端数据源为公网Kafka时,由于网络原因导致定时任务报“The task executes failed.Writer data to kafka failed”错误。 解决方案
务(LTS)的日志统计能力,由于ROMA Site协同版实例为边缘部署,需要将API的调用日志回传到华为云上才能实现API的监控分析。由于传输的数据量与API请求量相关,请求数据量过大,回传链路无法承载。因此ROMA Site协同版实例暂不支持查看API的调用日志和调用统计数据。
填写OBS桶拥有者的SK,具体获取方式请参考什么是我的凭证。 桶名称 填写要接入的OBS桶名称。 是否是https 固定为“是”,使用HTTPS传输协议。 OBS数据源的接入配置示例如下图所示。 图1 OBS数据源配置示例 完成数据源接入配置后,单击“开始检测”,检测ROMA Connect与数据源之间是否能够连通。
调用API时报“No backend available”错误 原因分析 可能是以下两种原因导致,请逐一排查: 后端服务无法访问。 ECS安全组未开放需要的端口。 解决方案 请修改后端服务。 修改ECS安全组配置,开放需要的端口。 父主题: 服务集成
"password": "********", "domain": { "name": "domainname" } }
用于定义水表需要上报的各种告警场景的数据,必要的话需要定义命令。 电池(Battery) 定义水表的电压、电流强度等数据。 传输规则(DeliverySchedule) 定义水表的一些传输规则,必要的话需要定义命令。 连接(Connectivity) 定义水表连接参数。 具体定义多少个物模型服务
kafka.common.security.plain.PlainLoginModule required \ username="**********" \ password="**********"; sasl.mechanism=PLAIN security.protocol=SASL_SSL
选择已创建的前端类型自定义认证。 前端请求协议 选择前端API使用的请求协议,可选择“HTTP”、“HTTPS”和“HTTP&HTTPS”,传输重要或敏感数据时推荐使用HTTPS。 后端超时 (ms) 后端服务请求的超时时间,默认为60000ms。 重试次数 ROMA Connect调用后端服务失败后的重试次数。
inbound port failed. 删除自定义入方向端口失败 请稍后重试或联系技术支持工程师协助解决 400 APIC.9224 Add custom inbound port failed. Add custom inbound port failed. 请稍后重试或联系技术支持工程师协助解决
选择已创建的前端类型自定义认证。 前端请求协议 选择前端API使用的请求协议,可选择“HTTP”、“HTTPS”和“HTTP&HTTPS”,传输重要或敏感数据时推荐使用HTTPS。 后端超时 (ms) 后端服务请求的超时时间,默认为60000ms。 重试次数 ROMA Connect调用后端服务失败后的重试次数。
Ingestion Service,简称DIS)为处理或分析流数据的自定义应用程序构建数据流管道,面向IoT、互联网等实时数据,提供高效采集、传输、分发能力。 ROMA Connect可以使用DIS作为数据集成任务的源端和目标端,也可以使用DIS作为LINK转发规则的目的端,把设备上报的数据转发到DIS。