当前位置: 首页 > news >正文

elasticsearch的常规操作--增删改查和批量处理

1、_cat 查询

GET /_cat/nodes:  查看所有节点
GET /_cat/health: 查看es 健康状况
GET /_cat/master: 查看主节点
GET /_cat/indices:查看所有索引show databases;

2、索引一个文档(保存)
保存一个数据,保存在哪个索引的哪个类型下,指定用哪个唯一标识

PUT customer/external/1;在customer 索引下的external 类型下保存1 号数据为
PUT customer/external/1
{
"name": "John Doe"
}


PUT 和POST 都可以,
POST 新增。如果不指定id,会自动生成id指定id 就会修改这个数据,并新增版本号
PUT 可以新增也可以修改。PUT 必须指定id;由于PUT 需要指定id,我们一般都用来做修改
操作,不指定id 会报错。

3、查询文档

GET customer/external/1


结果:

{
"_index": "customer", //在哪个索引
"_type": "external", //在哪个类型
"_id": "1",          //记录id
"_version": 2,      //版本号
"_seq_no": 1,       //并发控制字段,每次更新就会+1,用来做乐观锁
"_primary_term": 1, //同上,主分片重新分配,如重启,就会变化
"found": true,
"_source": {        //真正的内容
"name": "John Doe"
}
}


更新携带以下参数:

?if_seq_no=0&if_primary_term=1

4、更新文档

POST customer/external/1/_update
{
"doc":{
"name": "John Doew"
}
}


或者

POST customer/external/1{
"name": "John Doe2"
}


或者
 

PUT customer/external/1{
"name": "John Doe"
}
  • 不同:POST 操作会对比源文档数据,如果相同不会有什么操作,文档version 不增加

PUT 操作总会将数据重新保存并增加version 版本;
带_update 对比元数据如果一样就不进行任何操作。
看场景;
对于大并发更新,不带update;
对于大并发查询偶尔更新,带update;对比更新,重新计算分配规则。

  •  更新同时增加属性
POST customer/external/1/_update

{
"doc": { "name": "Jane Doe", "age": 20 }
}


PUT 和POST 不带_update 也可以

5、删除文档&索引

DELETE customer/external/1
DELETE customer


6、bulk 批量API

POST customer/external/_bulk

{"index":{"_id":"1"}}
{"name": "John Doe" }
{"index":{"_id":"2"}}
{"name": "Jane Doe" }


语法格式:

{ action: { metadata }}\n
{ request body }\n
{ action: { metadata }}\n
{ request body }\n


复杂实例:

POST /_bulk

{ "delete": { "_index": "website", "_type": "blog", "_id": "123" }}
{ "create": { "_index": "website", "_type": "blog", "_id": "123" }}
{ "title": "My first blog post" }
{ "index": { "_index": "website", "_type": "blog" }}
{ "title": "My second blog post" }
{ "update": { "_index": "website", "_type": "blog", "_id": "123", "_retry_on_conflict" : 3} }
{ "doc" : {"title" : "My updated blog post"} }


bulk API 以此按顺序执行所有的action(动作)。如果一个单个的动作因任何原因而失败,
它将继续处理它后面剩余的动作。
当bulk API 返回时,它将提供每个动作的状态(与发送
的顺序相同),所以您可以检查是否一个指定的动作是不是失败了。

http://www.lryc.cn/news/361342.html

相关文章:

  • 盘点2024年还在活跃发版的开源私有网盘项目附源码链接
  • MySQL 使用方法以及教程
  • 算法学习笔记——二进制
  • 计算机网络介绍
  • 解锁数据宝藏:高效查找算法揭秘
  • 利用EasyCVR视频智能监控技术,构建智慧化考场监管体系
  • 深度解析:速卖通618风控下自养号测评的技术要点
  • 国产算力——沐曦GPU性能及应用
  • 贪心算法拓展(反悔贪心)
  • 在spring框架的基础上自定义autowired注解
  • 2005NOIP普及组真题 3. 采药
  • preventDefault()与stopPropagation()有什么区别?
  • AIGC 全面介绍
  • 网站入门:Flask用法讲解
  • 头歌数据库备份与恢复
  • 小程序项目创建与Vant-UI引入
  • xtrabackup 使用
  • C++写一个简单的计算器程序案例
  • Spring Boot 开发 -- swagger3.0 集成
  • 探索安全之道 | 企业漏洞管理:从理念到行动
  • 【记录贴:分布式系列文章】
  • 初识SDN(二)
  • 某红书旋转滑块验证码分析与协议算法实现(高通过率)
  • Gin的快速入门和搭建
  • react-native运行程序 出现 Application XXX is waiting for the debugger
  • 什么文档加密软件好用?迅软DSE加密软件你不会还不知道吧?
  • 【kubernetes】关于k8s集群的污点、容忍、驱逐以及k8s集群故障排查思路
  • linux进程加载和启动过程分析
  • WLAN组网模型探究
  • 操作系统基础知识