elasticsearch node 简单使用

elasticsearch node 简单的使用 repo

https://juejin.im/entry/6844903607775526919

https://www.elastic.co/guide/en/elasticsearch/client/javascript-api/16.x/api-reference-6-8.html#api-search-6-8

https://www.npmjs.com/package/elasticsearch

https://www.npmjs.com/package/egg-es

前置条件
  1. elasticsearch 环境
  2. node(用了 egg) 环境
填充数据

开始选择用了 elasticsearch 包利用 js 直接填充城市 cities数据

https://juejin.im/entry/6844903607775526919

这里有一些 index、type、id 需要相同 这样才能正确的使用和填充数据删除之类的

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
const elasticsearch = require("elasticsearch");
// 所有城市数据
const cities = require('./cities.json')
const axios = require('axios')

// init apiVersion 需要和本地一样
const client = new elasticsearch.Client({
host: "localhost:9200",
log: "trace",
apiVersion: "6.8", // use the same version of your Elasticsearch instance
});
const sleep = time => new Promise(reslove => setTimeout(reslove, time))

const init = async () => {
try {
await client.ping({
requestTimeout: 30000
});
} catch (e) {
console.log('e', e)
}
}
init()

// 创建索引
// -> POST http://localhost:9200/es_user/_doc/1/_create
const createFunc = async () => {
try {
await client.create({
index: 'es_user',
type: '_doc',
id: '1',
body: {}
});
} catch (error) {
console.log('create error', error)
}
}

// 删除
// -> DELETE http://localhost:9200/es_user/_doc/1
const deleteFunc = async () => {
try {
await client.delete({
index: 'es_user',
type: '_doc',
id: '1',
});
} catch (error) {
console.log('delete error', error)
}
}

// 填充数据
const push = (cities, start, end) => {
var bulk = [];
cities.slice(start, end).forEach(city => {
bulk.push({
index: {
_index: 'es_user',
_type: '_doc',
}
})
bulk.push(city)
})

// console.log('bulk: go', bulk)

// 对传递的数据执行批量索引
client.bulk({
body: bulk
}, function (err, response) {
if (err) {
console.log("Failed Bulk operation".red, err)
} else {
console.log("Successfully imported %s".green, cities.length);
}
});

}

// 开始冲
// 这里为什么这样写....
const go = async () => {
// 1. 因为例子的json的数据非常大按照官方的建议说 1000-5000个数据 所以我这里拆了一下
let citiesLen = Math.ceil(cities.length / 1000)
for (let i = 0; i <= citiesLen; i++) {
// 2. 因为有时候老是提示没有权限 然后这里直接 设置一下(可以忽略的 因为第一次不太会)
await axios({
method: 'put',
url: 'http://localhost:9200/_all/_settings',
headers: {
'Content-Type': 'application/json'
},
data: {
"index.blocks.read_only_allow_delete": false
}
})
// 2. 让他停一会儿 懒得用 async map (可以在npm search)
await sleep(300)
// 3. 开始填充数据
push(cities, i * 1000, (i+1) * 1000)
}
}

// deleteFunc()
// createFunc()
// go()
写接口

node用了egg初始化的项目

router
1
2
// elasticsearch
router.get('/api/search', controller.elasticsearch.search);
func
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
// 因为用了 egg 为了方便 用 egg-es 
// https://www.npmjs.com/package/egg-es
// 文档的方法⬇️⬇️⬇️

// Usage
// {app_root}/config/plugin.js
exports.elasticsearch = {
enable: true,
package: 'egg-es',
};

// Configuration
// {app_root}/config/config.default.js
exports.elasticsearch = {
host: 'localhost:9200',
apiVersion: '6.3'
};

export default class Elasticsearch extends Service {
public async search(wd: string) {
try {
// https://www.elastic.co/guide/en/elasticsearch/client/javascript-api/16.x/api-reference-6-8.html#api-search-6-8
// search doc 因为body还没有理解 赞赏用了简单的搜索🔍
const response = await this.app.elasticsearch.search({
index: 'es_user',
body: {
query: {
match: {
name: wd,
},
},
}
})
console.log('response', response)
// 格式化一下数据
const list = response.hits.hits.map((i: { _source: object[] }) => i._source)
return {
count: response.hits.total || 0,
list,
}
} catch (e) {
console.log('search e', e)
return ''
}
}
}

数据都已经有了, 前端大伙随便搞搞就好了 后面还有很多功能还没有使用 分词、过滤、什么什么吧啦吧啦 后面用到了继续写文章介绍

打赏测试