0
点赞
收藏
分享

微信扫一扫

如何使用HBase快照实现跨集群全量与增量数据迁移

七千22 2022-09-22 阅读 72
数据hivehadoop虚拟化云计算

温馨提示：要看高清无码套图，请使用手机打开并单击图片放大查看。


1.文档编写目的



我们常常会碰到需要迁移HBase数据的场景，当一个HBase集群运行较长时间后，往往数据量都会很大，HBase集群往往支撑的都是线上的业务，不像跑批的Hive/Spark集群，不能随便停机。HBase默认提供import/export方法支持备份和还原，而且支持增量，但是因为是使用HBase的API导出和还原数据，对RegionServer的压力会很大，往往会影响旧集群的在线业务。


在前面的文章Fayson也讲过《​​如何在CDH中使用HBase快照​​》，HBase自身也提供了ExportSnapshot的方法可以从HDFS文件层基于某个快照快速的导出HBase的数据，并不会对RegionServer造成影响，但该源生的方法不支持增量。该文档主要通过使用HBase快照导出历史全量数据并还原到新的HBase集群，然后改造源生的ExportSnapshot类，通过比较变化的文件实现导出增量，并最终实现HBase跨集群的增量备份和还原。文末附github源码。


  • 内容概述

1.通过快照实现HBase跨集群的全量数据备份和还原

2.改造ExportSnapshot类说明

3.通过快照实现HBase跨集群的增量数据备份和还原

4.github源码和总结


  • 测试环境

1.CM和CDH版本为5.13.0

2.使用root用户操作


  • 前置条件

1.HBase0.95+


2.测试表信息描述



使用HBase的PerformanceEvaluation生成一张SNAPPY格式的表


1.使用HBase的pe命令生成一个10G的表

[root@ip-172-31-5-190 fayson]# hbase org.apache.hadoop.hbase.PerformanceEvaluation --compress=SNAPPY --size=10 sequentialWrite 10


2.TestTable表结构

