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

elasticsearch 7.x elasticsearch 使用scroll滚动查询一页,删除一页,影响后面滚动的查询吗

目录

一  scroll说明

1.1 问题

1.2 scroll分页的机制

1.3 案例分析

一  scroll说明

1.1 问题

elasticsearch 使用scroll滚动查询一页,删除一页,影响后面滚动的查询吗?

答案是:

在 Elasticsearch 中使用 Scroll API 进行“滚动一页,删除一页”的操作,不会影响后续滚动的查询结果。后续滚动仍然能够获取到最初发起 scroll 搜索时所有匹配的文档。

例子:

这就像你在一本书的目录页(快照)找到了所有相关章节的页码。即使你随后把书中第50页的内容撕掉了(删除),你的目录页上仍然会写着第50页,你仍然可以根据目录翻到那个位置(尽管内容已经没了)。Scroll API 就是按照最初的“目录”在翻页。

1.2 scroll分页的机制

核心原因在于 Scroll 工作原理类似于一个“快照”

1)初始化和快照:当你发起一个带有 scroll 参数的搜索请求时(例如 scroll=1m),Elasticsearch 会立即为当前查询条件“拍一张快照”。这个快照包含了那个时间点所有符合查询条件的文档的列表(以及它们的排序)。

2)保持上下文:Elasticsearch 会在内部维护一个“搜索上下文”(Search Context),用于保存这个快照的状态信息(如排序顺序、匹配的文档等)。你指定的 scroll 时间(如 1m)就是告诉 Elasticsearch 需要将这个上下文保持多久 alive。

3)后续滚动:当你使用返回的 _scroll_id 去获取下一页时,Elasticsearch 不会再次执行一次新的搜索。相反,它只是在这个固定的、最初的快照中向后移动游标,返回下一页的结果。

4)删除操作的影响:你执行删除操作(无论是删除刚查询到的文档还是其他任何文档)都是对实时索引的修改。而 Scroll 上下文仍然指向最初的那个旧快照。因此,删除操作不会从已经生成的快照中移除文档。

明白两点:

1.scroll删除数据是对库中实时数据的删除,而不是对scroll的快照中的上下文进行删除。elasticsearch 使用scroll滚动查询一页,删除一页,不影响后面滚动的查询

2.scroll的超时时间:是指每次从快照中取出一批数据放到上下文中,能够保存多久存活的时间。比如;超时时间时间为5s。第一次resttemplat.search 查询出一批快照数据放到上下文,然后进行逻辑A,逻辑B,逻辑C的处理,如果A+B+C=7s,7s大于5s,此时scrollid就会失效;再次执行resttemplat.search 就会报DELETE /_search/scroll   404 的错误。如果A+B+C=3s小于5s,scrollid在有效范围内,再次执行resttemplat.search完全没有问题。

1.3 案例分析

假设一个索引中有 5 个文档:[Doc1, Doc2, Doc3, Doc4, Doc5]

  1. 你发起一个 match_all 查询,并使用 scroll=1m。Elasticsearch 创建快照,包含了所有 5 个文档。

  2. 第一页返回了 [Doc1, Doc2]

  3. 你的程序处理完这一页后,删除了 Doc1 和 Doc2

  4. 你用 _scroll_id 请求下一页。

  5. 第二页会正确返回 [Doc3, Doc4]它不会因为 Doc1 和 Doc2 被删了就返回 [Doc3, Doc4, Doc5] 或者发生错乱。快照的大小和顺序在第一步就已经固定了。

  6. 你处理完第二页,又删除了 Doc3 和 Doc4

  7. 请求第三页,返回 [Doc5]

整个滚动过程完全不受中间删除操作的影响。

DeepSeek

http://www.dtcms.com/a/343887.html

相关文章:

  • 【LeetCode热题100道笔记+动画】最大子数组和
  • 任务同步和锁
  • 基于django/python的服装销售系统平台/服装购物系统/基于django/python的服装商城
  • sqli-labs通关笔记-第61关 GET字符型报错注入(单引号双括号闭合 限制5次探测机会)
  • 基于Django的学校实验室预约管理系统/基于python的实验室管理系统的设计与实现#python#django#FLASK
  • JAVA基础-java虚拟机
  • uniapp googlepay支付 内购项目
  • 豆包AI PPT与秒出PPT对比评测:谁更适合你?
  • 计算机毕设选题推荐 基于Spark的家庭能源消耗智能分析与可视化系统 基于机器学习的家庭能源消耗预测与可视化系统源码
  • Python办公之Excel(openpyxl)、PPT(python-pptx)、Word(python-docx)
  • 2026年计算机毕设推荐:基于大数据的慢性肾病数据可视化分析系统技术选型指南【Hadoop、spark、python】
  • 使用PPT进行科研绘图过程中常用的快捷键
  • 日志logging学习(1)
  • Gemini 2.5 Flash-Lite与 DeepSeek-V3 深度对比:谁在性价比上更胜一筹?
  • 【typenum】 21 类型级别计算最大公约数(Gcd)
  • map和set的使⽤
  • 52 C++ 现代C++编程艺术1-禁止隐式转换关键字explicit
  • Qt中用于图像缩放的核⼼⽅法QPixmap::scaled
  • 编写Linux下设备驱动时两种方案:内核态驱动开发和用户态驱动开发
  • --- 使用OpenFeign来优雅的对服务进行调用 ---
  • vue2怎么修改el-table样式
  • 金融风控AI引擎:实时反欺诈系统的架构设计与实现
  • CTFSHOW | 其他篇题解(二)web417 - web437
  • 进程间通信-IPC机制
  • 【开发日记】SpringBoot 实现支持多个微信小程序的登录
  • 初始数据结构——反射、枚举与Lambda的奇幻冒险
  • 如何理解AP服务发现协议中“如果某项服务需要在多个网络接口上提供,则应为每个网络接口使用一个独立的服务器服务实例。”?
  • 《Linux 网络编程一:网络编程导论及UDP 服务器的创建与数据接收》
  • “我 / 店模式” 靠联盟 + 积分破局,实现三方共赢!
  • 【Oracle】内存管理实战指南:ASMM vs AMM 配置全解析