预览加载中,请您耐心等待几秒...
1/10
2/10
3/10
4/10
5/10
6/10
7/10
8/10
9/10
10/10

亲,该文档总共17页,到这已经超出免费预览范围,如果喜欢就直接下载吧~

如果您无法下载资料,请参考说明:

1、部分资料下载需要金币,请确保您的账户上有足够的金币

2、已购买过的文档,再次下载不重复扣费

3、资料包下载后请先用软件解压,在使用对应软件打开

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113704267A(43)申请公布日2021.11.26(21)申请号202111016917.7(22)申请日2021.08.31(71)申请人平安普惠企业管理有限公司地址518000广东省深圳市前海深港合作区前湾一路1号A栋201室(入驻深圳市前海商务秘书有限公司)(72)发明人陈晟豪(74)专利代理机构深圳国新南方知识产权代理有限公司44374代理人康雅文(51)Int.Cl.G06F16/22(2019.01)G06F16/2457(2019.01)G06F16/2458(2019.01)G06F16/27(2019.01)权利要求书2页说明书12页附图2页(54)发明名称基于ElasticSearch的数据查询方法、系统、设备及存储介质(57)摘要本发明提出一种基于ElasticSearch的数据查询方法、系统、设备及存储介质,包括:将变化业务数据同步到ElasticSearch中;根据变化业务数据从目标数据库同步到ElasticSearch的延迟情况,判断ElasticSearch是否标记为延迟;若ElasticSearch未标记为延迟,则根据查询请求在ElasticSearch中进行查找。通过将目标数据库中原始数据和发生变化的原始数据同步到ElasticSearch中,由于ElasticSearch中自带分词的功能,在对目标数据库进行查询时,将查询的业务逻辑切换到ElasticSearch中,从而实现分词查询和字段匹配程度排序。CN113704267ACN113704267A权利要求书1/2页1.一种基于ElasticSearch的数据查询方法,其特征在于,包括:按照预设同步频率,将变化业务数据同步到ElasticSearch中,所述变化业务数据基于目标数据库中发生变化的原始数据获得,ElasticSearch还存储用户业务数据,所述用户业务数据通过所述目标数据库中的所有原始数据经过预设处理后获得,所述目标数据库中包括记录操作的日志文件;根据所述变化业务数据从所述目标数据库同步到ElasticSearch的延迟情况,判断ElasticSearch是否被标记为延迟;若ElasticSearch未被标记为延迟,则根据查询请求在ElasticSearch中进行查找,获取目标查找数据。2.根据权利要求1所述的基于ElasticSearch的数据查询方法,其特征在于,所述根据所述变化业务数据从所述目标数据库同步到ElasticSearch的延迟情况,判断ElasticSearch是否标记为延迟,包括:获取所述变化业务数据的生成时间和本地机器时间;若所述生成时间和所述本地机器时间之间的差值大于预设时间阈值,则判断所述变化业务数据为延迟;在预设时间段内,若延迟数据的个数大于预设数量阈值,则ElasticSearch标记为延迟,所述预设时间段根据所述预设同步频率获得。3.根据权利要求1所述的基于ElasticSearch的数据查询方法,其特征在于,所述根据所述变化业务数据从所述目标数据库同步到ElasticSearch的延迟情况,判断ElasticSearch是否标记为延迟,包括:获取所述目标数据库中的待同步原始数据以及ElasticSearch中的同步业务数据;若所述待同步原始数据经过所述预设处理后,与所述同步业务数据不同,则延迟数据的个数加1;在预设时间段内,若延迟数据的个数大于预设数量阈值,则ElasticSearch标记为延迟。4.根据权利要求1所述的基于ElasticSearch的数据查询方法,其特征在于,所述将变化业务数据同步到ElasticSearch中,之前还包括:在所述目标数据库和ElasticSearch之间建立第一中间件;通过所述第一中间件,降低ElasticSearch的刷新频率。5.根据权利要求1所述的基于ElasticSearch的数据查询方法,其特征在于,所述将变化业务数据同步到ElasticSearch中,之后还包括:增加ElasticSearch的刷新频率;并将ElasticSearch的在线索引更改为目标索引,所述目标索引用于存储所述变化业务数据和所述用户业务数据。6.根据权利要求1至5任一所述的基于ElasticSearch的数据查询方法,其特征在于,所述将变化业务数据同步到ElasticSearch中,之前还包括:在所述目标数据库和ElasticSearch之间建立第二中间件;通过所述第二中间件,跟读所述目标数据库的日志文件事件,获取发生变化的原始数据;2CN113704267A权利要求书2/2页对发生变化的原始数据进行解析,获取所述变化业务数据。7.根据权利要求1至5任一所述的基于ElasticSearch的