node.js - Elasticsearch 中的连接池

Question

我们如何在 Node js 中为 Elasticsearch 配置连接池？用于处理实例故障和检测死 Node 。

如何在nodejs中自定义elasticsearch的Transport、ConnectionPool、Connections类。

Answer 1

新的 RC1 client 支持此功能

这里是一个例子:

'use strict'
// docker run -p 9200:9200 -p 9300:9300 --rm -e "discovery.type=single-node" docker.elastic.co/elasticsearch/elasticsearch:6.7.0
const { Client } = require('@elastic/elasticsearch')
const client = new Client({
  nodes: ['http://127.0.0.1:9200/'],
  requestTimeout: 2000,
  sniffInterval: 500,
  sniffOnStart: true,
  sniffOnConnectionFault: true
})

client.on('sniff', (err, req) => {
  console.log('snif', err ? err.message : '', `${JSON.stringify(req.meta.sniff)}`)
})

setInterval(async () => {
  try {
    const info = await client.info()
    console.log(info.body.name)
  } catch (err) {
    console.log(err.message);
  }
}, 1500)

注意安装 v6:

“@elastic/elasticsearch”:“6.7.0-rc.1”，