0
0

Elasticsearch CRUD RestAPI

ElasticSearch 的安装 （7.16.1 版本）Kibana DevTool 的是使用创建索引，删除索引数据写入，更新，删除数据修改等操作。

  • 😄博主：程序员一灯，一个老菜鸟，哈哈哈哈

  • 🚌一个人可以走的很快，一群人可以走的很远🇨🇳

  • 🎉点赞➕评论➕收藏 ➕关注== 养成习惯（一键四连）📝
  • 🎉欢迎关注💗一起学习👍一起讨论⭐️一起进步📝
  • 🙏作者水平有限，欢迎各位大佬指点，相互学习进步！😆

🏮一、基本CRUD

🥃1.1、新增文档

PUT ${index_name}

PUT schools

🍸1）新增文档，并指定id字段（replace）

该模式下，若指定id对应的文档存在，则删除源文档后并写入新文档，并且version版本加1。

  1. PUT ${index_name}/_doc/1
  2. {
  3.     ...
  4. }
  5.  
  6. //多次执行后,version一直递增
  7. POST schools/_doc/1
  8. {"name":"Central School","description":"CBSE Affiliation","street":"Nagan","city":"paprola","state":"HP","zip":"176115","location":[31.8955385,76.8380405],"fees":2000,"tags":["Senior Secondary","beautiful campus"],"rating":"3.5"}

🍸2）新增文档，并指定ID字段（insert）

该模式下，若指定id对应的文档存在，则直接返回报错

  1. PUT ${index_name}/_create/1
  2. {
  3.     ...
  4. }
  6.  或者
  7. PUT ${index_name}/_create/1?op_type=create
  8. {
  9.     ...
  10. } 
  1. PUT bluepig/_create/1
  2. {
  3.     "name":"八戒1号猪",
  4.     "date":"2021年12月23日11:04:39"
  5. }
  7. PUT bluepig/_create/2?op_type=create
  8. {
  9.     "name":"八戒2号猪",
  10.     "date":"2021年12月23日11:06:02"
  11. } 
  1. 执行查询
  2. GET bluepig/_search
  4. 返回
  5. {
  6.   "took" : 0,
  7.   "timed_out" : false,
  8.   "_shards" : {
  9.     "total" : 1,
  10.     "successful" : 1,
  11.     "skipped" : 0,
  12.     "failed" : 0
  13.   },
  14.   "hits" : {
  15.     "total" : {
  16.       "value" : 2,
  17.       "relation" : "eq"
  18.     },
  19.     "max_score" : 1.0,
  20.     "hits" : [
  21.       {
  22.         "_index" : "bluepig",
  23.         "_type" : "_doc",
  24.         "_id" : "1",
  25.         "_score" : 1.0,
  26.         "_source" : {
  27.           "name" : "八戒1号猪",
  28.           "date" : "2021年12月23日11:04:39"
  29.         }
  30.       },
  31.       {
  32.         "_index" : "bluepig",
  33.         "_type" : "_doc",
  34.         "_id" : "2",
  35.         "_score" : 1.0,
  36.         "_source" : {
  37.           "name" : "八戒2号猪",
  38.           "date" : "2021年12月23日11:06:02"
  39.         }
  40.       }
  41.     ]
  42.   }
  43. }

🍸3）新增文档，不指定ID字段，系统自动生产ID

  1. POST ${index_name}/_doc
  2. {
  3.   ...
  4. }
  1. POST zhangsan/_doc
  2. {
  3.   "name":"张三",
  4.   "age":"25"
  5. }
  7. get zhangsan/_search
  9. {
  10.   "took" : 0,
  11.   "timed_out" : false,
  12.   "_shards" : {
  13.     "total" : 1,
  14.     "successful" : 1,
  15.     "skipped" : 0,
  16.     "failed" : 0
  17.   },
  18.   "hits" : {
  19.     "total" : {
  20.       "value" : 1,
  21.       "relation" : "eq"
  22.     },
  23.     "max_score" : 1.0,
  24.     "hits" : [
  25.       {
  26.         "_index" : "zhangsan",
  27.         "_type" : "_doc",
  28.         "_id" : "8XpD5X0BStHCKgTnOEeI",
  29.         "_score" : 1.0,
  30.         "_source" : {
  31.           "name" : "张三",
  32.           "age" : "25"
  33.         }
  34.       }
  35.     ]
  36.   }
  37. }

🥃1.2、查询文档

🍸1）GET查询指定ID文档

  1. GET /${index_name}/_doc/3
  1. 执行查询
  2. GET /bluepig/_doc/2
  4. 返回
  5. {
  6.   "_index" : "bluepig",
  7.   "_type" : "_doc",
  8.   "_id" : "2",
  9.   "_version" : 1,
  10.   "_seq_no" : 1,
  11.   "_primary_term" : 1,
  12.   "found" : true,
  13.   "_source" : {
  14.     "name" : "八戒2号猪",
  15.     "date" : "2021年12月23日11:06:02"
  16.   }
  17. }

