查询解析失败，未提供网格名称 - 如何解决此 Elasticsearch 异常

[2024-01-15T10:30:45,123][WARN ][o.e.r.a.RestValidateAction ] [node-1] failed to parse [geo_grid] query. grid name not provided
org.elasticsearch.common.ParsingException: failed to parse [geo_grid] query. grid name not provided
    at org.elasticsearch.index.query.GeoGridQueryBuilder.fromXContent(GeoGridQueryBuilder.java:98)
    at org.elasticsearch.index.query.AbstractQueryBuilder.parseInnerQueryBuilder(AbstractQueryBuilder.java:337)
    at org.elasticsearch.index.query.BoolQueryBuilder.fromXContent(BoolQueryBuilder.java:156)
    at org.elasticsearch.index.query.AbstractQueryBuilder.parseInnerQueryBuilder(AbstractQueryBuilder.java:337)
    at org.elasticsearch.rest.action.search.RestSearchAction.lambda$prepareRequest$0(RestSearchAction.java:102)
    at org.elasticsearch.rest.BaseRestHandler.handleRequest(BaseRestHandler.java:104)
    at org.elasticsearch.rest.RestController.dispatchRequest(RestController.java:335)

// GeoGridQueryBuilder.fromXContent 关键片段
String grid = null;
String gridId = null;
String fieldName = null;

// 解析 JSON 字段
while ((token = parser.nextToken()) != XContentParser.Token.END_OBJECT) {
    if ("grid".equals(fieldName)) {
        grid = parser.text();
    } else if ("grid_id".equals(fieldName)) {
        gridId = parser.text();
    } else if ("field".equals(fieldName)) {
        fieldName = parser.text();
    }
    // ...
}

// 关键校验：grid 必须非空
if (grid == null) {
    throw new ElasticsearchParseException(
        "failed to parse [{}] query. grid name not provided", NAME);
}

# 检查 ES 版本
curl -s "http://localhost:9200" | jq .version.number

# 如果你用的是 cURL，直接检查你的 JSON 文件
cat request.json | jq .

curl -X POST "http://localhost:9200/my_index/_search" -H "Content-Type: application/json" -d '
{
  "query": {
    "geo_grid": {
      "field": "location",
      "grid_id": "7/64/42"
    }
  }
}'

{
  "error": {
    "root_cause": [
      {
        "type": "parse_exception",
        "reason": "failed to parse [geo_grid] query. grid name not provided"
      }
    ],
    "type": "parse_exception",
    "reason": "failed to parse [geo_grid] query. grid name not provided"
  },
  "status": 400
}

curl -X POST "http://localhost:9200/my_index/_search" -H "Content-Type: application/json" -d '
{
  "query": {
    "geo_grid": {
      "field": "location",
      "grid": "geotile",
      "grid_id": "7/64/42"
    }
  }
}'

# 查看索引 mapping
curl -s "http://localhost:9200/my_index/_mapping" | jq '.[].mappings.properties.location'

{
  "type": "geo_point"
}

curl -X POST "http://localhost:9200/my_index/_validate/query" -H "Content-Type: application/json" -d '
{
  "query": {
    "geo_grid": {
      "field": "location",
      "grid_id": "7/64/42"
    }
  }
}' | jq .

{
  "query": {
    "geo_grid": {
      "field": "location",
      "grid": "geotile",
      "grid_id": "7/64/42"
    }
  }
}

{
  "query": {
    "geo_grid": {
      "field": "location",
      "grid": "geohash",
      "grid_id": "wtw3"
    }
  }
}

# 1. 创建索引，定义 geo_point 字段
curl -X PUT "http://localhost:9200/geo_test" -H "Content-Type: application/json" -d '
{
  "mappings": {
    "properties": {
      "location": { "type": "geo_point" },
      "name": { "type": "keyword" }
    }
  }
}'

# 2. 写入测试数据（上海坐标）
curl -X POST "http://localhost:9200/geo_test/_doc" -H "Content-Type: application/json" -d '
{
  "name": "上海东方明珠",
  "location": { "lat": 31.2304, "lon": 121.4737 }
}'

# 3. 使用 geotile 网格查询
curl -X POST "http://localhost:9200/geo_test/_search" -H "Content-Type: application/json" -d '
{
  "query": {
    "geo_grid": {
      "field": "location",
      "grid": "geotile",
      "grid_id": "7/102/56"
    }
  }
}'

# 4. 使用 geohash 网格查询
curl -X POST "http://localhost:9200/geo_test/_search" -H "Content-Type: application/json" -d '
{
  "query": {
    "geo_grid": {
      "field": "location",
      "grid": "geohash",
      "grid_id": "wtw3"
    }
  }
}'

# Python 示例
def build_geo_grid_query(field, grid, grid_id):
    """构建 geo_grid 查询，包含必填字段校验"""
    if not grid:
        raise ValueError("geo_grid 查询必须提供 grid 参数，可选值为: geotile, geohash")
    if not grid_id:
        raise ValueError("geo_grid 查询必须提供 grid_id 参数")
    if grid not in ("geotile", "geohash"):
        raise ValueError(f"不支持的 grid 类型: {grid}，仅支持: geotile, geohash")

    return {
        "query": {
            "geo_grid": {
                "field": field,
                "grid": grid,
                "grid_id": grid_id
            }
        }
    }

// Java 示例（使用 Elasticsearch Java Client）
Query gridQuery = GeoGridQuery.of(g -> g
    .field("location")
    .grid(GeoGridType.Geotile)   // 明确指定网格类型
    .gridId("7/102/56")
)._toQuery();

// GeoGridQueryBuilder.java（Elasticsearch 8.x）
String grid = null;
String gridId = null;
String fieldName = null;
float boost = AbstractQueryBuilder.DEFAULT_BOOST;
String queryName = null;

// 解析 geo_grid 查询的 JSON 内容
while ((token = parser.nextToken()) != XContentParser.Token.END_OBJECT) {
    if (token == XContentParser.Token.FIELD_NAME) {
        currentFieldName = parser.currentName();
    } else if (token == XContentParser.Token.VALUE_STRING) {
        if ("field".equals(currentFieldName)) {
            fieldName = parser.text();
        } else if ("grid".equals(currentFieldName)) {
            grid = parser.text();   // <-- 读取 grid 字段
        } else if ("grid_id".equals(currentFieldName)) {
            gridId = parser.text(); // <-- 读取 grid_id 字段
        } else if ("query_name".equals(currentFieldName) || "_name".equals(currentFieldName)) {
            queryName = parser.text();
        } else {
            throw new ElasticsearchParseException(
                "failed to parse [{}] query. unknown field [{}]", NAME, currentFieldName);
        }
    } else if (token == XContentParser.Token.VALUE_NUMBER) {
        if ("boost".equals(currentFieldName) || "_boost".equals(currentFieldName)) {
            boost = parser.floatValue();
        }
    }
    // ...
}

// 关键校验 1：grid 必须提供
if (grid == null) {
    throw new ElasticsearchParseException(
        "failed to parse [{}] query. grid name not provided", NAME);
}

// 关键校验 2：grid_id 必须提供
if (gridId == null) {
    throw new ElasticsearchParseException(
        "failed to parse [{}] query. grid id not provided", NAME);
}

// 校验通过，构建 QueryBuilder
GeoGridQueryBuilder builder = new GeoGridQueryBuilder(fieldName);
builder.setGridId(grid, gridId);
builder.queryName(queryName);
builder.boost(boost);
return builder;