12

我正在尝试连接到 AWS Elasticsearch，但我总是收到以下错误：

Exception in thread "main" org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: []
at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:278)
at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:197)
at org.elasticsearch.client.transport.support.InternalTransportClient.execute(InternalTransportClient.java:106)
at org.elasticsearch.client.support.AbstractClient.index(AbstractClient.java:98)
at org.elasticsearch.client.transport.TransportClient.index(TransportClient.java:334)
at org.elasticsearch.action.index.IndexRequestBuilder.doExecute(IndexRequestBuilder.java:313)
at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:91)
at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:65)
at com.c_backendcrawler.utility.ElasticSearch.uploadObject(ElasticSearch.java:25)
at com.c_backendcrawler.Start.main(Start.java:34)

我的代码如下：

 //Create Client
    Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", "zencubes-search").put("node.name","Darkhawk").build();
    TransportClient transportClient = new TransportClient(settings);
    transportClient.addTransportAddress(new InetSocketTransportAddress(
            "x.x.x.x",9300));
    return transportClient;

AWS Elasticsearch 的输出：

    {
status: 200,
name: "Darkhawk",
cluster_name: "817880037706:zencubes-search",
version: {
number: "1.5.2",
build_hash: "62ff9868b4c8a0c45860bebb259e21980778ab1c",
build_timestamp: "2015-04-27T09:21:06Z",
build_snapshot: false,
lucene_version: "4.10.4"
},
tagline: "You Know, for Search"
}

我试图卷曲（https://search-zencubes-search-xxxxxxxx.eu-west-1.es.amazonaws.com/）并且它可以工作 - 但不能在端口 9300 上。我在这里做错了什么？

4

4 回答 4

16

本机传输协议不支持使用 AWS Managed ElasticSearch，只能通过 REST 端点使用。考虑切换您的客户端以使用 REST 端点，例如https://github.com/searchbox-io/Jest。

来源：https ://forums.aws.amazon.com/thread.jspa?messageID=681938

于 2015-10-29T22:27:38.020 回答
7

自 Elasticsearch Java SDK 版本 5.6 起，就有可用的REST 客户端。这允许您连接到 AWS 上的 Elasticsearch Service。

目前，Elasticsearch Service 允许安装最高版本 5.5，但您可以针对 5.5 集群使用 5.6 Java SDK，但有一些限制。

注意：初始化时，RestClient您应该使用端口80或443分别代替9200. 例如

RestClient restClient = RestClient.builder(
    new HttpHost("search-test-elasti-xxxx-xxxxx.us-east-1.es.amazonaws.com", 80, "http")).build();
RestHighLevelClient restHighLevelClient = new RestHighLevelClient(restClient); 
// [...]
于 2017-10-18T12:27:38.450 回答
3

如何获取 AWS ES URL

转到 Elasticsearch Domain 控制台并在 Overview 选项卡中获取 Endpoint。

使用的端口是 443。

在此处输入图像描述

确保已配置访问控制。

在此处输入图像描述

供参考

创建 Elasticsearch 索引

curl -v -XPUT "${ES_ENDPOINT}/article/" -H 'Content-Type: application/json' -d '{
    "settings" : {
        "index" : {
            "number_of_shards" : 1,
            "number_of_replicas" : 0
        }
    }
}'
于 2020-06-02T01:44:40.260 回答
2

正如上面 John Russell 所说，您需要使用 REST 客户端与您的 AWS Elastic 集群进行通信。

Elastic 最近发布了自己的 Java REST 客户端的第一个 RC 版本，所以现在这也是一个选项。

客户文档： https ://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/index.html

Maven 回购： http ://search.maven.org/#search%7Cgav%7C1%7Cg%3A%22org.elasticsearch.client%22%20AND%20a%3A%22rest%22

于 2016-10-18T13:52:55.967 回答