检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
连接器 创建连接器 发布连接器 父主题: 数据集成指导
发布连接器 概述 在ROMA Connect中创建连接器后,您需要发布一个连接器实例,实现ROMA Connect与已部署连接器的对接。ROMA Connect通过已发布的连接器实例接入自定义数据源,实现对数据源的读写。 前提条件 已完成连接器的线下开发和部署,连接器与ROMA Connect
创建连接器 概述 ROMA Connect提供了常见的数据源连接支持,如关系型数据库、消息队列、API、NoSQL、对象存储等,这些数据源可以直接在ROMA Connect中使用,您只需要接入数据源,创建并启动数据集成任务,就可以将您的源端数据集成到目标端。 如果ROMA Connect
接入自定义数据源 概述 ROMA Connect支持把自定义的连接器作为一个数据源,并用于数据集成任务。在使用自定义数据源前,您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下,在接入数据源前您需要有可用的集成应用,否则请提前创建集成应用。 已有可用的连接器实例
添加SSL证书 如果API分组中的API支持HTTPS请求协议,则在绑定独立域名后,还需为独立域名添加SSL证书。SSL证书是进行数据传输加密和身份证明的证书,支持单向认证和双向认证两种认证方式。 单向认证:客户端与服务端连接时,客户端需要验证所连接的服务端是否正确。 双向认证:客户端与服务端连接时
定时器 定时器是一种能够按照预定的时间间隔触发特定操作的触发器。它可以在设定的时间周期内周期性地触发操作,也可以在指定的时间点触发操作。定时器常用于实现定时任务、定时调度等功能。 支持的动作 每分钟触发 每小时触发 每周触发 每月触发 固定时间间隔触发 配置参数 表1 每分钟触发
数据集成权限 表1 数据集成权限 权限 对应API接口 授权项(Action) 依赖的授权项 IAM项目 (Project) 企业项目 (Enterprise Project) 创建任务 POST /v2/{project_id}/fdi/instances/{instance_id
处理器 分支判断 并行处理 延时 EDI处理 变量赋值 变量修改 排序 数据转换 数据拆分 数据筛选 脚本处理 日志采集 数据映射 循环处理 异常监控 终止 对称加解密 非对称加解密
连接器 触发器 HTTP 数据库 华为云服务 SaaS应用 邮箱 其他 消息系统 自定义连接器
触发器 Open API FTP ActiveMQ Jira Software 定时器 ArtemisMQ RabbitMQ 事件网格 QQ邮箱 IBM MQ Kafka MySQL Oracle PostgreSQL Sql Server 父主题: 连接器
OpenAPI连接器 您可以创建一个自定义的OpenAPI连接器,支持通过OpenAPI标准的文件(支持json与yaml格式)导入,OpenAPI版本目前支持2.0与3.0。 Open API连接器支持多种鉴权模式,多种连接类型,支持自定义配置动作和动作参数。 创建OpenAPI
RSAUtils类说明 路径 com.roma.apic.livedata.common.v1.RSAUtils 说明 提供RSA加解密方法。 使用示例 通过以下java代码生成公钥和私钥: import java.security.KeyPair; import java.security.KeyPairGenerator
ActiveMQ ActiveMQ是一种基于Java Message Service(JMS)标准的开源消息中间件,提供可靠、高效、可扩展的消息传递机制,支持多种消息协议和传输协议,如TCP、UDP、SSL、NIO等。ActiveMQ支持多种队列和主题模式,可以用于异步消息传递、发布
Oracle Oracle连接器用于连接Oracle数据库,负责建立和维护应用程序和Oracle数据库之间的连接,并管理数据的传输。 Oracle是一个关系型数据库,以其高性能而闻名。 Oracle默认端口为1521,但是管理员可以根据需要将其更改为其他端口。 创建Oracle连接
FTP FTP连接器是基于FTP/SFTP协议实现文件传输的通道,通过FTP连接器可与外部FTP服务器进行文件交换。 FTP(File Transfer Protocol,文件传输协议)是TCP/IP 协议组中的协议之一。FTP协议包括两个组成部分:FTP服务器和FTP客户端。其中
Kafka Kafka是一个分布式流处理平台,最初由LinkedIn开发。它是一个高吞吐量、低延迟的平台,可以处理大量的实时数据流。Kafka主要由三个部分组成:生产者、消费者和代理服务器。生产者将数据发布到Kafka集群,消费者从Kafka集群订阅数据并进行处理,代理服务器则是Kafka
Open API Open API连接器用于生成并发布一个API,该API的具体实现将由“Open API”组件的后续组件完成。因此“Open API”组件只能作为组合应用的触发事件,且后续必须连接其它节点。 流任务启动成功后,用户可以在对应ROMA Connect实例的“服务集成
事件网格 事件网格(EventGrid,简称EG)是华为云提供的一款Serverless事件总线服务,支持华为云服务、自定义应用、SaaS应用以标准化、中心化的方式接入事件网格,通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件,帮助您轻松构建松耦合、分布式的事件驱动架构
IBM MQ IBM MQ是IBM提供的一个消息队列软件,它可以在分布式系统中进行异步通信,确保数据的可靠传输。MQ是一种基于消息的中间件,它提供了一种可靠、安全的方式来传输消息,可以在不同的应用程序、平台和系统之间进行通信。MQ可以确保消息在传输过程中不会丢失、重复或失序,并且可以在不同的系统之间进行数据转换和格式化
ArtemisMQ ArtemisMQ 是一个开源的高性能消息队列(Message Queue)系统,它是基于 Apache ActiveMQ 和 Apache Artemis 的技术构建而成的。ArtemisMQ 提供了可靠的异步消息传递机制,允许不同的应用程序之间通过消息进行通信