作者：京东物流 陈晓娟
一、ES
Elasticsearch 是一个流行的开源搜索引擎，它可以将大量数据快速存储和检索。Elasticsearch 还提供了强大的实时分析和聚合查询功能，数据模式更加灵活。它不需要预先定义固定的数据结构，可以随时添加或修改数据字段，而不需要进行繁琐的数据库迁移。横向扩展性好，ES 的分布式特性，可以简单地将数据水平切分到多个节点上，实现规模的无缝扩展。
二、ES 操作
1、postman
在 Elasticsearch 的早期版本中，用户主要依靠通用的 API 工具来进行操作和管理。Postman 作为一个通用的 API 测试工具，能够发送各种 HTTP 请求，包括 GET、POST、PUT、DELETE 等，用于与 Elasticsearch 进行交互。由于 Elasticsearch 通过 RESTful API 提供服务，Postman 成为了一个非常流行的选择。
（1）postman 创建索引
（2）查询索引
（3）删除索引
（4）删除文档
2、head 插件
随着 Elasticsearch 的发展，Head 插件逐渐被开发出来，提供了更多便利的功能。Head 插件不仅能够显示集群的拓扑结构，还能执行索引和节点级别的操作，提供了可视化的查询接口，支持 JSON 验证器等。这些功能使得 Head 插件成为了管理和操作 Elasticsearch 的重要工具。
（1）安装 head 插件
https://blog.51cto.com/u_16099317/10710264
（2）安装浏览器扩展程序
a、https://github.com/tradiff/elasticsearch-head-chrome
b、下载压缩包 解压
c、添加到浏览器扩展程序中，输入连接信息
三、head 插件下索引的增删改查操作
1、创建索引 (PUT/索引名)
DSL 语言
{ "settings": {//索引的分片数，确定后无法修改，通常一个分片处理20-50G数据 "number_of_shards": "2",//每个分片有多少个副本，可动态修改 "number_of_replicas": "1" }, "mappings": { "XXX": { "dynamic": "false", "_all": { "enabled": false }, "properties": { "uuid": { "type": "keyword" }, "interface_config": { "type": "text" },... } } }}
复制代码
2、查询 (GET/索引名)
GET/dp_test_temp_interface_execution_record_pre
复制代码
3、删除 (DELETE/索引名)
DELETE /userinfo
GET /userinfo
复制代码
4、修改 (PUT/索引名)
PUT /userinfo/ _mapping{ "properties": { "age": { "type": "interger" } }}
复制代码
四、编辑器与 ES 服务器的交互
1、创建客户端
private static RestHighLevelClient createClient() { final BasicCredentialsProvider credentialsProvider = new BasicCredentialsProvider(); credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("XXX", "XXX"));
RestClientBuilder builder = RestClient.builder(new HttpHost("XXX", XXX, "http")) .setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
return new RestHighLevelClient(builder); }
复制代码
2、对创建好的索引进行增删改查操作
RestHighLevelClient client = createClient();//查询private static void getDocument(RestHighLevelClient client) throws IOException { GetRequest getRequest = new GetRequest("XXX", "pcgat5EBH6d8RU1tFckI"); GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT); System.out.println("Get response: " + getResponse.getSourceAsString()); }//更新private static void updateDocument(RestHighLevelClient client) throws IOException { Map<String, Object> updateMap = new HashMap<>(); updateMap.put("message", "Elasticsearch is cool!");
UpdateRequest updateRequest = new UpdateRequest("posts", "1") .doc(updateMap); UpdateResponse updateResponse = client.update(updateRequest, RequestOptions.DEFAULT); System.out.println("Update response: " + updateResponse.getResult()); }//删除private static void deleteDocument(RestHighLevelClient client) throws IOException { DeleteRequest deleteRequest = new DeleteRequest("posts", "pcgat5EBH6d8RU1tFckI"); DeleteResponse deleteResponse = client.delete(deleteRequest, RequestOptions.DEFAULT); System.out.println("Delete response: " + deleteResponse.getResult()); }
复制代码
评论