附录 配置抽取文件模板 性能数据 CHR/MR数据 配置数据 父主题： 数据解析

查看更多 →

什么是信息抽取 信息抽取是从基础数据中抽取待创建图谱的实体、属性信息以及实体间的相互关系。目的是从原始数据（包括结构化数据或非结构化数据）中抽取结构化的信息。 配置方式 信息抽取分为结构化抽取和非结构化抽取，其适用范围和抽取方式如表1所示。 表1 配置方式说明 配置方式 适用范围

查看更多 →

取值： mysql：MySQL到MySQL迁移，MySQL到MySQL同步 mongodb：MongoDB到DDS迁移 cloudDataGuard-mysql：MySQL到MySQL灾备 gaussdbv5： GaussDB 同步 mysql-to-kafka：MySQL到Kafka同步

查看更多 →

2 1,800.00 数据库安全服务 数据库安全审计 | 基础版; 1 30,000.00 分布式缓存服务Redis版 基础版 | 5.0 | 主备 | X86 | D RAM | 2 | 4 GB; 1 2,776.00 分布式消息服务Kafka版 kafka.2u4g.cluster

查看更多 →

。 多并发抽取/写入速率，定义为分别取作业抽取并发数为1、10、20、30、50时，最大的抽取/写入速率。 数据源抽取写入性能实测数据 常见数据源的性能实测结果分别如表1和表2所示。 表1 读取性能实测数据 数据源 数据源规格 版本 单并发抽取速率（行/s） 多并发抽取速率（行/s）

查看更多 →

。 多并发抽取/写入速率，定义为分别取作业抽取并发数为1、10、20、30、50时，最大的抽取/写入速率。 数据源抽取写入性能实测数据 常见数据源的性能实测结果分别如表1和表2所示。 表1 读取性能实测数据 数据源 数据源规格 版本 单并发抽取速率（行/s） 多并发抽取速率（行/s）

查看更多 →

支持设置Kafka同步策略的有：PostgreSQL-Kafka同步，Oracle-Kafka同步，GaussDB-Kafka同步，GaussDB(for MySQL)-Kafka，MySQL-Kafka。 GaussDB(for MySQL)-Kafka，MySQL-Kafk

查看更多 →

管理驱动 管理集群配置 配置OBS连接 配置PostgreSQL/SQLServer连接 配置 数据仓库 服务（DWS）连接 配置云数据库MySQL/MySQL数据库连接 配置Oracle数据库连接 配置 DLI 连接 配置Hive连接 配置HBase连接 配置HDFS连接 配置FTP/SFTP连接

查看更多 →

仅支持目标库版本等于或高于源库版本。 MySQL为源迁移方案 表1 数据库信息 源数据库引擎 源数据库类型和版本 目标数据库类型和版本 迁移类型 MySQL 自建MySQL 5.5、5.6、5.7、8.0版本 其他云上MySQL 5.5、5.6、5.7、8.0版本 RDS for MySQL 所有版本 全量数据迁移

查看更多 →

分布式消息（Kafka） 分布式消息（Kafka）连接器包含“Topic列表”、“发送数据”、“指定分区发送”三个执行动作和“消费消息”一个触发事件。 连接参数 创建分布式（Kafka）连接时连接参数说明如表1所示。如果需要连接的Kafka配置了IP地址白名单限制，则需要放通 集成工作台 公网出口访问地址“124

查看更多 →

管理驱动 管理集群配置 配置OBS连接 配置PostgreSQL/SQLServer连接 配置数据仓库服务（DWS）连接 配置云数据库MySQL/MySQL数据库连接 配置Oracle数据库连接 配置DLI连接 配置Hive连接 配置HBase连接 配置HDFS连接 配置FTP/SFTP连接

查看更多 →

作业名称：输入便于记忆、区分的作业名称，例如：“mysql2dws”。 源端作业配置 源连接名称：选择步骤2：创建连接章节中创建的MySQL连接“mysqllink”。 使用SQL语句：选择“否”。 模式或表空间：选择从MySQL的哪个数据库导出表。 表名：选择导出哪张表。 其他可选参

查看更多 →

新增RDS for MySQL同步到Kafka。 新增其他云MySQL迁移到GaussDB(for MySQL)。 2021-10-30 第八次正式发布，包含以下修改点： 新增自建MySQL迁移到RDS for MySQL。 新增本地Oracle同步到GaussDB分布式版。 2021-08-30

查看更多 →

配置目的端作业参数，根据待导入数据的云服务配置对应参数，如表2所示。 表2 目的端作业参数 目的端数据库类型 目的端参数 参数说明 取值样例 云数据库MySQL 云数据库PostgreSQL 云数据库SQL Server - 整库迁移到RDS关系数据库时，目的端作业参数请参见配置MySQL/SQL Se

查看更多 →

Kafka Kafka是一个分布式流处理平台，最初由LinkedIn开发。它是一个高吞吐量、低延迟的平台，可以处理大量的实时数据流。Kafka主要由三个部分组成：生产者、消费者和代理服务器。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是

查看更多 →

数据库类—MySQLQuery MySQL SELECT操作使用，系统限制最大查询结果行数100条。 参数 是否必选 参数类型 描述 Ip 是 String 数据库ip 如果是华为云RDS实例，需要绑定EIP，并保证实例端口安全组策略开启放行，详细请参考华为云：通过公网连接MySQ L实例 。

查看更多 →

数据库类—MySQLInsert 适用于MySQLInsert 插入数据操作使用。 参数 是否必选 参数类型 描述 Ip 是 String 数据库ip: 如果是华为云RDS实例，需要绑定EIP，并保证实例端口安全组策略开启放行，详细请参考华为云：通过公网连接MySQL实例。 Port

查看更多 →

查询数据库错误日志（MySQL） 功能介绍 查询数据库最近的错误日志信息，最多查询2000条。 该接口计划于2025-03-31下线，建议及时切换到新接口查询错误日志。 调用接口前，您需要了解API 认证鉴权。 调试 您可以在 API Explorer 中调试该接口。 接口约束 该接口仅支持MySQL引擎。

查看更多 →

上此依赖。 数据库驱动 否 根据实际需要确定，如果你的实时任务中使用了数据库，那么就需要添加对应数据库的驱动程序包 如使用了oracle和mysql,那么就需要添加oracle和mysql的jdbc驱动。如果没使用数据库则不需要 父主题： 实时处理服务部署

查看更多 →

示例 使用Kafka发送数据，通过JDBC结果表将Kafka数据再输出到MySQL数据库中。 参考增强型跨源连接，在DLI上根据MySQL和Kafka所在的虚拟私有云和子网分别创建相应的增强型跨源连接，并绑定所要使用的Flink弹性资源池。 设置MySQL和Kafka的安全组，添

查看更多 →

示例 使用Kafka发送数据，通过JDBC结果表将Kafka数据再输出到MySQL数据库中。 参考增强型跨源连接，在DLI上根据MySQL和Kafka所在的虚拟私有云和子网分别创建相应的增强型跨源连接，并绑定所要使用的Flink弹性资源池。 设置MySQL和Kafka的安全组，添

查看更多 →