首页 > 其他分享 >MSE ZooKeeper 数据导入导出功能上线

MSE ZooKeeper 数据导入导出功能上线

时间:2023-01-09 10:06:10浏览次数:61  
标签:ZooKeeper 导出 导入 集群 Snapshot MSE 数据

作者:草谷


背景


MSE 提供了托管版的 ZooKeeper,拥有比自建开源 ZooKeeper 稳定性更高的SLA,同时管控面提供了丰富的服务自治功能。赶在2022年的岁末,MSE ZooKeeper 上线了一个非常实用的功能-数据导入导出功能,彻底解决了困恼用户长期以来无法自助处理数据的问题。通过阅读本文,你可以快速获得以下知识点和能力:


  • ZooKeeper 的持久化文件原理
  • 什么场景下会使用到导入导出功能
  • 如何在 MSE 上面使用导入导出功能


存储原理


此次上线的导出功能支持的数据类型包含快照文件snap和事物日志,在介绍功能之前,我们看下 ZooKeeper 的这2个数据文件是用来做什么的。


在 ZooKeeper 中,主要会产生2种和数据相关的持久化文件,一个是内存的数据快照 Snapshot 文件,另外一个是事务日志 log 文件;它们分别是什么作用,有什么区别呢?


下面2段代码是 Snap 快照的写入内容和产生的时机:


public void save(
DataTree dataTree,
ConcurrentHashMap<Long, Integer> sessionsWithTimeouts,
boolean syncSnap) throws IOException {
long lastZxid = dataTree.lastProcessedZxid;
File snapshotFile = new File(snapDir, Util.makeSnapshotName(lastZxid));
try {
snapLog.serialize(dataTree, sessionsWithTimeouts, snapshotFile, syncSnap);
} catch (IOException e) {
//
}
}

private boolean shouldSnapshot() {
int logCount = zks.getZKDatabase().getTxnCount();
long logSize = zks.getZKDatabase().getTxnSize();
return (logCount > (snapCount / 2 + randRoll))
|| (snapSizeInBytes > 0 && logSize > (snapSizeInBytes / 2 + randSize));
}


可以看到,Snapshot 写入的是一个 DataTree 的数据结构,里面存储的是 ZooKeeper 的全量内存数据,而生成 Snapshot 的条件,主要涉及到 snapCount,snapCount 是一个可配置的参数,默认是10W,也就是 Snapshot 是 Zookeeper 的内存快照,是一份全量数据,而这份全量数据,也并非实时写入到磁盘中的,需要达到一定的条件才会写入。


再看 ZooKeeper 的事务日志,针对客户端的每一次事务操作,Zookeeper 都会将他们记录到事务日志中,同时也会将数据变更应用到内存数据库中。刚才说到 Snapshot 的生成并非实时的,在上一次内存快照生成后,到下一份生成之前,就会有一部分数据没有写入到 Snapshot 中,那么这部分增量的数据,我们可以从事务日志中找到。


总结一下,简单来说,Snapshot 是存储的全量数据,事务日志 log 文件是记录着完整的每次事务操作,所以如果要完整的恢复一个 ZooKeeper 集群的数据,需要同时具备这2个文件。


使用场景


MSE 数据导入导出功能主要来自于客户的需求反馈,主要有如下三种使用场景:


数据的备份


如果需要对集群某个时刻的数据进行备份,用于后续恢复或者容灾使用,可以使用 MSE 的数据导出功能,将集群的数据导出成文件进行存储,如果集群出现了数据不符合预期的情况下,可以通过导入的功能,将集群数据恢复到备份时的状态


集群的迁移


需要迁移到新的 ZooKeeper 集群,又依赖到原 ZooKeeper 集群的数据时,可以通过 MSE 的数据导出功能,将数据导出,然后再放到新集群中,重新初始化,这样就相当于做了一次全量的数据迁移,这种迁移是需要停机的,但胜在简单易操作


分析客户端业务


MSE 导出的 Snapshot 文件和 log 文件,可以通过 ZooKeeper 自带的解析工具,解析成明文,里面包含的信息非常丰富,每条数据的大小,访问频率等,通过这些,可以查到一部分客户端是否错用 Zookeeper,能具体到路径,帮助揪出有问题的客户端。例如我们遇到过有用户客户端错用导致一个 Session 写入了大量的数据,最后通过分析事务文件,找到了具体的客户端IP和应用名,解除了风险。


