AWS ElasticSearchService - Java SDK 示例？

Question

我正在使用亚马逊的 ElasticsearchService。他们的文档让我有点不知所措。我发现它很大，但很难驾驭。无论如何，我正在寻找使用 ESService 使用他们的 AWS Java SDK 的示例。您有 link - 或一些代码来插入文档吗？

我实际上是在 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")

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

Answer 1

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

AWS ElasticSearchService - Java SDK 示例？

AWS ElasticSearchService - Java SDK example?

java

scala

amazon-web-services

aws-sdk

amazon-elasticsearch