(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210667993.2 (22)申请日 2022.06.14 (71)申请人 北京智慧星光信息技 术有限公司 地址 100080 北京市海淀区海淀大街8号A 座22层A区 (72)发明人 宋岩强　白剑波　李青龙　 (74)专利代理 机构 北京智宇 正信知识产权代理 事务所(普通 合伙) 11876 专利代理师 李明卓 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/2458(2019.01) G06F 16/21(2019.01) (54)发明名称 一种基于网关流量控制的Elasticsearch查 询方法及系统 (57)摘要 本发明公开了一种基于网关流量控制的 Elasticsear ch查询方法及系统， 该方法包 括： 判 断DSL请求参数是否满足查询保护条件， 不满足 则终止查询； 满足则按照预设缓存时间间隔对查 询时间进行归一化和时间段切分； 计算请求参数 的hash值， hash值为查询缓存ID； 判断查询缓存 ID是否存在于网关缓存ID中； 存在则反馈内存存 储的查询结果； 不存在则计算DSL评分值； 判断评 分值是否大于当前时间段剩余分值； 大于则将 DSL查询请求排队等候， 等待网关重新释放分值； 不大于则将当前时间段剩余 分值减去DSL评分值 作为更新后的当前时间段剩余分值， 在ES集群中 执行DSL查询请求， 返回查询结果； 将查询缓存ID 和查询结果存储至ES网关内存。 通过上述步骤避 免高并发、 复杂查询耗尽ES集群的计算资源。 权利要求书2页 说明书11页 附图5页 CN 115080617 A 2022.09.20 CN 115080617 A 1.一种基于网关流 量控制的Elasticsearc h查询方法， 其特 征在于， 包括： 获取DSL查询请求的请求 参数， 其中， 请求 参数包括 查询时间； 判断所述请求 参数是否满足ES集群的查询保护条件； 若所述请求参数不满足所述ES集群的查询保护条件， 则终止DSL查询请求， 返回查询异 常值； 若所述请求参数满足所述ES集群的查询保护条件， 则按照预设缓存时间间隔对所述查 询时间进行时间归一 化处理和时间段切分处 理； 计算请求 参数的hash值， 并将所述hash值作为所述D SL查询请求的查询缓存ID； 判断所述 查询缓存ID是否存在于 ES网关的网关缓存ID中； 若所述查询缓存ID存在于ES网关的网关缓存ID中， 则发送ES网关内存中存储的与所述 查询缓存ID相对应的查询结果； 若所述查询缓存ID不存在于ES网关的网关缓存ID中， 则计算DSL查询请求的DSL评分 值； 判断所述D SL评分值是否大于 ES集群的当前时间段剩余分值； 若所述DSL评分值大于ES集群的当前时间段剩余分值， 则将所述DSL查询请求进行排队 等候， 等待ES网关下一时刻重新释放分值； 若所述DSL评分值小于或者等于ES集群的当前时间段剩余分值， 则将当前时间段剩余 分值减去DSL评分值作为更新后的当前时间段剩余分值， 并且在ES集群中执行DSL查询请求 的搜索， 返回查询结果； 将所述DSL查询请求对应的查询缓存ID和查询结果存 储至ES网关内存。 2.根据权利要求1所述的基于网关流量控制的Elasticsearch查询 方法， 其特征在于， 所述ES集群的查询保护条件包括： 查询时间的跨度小于预设时间跨度、 模糊匹配条件的个 数小于预设个数、 聚合维度小于预设维度、 ES集群负荷值小于预设负荷。 3.根据权利要求1所述的基于网关流量控制的Elasticsearch查询 方法， 其特征在于， 按照预设缓存时间间隔对所述查询时间进 行时间归一化处理和时间段切分处理的步骤中， 包括： 计算预设缓存时间 间隔的整数倍时刻； 将查询时间的查询起始时间和终止时间换算到预设缓存时间间隔的整数倍 时刻， 得到 归一化查询时间； 按照预设缓存时间 间隔对归一化查询时间进行时间段切分。 4.根据权利要求1所述的基于网关流量控制的Elasticsearch查询 方法， 其特征在于， 计算DSL查询请求的D SL评分值的步骤中， 包括： 根据DSL查询请求确定查询时间的范围、 模糊匹配条件的个数和聚合维度； 根据预设计算分值对查询时间的范围、 模糊匹配条件的个数和聚合维度进行评分值累 加， 得到D SL查询请求的D SL评分值。 5.根据权利要求1所述的基于网关流量控制的Elasticsearch查询 方法， 其特征在于， ES网关每一时刻释放的分值是根据ES集群负荷、 ES集群 硬件确定 。 6.根据权利要求1 ‑5任一所述的基于网关流量控制的Elasticsearch查询方法， 其特征 在于， 还包括：权　利　要　求　书 1/2 页 2 CN 115080617 A 2记录所述D SL查询请求的请求 开始时间和请求结束时间。 7.一种基于网关流 量控制的Elasticsearc h查询系统， 其特 征在于， 包括： 获取模块， 用于获取D SL查询请求的请求 参数， 其中， 请求 参数包括 查询时间； 第一判断模块， 用于判断所述请求 参数是否满足ES集群的查询保护条件； 第一处理模块， 用于若所述请求参数不满足所述ES集群的查询保护条件， 则终止DSL查 询请求， 返回查询异常值； 第二处理模块， 用于若所述请求参数满足所述ES集群的查询保护条件， 则按照预设缓 存时间间隔对所述 查询时间进行时间归一 化处理和时间段切分处 理； 第三处理模块， 用于计算请求参数的hash值， 并将所述hash值作为所述DSL查询请求的 查询缓存ID； 第二判断模块， 用于判断所述 查询缓存ID是否存在于 ES网关的网关缓存ID中； 第四处理模块， 用于若所述查询缓存ID存在于ES网关的网关缓存ID中， 则发送ES网关 内存中存 储的与所述 查询缓存ID相对应的查询结果； 第五处理模块， 用于若所述查询缓存ID不存在于ES网关的网关缓存ID中， 则计算DSL查 询请求的D SL评分值； 第三判断模块， 用于判断所述D SL评分值是否大于 ES集群的当前时间段剩余分值； 第六处理模块， 用于若所述DSL评分值大于ES集群的当前时间段剩余分值， 则将所述 DSL查询请求进行排队等 候， 等待ES网关下一时刻重新释放分值； 第七处理模块， 用于若所述DSL评分值小于或者等于ES集群的当前时间段剩余分值， 则 将当前时间段剩余分值减去DSL评分值作为更新后的当前时间段剩余分值， 并且在ES集群 中执行DSL查询请求的搜索， 返回查询结果； 第八处理模块， 用于将所述DSL查询请求对应的查询缓存ID和查询结果存储至ES网关 内存。 8.一种计算机设备， 其特征在于， 包括： 至少一个处理器， 以及与所述至少一个处理器 通信连接的存储器， 其中， 所述存储器存储有可被所述至少一个处理器执行的指 令， 所述指 令被所述至少一个处理器执行， 以使所述至少一个处理器执行权利要求1 ‑6中任一所述的 基于网关流 量控制的Elasticsearc h查询方法。 9.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机指 令， 所述计算机指令用于使所述计算机执行1 ‑6中任一所述的基于网关流量控制的 Elasticsearc h查询方法。权　利　要　求　书 2/2 页 3 CN 115080617 A 3