使用elasticdump导入导出数据

一、安装elasticdump
终端中输入
1 npm install elasticdump -g
-g表示全局可用，直接在终端输入 elasticdump --version，出现版本信息即表示安装成功，如下
1
2 C:\Users\T470s>elasticdump --version
6.3.3

二、常用的导入导出方法
　1、将索引中的数据导出到本地
1 elasticdump --input=http://localhost:9200/demo --output=D:/ES/date/demo.json
　其中，demo是索引。
　2、将本地数据导入es中
1 elasticdump --input=D:/ES/date/demo.json --output=http://localhost:9200/demo1
　3、将es导入另一个es
1 elasticdump --input=http://ip:9200/demo --output=http://127.0.0.1:9200/demo
　4、含有分词的导入
前文：公司正在运行的项目需要搭一个测试环境，需要将正式环境的ES里面存储的数据导入到该测试环境的ES服务器里面。使用本地的windows系统来实现。
1，环境准备
因为elaticdump 依赖于nodejs的环境，需要下载nodejs的相关依赖环境，去nodejs官网直接安装包，我下载的是msi安装程序，安装好之后会直接配置好环境变量，在cmd或者Powershell直接下载elaticdump 即可：
1 npm install elasticdump

2，生产环境导出到测试环境
1）导出分词器，导出分词器的时候要特别注意，我们只能根据索引单个导入，不能全部导出，全部导出会出现索引不存在的错误：
1 elasticdump --input=http://ip:9200 --output=http://127.0.0.1:9200/ --type=analyzer --all=true　　
该全部导出导入的命令会如下错误：
1 Error Emitted => {“root_cause”:[{“type”:“action_request_validation_exception”,“reason”:“Validation Failed: 1: index is missing;”}],“type”:“action_request_validation_exception”,“reason”:“Validation Failed: 1: index is missing;”}
　
所以后面改为按索引分别导入则可以：
1
2
3 elasticdump --input=http://ip:9200/applog --output=http://127.0.0.1:9200/applog --type=analyzer
elasticdump --input=http://ip:9200/cms_article --output=http://127.0.0.1:9200/cms_article --type=analyzer
elasticdump --input=http://ip:9200/followup --output=http://127.0.0.1:9200/followup --type=analyzer
坑：再倒入的时候我并不知道到底有多少个索引，如何确定索引的名称？
这里我是直接先导出所有映射mapping到本地，然后找到索引的名称再到各导入分词：
1 elasticdump --input=D:/mapping.json --output=http://127.0.0.1:9200/ --all=true --type=mapping
疑惑：我这里的索引目前只有三个，如果是多个怎么处理？超过100?
2)导出映射mapping
映射mapping可以直接全部导入导出,直接命令：
1 elasticdump --input=http://ip:9200/ --output=http://127.0.0.1:9200/ --all=true --type=mapping
3）导出全部数据data
每个索引下的数据可以全部一次性导入：
1 elasticdump --input=http://ip:9200/ --output=http://127.0.0.1:9200/ --all=true --type=data
3,总结
1），如果不导入analyzer会怎么样？
我试过如果只导入data和mapping，则数据会导入，mapping会发生变化，最终的结果没有分词的效果。
2），如果不导入mapping也不会有分词的效果。
3），顺序导入最好按照：analyzer，mapping和data这个顺序来，防止出现分词失效的结果。

顺序导入按照：analyzer，mapping，data

es数据的导出

//索引的导出

// 导出 index 的 mapping 到 .json 文件

elasticdump \
  --input=http://production.es.com:9200/demo \
  --output=/data/demo.json \
  --type=mapping

//导出全部索引

elasticdump --input=http://ip:9200/ --output=http://127.0.0.1:9200/ --all=true --type=mapping

//数据的导出

// 导出 index 的所有数据到 .json 文件

elasticdump \
  --input=http://production.es.com:9200/demo \
  --output=/data/demo.json \
  --type=data

//导出全部数据

elasticdump --input=http://ip:9200/ --output=http://127.0.0.1:9200/ --all=true --type=data

//分词器导出

//导出分词器，导出分词器的时候要特别注意，我们只能根据索引单个导入，不能全部导出，全部导出会出现索引不存在的错误
//改为按索引分别导入：

elasticdump --input=http://ip:9200/applog --output=http://127.0.0.1:9200/applog --type=analyzer
elasticdump --input=http://ip:9200/cms_article --output=http://127.0.0.1:9200/cms_article --type=analyzer
elasticdump --input=http://ip:9200/followup --output=http://127.0.0.1:9200/followup --type=analyzer

es数据的导入

• 从本地文件导入数据

elasticdump  --input=/data/demo.json --output=http://localhost:9200/demo1

将es导入另一个es

elasticdump --input=http://ip:9200/demo --output=http://127.0.0.1:9200/demo

