如何利用云原生数仓 Databend 构建 MySQL 的归档分析服务

MySQL 归档服务需求分析

MySQL 常用 OLTP 业务环境,一般会使用比较好的硬件资源来提供对外服务。现在 MySQL 数据对外提供的数据动不动好几个 T 也是正常的。在很多业务中,数据有较强的生命周期,在线一段时间后,可能就是失去业务意义,如:

  • 某个业务下线
  • 业务数据超过服务周期,例如某个业务只需要近 3 个月的数据
  • 业务操作的日志类型的数据进行归档
  • 分库分表的数据库需要合并到同一个地方,提供统计查询及分析能力
  • 定期的备份归档,提供审计工作进行查询使用

这类工作是 DBA 提出归档方案,由开发人员提出对哪些数据可以归档,规范后可以借助于自动化的执行完成。

常见 MySQL 归档处理的方式

现在常见的归档方式一般分成两大类:MySQL & MariaDB,核心工具是:pt-archive 或是解析 binlog 获取归档的数据。

  • 首先说第一类使用 MySQL 存储归档

这类方案中,一般是通过购买 PC 机,通常是大容量(50T左右),大内存机型,可以跑实例,来对线上的生产库进行归档。甚至是备份同步。这种场景是最常见的。甚至见到在线下建一个主从,对 PolarDB 进行归档对外提供线下内网查询。

图片

该方式的优点:

  1. 基于 MySQL 环境,大家都熟悉好管理
  1. 和线上环境基本能保持同一个版本及高度的兼容
  2. 归档环境可以使用大容量便宜的磁盘构建

当然这种归档服务也有以下的缺点:

  1. 这种架构通常为了成本,归档节点通常没开启 Binlog,真正的备份还会放到对象存储中一份,也没有从库,如果发生数据损坏,或是硬盘损坏,数据恢复周期长。
  1. 计算能力不够,基本没有能力对计算节点扩展,如果需要计算,通常需要把数据抽出来放到大数据环境中计算。
  2. 这种架构存在大量的 CPU 和 RAM 资源的闲置
  • 第二类:使用 MariaDB 归档

MariaDB 推出一个实验特性:S3 engine 该引擎有较高的较压缩能力,基本也保持了 MySQL 的使用习惯。归档流程:先写 InnoDB,然后 alter table tb_name engine=s3;

该方案的优点:

  1. 基本保持了 MySQL 兼容能力
  1. 存储上支持 s3 类对象存储
  2. 支持高压缩存储

该方案的缺点:

  1. s3 引擎只能读,不能写
  1. 不支持增加写入,如需改变还需要转成 InnoDB 表
  1. 每次 InnoDB 到 s3 引擎的转换需要非常长的时间,增加了复杂度

那么现在有没有更完美的方案呢?这里给大家给推荐云原生数仓 Databend

Databend 可以提供的归档方式

Databend  架构及介绍

image.png

Databend 是一个使用 Rust 研发、开源、完全面向云架构的新式数仓,提供极速的弹性扩展能力,致力于打造按需、按量的 Data Cloud 产品体验。具备以下特点:

  • 开源 Cloud Data Warehouse 明星项目
  • Vectorized Execution 和 Pull&Push-Based Processor Model
  • 真正的存储、计算分离架构,高性能、低成本,按需按量使用
  • 完整的数据库支持,兼容 MySQL,Clickhouse 协议,SQL Over HTTP 等
  • 完善的事务性,支持 Time Travel,Database Clone,Data Share 等功能
  • 支持基于同一份数据的多租户读写、共享操作

Databend 设计上的原则:

1.No Partition

2.No index(Auto Index)

3.Support Transaction

4.Data Time travel/Data Zero copy clone/Data Share

5.Enough Performance/Low Cost

部署方式

图片

支持 MySQL,Clickhouse,SQL Over Http 三种方式的处理。

安装方式参考:https://databend.rs/doc/deploy

安装及使用中如果遇到问题,请添加 Wx:  82565387 获得支持。

数据写入方式

Insert  into 写入

支持 jdbc, python, golang 进行 insert 写入,推荐阅读:https://databend.rs/doc/develop

如果要使用 insert 写入,建议使用 Bulk insert 增加批量写入。这个使用上和 MySQL 没有什么区别,所以这里就不过多介绍了。

Streaming load

Streaming load 语法参考:https://databend.rs/doc/load-data/local

image.png

从上面图上可以看到 81 G 的文件,近 2 亿数据导入 Databend 只需要 3 分钟多一点。

另外现在 Databend 也支持直接读取压缩文件。例如:

读取压文件这块只是功能上跑通,但性能上不是最佳的方式,同样的数据使用压缩文件读取,现在大概需要 13 分钟,这个后续应该有不少空间可以提升。

基于 stage 写入

Stage 可以理解 Databend 的一个网盘管理功能。具体语法参考:https://databend.rs/doc/load-data/stage

image.png

在以上 PPT 中展示了 stage 的创建,文件上传,文件查看,通过 copy into 的命令可以把 Stage 的文件直接加载到 Databend 的表中。

利用 Databend 归档 MySQL 获得的优势

对于需要考虑 MySQL 归档的场景,建议可以考虑使用 Databend 加对象存储来替代,这样的方式的优点:

  1. 基于对象存储基本可以实现容量无限
  1. Databend 数据压缩比较高,正常情下可以做到 10:1, 降低存储空间
  1. 可以基于 MySQL 协议管理数据,对使用上基本可以做到没有任何变化
  1. 存算分离架构,对于计算层不足的情况下,可以非常方便的扩容,也无须担心存储的高可用
  1. 原来 MySQL 生态的工具基本可以重用

Databend 现在对象存储支持:AWS S3, Azure, 阿里云,腾讯云,青云,金山云以及 minio,ceph 等设备。同时 Databend 的计算能力惊力,如果需要分析,可以直接 Databend 直接进行计算。

利用 Databend 可以帮着用更方便的使用好云上的资源,让用户可以获得足够的性能及较低的成本。如果你对该方案有兴趣了解更多,也可以添加 v 信:82565387 进行交流。

关于 Databend

Databend 是一款开源、弹性、低成本,基于对象存储也可以做实时分析的新式数仓。期待您的关注,一起探索云原生数仓解决方案,打造新一代开源 Data Cloud。

  • Databend 文档:https://databend.rs/
  • Twitter:https://twitter.com/Datafuse_Labs
  • Slack:https://datafusecloud.slack.com/
  • Wechat:Databend
  • GitHub :https://github.com/datafuselabs/databend

数据运维技术 » 如何利用云原生数仓 Databend 构建 MySQL 的归档分析服务