正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
间被删除,腾出存储空间后(剩余存储空间大于5%),才能接收新的消息生产请求。此策略适用于消息消费处理较慢,或者对存量消息需要反复消费,不能提前删除的场景。 自动删除:自动删除最老的消息(消息总量的10%),腾出存储空间,以接收新的消息生产请求,消息生产业务不受影响。此策略适用于消
接入数据源 概述 在创建数据集成任务前,ROMA Connect需要先接入源端和目标端数据源,确保可以正常从源端读取数据以及向目标端写入数据。 前提条件 在接入数据源前,请确保ROMA Connect实例与您的数据源所在网络互通。 若ROMA Connect实例与数据源在相同VPC内时,可直接访问数据源。
计费项 计费说明 应用与数据集成平台的计费项为ROMA Connect实例。具体内容如表1所示。 表1 应用与数据集成平台计费项 计费项 计费项说明 适用的计费模式 计费公式 ROMA Connect实例 华为云ROMA Connect按照您选择的ROMA Connect实例规格进行计费。
使用ROMA Connect组合应用 组合应用可进行应用的复合集成,通过开放的API和事件通道进行应用的多次组装,形成新的组合应用,实现业务快速复制创新。 本章节通过以组合应用的方式开放一个接口为例(当访问这个接口的时候,系统返回“hello world”),帮助您快速熟悉ROMA
Java Demo使用说明 操作场景 除了前面章节介绍的使用原生Kafka客户端,MQS实例还可以通过HTTP RESTful方式访问,包括向指定Topic发送消息、消费消息以及确认消费。 这种方式主要用于适配原有业务系统架构,方便统一使用HTTP协议接入。 入门版规格实例不支持RESTful
Base64Utils类说明 路径 com.roma.apic.livedata.common.v1.Base64Utils 说明 提供Base64Utils编码和解码功能。 使用示例 Base64编码示例: importClass(com.roma.apic.livedata.common
在新增的请求参数中,“参数名”填写“x-auth”,“参数值”填写“user1:xxxx”。 图4 API调试 单击URL右侧的“调试”,页面下方显示调用API发送的请求信息和接收的响应结果信息。 此时,响应结果中显示调用API成功的响应信息“ROMA TEST!”。 HTTP/1.1 200 OK Transfer-Encoding:
ROMA Connect支持的数据源 数据集成任务支持的数据源 表1中为数据集成所支持的全量数据源类型,具体每种数据源所支持的任务模式和集成模式请参见接入数据源。 连接数据源的用户需要有创建连接数据库会话的权限。 表1 数据集成支持的数据源 数据源类型 支持的版本 API 无版本号
接入HL7数据源 概述 ROMA Connect支持把HL7(卫生信息交换标准)作为一个数据源,并用于数据集成任务。在使用HL7数据源前,您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下,在接入数据源前您需要有可用的集成应用,否则请提前创建集成应用。 操作步骤
创建Topic 概述 创建用于存储消息的Topic,供消息生产方发布消息和供消息消费方订阅消息。 前提条件 每个Topic都要归属到某个集成应用下,在创建Topic前您需要有可用的集成应用,否则请提前创建集成应用。 操作步骤 登录ROMA Connect控制台,在“实例”页面单击
SSL证书管理 概述 如果API分组中的API支持HTTPS请求协议,则在绑定独立域名后,还需为独立域名添加SSL证书。 前提条件 仅支持添加pem编码格式的SSL证书。 添加的SSL证书仅支持RSA、ECDSA和DSA加密算法。 创建SSL证书 登录ROMA Connect控制
ELK部署在独立服务器中,ELK的Logstash接收到日志数据后,根据设置的过滤解析规则,对日志数据进行拆分和过滤,然后将解析后的日志数据发送到ELK的ElasticSearch进行存储。 ELK的ElasticSearch接收到日志数据后,生成日志数据的索引并存储数据,为Ki
间被删除,腾出存储空间后(剩余存储空间大于5%),才能接收新的消息生产请求。此策略适用于消息消费处理较慢,或者对存量消息需要反复消费,不能提前删除的场景。 自动删除:自动删除最老的消息(消息总量的10%),腾出存储空间,以接收新的消息生产请求,消息生产业务不受影响。此策略适用于消
函数后端脚本开发说明 开发说明 函数后端通过编写函数脚本实现将多个服务封装成一个服务,在实际开发前请务必提前了解自定义后端开发要求。 函数后端当前仅支持使用JavaScript编写函数,JavaScript引擎运行于Java虚拟机,可调用ROMA Connect提供的Java类实现具体功能。
IAM认证开发(Token) 操作场景 当您使用Token认证方式完成认证鉴权时,需要获取用户Token并在调用接口时增加“X-Auth-Token”到业务接口请求消息头中。 调用接口有如下两种认证方式,您可以选择其中一种进行认证鉴权。 Token认证:通过Token认证调用请求。
计费概述 通过阅读本文,您可以快速了解应用与数据集成平台ROMA Connect的计费模式、计费项、续费、欠费等主要计费信息。 计费模式 旧版ROMA Connect提供包年/包月的计费模式。新版ROMA Connect提供按需计费、套餐包两种计费模式。 包年/包月是一种预付费模
根据ROMA Connect实例是否开启SASL_SSL,向Topic收发消息的操作有所差异。若开启SASL_SSL访问,则客户端向Topic发送和接收的消息会加密传输,安全性更高。 解压Kafka命令行工具和客户端证书。 在本地PC找到已下载的Kafka命令行工具和客户端证书文件,并分别解压。
附录 获取项目ID 获取账号ID 状态码 错误码 实例支持的APIC特性 数据集成参数说明 获取数据源配置文件
则,允许规则引擎的数据目的端接收所有设备发送的消息。如果您在没有创建其他入方向规则的情况下删除了这条规则,会让整个安全组缺少入方向规则,导致规则引擎的数据目的端不能收到设备发送的消息。 您可以通过添加入方向规则解决这个问题。如果业务场景需要规则引擎接收特定设备发送的信息,您可以添
acks=0:表示producer不需要等待任何确认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败),回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待lead