Elasticsearch全量数据增量遍历实现原理

本文涉及的产品
检索分析服务 Elasticsearch 版,2核4GB开发者规格 1个月
简介: 0、需求针对凤凰网财经版块的新闻数据和评论数据, 1个索引存储采集凤凰网财经版块的新闻数据;1个索引存储相关的财经数据评论结果。统计:1)某条新闻的评论数的多少?2)某条评论属于哪条新闻?3)当前已采集数据的所有评论、评论数汇总,按照评论数逆序排序,以便于图形化展示。

1、问题分解

1.1 数据如何存储,方案选型?

方案一:类似需求,1个索引ifeng_index存储新闻数据;1个索引ifeng_comm_index存储评论数据。

二者之间通过唯一值建立关联:评论数据中其来源新闻的唯一id值。

优点:数据分开存储,不存在交叉问题;

缺点:如果实现需求3),会非常复杂,做全局两通道的遍历和统计。


方案二:借助2.X-5.X版本ES中特有的父子文档实现。

注意:由于6.X版本以后,一个索引下只能存储一个type,所以父子文档也就不再可以使用。

所谓父子文档,可以理解为:

1)统一索引下的两个type,1个父type存储凤凰网新闻数据;1个子type存储凤凰网评论数据;

2)其中子type的Mapping定义要特殊处理;

3)其中子type的每条凤凰网评论数据都要关联唯一的父type的相关ID值。

优点:可以以相对较小的复杂度满足需求1)、2)、3)

缺点:以上方案二,ES6.X+都不再适用。

注意:

ES6.X已经移除父子文档的相关实现:http://t.cn/RE07V5A

但是转换为新的join的实现方式:http://t.cn/RE07IG1

综上分析,我是5.X的版本,采取方案二。


1.2 所需要技术支撑

1)父子文档技术

父子文档定义:

用于两个索引之间通过某一个特殊字段建立关联的场景。

在1对多的场景,尤其适用。如:1个父文档下有多个子文档。

缺点: 查询速度会比同等的嵌套查询慢5到10倍,详见:http://t.cn/ROir5rQ


父子文档实现:

建立父-子文档映射关系时只需要指定某一个文档 type 是另一个文档 type 的父亲。 该关系可以在如下两个时间点设置:1)创建索引时;2)在子文档 type 创建之前更新父文档的 mapping。


2)全局遍历技术

借助Scroll实现。之前的博文也有说明,http://t.cn/RE068mD

【scroll机制】:相对于from和size的分页来说,使用scroll可以模拟一个传统数据的游标,记录当前读取的文档信息位置。这个分页的用法,不是为了实时查询数据,而是为了一次性查询大量的数据(甚至是全部的数据)。

假设某索引下共有8个document,document中由code字段标记不同,0,1,2….8区分。


第一次scroll请求中,size设置为3,基于code升序排序,时间戳设置为1min;

第二次基于scroll_id查询,基于scroll_id查询第一次返回结果:0,1,2; 基于scroll_id查询第二次,返回结果:3,4,5; 基于scroll_id查询第三次,返回结果:6,7。

假设仍在的有效时间1min内,继续查询,返回结果:空。

若超时,继续scroll_id请求,则会返回类似如下的错误:


