ElasticSearch 错误：QueryParsingException[[mongoindex] 未能找到 geo_point 字段 [pin.location]]；答案

【问题标题】：ElasticSearch Error: QueryParsingException[[mongoindex] failed to find geo_point field [pin.location]];ElasticSearch 错误：QueryParsingException[[mongoindex] 未能找到 geo_point 字段 [pin.location]]；
【发布时间】：2015-02-09 07:36:26
【问题描述】：

我是 ES 的新手。我正在尝试编写java程序来使用ES对MongoDB进行地理搜索（安装了河流插件等并能够使用java程序进行正常搜索）。我在 mongodb 中有一个集合（表），其中存储了纬度和经度值。现在我想根据从 Java 程序传递的纬度和经度检索记录。

    FilterBuilder filter =  FilterBuilders.geoDistanceFilter("pin.location").lat(10).lon(20).distance(5,DistanceUnit.KILOMETERS).geoDistance(GeoDistance.PLANE);

    SearchResponse response = client.prepareSearch(INDEX)
                                    .setTypes(TYPE)
                                    .setSearchType(SearchType.QUERY_AND_FETCH)
                                    .setQuery(matchAllQuery())
                                    .setPostFilter(filter)
                                    .setFrom(0).setSize(60).setExplain(true)
                                    .execute()
                                    .actionGet();

如果我执行上述程序，我会收到“QueryParsingException[[mongoindex] failed to find geo_point field [pin.location]];” 这个 pin.location 是什么？我的 mongodb 表也有“纬度”和“经度”列。但在上面的过滤器中，我有“lat(10).lon(20)”。我在这里遗漏了一些东西。请帮我理解。任何快速帮助都非常感谢。

全栈tarce：

},"解释":true}]]];嵌套：QueryParsingException[[mongoindex] 找不到 geo_point 字段 [pin.location]]； } 在 org.elasticsearch.action.search.type.TransportSearchTypeAction$BaseAsyncAction.onFirstPhaseResult(TransportSearchTypeAction.java:233) 在 org.elasticsearch.action.search.type.TransportSearchTypeAction$BaseAsyncAction$1.onFailure(TransportSearchTypeAction.java:179) 在 org.elasticsearch.search.action.SearchServiceTransportAction$12.handleException(SearchServiceTransportAction.java:351) 在 org.elasticsearch.transport.netty.MessageChannelHandler.handleException（MessageChannelHandler.java:185）在 org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:175) 在 org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:125) 在 org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) 在 org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream（DefaultChannelPipeline.java:564）在 org.elasticsearch.common.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) 在 org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:296) 在 org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462) 在 org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443) 在 org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303) 在 org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) 在 org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream（DefaultChannelPipeline.java:564）在 org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559) 在 org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:268) 在 org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:255) 在 org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88) 在 org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108) 在 org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318) 在 org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89) 在 org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) 在 org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run（ThreadRenamingRunnable.java:108）在 org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:745)

谢谢，斯里

【问题讨论】：

在开始编写 Java 代码之前，您能否创建一个对 ES 进行相同查询的 HTTP 请求？类似：http://url-to-es/index/document?query=...

标签： elasticsearch elasticsearch-jdbc-river

【解决方案1】：

您正在创建的过滤器基于字段 pin.location

FilterBuilders.geoDistanceFilter("pin.location")

这回答了您关于此 pin.location 的问题。开始查看索引的映射，看看您添加到 elasticsearch 的字段是否属于 geo_point 类型。我自己没有使用过mongo河，但是根据这个问题你必须提供你自己的映射。

https://github.com/richardwilly98/elasticsearch-river-mongodb/issues/218#issuecomment-35824681

下面是来自上述帖子的示例：

curl -XPUT 'http://localhost:9200/location_test' -d '
{
    "mappings": {
        "places": {
            "properties": {
               "location": {
                    "type": "geo_point"
                }
            }
        }
    }
}
'

更多关于 elasticsearch 中 geo_point 的信息可以在这里找到： http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/mapping-geo-point-type.html

【讨论】：

不确定你的意思，你做了什么？也许明智的做法是首先尝试提出您正在执行的 curl 查询和预期的响应。这使得谈论它变得容易得多。

【解决方案2】：

感谢您的信息。问题已解决。使用以下配置工作正常。

curl -XPUT 'http://localhost:9200/myindex' -d '
{
   "settings" : {
        "number_of_shards" : 2,
        "number_of_replicas" : 1
    },
   "mappings" : {
      "my_details" : {
          "properties" : {
              "my_id" : {"type" : "integer", "store" : "yes" , "index":"not_analyzed"},
              "location" : {"type" : "geo_point", "store" : "yes", "index":"not_analyzed"}
          }
      }
  }

}'

curl -XPUT 'http://localhost:9200/_river/my_river/_meta' -d '
{
    "type": "mongodb",
    "mongodb": {
        "db": "MyDatabase",
        "collection": "my_details"
    },
    "index": {
        "name": "myindex",
        "type": "my_details"
    }

}'

注意：MongoDb 在“MyDatabase”中有“my_details”集合。
干杯，查达

【讨论】：