AWS Managed ElasticSearch上的弹性传输客户端

我正在尝试将AWS Managed ElasticSearch用于我的项目。

我已经关注了https://aws.amazon.com/blogs/aws/new-amazon-elasticsearch-service/ ,我能够启动一个实例并且成功了。 但我无法使用elasticsearch传输客户端从我的服务连接到同一个实例。

我知道传输客户端应该连接到9300端口,并且该端口我无法通过aws控制台打开。

这是我用来连接的代码,它可以成功连接到我在9300端口上的ec2机器上的弹性搜索设置。

ImmutableSettings.Builder settings = ImmutableSettings.settingsBuilder(); settings.put("cluster.name", "my-cluster-name") .put("client.transport.nodes_sampler_interval", "15s") .put("client.transport.ping_timeout", "15s") .put("client.transport.sniff", true) .put("client.transport.ignore_cluster_name", false).build(); client = new TransportClient(settings) .addTransportAddress( new InetSocketTransportAddress( env.getProperty("elastic-host-url-provided-by-aws",80) )); 

我得到了例外

org.elasticsearch.client.transport.NoNodeAvailableException:所有已配置的节点均不可用:[]位于org.elasticsearch.client.transport.TransportClientNodesService的org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:305)。在org.elasticsearch.client.support.AbstractClient.index(AbstractClient.java:98)的org.elasticsearch.client.transport.support.InternalTransportClient.execute(InternalTransportClient.java:106)执行(TransportClientNodesService.java:200)

我怀疑这个错误是因为我通过HTTP端口连接TransportClient。 但我不知道aws托管弹性搜索实例的TCP端口是什么。 我搜索了aws文件,但我找不到任何文件。 如果有人使用TransportClient连接Amazon ES,请告诉我。

注意:我已经validation我使用的elasticsearch java jar版本与服务器相同。 从我的系统我可以访问Kibana和ES HTTP PORTS没有任何问题。

AWS相关论坛链接 。

以下是AWS ElasticSearch服务的限制:

TCP传输服务支持端口80上的HTTP,但不支持TCP传输。

有关缺少对AWS Elasticsearch 5.x域的TCP传输支持的文档部分,请访问 :

TCP传输

该服务支持端口80上的HTTP,但不支持TCP传输。