检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
处理器 分支判断 并行处理 延时 EDI处理 变量赋值 变量修改 排序 数据转换 数据拆分 数据筛选 脚本处理 日志采集 数据映射 循环处理 异常监控 终止 对称加解密 非对称加解密 XML校验
M用户创建并授权的集成应用为“授权应用”。 对象 可查看和管理本集成应用下的资源,包括数据源、API、Topic和设备,您可对本集成应用下的资源进行创建、编辑、删除等操作,具体操作指导请参考数据源、API、Topic和设备的使用指导。 父主题: 集成应用管理
求体表单中上传文件使用的参数名称,可以通过变量的方式引用前序节点中的数据,请参考引用变量。 内容 仅当“输入方式”选择“文本输入”时需要配置。 获取上一个组件传递的文件信息,可以通过变量的方式引用前序节点中的数据,请参考引用变量。 父主题: 处理器
Connect。设备接入ROMA Connect后,即可以上报设备数据到ROMA Connect。您也可以通过ROMA Connect向设备下发控制命令,以达到控制设备的效果。 ROMA Connect不会直接存储设备上报的数据,您需要配置数据转发规则,把设备数据转发到其他服务进行存储。 约束与限制 通过
函数后端脚本开发说明 开发说明 函数后端通过编写函数脚本实现将多个服务封装成一个服务,在实际开发前请务必提前了解自定义后端开发要求。 函数后端当前仅支持使用JavaScript编写函数,JavaScript引擎运行于Java虚拟机,可调用ROMA Connect提供的Java类实现具体功能。
选择实例,用于后续验证连通性。 连接与安全 选择数据库的连接模式。当前支持“默认”模式,由系统根据用户配置自动拼接数据源连接字符串。 主机IP地址 填写数据库的连接IP地址。 端口 填写数据库的连接端口号。 数据库名 填写要连接的数据库名。 用户名 连接数据库的用户名。 密码 连接数据库的用户密码。 描述
XML校验 “XML校验”处理器用于对XML格式数据处理时,进行内容校验与处理。如校验正确在系统日志中没有错误信息,校验失败系统日志中会打印异常信息,并结束流任务的运行。 配置参数 参数 说明 XML 待校验的xml数据,文本输入大小限制10万字符。 XML Schemas Definition
定弹性IP地址。 数据接入服务 数据接入服务(Data Ingestion Service,简称DIS)为处理或分析流数据的自定义应用程序构建数据流管道,面向IoT、互联网等实时数据,提供高效采集、传输、分发能力。 ROMA Connect可以使用DIS作为数据集成任务的源端和目
费模式能提供较高的成本效益。 长期项目:对于周期较长的项目,如科研项目、大型活动策划等,包年/包月计费模式可以确保在整个项目周期内资源的稳定使用。 业务高峰预测:如果能预测到业务高峰期,如电商促销季、节假日等,可提前购买包年/包月资源以应对高峰期的需求,避免资源紧张。 数据安全要
消息集成API MQS实例管理 主题管理 应用权限管理 消息管理 消费组管理
设备集成API 设备分组管理 设备管理 订阅管理 产品模板 产品管理 规则引擎 服务管理
用户升级MySQL。 对于组合任务,可以尝试通过修改配置的方法规避,首先删除此表的配置,启动任务后会跳过这些数据,等任务执行成功后,再将表配置回来重新采集。 父主题: 数据集成组合任务
检索模型 概述 通过模型地图,用户可以根据模型的名字和路径关键字进行资产检索,快速查找所需数据信息。 前提条件 已完成采集技术模型和录入业务模型。 操作步骤 登录ROMA Connect,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“应用业务模型ABM
提高消费者的消费速度,通过优化消费者处理逻辑(减少复杂计算、第三方接口调用和读库操作),减少消费时间。 增加消费者每次拉取消息的数量:拉取数据/处理时间 >= 生产速度。 生产者端 生产消息时,给消息Key加随机后缀,使消息均衡分布到不同分区上。 在实际业务场景中,为消息Key加
速识别和查找。 数据类型 选择属性数据的数据类型。 Int:整型。选择“Int”时,还需填写最小值、最大值、步长和单位。 Number:数值。选择“Number”时,还需填写最小值、最大值、步长和单位。 String:字符串。选择“String”时,还需填写数据长度上限和枚举值。
获取资产包所属源实例的配置信息,仅资产迁移场景需要。 主要包括实例的安全组配置、实例配置参数和数据字典信息。 获取周边系统的对接信息,仅资产迁移场景需要。 系统 数据项 用途 数据源 数据源的访问IP、用户名和密码。 用于ROMA Connect对接数据源。 业务应用 业务应用的网段信息。 用于打通ROMA Connect到业务应用的网络。
y和Secret进行API请求的安全认证。 创建并开放数据API 接入数据源 接入数据源,确保可以正常从数据源读取数据。 创建数据后端 把数据源定义为后端服务,实现从数据源中读写数据。 发布数据API 发布数据后端,生成数据API,并对外开放。 绑定域名 在开放API前,您需要为
Kafka是一个分布式流处理平台,最初由LinkedIn开发。它是一个高吞吐量、低延迟的平台,可以处理大量的实时数据流。Kafka主要由三个部分组成:生产者、消费者和代理服务器。生产者将数据发布到Kafka集群,消费者从Kafka集群订阅数据并进行处理,代理服务器则是Kafka集群中的核心组件,负责处理消息的存储和转
Server或DB2数据库。 loop_index 上一个循环处理节点,当前循环的索引,从0开始。 loop_size 上一个循环处理节点的循环总次数。 split_index 上一个数据拆分节点,在数据拆分时当前数据块的索引,从0开始。 split_size 上一个数据拆分节点的数据拆分数量。
服务集成指导(旧版界面) 业务使用介绍 开放API 创建并开放数据API 创建并开放函数API 调用API API管理 自定义后端管理 控制策略管理 插件管理 配置自定义认证 配置后端服务的签名校验 配置API级联