检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Hive MRS 3.*.* MRS Kafka MRS 3.*.* MySQL 5.7、8.0 OBS 3 Oracle 11.2g(不推荐)、12.1g(不推荐)、12.2g、19c PostgreSQL 11 RabbitMQ 3.6.10 RocketMQ 4.8.0 Redis
Connect数据集成适用于异构数据源之间的数据类型转换和按需集成。对于业界主流数据库之间的数据迁移、同步场景，建议使用数据复制服务DRS；对于关系型数据库、大数据、文本等数据迁移到数据湖的场景，建议使用云数据迁移CDM。 表1 接入数据源 数据源接入配置 普通任务支持的集成模式（源端）
Hive”。 数据源名称 选择接入数据源中已配置的MRS Hive数据源。 目标端数据库名 选择待集成数据要写入的数据库。 说明： 需要使用自建的数据库，不能使用MRS Hive自带的default数据库。 目标端表 选择待集成数据要写入的数据表。 分隔符 填写MRS Hive数据源
OPENGAUSS：GaussDB数据源 MYSQL：MySQL数据源 ORACLE：Oracle数据源 POSTGRESQL：PostgreSQL数据源 SQLSERVER：SQL Server数据源 TAURUS：GAUSSDB(FOR MYSQL)数据源 DIS：DIS数据源 DWS：DWS数据源
联合查询，设备数量过多时可能存在查询超时，建议只查询单个条件并增加查询字段。 最小长度：2 最大长度：64 client_id 否 String 设备客户端ID，平台生成的设备唯一标识。设备名称、客户端ID、设备物理编号联合查询，设备数量过多时可能存在查询超时，建议只查询单个条件并增加查询字段。
实时的时间差。此指标主要针对Oracle类型任务，MySQL类型可忽略。 CDC已经处理结束、成功同步到目标端的最新的那个事务时间与当前时间的时间差，此指标比较真实的反映了数据写入的实际延迟，根据项目实际业务数据量配置延迟，建议配置 >= 3600 (1小时)。 ≥0 单位：毫秒
选择创建MQS到数据库的集成任务中接入的MySQL数据源。 选择执行语句类型 选择执行语句的类型，此处选择“SQL”。 高级设置 高级设置保持默认设置。 添加数据源后，在编辑器左侧选择数据源，然后您可以在右侧的语句编辑框中为数据源添加如下执行语句，从数据库中获取当前空余车位数量。 假设M
数据库 MySQL Redis DB2 GaussDB DWS Milvus Oracle PostgreSQL Sql Server 父主题： 连接器
接入FI Hive数据源 接入MySQL数据源 接入MongoDB数据源 接入MRS Hive数据源 接入MRS HBase数据源 接入FI HBase数据源 接入Oracle数据源 接入SQL Server数据源 接入DAMENG数据源 接入POSTGRESQL数据源 接入SFTP数据源
* 支持 支持 不支持 不支持 MySQL 5.7、8.0 支持 支持 支持 支持 OBS 3 支持 支持 不支持 不支持 Oracle 11.2g(不推荐)、12.1g(不推荐)、12.2g、19c 支持 支持 支持 支持 PostgreSQL 11 支持 支持 支持 支持 RabbitMQ
"info":"zz"}，其中xx、yy、zz为从源端传入的数据值。 MySQL 返回页首 任务的“集成模式”为“定时”或“实时”时，可以选择MySQL作为目标端数据源，具体配置如下。 表7 目标端MySQL信息 参数 配置说明 目标端表 选择已有的表，单击“选择表字段”，可以选择只需要集成的数据列字段。
数据信息。 MySQL 返回页首 任务的“集成模式”为“定时”时，可以选择MySQL作为源端数据源。 在创建任务页面中配置源端信息。 表15 源端MySQL信息 参数 配置说明 源端实例 选择当前正在使用的ROMA Connect实例。 源端集成应用 选择MySQL数据源所属的集成应用，在接入数据源时已配置。
多个数据源编排 一个数据API可以包含多个数据源，因此一次API请求可以涉及多个数据源，例如取第一个数据源查询结果作为第二个数据源的参数。 以MySQL为例说明，假设数据API有数据源1和数据源2，user01是数据源1的数据表和user02是数据源2的数据表，两张表的结构如下： 表1 表结构
为ElasticSearch数据配置索引生命周期策略。 10个 8核 16GB ELK：Kibana 5个 2核 256MB Kibana的磁盘空间需求取决于Kibana面板数量、复杂度、更新频率、在ElasticSearch中创建的索引数量及大小，磁盘空间需求较少，约500MB。
仅当“连接模式”选择“专业”时需要配置。 填写MySQL数据库的JDBC格式连接串，例如：jdbc:mysql://{hostname}:{port}/{dbname}。 {hostname}为数据库的连接地址。 {port}为数据库的连接端口号。 {dbname}为要接入的数据库名。 用户名 填写连接数据库的用户名。
选择实例所在的可用区，不同可用区之间物理隔离，但内网互通。 如果您需要提高ROMA Connect运行的可靠性，建议您将实例创建在不同的可用区内。 如果您需要较低的网络时延，建议您将实例创建在相同的可用区内。 CPU架构 根据当前环境所支持的CPU架构，可选择项有所不同，选择“x86计算”或“鲲鹏计算”。
Connect实例的规格选择参考，实际可创建的资源数量（如数据集成任务数、API数和消息Topic数）请参见配额限制。为了保证ROMA Connect的使用性能，请在规格范围内创建和使用资源。 系统数说明：系统指的是用户的业务系统，系统数指ROMA Connect实例集成对接的业务系统数量。一个业务系统与ROMA
设置数据源类型，可以为"mysql","mssql","oracle","postgresql","hive","redis","mongodb" 输入参数 type：类型 public void setUrl(String url) 设置数据源连接字符串。 如果数据源类型为"mysql","mssql"
接入Kafka数据源 接入MySQL数据源 接入MongoDB数据源 接入MQS数据源 接入MRS Hive数据源 接入MRS HDFS数据源 接入MRS HBase数据源 接入MRS Kafka数据源 接入OBS数据源 接入Oracle数据源 接入PostgreSQL数据源 接入Redis数据源
in this operation”错误 Mysql到Mysql时源端报“Illegal mix of collations for operation 'UNION'”错误 源端Mysql增量采集每小时执行一次时部分数据丢失 API到MySQL时源端报“401 unauthorized”错误
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
