如何从 Node JS 访问 AWS Elasticsearch

Question

我的 nodejs lambda 试图将数据索引到 ES 中，但由于此错误而失败：

2018-01-15T23:39:09.578Z (node:1) UnhandledPromiseRejectionWarning：未处理的承诺拒绝（拒绝 id：131）：授权异常 ::

用户：anonymous 无权执行：es:ESHttpPost on resource:****

我已将 AmazonESFullAccess 策略应用于 Lambda 函数角色。
我错过了什么？

Answer 1

我能够解决这个问题。代码缺少“connectionClass”和“amazonES”参数。

var AWS = require('aws-sdk');
var connectionClass = require('http-aws-es');
var elasticsearch = require('elasticsearch');
var elasticClient = new elasticsearch.Client({  
    host: ***,
    log: 'error',
    connectionClass: connectionClass,
    amazonES: {
      credentials: new AWS.EnvironmentCredentials('AWS')
    }
});