我是新java
来的python
。我知道有很多答案可以联系ElasticSearch
到java
。但我很难理解,有些已经过时了。在 python 中,我可以轻松导入elasticsearch
模块并连接到它。
这是python中的代码:
from elasticsearch import Elasticsearch
es = Elasticsearch('localhost', port=9200, http_auth=('username', 'password'), scheme="http")
但是在java
,我已经包含了elasticsearch
Maven 依赖项pom.xml
。我想连接到elasticsearch
. 我才知道RestHighLevelClient
可以做这份工作。我找到了这段代码。但不知道如何使其连接到 Elastic Search。
public RestHighLevelClient createESRestClient() {
CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(esUserName, esPassword));
RestClientBuilder restClientBuilder = RestClient
.builder(new HttpHost(esRestclientHost, 9200, "http"));
// Use this one if your ElasticSearch server is setup to use username & password authentication
if (esAuthentication) {
restClientBuilder.setHttpClientConfigCallback(h -> h.setDefaultCredentialsProvider(credentialsProvider));
}
return new RestHighLevelClient(restClientBuilder);
}
任何人都可以帮助我或向我展示一些使用 java 连接 Elastic Search 的示例代码。在 python 中,它分两行完成。帮我解决java
。