nodejs(egg) 与 ES (elasticsearch)沟通

1.安装 egg-es

npm i egg-es --save

2.建一个Controller 做资料新增
注意 my-index-005 这是ES内的index名称 , 假设为 my-index-005

const Controller = require('egg').Controller;
const elasticsearch = require('elasticsearch');

class EstestController extends Controller {

    async add() {

        var esClient = new elasticsearch.Client({
            host: 127.0.0.1:9002,
            log: 'info'
        });
      
        let result = await esClient.bulk({
            body: [
                { index: { _index: 'my-index-005', _id: '10002245' } },
                { content: '测试写入内容' }
            ]
        });
      
        this.ctx.body = result;
    }
}
module.exports = EstestController;

3.资料更新

    async edit() {
        let result = await esClient.bulk({
            body: [
                { update: { _index: 'my-index-005', _id: '10002245' } },
                { doc: { content: '更新後的内容' } },
            ]
        });
        this.ctx.body = result;
    }

4.搜寻

    async query() {
        let result = await esClient.search({
            index: 'news',
            body: {
                query: {
                    match: {
                        content: '欲查询的内容'
                    }
                }
            }
        });
        console.log('result: ', JSON.stringify(result));
    }

5.删除

    async delete() {
        let result = await esClient.bulk({
            body: [
                { delete: { _index: 'my-index-005', _id: '10002245' } },
            ]
        });
    }

完成便可以到kibana确认