egg-plugin-elasticsearch v1.0.2

egg-plugin-elasticsearch

目录

• 配置
  • 单客户端配置
  • 多客户端配置
  • plugin.js配置
• 使用
  • 单客户端示例
  • 多客户端示例
• 其它

配置

单客户端配置

{
  elasticsearch:{
    client:{
      node: 'https://localhost:9200/',
      auth: {
        username: '',
        password: ''
      },
      maxRetries: 5,
      requestTimeout: 60000,
      sniffOnStart: true
    }
  }
}

多客户端配置

{
  elasticsearch:{
    clients: {
      clientA: {
        node: 'https://localhost:9200/',
        auth: {
          username: '',
          password: ''
        },
        maxRetries: 5,
        requestTimeout: 60000,
        sniffOnStart: true
      },
      clientB: {
        node: 'https://localhost/es/api2/',
        auth: {
          username: '',
          password: ''
        },
        maxRetries: 5,
        requestTimeout: 60000,
        sniffOnStart: true
      }
    }
  }
}

plugin.js配置

{
  elasticsearch: {
    enable: true,
    package: 'egg-plugin-elasticsearch'
  }
}

使用

单客户端示例

public async demo () {
  const { ctx, app } = this
  // 通过app获取。 
  const client = app.elasticsearch
  // 通过ctx获取。 es为简写
  const client = ctx.elasticsearch
  const client = ctx.es
  try {
    const result = await client.info()
    return ctx.setResult(result.body)
  } catch (error) {
    console.log(error)
    return ctx.setError([error])
  }
}

多客户端示例

public async demo () {
  const { ctx, app } = this
  // 通过app获取。 
  const client = app.elasticsearch.get('clientA')
   const clientB = app.elasticsearch.get('clientB')
  // 通过ctx获取。 es为简写
  const clientA = ctx.elasticsearch.get('clientA')
  const clientB = ctx.es.get('clientB')
  try {
    const result = await clientA.info()
    return ctx.setResult(result.body)
  } catch (error) {
    console.log(error)
    return ctx.setError([error])
  }
}

其它

使用了elasticsearch官方 SDK7.12.0 做的封装，API使用请自行查阅：

Elasticsearch JavaScript Client