#!/usr/bin/env bash

array=(“full_vehicle_portrait” “latest_car_history_trail_dt” “vehicle_abnormal_monitor” “gantry_transaction-20200914” “vehicle_abnormal_summary”)
for(( i=0;i<KaTeX parse error: Expected '}', got '#' at position 2: {#̲array[@]};i++))…{array[i]}
#创建索引
curl -X PUT ‘http://cdh173:9200/$VAR1?pretty’

elasticdump
–input=http://33.69.6.95:9200/$array[i]--output=http://cdh219:9200/${array[i]}
–type=analyzer
elasticdump
–input=http://33.69.6.95:9200/$array[i]--output=http://cdh219:9200/${array[i]}
–type=settings
elasticdump
–input=http://33.69.6.95:9200/$array[i]--output=http://cdh219:9200/${array[i]}
–type=mappingcc

elasticdump --size=200
–input=http://33.69.6.95:9200/$array[i]--output=http://cdh219:9200/${array[i]}
–type=data
done

如果我es里索引非常多，这样一个一个去执行依然会耗时，怎么做？当然想到了shell脚本。
脚本名字为：esExportOrInput.sh
#!/bin/sh
index_name=$1
index_data=$1"_data"
index_settings=$1"_settings"
echo “开始执行”

导出索引Mapping数据

./elasticdump --input=http://source:9200/
i
n
d
e
x
n
a
m
e
/
−
−
o
u
t
p
u
t
=
.
/
index_name/ --output=./
indexn​ame/−−output=./index_name.json --type=mapping
./elasticdump --input=http://source:9200/
i
n
d
e
x
n
a
m
e
/
−
−
o
u
t
p
u
t
=
.
/
index_name/ --output=./
indexn​ame/−−output=./index_settings.json --type=settings

导出索引数据

./elasticdump --input=http://source:9200/
i
n
d
e
x
n
a
m
e
/
−
−
o
u
t
p
u
t
=
.
/
index_name/ --output=./
indexn​ame/−−output=./index_data.json --type=data --limit=1000

#导入索引Mapping数据
echo "执行删除目标服务的索引start："
i
n
d
e
x
n
a
m
e
c
u
r
l
−
X
D
E
L
E
T
E
h
t
t
p
:
/
/
t
a
r
g
e
t
:
9200
/
index_name curl -XDELETE http://target:9200/
indexn​amecurl−XDELETEhttp://target:9200/index_name
echo "执行删除目标服务的索引end：“
i
n
d
e
x
n
a
m
e
s
l
e
e
p
3
e
c
h
o
"
等待三秒。。。
"
.
/
e
l
a
s
t
i
c
d
u
m
p
−
−
i
n
p
u
t
=
.
/
index_name sleep 3 echo "等待三秒。。。" ./elasticdump --input=./
indexn​amesleep3echo"等待三秒。。。"./elasticdump−−input=./index_settings.json --output=http://target:9200/
i
n
d
e
x
n
a
m
e
/
−
−
t
y
p
e
=
s
e
t
t
i
n
g
s
.
/
e
l
a
s
t
i
c
d
u
m
p
−
−
i
n
p
u
t
=
.
/
index_name/ --type=settings ./elasticdump --input=./
indexn​ame/−−type=settings./elasticdump−−input=./index_name.json --output=http://target:9200/
i
n
d
e
x
n
a
m
e
/
−
−
t
y
p
e
=
m
a
p
p
i
n
g
.
/
e
l
a
s
t
i
c
d
u
m
p
−
−
i
n
p
u
t
=
.
/
index_name/ --type=mapping ./elasticdump --input=./
indexn​ame/−−type=mapping./elasticdump−−input=./index_data.json --output=http://target:9200/KaTeX parse error: Expected 'EOF', got '#' at position 39: …a --limit=1000 #̲清除生成的文件 rm -f .…index_name.json
rm -f ./
i
n
d
e
x
s
e
t
t
i
n
g
s
.
j
s
o
n
r
m
−
f
.
/
index_settings.json rm -f ./
indexs​ettings.jsonrm−f./index_data.json
#清除生成的文件
echo “索引”$index_name"执行完毕”

执行时候需要传递1个变量，就是索引名字index_name

温馨提示：
1、这个脚本仅仅只能在安装了elasticdump服务器上使用，脚本目录在/root/node_modules/elasticdump/bin
2、导出导入默认100条一批，可以添加–limit 每页条数 来自定义每页数量。
3、导入的时候一定要限制性settings的文件导入，在执行mapping的导入，不然会冲突，因为settings上带了uuid的唯一标识。
样例：如果我要对bum_user这个索引的数据从测试环境迁移到压测服务器target上，就这样执行命令
./esExportOrInput.sh bum_user

留个作业，可以对源服务器和目标服务器进行动态参数传递，就可以做到万能适配了，有兴趣就重写