检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
业务使用介绍 功能简介 消息集成MQS是ROMA Connect的消息集成组件,使用统一的消息接入机制,提供跨网络访问的安全、标准化消息通道。使用ROMA Connect进行消息集成,有如下优势: 支持原生Kafka特性 兼容社区版Kafka的API,具备原生Kafka的所有消息处理特性。
对象存储服务 对象存储服务连接器用于对接华为云对象存储服务。 对象存储服务(Object Storage Service,简称OBS)是一个基于对象的海量存储服务,为您提供海量、安全、高可靠、低成本的数据存储能力。 创建对象存储服务连接 登录新版ROMA Connect控制台。
支持在源端或者目标端故障恢复后,或者人工重启任务后,自动从上次中断的位置恢复执行,继续进行数据采集,保证数据不丢失。 使用流程 使用ROMA Connect进行数据集成的流程如下图所示。 图1 业务使用流程 已创建实例和集成应用。 接入数据源。 接入源端和目标端数据源,确保可以正常从源端读取数据以及向目标端写入数据。
消息集成 向Topic生产的消息是否有长度限制? MQS支持的Kafka服务端版本是多少?
n内共享弹性计算、块存储、对象存储、VPC网络、弹性公网IP、镜像等公共服务。Region分为通用Region和专属Region,通用Region指面向公共租户提供通用云服务的Region;专属Region指只承载同一类业务或只面向特定租户提供业务服务的专用Region。 可用区(AZ,Availability
实例管理 区域和可用区 创建实例时为什么无法查看子网和安全组等信息? 实例创建后,支持修改VPC和子网吗? 是否支持跨VPC和跨子网访问ROMA Connect? 同一个实例中,为什么看到的数据跟其他人看到的不一样?
设备集成 设备集成支持哪些通信协议? 为什么我的设备不能接入设备集成? 为什么规则引擎的数据目的端未收到设备发送的消息?
数据集成 数据集成普通任务 数据集成组合任务
况填写。 认证使用的AK和SK硬编码到代码中或者明文存储都有很大的安全风险,建议在配置文件或者环境变量中密文存放,使用时解密,确保安全;本示例以AK和SK保存在环境变量中为例,运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和CLOUD_SDK_SK。
使用自定义认证 创建自定义认证的API 在ROMA Connect中创建一个使用自定义认证的API。 在实例控制台的左侧导航栏选择“服务集成 APIC > API列表”,在页面右上角单击“创建API”。 在创建API页面配置API的前端请求信息。 图1 前端请求信息 表1 前端请求信息
使用ROMA Connect集成消息 概述 ROMA Connect提供了安全、标准化消息通道,实现不同消息系统的集成对接。 本章节通过完成一个使用Kafka命令行与ROMA Connect对接的配置样例,帮助您快速熟悉使用ROMA Connect集成消息的过程。 使用ROMA Connect集成消息的步骤如下所示:
world”),帮助您快速熟悉ROMA Connect组合应用的使用过程。 使用ROMA Connect组合应用的步骤如下所示: 步骤一:新建组合应用 步骤二:配置工作流 步骤三:发布应用 步骤四:验证结果 准备工作 在开始操作前,您需要提前完成以下准备工作。 已申请体验版实例或者已创建新版ROMA Connect实例。
erature”。 表2 服务能力信息配置 参数 配置说明 物模型服务名称 填写物模型服务的名称,此处填写为“Temperature”。 是否启用 是否启用该物模型服务,保持默认“启用”。 描述 填写物模型服务的描述信息。 为物模型服务添加属性。 在“物模型”页签下的左侧选择3中添加的物模型服务。
Java Demo使用说明 操作场景 除了前面章节介绍的使用原生Kafka客户端,MQS实例还可以通过HTTP RESTful方式访问,包括向指定Topic发送消息、消费消息以及确认消费。 这种方式主要用于适配原有业务系统架构,方便统一使用HTTP协议接入。 入门版规格实例不支持RESTful
使用已订阅的资产 用户可以基于已订阅的资产,快速完成应用和数据集成业务的构建,减少业务的部署时间。 使用已订阅的API资产 登录新版ROMA Connect控制台。 在左侧导航栏选择“资产中心>我的资产”,切换到“我的订阅”页签。 单击需要使用的资产名称,并切换到“API资产”页签。
模型管理 管理模型采集任务 同步数据库和缓存数据 父主题: 应用业务模型使用指导
使用自定义后端开发自定义认证 方案概述 开发自定义认证 使用自定义认证
采集技术模型 接入扩展采集器(可选) 接入数据源 创建采集任务 父主题: 应用业务模型使用指导
数据源 数据源连接测试失败排查操作 MRS Hive数据源测试连接失败 FTP数据源测试连接失败 OBS数据源测试连接失败 Kafka数据源连接失败
录入业务模型 创建信息架构 录入资产目录 录入基础数据 父主题: 应用业务模型使用指导