前言
本文具体探讨 MySQL 数据实时同步到 Elasticsearch (以下简称 ES ) 技术方案和思考，同时使用一定篇幅介绍一些前置知识，从理论到实践，让读者更好的理解这块内容和相关问题。包括：
为什么我们要将数据从 MySQL 实时同步到 ES ，本质是什么？
为什么是 ES，而不是其他 OLAP 引擎？
MySQL 到 ES 数据实时同步方案中有哪些细节需要注意？
MySQL 到 ES 数据实时同步方案可以有哪些选择，优缺点是什么？
相信看完本文，你会对 MySQL 数据实时同步到 ES 有更多的了解。
数据库去规范化
Database normalization is the process of structuring a database, usually a relational database, in accordance with a series of so-called normal forms in order to reduce data redundancy and improve data integrity. It was first proposed by Edgar F. Codd as part of his relational model.
数据库规范化是指关系型数据库中通过一系列数据库范式来减少数据冗余、增强数据一致性的策略。例如我们平时使用的关系型数据库的关系模型可以认为是 Database Normalization 的一种实现方式，这些关系型数据库基本都至少遵循了数据库第三范式，可以称之为 Normalized Database。关于数据库范式的内容，本文不再展开。
Denormalization is a strategy used on a previously-normalized database to increase performance. In computing, denormalization is the process of trying to improve the read performance of a database, at the expense of losing some write performance, by adding redundant copies of data or by grouping data. It is often motivated by performance or scalability in relational database software needing to carry out very large numbers of read operations. Denormalization differs from the unnormalized form in that denormalization benefits can only be fully realized on a data model that is otherwise normalized.
Database Normalization 在带来我们看得见的好处同时(利于事务操作性能、存储成本降低)，伴随数据规模扩大、并发度提高、复杂度上升，弊端也慢慢展现，这时候 Database Denormalization 能够一定程度满足这些挑战，总体思路是通过一系列降低写入性能的操作例如更多的数据冗余、数据分组等来提升数据库读取的性能。
去规范化的时机
数据去规范化动机多样，当出现因数据复杂操作影响系统稳定性、业务响应/并发要求不满足等都是触发因素。
业务稳定性问题：面向 C 端的互联网应用特征是并发量较高，SQL 偏向点查点写，相对简单，但是沉淀下来的数据(比如订单、支付等) 需要做运营往往涉及传统企业级应用对于数据库的操作特征，大范围数据栅查、表关联、排序等实时操作，以及满足报表/BI等更加复杂的数据库需求。通过去规范化和负载分离是较合理的选择。
复杂查询性能问题：企业级应用例如ERP、CRM、BOSS或者其他一些企业运营系统，经常涉及表关联、聚合、多维删选、排序等操作，并常常带来性能问题。通过去规范化的一些方式，如下文提到的数据冗余和预计算方式，显著改善性能。
去规范化的几种实现方式
假设有如下三张表，学生、班级和教师。需求是:已知学生的学号，需要查询当前学生的班主任是名字。
使用规范化数据查询,是一个 3 表联查操作，而在数据库中，大体分三步：
通过学生学号获取学生信息，得到班级编号
通过班级编号获取班级信息，得到班主任工号
通过班主任工号得到教师信息，得到班主任的名字
如果在数据量较大，有一定并发要求，并且涉及更多表关联时候，这种计算就不能满足需求，这个时候去规范化的优化方式就登场了。
列级处理——主查询表冗余字段
通过在主表冗余计算好的数据，可避免频繁重复计算数据。如下场景适合在主数据表内冗余数据：
在学生表冗余班主任的名字信息，表的设计变为如下：
这时候查询就只有一步了：
根据序号获取学生信息，同时也得到了其班主任名字的信息
优点：方法较为简单易懂，容易实现。
缺点：侵入业务逻辑，拖慢业务代码性能的同时，长期迭代所产生的变化可能会有稳定性风险。
表级处理——宽表预构建/Cube预构建
表级处理主要操作就是构建宽表，或者构建数据立方体(Data Cube)。构建好的宽表包含了用户查询时需要的所有维度、度量信息。以上面学生查找班主任的问题为例，构建的宽表结构如下。
表级处理常见实现方式包括 应用多写、数据库自身实现的物化视图、数据迁移同步。
应用多写
在主数据相同数据库内创建宽表，应用写入数据的时候同时也向宽表写入数据(事务保证一致性)，复杂查询即可从该表进行。
优点：实现简单、低成本
缺点：对主数据库造成更大的读写压力，外加业务改造成本。
RDBMS 物化视图
Oracle、SqlServer 等数据库物化视图方案，通过数据冗余与预计算减少 join、聚合，从而提升查询性能。例如，在 Oracle 上完成学生查找班主任这个查询，可以构建一张“学生管理表”的物化视图，查询请求直接请求物化视图即可得到查询结果，避免 join ，显著改善该 SQL 执行效率。
优点：数据库引擎自身支持，使用成本较低
缺点：RDBMS 实现的方式有自己的局限性，比如生成物化视图的数据需要做一些业务紧相关变换就无法满足，或者某些数据库并没有完整实现该能力(物化视图在 2000 年左右是数据库学术圈研究的重点)。
数据迁移同步
借助数据同步工具，准实时将主数据表数据组织变换(包括按照业务逻辑变换)形成普通表或大宽表，写入第三方存储引擎(如 OLAP 存储引擎或者搜索系统)。复杂查询直接在预构建好的表上或者 cube 上执行，从而达到良好的性能。数据迁移工具的选择较多，总体上按照其侧重点，可以分为如下几类：
大数据类：为大数据产品流入数据提供服务，因为大数据产品本身特点，侧重批量定时的迁移，实时同步一般需要用特别的方法，往往和业务特征紧耦合。常见的数据迁移同步工具有 sqoop、datax 等
流计算类：为自身流计算框架生态服务，侧重计算，迁移同步更多是类似数据连接器的角色，代表的产品如 Flink
消息类：为自身消息产品生态服务，如丰富的 kafka connector、debezium 等
数据库类：数据库厂家一般都会提供原厂工具，典型如 Oracle 的 GoldenGate
云厂商类：云厂商提供的数据迁移同步工具，主要侧重自身云上数据库生态产品之间的互融互通和将线下自建数据库的数据上云，例如阿里云 DTS, 腾讯云 DTS , AWS 的 DMS 等
专业数据迁移同步工具: 包括部分开源产品或第三方独立公司提供的数据迁移同步工具，例如 canal、streamsets、maxwell、cloudcanal、striim、fivetran ，以及老牌数据集成厂商 Informatica 、Qlik 等所提供的产品
优点:
缺点: 需要对纷繁多样的数据迁移同步工具、承载复杂查询数据库产品选型，对技术同学能力有一定要求
MySQL 到 ES 数据实时同步技术架构
我们已经讨论了数据去规范化的几种实现方式。MySQL 到 ES 数据同步本质上是数据去规范化多种实现方式中的一种，即通过“数据迁移同步”构建高效数据应用，解决规范化数据复杂查询的效率问题。本节我们分享下“MySQL 到 ES 数据迁移同步”项目时可选的比较常见的两种技术架构，通过比较他们的优缺点和应用场景给读者后续架构选型时提供一些思路。
为什么是 MySQL
MySQL 在关系型数据库历史上并没有特别优势的位置，Oracle/DB2/PostgreSQL(Ingres) 三老比 MySQL 开发早了 20 来年, 但是乘着 2000 年的互联网东风, LAMP 架构得到迅速的使用，特别在中国，大部分新兴企业的 IT 系统主数据沉淀于 MySQL 中。
高并发能力：MySQL 内核特征特别适合高并发简单 SQL 操作 ，链接轻量化(线程模式)，优化器、执行器、事务引擎相对简单粗暴，存储引擎做得比较细致
稳定性好：主数据库最大的要求就是稳定、不丢数据，MySQL 内核特征反倒让其特点鲜明，从而达到很好的稳定性，主备系统也很早就 ready ,应对崩溃情况下的快速切换，innodb 存储引擎也保障了 MySQL 下盘稳定
操作便捷：良好、便捷的用户体验(相比 PostgreSQL) , 让应用开发者非常容易上手 ,学习成本较低
开源生态：MySQL 是一款开源产品，让上下游厂商围绕其构建工具相对简单，HA proxy、分库分表中间件让其实用性大大加强，同时开源的特质让其有大量的用户
为什么是 ES
ES 几个显著的特点，能够有效补足 MySQL 在企业级数据操作场景的缺陷，而这也是我们将其选择作为下游数据源重要原因
文本搜索能力：ES 是基于倒排索引实现的搜索系统，配合多样的分词器，在文本模糊匹配搜索上表现得比较好，业务场景广泛
多维栅选性能好：亿级规模数据使用宽表预构建(消除 join)，配合全字段索引，使 ES 在多维删选能力上具备压倒性优势，而这个能力是诸如 CRM, BOSS, MIS 等企业运营系统核心诉求，加上文本搜索能力，独此一家
开源和商业并行：ES 开源生态非常活跃，具备大量的用户群体，同时其背后也有独立的商业公司支撑，而这让用户根据自身特点有了更加多样、渐进的选择
为什么是数据迁移同步方式
相对于数据去规范化的其他几种方案，数据迁移同步方式存在以下几个优点，也是其成为目前业界主流方式的原因
稳定性好：迁移同步对主数据库的操作主要是进行数据和日志的顺序读取，同时并发小，对主数据库稳定性影响较小(较多的下游订阅可能在网络层面存在影响，一般用消息解决)。另外日志(Binlog/WAL/Redo等)可重放特质，让下游丢数据的可能性大大减小(处理好幂等的情况下)
业务解耦：一般而言主数据库更多承载事务型操作，而下游数据系统承载运营等层面的业务, 典型如电商的买家侧和卖家侧业务
业务侵入小：数据迁移同步对业务无侵入，双端对接标准数据库(源)，可以便利地找到开源、商业、云等各个方向的成熟解决方案或产品
业务适配性好：某些数据迁移同步产品能够嵌入业务逻辑，让下游获取到更加贴近业务的数据，从而让数据服务更加有效和便捷
数据迁移同步模型选择
订阅消费
优点
堆积能力：由于引入了消息队列，所以整个链路是具备变更数据的堆积能力的。假设变更数据消费的比较慢，MySQL 本地较老的 binlog 文件由于磁盘空间的不足而被删除时，消息队列中的数据仍然存在，数据同步仍然可以正常进行
数据分发能力：引入消息队列后可以支持多方订阅。如果下游多个应用都依赖源端的变更数据，可以订阅同一份 topic 即可
数据加工能力：由于变更数据是由下游消费者订阅，因此订阅后可以灵活的做一些数据加工。例如从外部调用微服务接口或者反查一些数据来做数据加工都是比较方便的
缺点
端到端直连
优点：
缺点：
数据迁移同步模型选择总结
从笔者以往的经验来看，如果没有众多的下游数据订阅，建议采用直连模式
。数据同步链路往往置于在线业务中，随着业务规模以及重要性逐渐加大，链路 稳定性 更为重要些。
不过 端到端模式 只要支持对端数据源为消息中间件，可立刻实现订阅模式，数据加工能力在某些数据迁移同步产品上可通过上传业务代码运行的方式解决。
另外，数据架构在满足业务需求的同时，简洁和清晰能够让系统更加易于维护和排查，当遇到链路每天同步几千万条上亿条数据、偶发丢几条需要排查，或同步链路卡住不同步等情况，端到端方式往往体现出相当大的优势。
MySQL 到 ES 数据实时同步核心挑战
关系型数据库中不同表之间的数据常存在关联，同步到 ES 之后，这种关联关系该如何去组织，同时又能够很好的匹配到 ES 的最佳实践 ? 本小节会展开讨论这个问题，并对常见的数据同步工具选型提供一些参考对比。
MySQL 关联表在 ES 上的设计
关系型数据库库中的表 join 关系在 ES 可以用几种数据类型来表达，包括 objected,nested,join 三种。
objected
object 类型可以存储嵌套结构.
优点：
缺点：
当采用 objected 字段存储 products 信息时，原本存储的信息如下：
"order_id" : 123,
"products" : [
{
"price" : 10,
"sku" : "SKU_10",
},
{
"price" : 20,
"sku" : "SKU_20",
}
]
在ES中存储的样子为：
{
"order_id": [ 123 ],
"products.price": [ 10, 20],
"products.sku": [ SKU_10, SKU_20 ],
}
可以看到在ES的存储中，producets 中每个字段的值都已经被打平处理。如果我们查询订单 ID 为 123，价格 price 为 10，SKU 为 “SKU_20” 的文档，我们同样可以搜索到结果，但这样显然就丢失了其内部之间的关系了。
nested
nested 类型可以存储嵌套结构，表示一对多关系，是 object 类型的拓展
优点：
缺点：
一个 nested field 只能属于一个主文档
在 nested 类型中，子文档和主文档之间是强绑定，主文档更新的时候会强制更新子文档。在写多读少的场景，性能开销较大
child 文档的查询必须通过父文档再找到子文档
子文档频繁修改的话会影响别的子文档和父文档，因为本质上在 lucence 实现上是父文档下的冗余存储
join
join 类型可以配置父子文档，通过父子文档来实现一对多的能力，一个索引只能建一个。相比 nested 类型，该类型更加灵活。父子文档之间通过 parentId 来关联，实际实现上他们就是独立的文档。因此带来的好处主要是
优点：
缺点：
join 和 nested 类型比较
MySQL 到 ES 实时数据同步实现去规范化
在了解 ES 的一些关键类型之后，我们就可以描述通过数据同步去规范化的几种实现方式。
主表冗余数据
业务侧将一些查询时需要的关系数据提前冗余在源表的一个字段中。例如序列化成json存储在源表的一个冗余字段内，利用数据同步工具写入对端 ES 的 join/nested 类型字段。例如我们有订单表和商品表如下图所示。假设我们的搜索需求是，给定一个订单ID，同时将这个订单的订单明细以及所有包含的多件商品的明细全部搜索出来。
如果采用这种列级处理模式，我们在订单表新增一个冗余列，然后将商品表的所有明细信息，按照kv组织成json写入冗余列即可，如下图所示。对端 ES 的 mapping 结构按照如下方式定义。数据同步工具直接将该保函关联表数据的订单表直接同步到对端 ES ，即可在 ES 上搜索符合我们需求的数据。
{
"mappings": {
"_doc": {
"properties": {
"order_id": {
"type": "long"
},
"order_price": {
"type": "long"
},
"product_count": {
"type": "long"
},
"discount": {
"type": "long"
},
"product_info": {
"type": "nested"
},
}
}
}
}
优点：
缺点：
索引、搜索性能非最佳：提供给 ES 的不是预构建好的宽表数据。例如例子中，订单关联的商品信息，全部存储在主表的一个object/nested/join 字段内，这种实现方式会有索引、搜索性能方面的额外开销，不是性能最佳的实现方式
业务系统侵入：业务系统写主数据的时候需要额外写入信息
主数据库表冗余过多数据：关系型数据库的表冗余了过多其他表的信息，可能存在存储和性能开销
总结
多表订阅合并预构建宽表数据
数据同步工具同时订阅搜索时依赖的所有表，先到的数据先进到 ES，没有数据过来的字段为空。以上面提到的订单和商品表的例子来说，即同时同步订单表和商品表到对端索引。对端索引的 mapping 定义如下所示，包含订单和商品表的所有字段，定义的索引是一张宽表。流计算中多流汇聚配合时间窗口 join 多表的方式与该种方式有异曲同工之处。
优点：
数据同步工具配置同步任务较为简单，无业务入侵，不耦合业务系统逻辑
对数据同步工具要求低，除了同步以外，不需要其他额外的功能特性
基于预构建宽表的方式在 ES 上也有较好的索引和查询性能。
同步链路不会因为宽表某些列缺失数据阻塞整个数据链路的同步(是否有该优点取决于数据同步工具本身设计，如果引入时间窗口，则同步链路会因为等待列数据影响同步时效性)。
缺点：
总结
{
"mappings": {
"_doc": {
"properties": {
"order_id": {
"type": "long"
},
"order_price": {
"type": "long"
},
"product_count": {
"type": "long"
},
"discount": {
"type": "long"
},
"product_id": {
"type": "long"
},
"product_unit_price": {
"type": "long"
},
"product_name": {
"type": "text"
},
}
}
}
}
同步过程回查预构建
实现方式
数据同步工具订阅的表称为主表。数据同步过程中，反查数据库查询的表称为从表。利用数据同步工具自身的能力，在订阅主表期间，自动通过回查的方式，填补宽表中的列，形成完整的宽表行数据。对端 ES 的mapping 定义例子与“多表订阅合并预构建宽表数据”中的保持相同。
优点：
基于反查的方式构建宽表灵活性好，可以在生成宽表前基于主表的数据对从表数据做一些轻度的数据加工
一条主表的数据，通过反查生成宽表行，可以配合数据加工生成多条宽表行数据
基于反查的方式可以比较轻松的实现跨实例的 join ，从而生成宽表行(相对好实现，具体要看数据同步工具本身是否支持)
基于宽表预构建的方式在 ES 上有较好的索引、查询性能。
缺点：
总结
数据迁移同步工具选型
数据迁移同步工具的选择比较多样，下表仅从 MySQL 同步 ES 这个场景下，对一些笔者深度使用研究过的数据同步工具进行对比(不一定精确，如有错误请联系笔者更正)，用户可以根据自己的实际需要选取适合自己的产品。
特性/产品
| canal
| 云DTS
| cloudcanal
|
| 系统部署 | ❌ 需手动部署,并基于配置文件去配置, 初次上手有门槛 ✅ 私有化部署 | ✅ saas化产品，开箱即用 ❌ 依赖云平台私有化部署 | ✅ saas化产品，开箱即用 ✅ 可私有化部署 |
| 架构模式 | 订阅消费模型 | 直连模式 | 直连模式 |
| 版本支持 | ✅ 支持自建的es6和es7以及阿里云es | ✅ 只支持阿里云es及其提供的版本 ❌ 不支持开源自建es | ✅ 支持自建es6和es7以及阿里云es |
| 产品化 |
❌ 有Admin管控控制台，但是产品化程度较低，监控报警审计功能不完整、无可视化创建任务等能力 | ✅ 完整的产品化能力 | ✅ 完整的产品化能力 |
| 结构迁移 | ❌ 不支持 | ✅ 仅支持同步到全新索引 ✅ 支持全局的索引分片数、分区副本数设置 ❌ 不支持表级的索引分片数、分区副本数设置 ❌ 不支持列映射、列自动创建 | ✅ 可同步到已存在的索引，支持索引自动创建、列映射、列自动创建 ✅ 支持表级别的索引分片数、分区副本数设置 |
全量迁移 | ❌ 不支持 | ✅ 支持 | ✅ 支持 |
| 增量同步 | ✅ 支持 | ✅ 支持 | ✅ 支持 |
| 数据过滤 | ❌ 不支持 | ✅ 支持 | ✅ 支持 |
| 时区 | ❌ 不支持时区转换，采用同步机器时区 ❌ 对端索引时间类型format和源端同步数据的format不一致会有精度丢失问题 | ✅ 支持全局时区转换配置 ❌ 只支持同步到新建的索引表，精度不可更改，对已存在索引的同步支持不佳 | ✅ 支持全局时区转换配置 ✅ 全量、增量支持自动识别对端已经存在的索引的format和精度 |
| 特殊类型支持 | ❌ 不支持源端json类型 ✅ 支持对端object/nested/join类型，但是需手动配置 | ❌ 不支持选择nested类型 ✅ 新建表支持映射object，但是无法映射nested类型 | ✅支持源端json类型 ✅支持json类型自由映射对端object/nested类型 |
join支持 | ✅ 支持。基于父子文档的join方案 ❌ join方案会影响搜索性能。基于父子文档的join方案，缺点是会影响对应索引搜索的效率，因为会构建全局序数 | ❌ 无join支持 |
✅ 支持基于反查预先构建宽表的能力，响度比较好的写入和搜索性能
|
| 成本和服务支持 | 开源产品，需自维护，无商业服务 | small规格的mysql->es链路价格为1.78元/每小时，服务走阿里云平台 | CloudCanal社区版功能完整，免费使用。有社区支持。同时提供商业化产品和服务。 |
写在最后
MySQL 到 ES 数据同步构建数据检索服务给中小企业带来了稳定且实用的在线数据方案，在满足业务诉求(高并发业务与企业级应用常态化)的同时 ，易上手且具备不错的可维护性，在适当的场景下，值得尝试和实践。
最后感谢各位的阅读，内容相对浅显且直接，希望对你有所帮助和启发。在此也简单介绍下笔者自己，本人在阿里巴巴中间件和云智能团队从事过几年时间数据相关工作，在该领域具备一定的经验，对这个方向感兴趣的朋友可以一起探讨相关技术问题，我们专门开设了一个问答社区 askcug.com 以便大家探讨，欢迎加入探讨。
参考资料
[1] 维基百科：Database normalization
[2] 维基百科：Denormalization
[3] When and How You Should Denormalize a Relational Database
[4] 爱奇艺|海量数据实时分析服务技术架构演进
[5] 从 ES 到 Kylin，斗鱼客户端性能分析平台进化之旅
[6] 常见开源OLAP技术架构对比
[7] Elasticsearch:Tune for search speed
[8] Elasticsearch:Field data types
[9] Designing Data-Intensive Applications
[10] Materialized Views
[11] A Relational Model of Data for Large Shared Data Banks
- EOF -
觉得这条资讯有帮助？请转发给更多人
推荐关注 技术最前线，看 IT 要闻
点赞和在看就是最大的支持❤️
