如何通过NodeJS调用elasticsearch api？

我的任务是对弹性搜索 api 进行 POST api 调用，

https://search-test-search-fqa4l6ubylznt7is4d5yxlmbxy.us-west-2.es.amazonaws.com/klove-ddb/recipe/_search

我以前没有任何对 AWS 服务进行 api 调用的经验。

所以，我尝试了这个 -

axios.post('https://search-test-search-fqa4l6ubylznt7is4d5yxlmbxy.us-west-2.es.amazonaws.com/klove-ddb/recipe/_search')
            .then(res => res.data)
            .then(res => console.log(res));

但我收到{“Message”：“User：anonymous无权执行：es：ESHttpPost”}

我还检查了一些 IAM 角色，并将 AWSESFullAccess 策略添加到我的个人资料中。

我仍然无法解决任何问题。

请帮我。

您看到错误的原因User: anonymous is not authorized to perform: es:ESHttpPost是因为您在不让 ElasticSearch 知道您是谁的情况下请求数据 - 这就是为什么它显示“匿名”。

有多种身份验证方法，最简单的方法是使用弹性搜索库。使用此库，您将为该库提供一组 IAM 角色/用户的凭证（访问密钥、秘密密钥）。它将使用它来创建签名请求。签名的请求将使 AWS 知道谁实际发出请求，因此该请求不会以匿名方式接收，而是由您自己接收。

使其发挥作用的另一种方法是将您的访问策略调整为基于 IP：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "AWS": "*"
            },
            "Action": "es:*",
            "Condition": {
                "IpAddress": {
                    "aws:SourceIp": [
                        "AAA.BBB.CCC.DDD"
                    ]
                }
            },
            "Resource": "YOUR_ELASTICSEARCH_CLUSTER_ARN"
        }
    ]
}

这项特殊政策将对任何拥有您在此处提供的 IP（范围）的人开放。不过，这将使您免去签署请求的麻烦。

帮助设置的库elasticsearch-js使用 AWS ES 是this one

一个工作示例如下：

const AWS = require('aws-sdk')
const elasticsearch = require('elasticsearch')
const awsHttpClient = require('http-aws-es')

let client = elasticsearch.Client({
    host: '<YOUR_ES_CLUSTER_ID>.<YOUR_ES_REGION>.es.amazonaws.com',
    connectionClass: awsHttpClient,
    amazonES: {
        region: '<YOUR_ES_REGION>',
        credentials: new AWS.Credentials('<YOUR_ACCESS_KEY>', '<YOUR_SECRET_KEY>')
    }
});

client.search({
    index: 'twitter',
    type: 'tweets',
    body: {
        query: {
            match: {
                body: 'elasticsearch'
            }
        }
    }
})
.then(res => console.log(res));