在现代企业中，数据无处不在，贯穿于各个业务环节和系统之间。无论是跨系统的数据集成、多地域的数据协同，还是实时应用的数据同步，数据的一致性和及时性都至关重要。在数字化转型的过程中，如何确保不同系统、地域、设备之间的数据同步，成为了企业面临的重要挑战。
本专题将基于实践经验，从常见需求入手，为大家介绍热门数据源与数据目标之间的数据同步（全量/增量）如何实现？了解如何快速搭建数据管道，实现数据的高效迁移与无缝同步。
本文教程为：**MySQL → MongoDB **的数据同步任务。
在实际应用中，数据同步涉及诸多场景，如容灾备份、应用改造/替代、数据库版本升级/回退、数据库替代、业务分流等，不同的场景在数据流向、同步需求、数据处理等方面会有不同的需求，需要针对性地选择迁移工具和方案。
以 MySQL 到 MongoDB 的数据同步需求为例，这样从关系型数据库到非关系型数据库的数据移动需要考虑数据结构的差异和转换规则。MySQL 基于表结构，而 MongoDB 是文档型数据库，数据格式更为灵活。同步过程中，需要将 MySQL 中的表结构映射到 MongoDB 的文档结构，并确保数据类型兼容。此外，还需考虑数据一致性、实时性要求，以及增量同步机制的实现。
一、什么是 MySQL？
MySQL 是一个流行的开源关系型数据库管理系统（RDBMS），其特点是高性能、可靠性和易用性，广泛应用于 Web 应用、企业应用和数据仓库。基于 SQL（结构化查询语言），MySQL 适用于各种规模的应用、具有跨平台特性、提供多种存储引擎、支持事务和外键。其中，MySQL 的高性能和可靠性在实际应用中尤为重要，因为它能够处理大量的数据和高并发的请求，而不会显著降低系统的响应速度。MySQL 的易用性也是一个关键优势，用户可以通过图形化界面或者命令行进行数据库管理，相对简单易学。
优势
- 开源：社区活跃，提供持续的更新和支持。
- 跨平台：支持多种操作系统，如 Windows、Linux 和 macOS。
- 高性能：优化了读写性能，适合处理大量数据。
- 灵活性：支持多种数据类型，包括整型、浮点数、字符串和日期等。
- 安全性：提供多层次的安全特性，包括用户权限管理、加密连接等。
二、什么是 MongoDB？
MongoDB 是一款面向文档的、分布式数据库系统，用于存储和管理大量结构化和非结构化数据。其核心概念包括文档存储和分布式，主要特性有动态模式、索引、聚集、映射-归约和复制。它广泛应用于内容管理系统、电子商务平台、社交媒体网站、物联网应用和移动应用开发等领域。MongoDB 利用灵活的文档取代表和行来处理和存储各种形式的数据。 作为 NoSQL 数据库解决方案，MongoDB 提供了一个弹性数据存储模型，可以让用户轻松地存储和查询多元数据类型。 不仅简化了数据库管理，而且为跨平台应用程序和服务创建了高度可扩展的环境。MongoDB 的设计理念是为了应对大数据量、高性能和灵活性需求，它以 JSON-like 的格式存储数据，使得数据结构更加灵活和丰富。
优势
- 负载均衡：MongoDB 的负载均衡共享过程一次性跨多个虚拟机分布大量数据，同时仍保持可接受的读写吞吐量。 这种水平扩展可以帮助组织避免硬件垂直扩展的成本，同时还能扩展基于云的部署的容量。
- 特设数据库查询：MongoDB 能够处理不需要预定义模式的特设数据库查询。通过使用一种类似于 SQL 数据库的查询语言，对于入门和高级开发人员而言都非常容易上手。这种便利性使用户能够通过常见的帮助命令和简单的 shell 命令轻松地推送、查询、排序、更新和导出数据。
- 多语言支持：MongoDB 曾发布了多个版本，并且仍在持续开发中，具备对流行编程语言的驱动程序支持，包括 Python、PHP、Ruby、Node.js、C++、Scala、JavaScript 等。
三、方案选择：如何实现 MySQL → MongoDB 的数据同步？
实现 MySQL 到 MongoDB 的数据同步的常见方式包括，手动构建数据管道或使用自动化工具：
手动构建数据管道
例如编写 Python 脚本来处理数据的提取、转换和加载（ETL）。这里可以借助 Apache Airflow 等工具来调度和管理这些任务。然而，这种手动方法需要开发者具备深厚的编程和数据工程知识，通常需要花费一周甚至更长时间来完成整个开发流程。此外，手动构建的数据管道需要持续的维护和监控，以确保数据的准确性和实时性。
自动化工具
例如选择使用 TapData 这样的自动化数据集成平台，只需三步就可以在几分钟内开启所需的数据同步任务：
- 将 MySQL 设置为源连接
- 将 MongoDB 设置为目标连接
- 定义要传输的数据以及传输频率
TapData 内置 100+ 数据连接器，提供了友好的用户界面和强大的实时同步功能，无需编写复杂的代码即可轻松实现数据的迁移和同步。这样不仅节省了大量的时间和人力成本，还能保障数据同步过程的稳定性和可靠性。对于那些希望快速、高效地完成 MySQL 到 MongoDB 数据同步的企业和开发者来说，这样的便捷工具无疑是一个理想的选择。
四、TapData 高效同步完整教程
完成 TapData Agent 部署后，即可跟随以下教程在 TapData 中添加源与目标的数据连接（支持版本：MySQL 5.0、5.1、5.5、5.6、5.7、8.x；MongoDB 3.4、3.6、4.0+），并快速构建数据管道。（*涉及工具版本为 TapData 本地部署版）
版本指路：
>>> 点击登录 TapData Cloud
>>> 申请试用 TapData 本地部署版
① 准备工作（作为源库）
数据源：MySQL
为保障任务的顺利执行，您需要为 MySQL 数据库开启 Binlog（可实现增量数据同步），然后为数据复制/开发任务创建一个数据库账号。
- 登录 MySQL 数据库，执行下述格式的命令，创建用于数据同步/开发任务的账号。
- MySQL 5.x
- MySQL 8.x
CREATE USER 'username'@'host' IDENTIFIED BY 'password';
- username：用户名。
- password：密码。
- host：允许该账号登录的主机，百分号（%）表示允许任意主机。
示例：创建一个名为 tapdata 的账号。
CREATE USER 'tapdata'@'%' IDENTIFIED BY 'Tap@123456';
- 为刚创建的账号授予权限，简易示例如下，推荐基于业务需求设置更精细化的权限控制。
- 授予指定库权限
- 授予所有库权限
GRANT REPLICATION SLAVE, REPLICATION CLIENT ON . TO 'username' IDENTIFIED BY 'password'; GRANT SELECT ON database_name.* TO 'username' IDENTIFIED BY 'password';
- database_name：要授予权限的数据库名称。
- username：用户名。
- password：密码。
- 为保障读取 MySQL 数据库的增量数据，您需要跟随下述步骤开启 Binlog。
a. 使用 vim 命令，修改 $MYSQL_HOME/mysql.cnf 中的配置，例如：
server_id = 223344 log_bin = mysql-bin expire_logs_days = 1 binlog_format = row binlog_row_image = full
- server_id：对于 MySQL 中的每个服务器和复制客户端必须是唯一的，设置为大于 0 的整数
- log_bin：Binlog 序列文件的基本名称
- expire_logs_days：二进制日志文件保留的天数，到期自动删除
- binlog_format：设置为 row
- binlog_row_image：设置为 full
修改完成后，执行下述命令重启 MySQL 进程。
/etc/inint.d/mysqld restart
（可选）登录 MySQL 数据库，执行下述命令确认配置已生效，即输出的结果中，format 的值为 ROW。
SHOW VARIABLES LIKE 'binlog_format';
输出示例如下：
+---------------+-------+ | Variable_name | Value | +---------------+-------+ | binlog_format | ROW | +---------------+-------+ 1 row in set (0.00 sec)
数据目标：MongoDB
基本配置
- 目标端 MongoDB 支持副本集和分片集群。
- 如果您的目标端 MongoDB 只有一个节点，您可以将其配置为单成员的复制集，以开启 oplog 功能。
- 确保为目标 MongoDB 配置了足够的资源来处理源数据库的工作负载。
账户权限
如果目标 MongoDB 启用了安全身份验证，则 Tapdata 使用的用户帐户必须具有以下角色 / 权限：
- clusterMonitor（数据验证功能需要使用）
- readWrite（作为目标数据库需要拥有的角色） 要创建具有以上权限的用户，您可以参考以下示例：
use admin db.createUser({ "user" : "johndoe", "pwd" : "my_password", "roles" : [ { "role" : "clusterMonitor", "db" : "admin" }, { "role" : "readWrite", "db" : "my_db" }, { "role" : "read", "db" : "local" } ] }
*注意：只有 MongoDB 版本 3.2 需要 local 数据库的读取权限。
② 创建 MySQL 的连接
- 进入 TapData 控制台，在左侧导航栏，单击连接管理。
- 单击页面右侧的创建，在弹框中，搜索并选择 MySQL。
- 在跳转到的页面，根据下述说明填写 MySQL 连接信息：
-
连接信息设置
- 连接名称：填写具有业务意义的独有名称。
- 连接类型：支持将 MySQL 作为源或目标库。
- 地址：数据库连接地址。
- 端口：数据库的服务端口。
- 数据库：数据库名称，即一个连接对应一个数据库，如有多个数据库则需创建多个数据连接。
- 账号：数据库的账号。
- 密码：数据库账号对应的密码。
-
高级设置
- 连接参数：额外的连接参数，默认为空。
- 时区：默认为数据库所用的时区，您也可以根据业务需求手动指定。 如果源库为默认数据库时区（+8:00），目标端数据库为指定时区+0:00，那么假设源端数据库存储的时间为 2020-01-01 16:00:00，目标端数据库存储的时间则为 2020-01-01 08:00:00
- 共享挖掘：挖掘源库的增量日志，可为多个任务共享源库的增量日志，避免重复读取，从而最大程度上减轻增量同步对源库的压力，开启该功能后还需要选择一个外存用来存储增量日志信息。
- 包含表：默认为全部，您也可以选择自定义并填写包含的表，多个表之间用英文逗号（,）分隔。
- 排除表：打开该开关后，可以设定要排除的表，多个表之间用英文逗号（,）分隔。
- Agent 设置：默认为平台自动分配，您也可以手动指定 Agent。
- 模型加载频率：数据源中模型数量大于 1 万时，TapData 将按照设置的时间定期刷新模型。
-
SSL 设置：选择是否开启 SSL 连接数据源，可进一步提升数据安全性，开启该功能后还需要上传 CA 文件、客户端证书、客户端密钥文件等，相关文件已在开启 SSL 连接中获取。
- 单击连接测试，测试通过后单击保存：
*提示：如提示连接测试失败，请根据页面提示进行修复。
③ 创建 MongoDB 的连接
- 参照 MySQL 连接创建流程，完成 MongoDB 连接配置信息填写，添加数据目标：
- 测试 MongoDB 的连接：
④ 创建数据复制/开发任务
- 左侧导航栏点击数据复制，并点击右侧创建：
- 进入 DAG 页面，构建数据复制任务，通过拖拉拽的方式添加源与目标节点，并连接源与目标
- 单击源与目标节点，即可按需对二者进行设置：
- 保存任务
⑤ 任务启动与监控
- 启动任务，任务全量同步正常运行：
- 增量同步开启
以上，便是借助 TapData 快速实现数据库 MySQL 到 MongoDB 的全、增量同步的模拟教程。
后续，我们还将持续输出本专题内容，欢迎关注 TapData 官方公众号，了解更多。
关于 TapData
TapData Inc.「深圳钛铂数据有限公司」，成立于2019年9月，核心员工来自 MongoDB、Oracle、百度等，研发人员占比超80%，至今已获五源资本等多家头部风投数千万美元融资。已服务中国移动、中国联通、南方电网、中国一汽、中芯国际、周生生、富邦银行等数十家行业标杆企业。TapData 坚持“开放+开源”战略，推出 TapData Cloud，将无代码数据实时同步的能力以 SaaS 的形式免费开放，目前已积累 1,000+ 云版和企业版客户，覆盖金融、制造、零售、能源、政府等多个行业。此外，TapData 社区版也已发布，正在面向开发者逐步共享其核心功能。
TapData Live Data Platform是一个以低延迟数据移动为核心优势构建的现代数据平台。企业可以用来实现核心数据系统之间的实时同步、实时交换及实时处理。当实时数据需求日益增多时，企业可以结合分布式存储，使用 TapData 将孤岛数据无缝集中到中央数据平台，为众多下游业务提供一站式的实时数据交换和发布服务。
产品优势：
- 开箱即用与低代码可视化操作
- 内置 100+ 数据连接器，稳定的实时采集和传输能力
- 秒级响应的数据实时计算能力
- 稳定易用的数据实时服务能力
【推荐阅读】
- 如何高效整合分散数据，构建统一的实时数据平台？
- 流式处理 vs 批处理，新数据时代的数据处理技术该如何选择？
- TapData 医疗美容行业数字化白皮书上线
- 战略资讯 | TapData 牵手思想科技，开启数据管理新篇章！