IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> 【es】elasticsearch生产数据备份和恢复方案 -> 正文阅读

[大数据]【es】elasticsearch生产数据备份和恢复方案

一、前言概要

生产环境中运行的组件,只要有数据存储,定时备份、灾难恢复是必修课,MySQL数据库的备份方案已经非常成熟,elasticsearch也同样有成熟的数据备份、恢复方案,我们来了解一下。

本篇介绍Elasticsearch生产集群数据的数据备份、恢复和升级的常规操作。

二、数据备份

我们知道Elasticsearch的索引拆分成多个shard进行存储在磁盘里,shard虽然分了primary shard和replica shard,可以保证集群的数据不丢失,数据访问不间断,但如果机房停电导致集群节点全部宕机这种重大事故时,我们就需要提前定期地对数据进行备份,以防万一。

既然是磁盘文件存储,那存储介质的选择就有很多了:本地磁盘,NAS,文件存储服务器(如FastDFS、HDFS等),各种云存储(Amazon S3, 阿里云OSS)等

同样的,Elasticsearch也提供snapshot api命令来完成数据备份操作,可以把集群当前的状态和数据全部存储到一个其他目录上,本地路径或网络路径均可,并且支持增量备份。可以根据数据量来决定备份的执行频率,增量备份的速度还是很快的。

1.创建备份仓库

我们把仓库地址暂定为本地磁盘的/home/esuser/esbackup目录

首先,我们需要在elasticsearch.yml配置文件中加上

path.repo: /home/esuser/esbackup

并重启Elasticsearch。

启动成功后,发送创建仓库的请求:

####################################

$ curl -XPUT'http://elasticsearch02:9200/_snapshot/esbackup?pretty'? \

-H? 'Content-Type: application/json'? \

-d? '{

? ? "type": "fs",

? ? "settings": {

??? ? ? "location": "/home/esuser/esbackup",

? ? ? ? "max_snapshot_bytes_per_sec" : "50mb",

? ? ? ? "max_restore_bytes_per_sec" : "50mb"

? ? }

}'

{"acknowledged":true}

#####################################

参数说明:

type: 仓库的类型名称,请求里都是fs,表示file system。

location: 仓库的地址,要与elasticsearch.yml配置文件相同,否则会报错

max_snapshot_bytes_per_sec: 指定数据从Elasticsearch到仓库(数据备份)的写入速度上限,默认是20mb/s

max_restore_bytes_per_sec: 指定数据从仓库到Elasticsearch(数据恢复)的写入速度上限,默认也是20mb/s

用于限流的两个参数,需要根据实际的网络进行设置,如果备份目录在同一局域网内,可以设置得大一些,便于加快备份和恢复的速度。

2.查看仓库的信息

$? curl -X GET? ? 'http://elasticsearch02:9200/_snapshot/esbackup?pretty'

3.索引备份

仓库创建好并验证完成后,可以执行snapshot api对索引进行备份了.

如果不指定索引名称,表示备份当前所有open状态的索引都备份,还有一个参数wait_for_completion,表示是否需要等待备份完成后才响应结果,默认是false,请求提交后会立即返回,然后备份操作在后台异步执行,如果设置为true,请求就变成同步方式,后台备份完成后,才会有响应。建议使用默认值即可,有时备份的整个过程会持续1-2小时。

示例1:备份所有的索引,备份名称为snapshot_20200122

$ curl -X? PUT? 'http://elasticsearch02:9200/_snapshot/esbackup/snapshot_20200122?pretty'

{"accepted":true}

例2:备份索引music的数据,备份名称为snapshot_20200122_02,并指定wait_for_completion为true

#####################################

$ curl -X? PUT? ?'http://elasticsearch02:9200/_snapshot/esbackup/snapshot_20200122_02?wait_for_completion=true&pretty'? \

-H? 'Content-Type: application/json'? \

-d? '{

? "indices": "music",

? "ignore_unavailable": true,

? "include_global_state": false,

? "partial": true

}'

########################################

参数说明:

indices:索引名称,允许写多个,用","分隔,支持通配符。

ignore_unavailable:可选值true/false,如果为true,indices里不存在的index就可以忽略掉,备份操作正常执行,默认是false,如果某个index不存在,备份操作会提示失败。

include_global_state:可选值true/false,含义是要不要备份集群的全局state数据。

partial:可选值true/false,是否支持备份部分shard的数据。默认值为false,如果索引的部分primary shard不可用,partial为false时备份过程会提示失败。

使用snapshot api对数据的备份是增量进行的,执行snapshotting的时候,Elasticsearch会分析已经存在于仓库中的snapshot对应的index file,在前一次snapshot基础上,仅备份创建的或者发生过修改的index files。这就允许多个snapshot在仓库中可以用一种紧凑的模式来存储,非常节省存储空间,并且snapshotting过程是不会阻塞所有的Elasticsearch读写操作的。

同样的,snapshot作为数据快照,在它之后写入index中的数据,是不会反应到这次snapshot中的,snapshot数据的内容包含index的副本,也可以选择是否保存全局的cluster元数据,元数据里面包含了全局的cluster设置和template。