hbase(main):013:0* desc 'TestTable'Table TestTable is ENABLED                                                                                      TestTable                                                                                                       
COLUMN FAMILIES DESCRIPTION                                                                                     {NAME => 'info', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'ROW', REPLICATION_SCOPE => '0', COMPRESSION => '
SNAPPY', VERSIONS => '1', TTL => 'FOREVER', MIN_VERSIONS => '0', KEEP_DELETED_CELLS => 'FALSE', BLOCKSIZE => '65
536', IN_MEMORY => 'false', BLOCKCACHE => 'true'}                                                               1 row(s) in 0.0540 seconds
hbase(main):014:0>

如何使用HBase快照实现跨集群全量与增量数据迁移_hive


3.TestTable表HDFS大小

[root@ip-172-31-6-148 ~]# hadoop fs -du -h /hbase/data/default/2.5 G  7.5 G  /hbase/data/default/TestTable334    1002    /hbase/data/default/picHbase[root@ip-172-31-6-148 ~]#

如何使用HBase快照实现跨集群全量与增量数据迁移_数据_02

此处由于指定了TestTable表的压缩格式为SNAPPY，所以在HDFS上只有2.5GB


4.TestTable表的总数据量，共10485760条数据

如何使用HBase快照实现跨集群全量与增量数据迁移_数据_03


3.通过快照实现HBase跨集群的全量数据备份和还原

3.1生成TestTable表快照



通过CM生成TestTable表快照TestTable-snapshot1

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_04


3.2导出TestTable快照数据



1.在命令行使用HBase自带的ExportSnapshot导出快照

[root@ip-172-31-6-148 ~]# hbase org.apache.hadoop.hbase.snapshot.ExportSnapshot -snapshot TestTable-snapshot1 -copy-to hdfs://ip-172-31-6-148.fayson.com:8020/hbasebackup/TestTable-snapshot1

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_05


2.查看导出的快照数据

[root@ip-172-31-6-148 ~]# hadoop fs -ls /hbasebackup/TestTable-snapshot1Found 2 itemsdrwxr-xr-x   - root supergroup          0 2017-11-02 04:22 /hbasebackup/TestTable-snapshot1/.hbase-snapshotdrwxr-xr-x   - root supergroup          0 2017-11-02 04:21 /hbasebackup/TestTable-snapshot1/archive[root@ip-172-31-6-148 ~]#

如何使用HBase快照实现跨集群全量与增量数据迁移_数据_06


3.查看导出快照数据大小

[root@ip-172-31-6-148 ~]# hadoop fs -du -h /hbasebackup/TestTable-snapshot11.2 K  3.6 K  /hbasebackup/TestTable-snapshot1/.hbase-snapshot2.5 G  7.6 G  /hbasebackup/TestTable-snapshot1/archive[root@ip-172-31-6-148 ~]#

如何使用HBase快照实现跨集群全量与增量数据迁移_hadoop_07

可以看到导出快照实际是把快照的信息及快照记录的所有数据文件分别导出到指定目录下的.hbase-snapshot和archive目录下。

导出快照总耗时：50sec


3.3导入快照并恢复TestTable表



Fayson这里使用的是一个集群做快照导出与恢复操作，所以这里先把集群TestTable的快照和表删掉，然后再通过导出快照和数据将TestTable表恢复


1.通过CM删除TestTable-snapshot1快照数据

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_08


2.通过hbase shell把TestTable DROP掉

[root@ip-172-31-6-148 ~]# hbase shellhbase(main):002:0> disable 'TestTable'hbase(main):003:0> drop 'TestTable'

如何使用HBase快照实现跨集群全量与增量数据迁移_hadoop_09

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_10


确认TestTable表的数据已完全被清除

如何使用HBase快照实现跨集群全量与增量数据迁移_hadoop_11


3.将导出的快照数据恢复至相应的目录

[root@ip-172-31-6-148 ~]# sudo -u hbase hadoop fs -cp /hbasebackup/TestTable-snapshot1/.hbase-snapshot/TestTable-snapshot1 /hbase/.hbase-snapshot[root@ip-172-31-6-148 ~]# sudo -u hbase hadoop fs -cp /hbasebackup/TestTable-snapshot1/archive/data/default/TestTable /hbase/archive/data/default/

如何使用HBase快照实现跨集群全量与增量数据迁移_数据_12

将导出的快照目录拷贝至/hbase/.hbase-snapshot目录，导出的归档文件拷贝至/hbase/archive目录下，如果目录不存在则直接使用导出的归档目录覆盖/hbase/archive目录即可。


4.通过CM界面，使用TestTable-snapshot1快照恢复TestTable表


如何使用HBase快照实现跨集群全量与增量数据迁移_数据_13


此时可以看到TestTable状态为已删除，接下来执行快照恢复操作

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_14


表状态显示正常

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_15


5.验证恢复后的表数据是否与快照时数据一致

通过快照恢复的数据与快照时的数据总条数一致，表内容一致。


如何使用HBase快照实现跨集群全量与增量数据迁移_hadoop_16

快照恢复总耗时：23.89s


4.通过快照实现HBase跨集群的增量数据备份和还原

4.1修改TestTable表数据



1.使用Pe命令为TestTable表每一行增加一列Cloumn

[root@ip-172-31-6-148 ~]# hbase pe append 1

增加后的数据显示

如何使用HBase快照实现跨集群全量与增量数据迁移_数据_17


2.通过hbase shell随机修改和删除表数据

put 'TestTable','00000000000000000000000000','info:0','00000000000'put 'TestTable','00000000000000000000000000','info:AppendTest','00000'deleteall 'TestTable','00000000000000000000000001'deleteall 'TestTable','00000000000000000000000005'deleteall 'TestTable','00000000000000000000009991'put 'TestTable','00000000000000000000000009','info:AppendTest','99999999'delete 'TestTable','00000000000000000000012345','info:0'

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_18


3.TestTable表的数据总量为10485757

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_19


4.2再次创建TestTable表快照



如何使用HBase快照实现跨集群全量与增量数据迁移_hive_20

创建TestTable-snapshot2快照耗时：10.92s


4.3导出第二次快照的增量数据



这一步主要是将TestTable-snapshot2与TestTable-snapshot1两次快照之间的增量数据导出，HBase默认的ExportSnapshot方法是没有增量快照导出的方法，这里Fayson在原有快照导出的基础上对源码进行修改，来完成两个快照之间增量数据的导出。


1.在命令行执行如下命令将两次快照的增量数据导出到HDFS

[root@ip-172-31-6-148 ~]# hbase org.hadoop.hbase.dataExport.ExportSnapshot -snapshot TestTable-snapshot2 -copy-to hdfs://ip-172-31-6-148.fayson.com:8020/hbasebackup/snapshot2-snapshot1/ -snapshot-old TestTable-snapshot1

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_21


2.导出的数据目录

[root@ip-172-31-6-148 ~]# hadoop fs -du -h /hbasebackup/snapshot2-snapshot11.6 K    4.7 K  /hbasebackup/snapshot2-snapshot1/.hbase-snapshot655.6 M  1.9 G  /hbasebackup/snapshot2-snapshot1/archive[root@ip-172-31-6-148 ~]#

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_22

导出增量快照数据总耗时：17sec

通过以上导出的快照数据文件及大小可以看出使用快照增量导出的方式只将快照中有变化的数据文件导出，而非导出表的全量数据。


4.4导入增量快照数据并恢复表



1.导入增量数据前相应目录数据

HBase的快照目录

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_23


归档目录TestTable表数据

如何使用HBase快照实现跨集群全量与增量数据迁移_hadoop_24


2.将导出的快照增量数据导入到HDFS相应目录

[root@ip-172-31-6-148 lib]# sudo -u hbase hadoop fs -cp /hbasebackup/snapshot2-snapshot1/.hbase-snapshot/TestTable-snapshot2 /hbase/.hbase-snapshot[root@ip-172-31-6-148 lib]# sudo -u hbase hadoop fs -cp /hbasebackup/snapshot2-snapshot1/archive/data/default/TestTable /hbase/archive/data/default/


3.导入增量数据后数据目录

HBase快照目录


如何使用HBase快照实现跨集群全量与增量数据迁移_hadoop_25


归档目录数据

如何使用HBase快照实现跨集群全量与增量数据迁移_数据_26


4.通过CM界面使用TestTable-snapshot2快照恢复TestTable表数据


如何使用HBase快照实现跨集群全量与增量数据迁移_hive_27

快照恢复总耗时：49.84s


5.通过CM界面使用TestTable-snapshot2快照恢复TestTable表数据


如何使用HBase快照实现跨集群全量与增量数据迁移_hive_28

如何使用HBase快照实现跨集群全量与增量数据迁移_数据_29

表数据大小：10485757

如何使用HBase快照实现跨集群全量与增量数据迁移_数据_30


5.增量导出源码修改说明



1.代码中增加对比快照参数-snapshot-old

if (cmd.equals("-snapshot")) {
    snapshotName = args[++i];} else if (cmd.equals("-snapshot-old")) {
    snapshotOldName = args[++i];} else if (cmd.equals("-target")) {
    targetName = args[++i];}

 

2.修改导出文件逻辑，对比新旧快照文件列表差异，将有差异的数据文件导出

//TODO 增加快照增量文件判断逻辑
String snapshotOldPath = conf.get(CONF_SNAPSHOT_OLD_DIR);if(snapshotOldPath != null && snapshotOldPath.length() > 0) {
    LOG.info("测试snapshotOldDir:" + conf.get(CONF_SNAPSHOT_OLD_DIR));
    Path snapshotOldDir = new Path(conf.get(CONF_SNAPSHOT_OLD_DIR));
    FileSystem oldFs = FileSystem.get(snapshotOldDir.toUri(), conf);

    List<Pair<SnapshotFileInfo, Long>> snapshotOldFiles = getSnapshotFiles(conf, oldFs, snapshotOldDir);
    Set<String> oldFiles = new HashSet<String>();
    for(Pair<SnapshotFileInfo, Long> pair : snapshotOldFiles) {
        LOG.info("测试OLD：SnapShotFileInfo：" + pair.getFirst().getHfile());
        oldFiles.add(pair.getFirst().getHfile());
    }

    for(Pair<SnapshotFileInfo, Long> pair : origSnapshotFiles) {
        String hfile = pair.getFirst().getHfile();
        if(!oldFiles.contains(hfile)) {
            LOG.info("新增的：SnapShotFileInfo：" + pair.getFirst().getHfile());
            snapshotFiles.add(pair);
        }
    }
} else {
    snapshotFiles = origSnapshotFiles;}

如何使用HBase快照实现跨集群全量与增量数据迁移_hive_31


3.将修改的源码编译成dataExport-0.0.1-SNAPSHOT.jar包，将该jar文件放入/opt/cloudera/parcels/CDH/lib/hbase/lib目录下


如何使用HBase快照实现跨集群全量与增量数据迁移_hadoop_32

具体请参考github源码地址：https://github.com/javaxsky/hbaseexport


6.总结



  • HBase的Snapshot仅涉及metadata的记录，不会涉及数据的拷贝
  • HBase的ExportSnapshot导出快照操作时在HDFS层级进行的，不会对HBase的Master和RegionServer服务造成额外的负担。
  • 重写的ExportSnapshot增量快照导出是通过两个快照文件列表的差异实现，只需要将有差异的文件导出即可。
  • 使用ExportSnapshot导出快照数据时未造成导出数据膨胀，与原始启用了Snappy压缩的HBase表大小基本一致。
  • 在修改HBase自带的ExportSnapshot，需要根据对应的HBase版本获取源码进行修改，不同版本的ExportSnapshot的Packages路径有改动。
  • 在跨集群传输SnapShot文件时推荐使用Cloudera企业版功能BDR，实现跨集群的文件拷贝传输。



为天地立心，为生民立命，为往圣继绝学，为万世开太平。

温馨提示：要看高清无码套图，请使用手机打开并单击图片放大查看。





推荐关注Hadoop实操，第一时间，分享更多Hadoop干货，欢迎转发和分享。

如何使用HBase快照实现跨集群全量与增量数据迁移_数据_33

原创文章，欢迎转载，转载请注明：转载自微信公众号Hadoop实操



举报

相关推荐

0864-7.1.6-如何跨CDP集群通过HBase快照迁移数据

hdfs数据hadoop虚拟化云计算

全量、增量数据在HBase迁移的多种技巧实践

云计算华为云

HDFS和HBase跨集群数据迁移 源码

android汇编语言机器学习网络协议tcp/ip开发语言

使用Xtrabakcup工具实现增量、全量备份

mysqllinux增量备份运维

数据仓库-增量抽取与全量抽取

数据时间戳数据仓库大数据yyds干货盘点

HBase集群数据迁移方案

hbase数据迁移hadoopmapreduceapache

MySQL全量、增量备份与恢复

数据库个人学习

Hbase跨集群同步数据

apachehadoophdfsHadoop大数据

HDFS数据(跨集群)迁移

hdfshadoop数据Redis数据库

XtraBackup实现全量+增量+Binlog恢复库

mysql数据库备份XtraBackup全量增量Binlog恢复库MySQL数据库
0 条评论