Elasticsearch Painless脚本处理多值对象：获取过滤后最大groupe_an值

问题根源 #

你当前的索引mapping中，micro.ans是普通Object类型，Elasticsearch会将数组内的对象扁平化存储，导致an和groupe_an成为两个独立的多值字段，它们的元素顺序无法保证一一对应，这也是你用索引k的临时方案不可靠的原因。同时，doc上下文只能访问扁平化后的单个字段值，无法直接遍历原始的对象数组，因此触发Extraneous for each loop异常。

正确索引方案：将micro.ans设为Nested类型 #

Nested类型会将数组中的每个对象独立索引，完整保留对象内字段的关联关系，确保你能正确遍历每个(an, groupe_an)对。

1. 创建带Nested类型的索引 #

PUT test-500
{
  "mappings": {
    "properties": {
      "micro": {
        "properties": {
          "ans": {
            "type": "nested", // 关键：设置为nested类型
            "properties": {
              "an": {
                "type": "keyword"
              },
              "groupe_an": {
                "type": "float"
              }
            }
          }
        }
      }
    }
  }
}

2. 插入数据（与原数据一致） #

PUT test-500/_doc/1
{
  "micro" : {
    "ans" : [
      {"an": "686660", "groupe_an" : 14.0},
      {"an": "439750", "groupe_an" : 6.0}
    ]
  }
}      

PUT test-500/_doc/2
{
  "micro" : {
    "ans" : [
      {"an": "286660", "groupe_an" : 100.0},
      {"an": "239750", "groupe_an" : 200.0}
    ]
  }
}

对应的Painless脚本 #

通过访问params._source获取原始文档的对象数组，遍历每个ans对象，过滤匹配queried_an的项并记录最大的groupe_an值：

GET test-500/_search
{
  "query": {
    "script_score": {
      "query": {
        "match_all": {}
      },
      "script": {
        "source": """
          double maxGroupe = 0.0;
          // 遍历原始文档中的ans数组
          for (def item : params._source.micro.ans) {
            if (item.an == params.queried_an) {
              if (item.groupe_an > maxGroupe) {
                maxGroupe = item.groupe_an;
              }
            }
          }
          return maxGroupe;
        """,
        "lang": "painless",
        "params": {
          "queried_an": "239750"
        }
      }
    }
  }
}

补充说明 #

• 若文档体积较大，频繁访问_source可能影响性能，也可以结合nested查询+脚本的方式优化，但上述方案是最直接的实现。
• 如需处理未匹配到queried_an的场景，可根据需求调整maxGroupe的初始值（比如设为-Infinity或返回特定标记值）。

内容的提问来源于stack exchange，提问作者Bob Yoplait