检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
连接地址 实例的相关对接地址,包括: ROMA Connect连接地址 设备集成LINK连接地址 服务集成APIC连接地址 服务集成 APIC内网连接地址(自定义后端组件和网关组件) 消息集成 MQS内网连接地址 消息集成 MQS公网连接地址(仅开启公网访问时展示) 您可以单击连接地址右侧的
消息集成开发指导 开发说明 开发准备 MQS连接开发(开源客户端) MQS连接开发(RESTful API)
MQS支持的Kafka服务端版本是多少? MQS支持Kafka 1.1.0、2.7版本。 父主题: 消息集成
配置API授权 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“服务集成 APIC > API管理”,在“API列表”页签中单击API右侧的“授权”。 在授权API页面,单击“添加集成应用”。
执行完成后,可在目标端数据库的数据表中查看集成同步过来的数据。 父主题: 跨系统业务数据集成与转换
Base64Utils类说明 路径 com.roma.apic.livedata.common.v1.Base64Utils 说明 提供Base64Utils编码和解码功能。 使用示例 Base64编码示例: importClass(com.roma.apic.livedata.common.v1
Topic所属的集成应用默认具备向Topic发布和订阅消息的权限。 操作步骤 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“消息集成 MQS > Topic管理”,单击Topic右侧的“设置集成应用权限”。
规则数据解析参数不合法,当启用数据解析时,查询字段不能为空,当关闭数据解析时,查询字段和查询条件必须为空,请修正后重试 检查规则数据解析参数是否合法。
导入成功后,在页面的Topic列表中可查看导入的Topic。 导出Topic 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“消息集成 MQS > Topic管理”。 导出Topic。
RabbitMqProducer类说明 路径 com.roma.apic.livedata.client.v1.RabbitMqProducer 说明 生产RabbitMQ消息。若发送消息没有异常,则消息发送成功;若发送消息抛出异常,则消息发送失败。
Kafka主要由三个部分组成:生产者、消费者和代理服务器。生产者将数据发布到Kafka集群,消费者从Kafka集群订阅数据并进行处理,代理服务器则是Kafka集群中的核心组件,负责处理消息的存储和转发。Kafka的主要优点是可扩展性、高吞吐量、低延迟、可靠性和持久性。
开发说明 开发场景 开发规范 客户端使用建议 客户端参数配置建议 父主题: 消息集成开发指导
服务端 合理设置Topic的分区数,在不影响业务处理效率的情况下,调大Topic的分区数量。 当服务端出现消息堆积时,对生产者进行熔断,或将生产者的消息转发到其他Topic。
图1 包年/包月ROMA Connect实例生命周期 到期预警 包年/包月ROMA Connect实例在到期前第7天内,系统将向用户推送到期预警消息。预警消息将通过邮件、短信和站内信的方式通知到华为账号的创建者。
通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。
迁移准备 确保消息生产与消费客户端与ROMA Connect实例的消息集成MQS连接地址网络互通。您可以在ROMA Connect实例控制台的“实例信息”页面查看消息集成MQS连接地址。 如果使用内网地址连接,则客户端与ROMA Connect实例应在同一VPC内。
通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。
服务管理 设备服务相关API,包括设备服务和属性的创建、修改、查询、删除等操作。 订阅管理操作 设备订阅相关API,包括订阅的创建、修改、查询、删除等操作。
通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。
身份认证通过后,该请求才会发送给后端服务进行业务处理。 父主题: API调用认证开发(APP认证)