{

 "error": {

 "root_cause": [

 {

 "type": "search_context_missing_exception",

 "reason": "No search context found for id [79110689]"

 },

 {

 "type": "circuit_breaking_exception",

 "reason": "[parent] Data too large, data for [<transport_request>] would be [23195655038/21.6gb], which is larger than the limit of [23190280601/21.5gb]",

 "bytes_wanted": 23195655038,

 "bytes_limit": 23190280601

 },

3)增量遍历统计计数

对修改字段打flag标记,可以通过ES中update_by_query方法,对ES中数据进行更新操作。

如果:不存在flag字段,遍历到该条记录的时候,新增flag字段且flag置为1。

如果:存在flag字段,代表该条记录已经被遍历过。

这样的好处,防止数据被循环遍历。

其实:scroll机制已经预防了这一点,以防万一。


2、具体原理

2.1 scroll实现遍历DSL实现

步骤1:scroll查询。

基于特定的字段进行排序如下:


POST scroll_index/_search?scroll=1m

{

 "size": 3,

 "query": {

 "match_all": {}

 },

 "sort": {

 "code":"asc"

 }

}

返回结果:


{

 "_scroll_id": "DnF1ZXJ5VGhlbkZldGNoBQAAAAAFcOGqFllFRGNIdVQ2Ui1LaFJRblJKOWVDNkEAAAAABXDhqxZZRURjSHVUNlItS2hSUW5SSjllQzZBAAAAAAPXB3EWTllZcVhfUlNSRUN5M3NueUJ2YkVXUQAAAAAD1wd0Fk5ZWXFYX1JTUkVDeTNzbnlCdmJFV1EAAAAAA9cHchZOWVlxWF9SU1JFQ3kzc255QnZiRVdR",

 "took": 4,

 "timed_out": false,

 "_shards": {

 "total": 5,

 "successful": 5,

 "failed": 0

 },

 "hits": {

 "total": 8,

 "max_score": null,

 "hits": [

 {

 "_index": "scroll_index",

 "_type": "scroll_type",

 "_id": "0",

 "_score": null,

 "_source": {

 "code": 0

 },

 "sort": [

 0

 ]

 },

 {

 "_index": "scroll_index",

 "_type": "scroll_type",

 "_id": "1",

 "_score": null,

 "_source": {

 "code": 1

 },

 "sort": [

 1

 ]

 },

 {

 "_index": "scroll_index",

 "_type": "scroll_type",

 "_id": "2",

 "_score": null,

 "_source": {

 "code": 2

 },

 "sort": [

 2

 ]

 }

 ]

 }

}

步骤2:基于Scroll_id查询


POST /_search/scroll

{

 "scroll" : "1m",

 "scroll_id" : "DnF1ZXJ5VGhlbkZldGNoBQAAAAAFcOGqFllFRGNIdVQ2Ui1LaFJRblJKOWVDNkEAAAAABXDhqxZZRURjSHVUNlItS2hSUW5SSjllQzZBAAAAAAPXB3EWTllZcVhfUlNSRUN5M3NueUJ2YkVXUQAAAAAD1wd0Fk5ZWXFYX1JTUkVDeTNzbnlCdmJFV1EAAAAAA9cHchZOWVlxWF9SU1JFQ3kzc255QnZiRVdR"

}

步骤3:循环执行,直至遍历结束。

主要注意的时间。


2.3 增量部分java如何实现?

在延迟指定时间后以指定的间隔时间循环执行定时任务。

借助Java Timer类实现。 Timer 是一种定时器工具,用来在一个后台线程计划执行指定任务。


 public class TimerTest03 {

       Timer timer;


       public TimerTest03(){

           timer = new Timer();

           timer.schedule(new TimerTaskTest03(), 1000, 2000);

       }


       public static void main(String[] args) {

           new TimerTest03();

       }

   }


   public class TimerTaskTest03 extends TimerTask{


       @Override

       public void run() {

           Date date = new Date(this.scheduledExecutionTime());

           System.out.println("本次执行该线程的时间为:" + date);

       }

   }

2.5 父子文档的实现。

步骤1:定义索引,同常规定义索引一致。

但,要规划好父子文档,通过:type类型区分。

如,父文档的type定义为:fenghuang_type, 子文档定义为ifeng_comm_type。


PUT ifeng_index

{

 "mappings": {

   "ifeng_type": {},

   " ifeng_comm_type ": {

     "_parent": {

       "type": "fenghuang_type"

     }

   }

 }

}

步骤2:插入子文档数据。

父文档数据插入和传统导入数据方式一致。

举例如下:

PUT /ifeng_index/ifeng_comm_type/1?parent=XVFBASDE!

注意: 父子文档关联建立的关键是:在导入子文档数据的时候通过加入参数parent=父文档的_id。


步骤3:基于父文档查询子文档。

POST ifeng_index/ifeng_comm_type/_search

{

 "query": {

   "has_parent": {

     "type":  "ifeng_type",

     "query": {

       "match": {

         "title": "世锦赛-墨西哥锦标赛移动日精彩集锦"

       }

     }

   }

 }

}

步骤4:基于子文档查询父文档。

POST ifeng_index/ifeng_type/_search

{

 "query": {

   "has_child": {

     "type":  "ifeng_comm_type",

     "score_mode": "max",

     "query": {

       "match": {

         "title": "很精彩,棒极啦!"

       }

     }

   }

 }

}

步骤5: 查看索引中每个父文档下有多少个子文档

POST /ifeng_index/ifeng_type/

{

 "size": 0,

 "aggs": {

 "ifeng_key_agg": {

 "terms": {

 "field": "_key",

 "order": {

 "ifeng_comm_type": "desc"

 }

 },

 "aggs": {

 "ifeng_comm_type": {

 "children": {

 "type": "ifeng_comm_type"

 }

 }

 }

 }

 }

3、小结

通过父子文档,实现了1对多数据的关联;

通过scroll可以实现遍历操作,实现全量遍历;

通过scroll+java定时任务Timer,实现增量遍历。

相关实践学习
使用阿里云Elasticsearch体验信息检索加速
通过创建登录阿里云Elasticsearch集群,使用DataWorks将MySQL数据同步至Elasticsearch,体验多条件检索效果,简单展示数据同步和信息检索加速的过程和操作。
ElasticSearch 入门精讲
ElasticSearch是一个开源的、基于Lucene的、分布式、高扩展、高实时的搜索与数据分析引擎。根据DB-Engines的排名显示,Elasticsearch是最受欢迎的企业搜索引擎,其次是Apache Solr(也是基于Lucene)。 ElasticSearch的实现原理主要分为以下几个步骤: 用户将数据提交到Elastic Search 数据库中 通过分词控制器去将对应的语句分词,将其权重和分词结果一并存入数据 当用户搜索数据时候,再根据权重将结果排名、打分 将返回结果呈现给用户 Elasticsearch可以用于搜索各种文档。它提供可扩展的搜索,具有接近实时的搜索,并支持多租户。
相关文章
|
2月前
|
Web App开发 JavaScript Java
elasticsearch学习五:springboot整合 rest 操作elasticsearch的 实际案例操作,编写搜索的前后端,爬取京东数据到elasticsearch中。
这篇文章是关于如何使用Spring Boot整合Elasticsearch,并通过REST客户端操作Elasticsearch,实现一个简单的搜索前后端,以及如何爬取京东数据到Elasticsearch的案例教程。
214 0
elasticsearch学习五:springboot整合 rest 操作elasticsearch的 实际案例操作,编写搜索的前后端,爬取京东数据到elasticsearch中。
|
2月前
|
消息中间件 监控 关系型数据库
MySQL数据实时同步到Elasticsearch:技术深度解析与实践分享
在当今的数据驱动时代,实时数据同步成为许多应用系统的核心需求之一。MySQL作为关系型数据库的代表,以其强大的事务处理能力和数据完整性保障,广泛应用于各种业务场景中。然而,随着数据量的增长和查询复杂度的提升,单一依赖MySQL进行高效的数据检索和分析变得日益困难。这时,Elasticsearch(简称ES)以其卓越的搜索性能、灵活的数据模式以及强大的可扩展性,成为处理复杂查询需求的理想选择。本文将深入探讨MySQL数据实时同步到Elasticsearch的技术实现与最佳实践。
132 0
|
4月前
|
存储 缓存 监控
|
4月前
|
数据采集 人工智能 自然语言处理
阿里云Elasticsearch AI语义搜索:解锁未来搜索新纪元,精准洞察数据背后的故事!
【8月更文挑战第2天】阿里云Elasticsearch AI场景语义搜索最佳实践
215 5
|
5月前
|
存储 安全 文件存储
【elasticsearch】es6重启服务后数据消失,es6如何配置数据持久化储存
【elasticsearch】es6重启服务后数据消失,es6如何配置数据持久化储存
57 1
|
6月前
|
索引
利用滚动索引来管理海量Elasticsearch数据
利用滚动索引来管理海量Elasticsearch数据
110 3
|
5月前
|
Java
Java 实现 Elasticsearch 查询全部数据
【7月更文挑战第7天】Java 实现 Elasticsearch 查询全部数据
|
27天前
|
存储 安全 数据管理
如何在 Rocky Linux 8 上安装和配置 Elasticsearch
本文详细介绍了在 Rocky Linux 8 上安装和配置 Elasticsearch 的步骤,包括添加仓库、安装 Elasticsearch、配置文件修改、设置内存和文件描述符、启动和验证 Elasticsearch,以及常见问题的解决方法。通过这些步骤,你可以快速搭建起这个强大的分布式搜索和分析引擎。
38 5
|
2月前
|
存储 JSON Java
elasticsearch学习一:了解 ES,版本之间的对应。安装elasticsearch,kibana,head插件、elasticsearch-ik分词器。
这篇文章是关于Elasticsearch的学习指南,包括了解Elasticsearch、版本对应、安装运行Elasticsearch和Kibana、安装head插件和elasticsearch-ik分词器的步骤。
180 0
elasticsearch学习一:了解 ES,版本之间的对应。安装elasticsearch,kibana,head插件、elasticsearch-ik分词器。
|
3月前
|
NoSQL 关系型数据库 Redis
mall在linux环境下的部署(基于Docker容器),Docker安装mysql、redis、nginx、rabbitmq、elasticsearch、logstash、kibana、mongo
mall在linux环境下的部署(基于Docker容器),docker安装mysql、redis、nginx、rabbitmq、elasticsearch、logstash、kibana、mongodb、minio详细教程,拉取镜像、运行容器
mall在linux环境下的部署(基于Docker容器),Docker安装mysql、redis、nginx、rabbitmq、elasticsearch、logstash、kibana、mongo