1

我正在使用亚马逊的 ElasticsearchService。他们的文档让我有点不知所措。我发现它很大,但很难导航。无论如何,我正在寻找使用他们的 AWS Java SDK 使用 ESService 的示例。你有一个链接 - 或一些插入文档的代码吗?

我实际上是在 Scala 中使用它,到目前为止我得到的是:

val awsEsClient: AWSElasticsearchClient = new AWSElasticsearchClient()
awsEsClient.setRegion(Region.getRegion(Regions.EU_CENTRAL_1))
awsEsClient.setEndpoint("es.eu-central-1.amazon.aws.com")
val createD = new CreateElasticsearchDomainRequest()

我应该在哪里指定我自己的实例 ARN?看起来像的uri

arn:aws:es:eu-central-1:xxxxxxxxxxx:domain/yyyyyyyy

另外,在使用他们的 SDK 时,我想我不需要在任何地方指定他们提供的端点?路过的那个

search-yyyyyy-xxxxxxxxxx.eu-central-1.es.amazonaws.com

或者也许这是我应该指定的,而不是

awsEsClient.setEndpoint("es.eu-central-1.amazon.aws.com")

感谢您的帮助,如果所有这些问题听起来很明显,我们深表歉意。

4

1 回答 1

4

所以,我从一开始就搞错了。SDK 仅用于管理服务,例如启动新节点等 - 而不是访问它。为此,亚马逊提供的唯一解决方案是使用 Elastic Search 提供的通用 REST API 的 HTTP 端点。接下来的问题是对请求进行身份验证。我已经编译了一个 scala 库来为每个请求执行此操作,可在此处获得:https ://github.com/ticofab/aws-request-signer 。

于 2015-12-19T15:23:52.837 回答