🍸2）search api查询满足条件的文档

  1. 查询索引下全部文档
  2. GET /${index_name}/_search
  4. 查询满足指定条件全部文档
  5. GET /#{index_name}/_search
  6. {
  7.   "query": {
  8.     "match": {
  9.       ...
  10.     }
  11.   }
  12. }
  1. GET /bluepig/_search
  2. {
  3.   "query": {
  4.     "match": {
  5.       "name": "八戒"
  6.     }
  7.   }
  8. }

🍸3) 查看索引的基本配置信息

GET /${index_name}

GET schools

🍸4) 查看索引的基本状态信息

GET _cat/indices/${index_name}

GET _cat/indices/schools

🥃1.3、更新文档

🍸1）更新指定ID文档，存在则更新，不存在则新增（也是新增文档的一种）

  1. PUT ${index_name}/_doc/1
  2. {
  3.     ...
  4. }
  1. PUT schools2/_doc/11
  2. {"name":"Central School","description":"CBSE Affiliation","street":"Nagan","city":"paprola","state":"HP","zip":"176115","location":[31.8955385,76.8380405],"fees":2000,"tags":["Senior Secondary","beautiful campus"],"rating":"3.5"}

🍸2）更新指定ID文档，更新文档必须存在，否则报错

  1. //限制操作类型是更新，那么如果不存在则更新不了，报错
  2. POST /${index_name}/_update/1
  3. {
  4.   "doc": {
  5.     "name":"aa",
  6.     "age":12
  7.   }
  8. }

🥃1.4、删除文档

🍸1）删除指定ID文档

DELETE /${index_name}/_doc/1

🍸2）删除满足条件查询文档

  1. POST /${index_name}/_delete_by_query
  2. {
  3.   "query":{
  4.     "match":{
  5.       ...
  6.     }
  7.   }
  8. }
  1. POST /schools/_delete_by_query
  2. {
  3.   "query":{
  4.     "match":{
  5.       "_id":2
  6.     }
  7.   }
  8. }

🏮二、bulk api 批量

支持在一次api中对不同的索引进行操作
支持create index update delete

  1. //1、创建索引users name=aa
  2. //2、删除索引id=2
  3. //3、创建索引users id=2
  4. //4、更新索引 新增了个字段
  5. POST _bulk
  6. {"index":{"_index":"users","_id":"1"}}
  7. {"name":"aa"}
  8. {"delete":{"_index":"users","_id":"2"}}
  9. {"create":{"_index":"users","_id":"2"}}
  10. {"name":"bb"}
  11. {"update":{"_id":"1","_index":"users"}}
  12. {"doc":{"auto_inc":"11"}}
  14. #批量操作
  15. #1.删除5号
  16. #新增8号
  17. #更新2号 name为2号
  19. POST _bulk
  20. {"delete":{"_index":"person1","_id":"5"}}
  21. {"create":{"_index":"person1","_id":"8"}}
  22. {"name":"八号","age":18,"address":"北京"}
  23. {"update":{"_index":"person1","_id":"2"}}
  24. {"doc":{"name":"2号"}}
  26. POST schools_gov/_bulk
  27. {"index":{"_index":"schools_gov","_id":"1"}}
  28. {"name":"Model School","description":"CBSE Affiliation","street":"silk city","city":"Hyderabad","state":"AP","zip":"500030","location":[17.3903703,78.4752129],"fees":200,"tags":["Senior Secondary","beautiful campus"],"rating":"3"}
  29. {"index":{"_index":"schools_gov","_id":"2"}}
  30. {"name":"Government School","description":"State Board Affiliation","street":"Hinjewadi","city":"Pune","state":"MH","zip":"411057","location":[18.599752,73.6821995],"fees":500,"tags":["Great Sports"],"rating":"4"}

🏮三、CRUD的练习例子

GET movies/_search

查询movies的数据

GET movies/_count

查询movies的总数

GET _cat/indices

查看所有的索引

GET movies/_doc/24

查询id为24的数据

POST users/_doc/1

POST users/_doc/1

{

"firstname": "will",

"lastname": "smith"

}

#添加id为1的文档 ，如果没有指定id，ES会自动生成

POST users/_create/2

{

"firstname": "will",

"lastname": "smith"

}

#创建id为2的文档，如果索引中已存在相同id，会报错；

POST users/_update/2

{

"doc": {

"age": 30

}

}

在id位2的文档中添加一个age属性，修改结构

DELETE users/_doc/2

删除id为2的文档

DELETE users

删除 users 索引

PUT users/_doc/1

{

"firstname": "Jack",

"lastname": "ma"

}

创建或者修改文档

PUT users/_create/2

{

"firstname": "will",

"lastname": "smith"

}

批量查询多个指定的id的数据，也可以批量查询

POST users/_bulk

{"index":{"_id":3}}

{"firstname":"a","lastname":"A"}

{"index":{"_id":2}}

{"firstname":"a","lastname":"A"}

{"index":{"_id":3}}

{"firstname":"a","lastname":"A"}

{"index":{"_id":4}}

{"firstname":"a","lastname":"A"}

{"index":{"_id":5}}

{"firstname":"a","lastname":"A"}

批量插入数据

标签： elasticsearch 大数据 big data
本文转载自: https://blog.csdn.net/zhou9898/article/details/122102268
版权归原作者 程序员一灯 所有， 如有侵权，请联系我们删除。
登录后发布评论

“Elasticsearch CRUD RestAPI”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？