es-geo查询

2024-08-24 15:08
文章标签 es 查询 geo

本文主要是介绍es-geo查询，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

最近有两个需求是通过地图选择坐标，查询指定距离内的信息，和通过坐标集合组成不规则形状查询出不规则形状范围内的数据，在最起初我看到这个需求的时候第一个想法就是太复杂了，抵触。但是没有办法既然需求下来了只能硬着头皮上了，在调研之后最终还是决定了使用elasticsearch，下面就开始介绍如何使用elasticsearch来进行相关操作

设置数据格式

地理坐标点（geo-point） 是指地球表面可以用经纬度描述的一个点。地理坐标点可以用来计算两个坐标位置间的距离，或者判断一个点是否在一个区域中。地理坐标点不能被动态映射（dynamic mapping）自动检测，而是需要显式声明对应字段类型为 geo_point ,例子中的location字段

PUT platform_foreign_website
{"mappings": {"store":{"properties": {"id": {"type": "text"},"storeName": {"type": "text"},"location":{"type": "geo_point"}}}}
}

存储示例：

  • 半角逗号分割的字符串形式 “lat,lon“
  • 明确以 lat 和 lon 作为属性的对象
  • 数组形式表示 [lon,lat]

需要特别注意的就是纬度在前边经度在后边（latitude,longitude），数组表示形式是经度在前纬度在后（[longitude,latitude]）

geo_distance 找出指定位置在给定距离内的数据，相当于指定圆心和半径找到圆中点

  • 找出两千米范围内的所有门店
  • distance：距离 单位/km
  • location：坐标点 圆心所在位置

es代码示例

//无排序
GET platform_foreign_website/communit/_search
{"query": {"constant_score": {"filter": {"geo_distance": {"distance": "2km","location": {"lat": 39.662263,"lon": 118.197815}}},"boost": 1.2}}
}//带排序
GET platform_foreign_website/communit/_search
{"query": {"constant_score": {"filter": {"geo_distance": {"distance": "1km","location": {"lat": 39.662263,"lon": 118.197815}}},"boost": 1.2}},"sort": [{"_geo_distance" : {"location" : [{"lat" : 40.010955,"lon" : 118.68545}],"unit" : "km","distance_type" : "arc","order" : "asc","validation_method" : "STRICT"}
}]
}

java代码示例:

这里选用的是ElasticsearchTemplate 模板，因为没有分页取值比较方便，可以根据自己的业务逻辑自行选择

