检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
数据集成：接入源端和目标端数据源，然后通过集成任务进行源端到目标端的数据集成。 服务集成：把已有后端服务、数据源和自定义函数封装成标准的RESTful API，并对外开放。 消息集成：创建消息Topic，不同系统通过Topic进行对接，发送和接收消息。 设备集成：在云端定义设备模型和注册设备
在组合应用的流任务编排中，以及连接器和处理器配置中涉及到大量的输入输出信息，还涉及到大量的配置信息需要填写。用户在编辑设计组合应用时，可以通过变量的方式快速引用流任务中的输入输出信息和配置信息，帮助用户便捷高效的设计组合应用。 组合应用中的变量可以分为系统变量、节点变量和自定义变量三种。同名变量的优先级为：系统变量
c收发消息的操作有所差异。若开启SASL_SSL访问，则客户端向Topic发送和接收的消息会加密传输，安全性更高。 解压Kafka命令行工具和客户端证书。 在本地PC找到已下载的Kafka命令行工具和客户端证书文件，并分别解压。 此处以Windows系统为例，并假设解压后的Kaf
endpoint为https://{rest_connect_address}:9292，通过指定实例接口查询rest_connect_address的IP地址。 URI POST /v1/topic/{topic_name}/messages 表1 参数说明 参数 类型 必选 说明 topic_name
创建一个集成应用。 描述 填写策略的描述信息。 策略内容：支持表单模式和脚本模式两种方式，脚本模式配置请参见脚本配置示例。 策略基本信息 Broker地址 日志要推送的目标Kafka连接地址列表，多个地址间以英文逗号（,）隔开。 Topic主题 日志要推送的目标Kafka Topic名称。
否 Integer 服务归属的产品模板ID，产品模板ID和产品ID二选一必填，自动向下取整。 最小值：1 最大值：99999999999999999 product_id 否 Integer 服务归属的产品ID，产品模板ID和产品ID二选一必填，自动向下取整。 最小值：1 最大值：99999999999999999
Connect内分配唯一的ID和密码，使设备可以接入到ROMA Connect。 前提条件 ROMA Connect与停车场设备和停车场管理系统的网络互通。若通过公网互通，ROMA Connect实例需绑定弹性IP。 停车场设备包含车位感应设备和进出门闸设备，配置过程类似，此处以车位感应设备的配置为例进行说明。
数据源名称，方便您快速识别和查找。 集成应用 选择1中所创建的集成应用。 描述 填写MQS数据源的描述信息。 连接地址 选择当前ROMA Connect实例的“消息集成 MQS内网连接地址”，您可以在ROMA Connect控制台的实例信息页面查看该地址。 是否SSL 仅当ROMA
ConnectionConfig 说明 与RabbitMqConfig和RabbitMqProducer配合使用，对RabbitMQ客户端进行连接配置。 构造器详情 public ConnectionConfig(String host, int port, String userName, String
附录：如何提高消息处理效率 消息生产和消费的可靠性必须由ROMA Connect、生产者和消费者协同工作才能保证，对使用ROMA Connect的生产者和消费者有如下的使用建议。 重视消息生产与消费的确认过程 消息生产 生产消息后，生产者需要根据ROMA Connect的返回信息
SDK支持Node.js和浏览器两种运行环境，本章节Node.js开发环境为例介绍。 前提条件 已获取API的调用信息，具体请参见开发准备。 已安装开发工具和JavaScript开发语言环境，具体请参见开发准备。 Nodejs安装后，在命令行中，用npm安装“moment”和“moment-timezone”模块。
Q支持多种队列和主题模式，可以用于异步消息传递、发布/订阅、消息路由等场景。它还提供了可视化的管理界面，便于配置和监控，具有较高的可靠性和灵活性。ActiveMQ可用于构建分布式系统，支持多种编程语言和平台，提供了广泛的API支持。 创建ActiveMQ连接 登录新版ROMA Connect控制台。
同一个API，在不同环境中调用不同的后端服务。 负载通道 ROMA Connect通过创建负载通道，可访问同一VPC内的弹性云服务器（ECS），并把弹性云服务器中已部署的后端服务用于API开放。另外负载通道还可以实现后端服务访问的负载均衡功能。 生产者 生产者为向消息主题（Top
Q支持多种队列和主题模式，可以用于异步消息传递、发布/订阅、消息路由等场景。它还提供了可视化的管理界面，便于配置和监控，具有较高的可靠性和灵活性。ActiveMQ可用于构建分布式系统，支持多种编程语言和平台，提供了广泛的API支持。 创建ActiveMQ连接 登录新版ROMA Connect控制台。
在实际的生产中，API提供者可能有多个环境，如开发环境、测试环境、生产环境等，用户可以自由将API发布到某个环境，供调用者调用。 对于不同的环境，API的版本、请求地址甚至于包括请求消息等均有可能不同。如：某个API，v1.0的版本为稳定版本，发布到了生产环境供生产使用，同时，该API正处于迭代中，v1.
可查看授权应用的数据源。 可查看、调试和导出授权应用的API。 可查看和导出授权应用的Topic。 可查看授权应用的设备、产品和规则，可导出授权应用的设备、产品和规则，并调试设备。 modify 可在授权应用下创建和编辑数据源。 可在授权应用下创建、编辑、发布、下线和导入API。 可在授权应用下创建和编辑Topic。
若数据后端执行语句查询获取的数据量较大，建议携带offset和limit参数进行分页，避免因响应数据太大导致响应超时。使用方式如下： select * from table01 limit '${limit}' offset ${offset} 其中offset和limit参数key在后端服务请求的H
构造一个无参数的HttpClient。 方法列表 com.roma.apic.livedata.client.v1.HttpClient 返回类型 方法和说明 okhttp3.Response request(HttpConfig config) 用于发送rest请求 okhttp3.Response
导入API：支持导入YAML和JSON格式API定义文件，且文件内容应满足Swagger 2.0规范。 导出API：支持导出YAML和JSON格式API定义文件。 前提条件 导入API前，您需要在导入的API定义文件中补全API的Swagger扩展定义。 导入API前，请确保API和API分组的配额满足需求。
否 String 自定义后端API请求方式。 type = path时必填 ld_api_path 否 String 自定义后端API的访问地址。 type = path时必填 roma_app_id 否 String 集成应用ID。 校验应用下后端API定义是否重复时必填 响应参数
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
