检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
生产消息接口说明 功能介绍 向指定队列发送消息，可同时发送多条消息。 每次最多发送10条。 每次发送的消息总负载不超过2MB。 endpoint为https://{rest_connect_address}:9292，通过指定实例接口查询rest_connect_address的IP地址。 URI
线、下划线组成，且只能以英文或中文开头。 说明： 中文字符必须为UTF-8或者unicode编码。 port Integer VPC通道中主机的端口号。 取值范围1 ~ 65535。 balance_strategy Integer 分发算法。 1：加权轮询（wrr） 2：加权最少连接（wleastconn）
接入ArtemisMQ数据源 概述 ROMA Connect支持把ArtemisMQ作为一个数据源，并用于数据集成任务。在使用ArtemisMQ数据源前，您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下，在接入数据源前您需要有可用的集成应用，否则请提前创建集成应用。
url) 使用get方法调用http或https服务 String callGETAPI(String host, String service, String params, String header) 使用get方法调用http或https服务 Response get(String
用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 响应参数 无 请求示例 GET https://{endpoint}/v2/{project_id}/mqs/instances/{instance_id} 响应示例 状态码： 200
接入Kafka数据源 概述 ROMA Connect支持把Kafka作为一个数据源，并用于数据集成任务。在使用Kafka数据源前，您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下，在接入数据源前您需要有可用的集成应用，否则请提前创建集成应用。 操作步骤 登录ROMA
接入HL7数据源 概述 ROMA Connect支持把HL7（卫生信息交换标准）作为一个数据源，并用于数据集成任务。在使用HL7数据源前，您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下，在接入数据源前您需要有可用的集成应用，否则请提前创建集成应用。 操作步骤
接入IBM MQ数据源 概述 ROMA Connect支持把IBM MQ作为一个数据源，并用于数据集成任务。在使用IBM MQ数据源前，您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下，在接入数据源前您需要有可用的集成应用，否则请提前创建集成应用。 操作步骤
当队列中消息较少时，单次消费返回的消息数量可能会少于指定条数，但多次消费最终可获取全部消息。当返回的消息为空数组时，表示未消费到消息。 endpoint为https://{rest_connect_address}:9292，通过指定实例接口查询rest_connect_address的IP地址。 URI
KafkaConfig类说明 路径 com.roma.apic.livedata.config.v1.KafkaConfig extends java.util.Properties 说明 与KafkaProducer或KafkaConsumer配合使用，对Kafka客户端进行配置。
配置设备数据转发MQS 概述 ROMA Connect不会直接存储设备上报的数据，用户需要通过配置数据转发规则，把设备数据转发到其他服务进行存储。本实践中，把设备数据转发到ROMA Connect的消息集成MQS。 操作步骤 创建用于存储设备数据的消息Topic。 在左侧的导航栏选择“消息集成
获取项目ID 调用API获取项目ID 项目ID可以通过调用IAM的查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET https://{Endpoint}/v3/projects/”，其中{Endpoint}为IAM的终端节点，可以从地区和终端节点获取。接口的认证鉴权请参见认证鉴权。
30秒内不能被该消费组再次消费，若在这30秒内没有被消费者确认消费，则MQS认为消息未消费成功，将可以被继续消费。 endpoint为https://{rest_connect_address}:9292，通过指定实例接口查询rest_connect_address的IP地址。 URI
HTTP请求 HTTP请求连接器可以通过HTTP/HTTPS协议调用其它开放的API，以获取编排所需的数据。 创建HTTP请求连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”，在连接器页面单击“新建连接”。 选择“HTTP请求”连接器。 在弹窗中配置连接器信息，完成后单击“确定”。
准备资源 概述 在创建ROMA Connect实例前您需要提前准备相关依赖资源，包括VPC、子网和安全组。每个ROMA Connect实例都部署在某个虚拟私有云（VPC）中，并绑定具体的子网和安全组，通过这样的方式为ROMA Connect提供一个隔离的、用户自主配置和管理的虚拟网络环境以及安全保护策略。
kens），拼接起来如下所示。 https://iam.xxx.com/v3/auth/tokens 为查看方便，在每个具体API的URI部分，只给出resource-path部分，并将请求方法写在一起。这是因为URI-scheme都是HTTPS，而Endpoint在同一个区域也相同，所以简洁起见将这两部分省略。
"min_version" : "", "links" : { "rel" : "self", "href" : "https://roma.example.com/v1" }, "id" : "v1", "updated" : "2018-06-28T12:20:21Z"
选择健康检查所使用的协议，可选择“TCP”、“HTTP”和“HTTPS”。 双向认证 仅当“协议”选择“HTTPS”时可配置。 选择是否在ROMA Connect和后端服务器间启用双向认证。 路径 仅当“协议”选择“HTTP”或“HTTPS”时需要配置。 填写健康检查的URL地址路径。 Method
选择健康检查所使用的协议，可选择“TCP”、“HTTP”和“HTTPS”。 双向认证 仅当“协议”选择“HTTPS”时可配置。 选择是否在ROMA Connect和后端服务器间启用双向认证。 路径 仅当“协议”选择“HTTP”或“HTTPS”时需要配置。 填写健康检查的URL地址路径。 Method
创建MQS到数据库的集成任务 概述 通过数据集成任务，把MQS中的设备数据进行数据结构转换并写入停车场管理系统的数据库中。此处假设停车场管理系统的数据库为MySQL。 操作步骤 接入MQS数据源。 在左侧的导航栏选择“数据源管理”，单击页面右上角的“接入数据源”。 在接入数据源页
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
