如何在 AWS lambda 中连接 ElasticSearch

Question

我已经创建了 ElasticSearch 服务的公共实例。我找不到任何关于如何将我的 lambda 函数连接到它的适当示例。
我想过使用带有 javascript 的 AWS-SDK（类：AWS.ES）来建立连接。但是找不到方法。
如何创建连接并使用它进行基本查询？

Answer 1

这是给您的示例代码。我已经在我的 lambda 函数中实现了

var elasticsearch=require('elasticsearch');
var esInput = getRequireFormat(data);

elasticSearch(esInput, function(err, response) {
  if (err) {
    callback(null, err);
  } else {
    callback(null, response);
  }
});

function elasticSearch(data, callback) {
  var client = new elasticsearch.Client({
    hosts: [
      process.env['elasticsearch'] // lambda and elastic search connection
    ]
  });
  client.bulk({
    body: data // query
  }, function(err) {
    if (err) {
      callback(err);
    } else {
      callback(null, 'Success');
    }
  });
}

function getRequireFormat(data) {
  data = JSON.parse(data.toString());
  var i;
  var length = data.length * 2;
  var x = 0;

  for (i = 0; i < length;) {
    (function(i) {

      const json = {
        'index': {
          '_index': data.name.toLowerCase(),
          '_type': data.type,
          '_id': data.x
        }
      };
      data.splice(i, 0, json);
      x = x + 1;
    })(i);
    i = i + 2;
  }
  return data;
}