//无排序
private List<Store> getStores(CommunityToStoreParameter communityToStoreParameter) {//拼接条件BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();QueryBuilder isdeleteBuilder = QueryBuilders.termQuery("isdelete", false);// 以某点为中心，搜索指定范围GeoDistanceQueryBuilder distanceQueryBuilder = new GeoDistanceQueryBuilder("location");distanceQueryBuilder.point(communityToStoreParameter.getLatitude(), communityToStoreParameter.getLongitude());//查询单位：kmdistanceQueryBuilder.distance(communityAndStoresdistance, DistanceUnit.KILOMETERS);boolQueryBuilder.filter(distanceQueryBuilder);boolQueryBuilder.must(isdeleteBuilder);SearchQuery storesearchQuery = new NativeSearchQueryBuilder().withIndices(ESIndexAndTypeConstant.INDEX_NAME).withTypes(ESIndexAndTypeConstant.STORE_TYPE_NAME).withQuery(boolQueryBuilder).build();return elasticsearchTemplate.queryForList(storesearchQuery, Store.class);}//有排序
private Page<Store> getStores(Integer page, Integer size, AroundStoreParameter aroundStoreParameter, Double latitude, Double longitude, QueryBuilder isdeleteBuilder) {Pageable pageable = PageRequest.of(page - 1, size);NativeSearchQueryBuilder nativeSearchQueryBuilder = new NativeSearchQueryBuilder();BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();// 以某点为中心，搜索指定范围GeoDistanceQueryBuilder distanceQueryBuilder = new GeoDistanceQueryBuilder("location");distanceQueryBuilder.point(latitude, longitude);//查询单位：kmdistanceQueryBuilder.distance(aroundStoreParameter.getDistance(), DistanceUnit.KILOMETERS);boolQueryBuilder.filter(distanceQueryBuilder);boolQueryBuilder.must(isdeleteBuilder);nativeSearchQueryBuilder.withQuery(boolQueryBuilder);// 按距离升序GeoDistanceSortBuilder distanceSortBuilder =new GeoDistanceSortBuilder("location", latitude, longitude);distanceSortBuilder.unit(DistanceUnit.KILOMETERS);distanceSortBuilder.order(SortOrder.ASC);nativeSearchQueryBuilder.withSort(distanceSortBuilder);nativeSearchQueryBuilder.withPageable(pageable);return storeRepository.search(nativeSearchQueryBuilder.build());}

geo_polygon（地理多边形查询）: 一个查询，查询多边形内的所有的点,实现地图画圈筛选

es代码示例

GET platform_foreign_website/store/_search
{"query": {"bool": {"must": [{"match_all": {}}],"filter": {"geo_polygon": {"location": {"points": [{ "lat": 39.634863, "lon": 118.137071 },{ "lat": 39.6349, "lon": 118.13291 },{ "lat": 39.633121, "lon": 118.128941 },{ "lat": 39.629607, "lon": 118.130915 },{ "lat": 39.632696, "lon": 118.132769 },{ "lat": 39.630513, "lon": 118.136018 }]}}}}}
}

java代码示例

public PageResultVO storeRange(Integer page, Integer size, List<StoreRangeParameter> storeRangeParameters) {Pageable pageable = PageRequest.of(page - 1, size);//坐标集合List<GeoPoint> geoPoints = storeRangeParameters.stream().map(a ->new GeoPoint(a.getLatitude(), a.getLongitude())).collect(Collectors.toList());//拼接查询条件BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();QueryBuilder locationBuilder = QueryBuilders.geoPolygonQuery("location", geoPoints);QueryBuilder isdeleteBuilder = QueryBuilders.termQuery("isdelete", false);boolQueryBuilder.filter(locationBuilder);boolQueryBuilder.must(isdeleteBuilder);SearchQuery communityNativeBuilder = new NativeSearchQueryBuilder().withPageable(pageable).withQuery(boolQueryBuilder).build();Page<Community> communities = communityRepository.search(communityNativeBuilder);List<CommunityInfoResultVO> communityInfoResultVOList = communities.getContent().stream().map(community ->new CommunityInfoResultVO(community.getCommunityName(), community.getLongitude(), community.getLatitude())).collect(Collectors.toList());return new PageResultVO<>(communities.getTotalElements(), communityInfoResultVOList);}

这里说明一下为什么有的是用filter（）有的使用must（）：must查询需要打分评估进行_score，但是filter，先使用filter把无用的数据过滤掉，在已经处理过的数据中must查询，能够有效地提升性能

这里说了 geo_distance（找出与指定位置在给定距离内的点） 和 geo_polygon（找出落在多边形中的点）两种方法，elasticsearch其实还有另外两种 方法 geo_bounding_box（找出落在指定矩形框中的坐标点） 和 geo_distance_range（找出与指定点距离在给定最小距离和最大距离之间的点），因为需求没有涉及到暂时没有调研，以后会慢慢完善

所有这些过滤器的工作方式都相似： 把 索引中所有文档（而不仅仅是查询中匹配到的部分文档，见 fielddata-intro）的经纬度信息都载入内存，然后每个过滤器执行一个轻量级的计算去判断当前点是否落在指定区域

geo_bounding_box（盒模型）找出落在指定矩形框中的坐标点，用于可视化范围筛选,例如：整个屏幕范围内的数据筛选（左上角坐标点和右下角坐标点）

es示例

GET platform_foreign_website/store/_search
{"query": {"bool": {"must": [{"match_all": {}}],"filter": {"geo_bounding_box": {"location": {"top_left": {"lat": 39.634863,"lon": 118.137071},"bottom_right": {"lat": 39.630513,"lon": 118.136018}}}}}}
}

java 代码示例

public TotalResultVO regionList(){BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();QueryBuilder isdeleteBuilder = QueryBuilders.termQuery("if_deleted", 0);QueryBuilder positionBuilder = QueryBuilders.existsQuery("position");boolQueryBuilder.must(isdeleteBuilder).must(positionBuilder);//坐标顺序一定要是左上 和右下 ，顺序不对查询结果会有问题 QueryBuilder positionQueryBuilder = QueryBuilders.geoBoundingBoxQuery("position").setCorners(new GeoPoint(Latitude,Longitude), new GeoPoint(Latitude,Longitude));boolQueryBuilder.filter(positionQueryBuilder);SearchQuery searchQuery =new   NativeSearchQueryBuilder().withPageable(getPageable()).withQuery(boolQueryBuilder).build();Page<Region> regionPage = regionRepository.search(searchQuery);
}

geo_distance_range 找出与指定点距离在给定最小距离和最大距离之间的点， 5.x版本不再支持，建议使用 geo_distance

这篇关于es-geo查询的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1102830。

相关文章

活用c4d官方开发文档查询代码

活用c4d官方开发文档查询代码

当你问AI助手比如豆包，如何用python禁止掉xpresso标签时候，它会提示到 这时候要用到两个东西。https://developers.maxon.net/论坛搜索和开发文档 比如这里我就在官方找到正确的id描述 然后我就把参数标签换过来
阅读更多...
ural 1026. Questions and Answers 查询

ural 1026. Questions and Answers 查询

1026. Questions and Answers Time limit: 2.0 second Memory limit: 64 MB Background The database of the Pentagon contains a top-secret information. We don’t know what the information is — you
阅读更多...
Mybatis中的like查询

Mybatis中的like查询

<if test="templateName != null and templateName != ''">AND template_name LIKE CONCAT('%',#{templateName,jdbcType=VARCHAR},'%')</if>
阅读更多...
京东物流查询｜开发者调用API接口实现

京东物流查询｜开发者调用API接口实现

快递聚合查询的优势 1、高效整合多种快递信息。2、实时动态更新。3、自动化管理流程。 聚合国内外1500家快递公司的物流信息查询服务，使用API接口查询京东物流的便捷步骤，首先选择专业的数据平台的快递API接口：物流快递查询API接口-单号查询API - 探数数据 以下示例是参考的示例代码： import requestsurl = "http://api.tanshuapi.com/a
阅读更多...
DAY16：什么是慢查询，导致的原因，优化方法 | undo log、redo log、binlog的用处 | MySQL有哪些锁

DAY16：什么是慢查询，导致的原因，优化方法 | undo log、redo log、binlog的用处 | MySQL有哪些锁

目录 什么是慢查询，导致的原因，优化方法 undo log、redo log、binlog的用处  MySQL有哪些锁   什么是慢查询，导致的原因，优化方法 数据库查询的执行时间超过指定的超时时间时，就被称为慢查询。 导致的原因： 查询语句比较复杂：查询涉及多个表，包含复杂的连接和子查询，可能导致执行时间较长。查询数据量大：当查询的数据量庞大时，即使查询本身并不复杂，也可能导致
阅读更多...
oracle11.2g递归查询（树形结构查询）

oracle11.2g递归查询（树形结构查询）

转自： 一 二 简单语法介绍 一、树型表结构：节点ID 上级ID 节点名称二、公式： select 节点ID,节点名称,levelfrom 表connect by prior 节点ID=上级节点IDstart with 上级节点ID=节点值 oracle官网解说 开发人员：SQL 递归： 在 Oracle Database 11g 第 2 版中查询层次结构数据的快速
阅读更多...
ElasticSearch的DSL查询⑤（ES数据聚合、DSL语法数据聚合、RestClient数据聚合）

ElasticSearch的DSL查询⑤（ES数据聚合、DSL语法数据聚合、RestClient数据聚合）

目录 一、数据聚合 1.1 DSL实现聚合 1.1.1 Bucket聚合  1.1.2 带条件聚合 1.1.3 Metric聚合 1.1.4 总结 2.1 RestClient实现聚合 2.1.1 Bucket聚合 2.1.2 带条件聚合 2.2.3 Metric聚合 一、数据聚合 聚合（aggregations）可以让我们极其方便的实现对数据的统计、分析、运算。例如：
阅读更多...
MySQL基础（7）- 多表查询

MySQL基础（7）- 多表查询

目录 一、笛卡尔积的错误与正确的多表查询 1.出现笛卡尔积错误 2.正确的多表查询：需要有连接条件 3.查询多个表中都存在的字段 4.SELECT和WHERE中使用表的别名 二、等值连接vs非等值连接、自连接vs非自连接 1.等值连接  vs  非等值连接 2.自连接  vs  非自连接 3.内连接  vs  外连接 4.UNION  和 UNION ALL的使用 5.7种J
阅读更多...
Redis地理数据类型GEO

Redis地理数据类型GEO

通常要计算两个地理位置的距离不是很方便，这里可以直接通过Redis提供的GEO操作来完成地理位置相关的计算 1）添加地理位置 语法：geoadd key longitude latitude member [longitude latitude member] ...字段说明：key：存放地理位置的集合名称longitude：地理坐标的经度latitude：地理坐标的纬度member：表示这
阅读更多...
OpenGL ES学习总结：基础知识简介

OpenGL ES学习总结：基础知识简介

什么是OpenGL ES? OpenGL ES (为OpenGL for Embedded System的缩写） 为适用于嵌入式系统的一个免费二维和三维图形库。 为桌面版本OpenGL 的一个子集。 OpenGL ES管道(Pipeline) OpenGL ES 1.x 的工序是固定的，称为Fix-Function Pipeline,可以想象一个带有很多控制开关的机器，尽管加工
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2