弹性无痛“状态”替代方案

Question

这是我第一次尝试无痛脚本，但是几乎每个示例都使用“state”对象，这在我的版本中不可用。

即

"aggs": {
    "terms": {
      "scripted_metric": {
        "init_script": "state.id_map = [:]; state.sum = 0.0;",
        "map_script": """
          def id = doc['record_id.ID'].value;
          if (!state.id_map.containsKey(id)) {
            state.id_map[id] = true;
            state.sum += doc['VAL'].value;
          }
        """,
        "combine_script": """
            def sum = state.sum;
            def stats = [:];
            stats.sum = sum;
            return stats
        """,
        "reduce_script": "return states"
      }
    }
  }

导致:变量[state]未定义。

省略它也没有帮助

"init_script": "Map id_map = new HashMap(); double sum = 0.0;",
        "map_script": """
          def id = doc['record_id.ID'].value;
          if (!id_map.containsKey(id)) {
            id_map[id] = true;
            sum += doc['VAL'].value;
          }
        """,

结果为:“变量[id_map]未定义。”在map_script部分

早期版本的替代方法是什么？

Answer 1

您上面的脚本在6.4版及更高版本中运行良好。

由于您正在运行ES 5.x，因此需要稍微更改语法：

• 将状态替换为params._agg
• 将状态替换为params._aggs

像这样:

"aggs": {
    "terms": {
      "scripted_metric": {
        "init_script": "params._agg.id_map = [:]; params._agg.sum = 0.0;",
        "map_script": """
          def id = doc['record_id.ID'].value;
          if (!params._agg.id_map.containsKey(id)) {
            params._agg.id_map[id] = true;
            params._agg.sum += doc['VAL'].value;
          }
        """,
        "combine_script": """
            def sum = params._agg.sum;
            def stats = [:];
            stats.sum = sum;
            return stats
        """,
        "reduce_script": "return params._aggs"
      }
    }
  }