重新索引GeoIP数据至GeoPoint格式的Elasticsearch Painless脚本问题

我明白你要把旧索引里嵌套的geoip.location对象（包含lon和lat字段）转换成geo_point类型要求的数组格式，适配目标索引的映射对吧？我帮你补全并修正_reindex请求里的Painless脚本部分，应该能解决你的问题。

完整的重新索引请求 #

POST _reindex
{
  "source": {
    "index": "你的旧索引名称" // 替换成实际的源索引名
  },
  "dest": {
    "index": "logs-audit-geopoint"
  },
  "script": {
    "source": """
      // 检查源文档是否存在geoip及location字段，避免空指针异常
      if (ctx._source.json?.geoip?.location != null) {
        def lon = ctx._source.json.geoip.location.lon;
        def lat = ctx._source.json.geoip.location.lat;
        // 将lon和lat转换为数组格式，赋值给目标字段
        ctx._source.json.geoip.location = [lon, lat];
      }
    """
  }
}

关键说明 #

• 空值处理：脚本里加了ctx._source.json?.geoip?.location != null的判断，是为了防止源文档中缺少geoip或location字段时抛出空指针错误，保证重新索引过程不会中断。
• 字段路径匹配：要确保脚本里的字段路径和你源文档的结构完全一致——你的源数据是嵌套在json字段下的geoip.location，所以脚本里的路径要严格对应。
• GeoPoint格式适配：Elasticsearch的geo_point类型原生支持[经度, 纬度]的数组格式，这个脚本正好把原有的对象结构转成了符合要求的格式。

如果之前的脚本报错，大概率是没处理空值或者字段路径写错了，试试上面这个完整请求应该能解决问题。

内容的提问来源于stack exchange，提问作者Saad Ahmed