动手实践


接下来,给大家介绍下,如何对一个集群的数据进行导入导出:


将集群的数据进行导出


导入导出功能在 ZooKeeper 专业版的数据管理-节点管理-面板中,基础版目前暂不支持,请升级到专业版:


MSE ZooKeeper 数据导入导出功能上线_MSE


点击数据导出按钮,即可将这个集群的数据进行导出:


MSE ZooKeeper 数据导入导出功能上线_数据_02


此刻会出现导出的功能页面,这里支持导出的文件将分开展示,也就是,快照导出,和事务日志导出需要单独选择,这样也是为了满足不同需求的用户,同时也能提高导出效率;


按需选择,点击导出后,大概2-5分钟,可下载的文件会显示在下载列表中,进行下载即可。


MSE ZooKeeper 数据导入导出功能上线_MSE_03


将导出的数据导入到另一个集群中


点击数据导入按钮,出现导入数据对话框,这里直接选择上转上一步导出的 Snapshot 文件即可:​


MSE ZooKeeper 数据导入导出功能上线_MSE_04


整体的数据导入导出功能就演示完了,简单高效,相比于自建 ZooKeeper 的数据腾挪,效率提高了100%,并且导入数据后,集群的初始化也是自动的,不用再担心因为操作步骤错误导致集群起不来了。


运营活动


重磅推出 MSE 专业版,更具性价比,可直接从基础版一键平滑升级到专业版!


MSE ZooKeeper 数据导入导出功能上线_MSE_05


点击​​此处​​查看购买

标签:ZooKeeper,导出,导入,集群,Snapshot,MSE,数据
From: https://blog.51cto.com/u_13778063/5996848

相关文章

  • MSE ZooKeeper 数据导入导出功能上线
    作者:草谷背景MSE提供了托管版的ZooKeeper,拥有比自建开源ZooKeeper稳定性更高的SLA,同时管控面提供了丰富的服务自治功能。赶在2022年的岁末,MSEZooKeeper上线了一个......
  • odoo 文件导入流程
    文件上传到表中[email protected]('/base_import/set_file',methods=['POST'])defset_file(self,file,import_id,jsonp='callback'):impo......
  • 解决scikit-learn中导入数据的问题
    在学习sklearn时,使用boston房价数据时,使用如下代码获取数据:1、无法导入数据,我这里版本是1.2,具体:importpandasaspdimportnumpyasnpimportsklearnfromsk......
  • Kafka学习笔记(七):Kafka KRaft - Removing Zookeeper
    关于KafkaKRaft在2020年,ApacheKafka项目做开始着手移除Zookeeper依赖(KIP-500)当Kafka集群拥有超过10万个分区时,Zookeeper有扩展问题删除Zookeeper之后,ApacheKa......
  • Kafka学习笔记(六):Zookeeper
    ZookeeperZookeeper管理代理,保留一份代理的名单Zookeeper帮助完成分区的领导者选举当kafka有更改时,Zookeeper会发送通知,比如新的主题、代理崩溃、代理启动、删除主题等......
  • SiteFactory编辑器支持Word自动导入
    ​ 当前功能基于PHP,其它语言流程大致相同 1.新增上传wordjson配置在ueditor\php\config.json中新增如下配置:     /* 上传word配置 */    "wordAction......
  • solr使用网页浏览器批量导入数据库中数据(本案例是mysql)
    如果想要知道如何安装solr,集成IKAnalyzer中文分词器,批量导入数据库数据,java使用参照以下本博主博文:安装solr集成IKAnalyzer中文分词器solr使用浏览器批量导入数据库中数据s......
  • SiteFactory编辑器支持Word图片导入
    ​图片的复制无非有两种方法,一种是图片直接上传到服务器,另外一种转换成二进制流的base64码目前限chrome浏览器使用首先以um-editor的二进制流保存为例:打开umeditor.js,......
  • python-自定义模块及导入方法
    1.自定义模块​ 一个较大的程序一般应分为若干个程序块,若个程序块称为模块,每个模块用来实现一部分特定的功能。​ 这样做的目的是为了将代码有组织的存放在一起,方便管......
  • Vite 配置组件自动导入之后,模板中使用组件显示未定义
    在vite.config.ts文件中配置完自动导入组件之后,在模板中使用,WebStorm会给出一个黄色波浪线,提示我没有定义组件。虽然能够dev和build,但是一堆黄色的波浪线很影响观感......