每次只能执行一次snapshot操作,如果某个shard正在被snapshot备份,那么这个shard此时就不能被移动到其他node上去,这会影响shard rebalance的操作。只有在snapshot结束之后,这个shard才能够被移动到其他的node上去。

4.?查看snapshot备份列表

查看仓库内所有的备份列表:

$? curl -X? GET? 'http://elasticsearch02:9200/_snapshot/esbackup/_all?pretty'

查看单个备份数据:

$ curl -X GET? ?'http://elasticsearch02:9200/_snapshot/esbackup/snapshot_20200122_02?pretty'


5.删除snapshot备份

如果需要删除某个snapshot备份快照,一定要使用delete命令,别做出跑到服务器目录下做rm操作,因为snapshot是增量备份的,里面有各种依赖关系,极可能损坏backup数据。

记住不要上来就自己干文件,请使用人家标准的命令来执行:

$? curl -X DELETE? 'http://elasticsearch02:9200/_snapshot/esbackup/snapshot_20200122?pretty'

{"acknowledged":true}

6.?查看备份进度

备份过程长短视数据量而定,wait_for_completion设置为true虽然可以同步得到结果,但时间太长的话也不现实,我们是希望备份操作后台自己搞,我们时不时的看看进度就行。

其实还是调用的snapshot的get操作命令,加上_status参数即可,备份过程中会显示什么时间开始的,有几个shard在备份等等信息:

$ curl -X GET? 'http://elasticsearch02:9200/_snapshot/esbackup/snapshot_20200122_02/_status?pretty'

7. 取消备份

正在备份的数据可以执行取消,使用的是delete命令:

$ curl -X DELETE? 'http://elasticsearch02:9200/_snapshot/esbackup/snapshot_20200122?pretty'

这个命令有两个作用:

如果备份正在进行中,那么取消备份操作,并且删除备份了一半的数据。

如果备份已经完成,直接删除备份数据。

三、数据恢复

生产环境的备份操作,是定期执行的,执行的频率看实际的数据量,有1天执行1次的,有4小时一次的,简单的操作是使用shell脚本封装备份的命令,然后使用Linux的crontab定时执行。

既然数据有备份,那如果数据出现异常,或者需要使用到备份数据时,恢复操作就能派上用场了。

1.常规恢复

数据恢复使用restore命令,示例如下:

$ curl -X? POST? 'http://elasticsearch02:9200/_snapshot/esbackup/snapshot_20200122_02/_restore?pretty'

{"accepted":true}

注意被恢复的索引,必须全部是close状态的,否则会报错,关闭索引的命令:

$ curl -X? POST? 'http://elasticsearch02:9200/music/_close?pretty'

恢复完成后,索引自动还原成open状态。

同样有些参数可以进行选择:

######################################################

$ curl -X? POST? 'http://elasticsearch02:9200/_snapshot/esbackup/snapshot_20200122_02/_restore?\

-H? 'Content-Type: application/json'? \

-d? '{

? ? "indices": "music",

? ? "ignore_unavailable": true,

? ? "include_global_state": true

}'

########################################################

默认会把备份数据里的索引全部还原,我们可以使用indices参数指定需要恢复的索引名称。

同样可以使用wait_for_completion参数,ignore_unavailable、partial和include_global_state与备份时效果相同,不赘述。

2.监控restore的进度

调用的recovery的get操作命令查看恢复的进度:

$ curl -X GET? ?'http://elasticsearch02:9200/music/_recovery?pretty'

3.取消restore

与备份类似,delete正在恢复的索引可以取消恢复过程:

$ curl -X DELETE? ?'http://elasticsearch02:9200/music/_recovery?pretty'

四、集群升级

我们现在使用的版本是6.3.1,目前官网最新版本已经是7.5.2了,如果没有重大的变更或严重bug报告的情况下,一般是不需要做升级,毕竟升级有风险,发布要谨慎。

这里就简单说一下通用的步骤,谨慎操作:

1. 查看官网最新版本的文档,从当前版本到目标版本的升级,有哪些变化,新加入的功能和修复的bug。

2. 在开发环境或测试环境先执行升级,相应的插件也做一次匹配升级,稳定运行几个项目版本周期后,再考虑生产环境的升级事宜。

3. 升级前对数据进行全量的备份,万一升级失败,还有挽救的余地。

4.申请生产环境升级的时间窗口,逐个node进行升级验证。

集群版本升级这类操作,实践起来比较复杂,受项目本身影响比较大,这里就简单提及要注意的地方,没有作详细的案例操作,真要有版本升级的操作,请各位慎重操作,多验证,确保测试环境充分测试后再上生产,记得数据要备份。

六、参考

elasticsearch生产数据备份恢复方案

?https://segmentfault.com/a/1190000022910433

Elasticsearch Snapshot and Restore

https://zhuanlan.zhihu.com/p/43416538

elasticsearch数据备份说明

https://zhuanlan.zhihu.com/p/43416538

elasticsearch备份和还原脚本

https://www.cnblogs.com/personsiglewine/p/12510845.html

How To Setup Your Elasticsearch Cluster and Backup Data

https://www.twilio.com/blog/setup-elasticsearch-cluster-backup

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2021-08-30 12:07:06  更:2021-08-30 12:07:34 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/23 16:54:14-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码