标签：script doc long taskFinishTime state ElasticSearch value responseTime

1.需求

选出前5条当前响应时间最大的url数据

2.实现

用key_id分组url，在内部选出最大taskFinishTime那条数据，根据其responseTime进行排序。

对buckets数据排序，要求排序字段是个值，不能是聚合。

所以这里使用scripted_metric统计last_response_time，就可以直接取到值。

（之前试过根据taskFinishTime排序，选出top hits 1的数据，显示其responseTime。但这种结果中有buckets，没法用作排序字段）

script中涉及：

taskFinishTime的是date类型的，取到的doc['taskFinishTime'].value不能直接和long类型的变量state.taskFinishTime作比较。

所以进行转换Date->Instant->Long，Date转Long语句doc['taskFinishTime'].value.toInstant().toEpochMilli()

es语句

GET /aaa/_search
{
  "size": 0,
  "query": {
    "bool": {
      "filter": {
        "range": {
          "taskFinishTime": {
            "gte": 1630825435000,
            "lte": 1630911835000
          }
        }
      },
      "must": [
        {
          "exists": {
            "field": "result.http_request.responseTime"
          }
        },
        {
          "exists": {
            "field": "result.http_request.statusCode"
          }
        }
      ]
    }
  },
  "aggs": {
    "group_by_url": {
      "terms": {
        "field": "key_id.keyword",
        "size": 10000
      },
      "aggs": {
        "url_nodealias": {
          "top_hits": {
            "size": 1,
            "_source": {
              "includes": [
                "nodealias"
              ]
            }
          }
        },
        "last_response_time": {
          "scripted_metric": {
            "init_script": "state.taskFinishTime = 0L; state.responseTime = 0L;",
            "map_script": "if(doc['taskFinishTime'].value.toInstant().toEpochMilli() > state.taskFinishTime) {state.taskFinishTime = doc['taskFinishTime'].value.toInstant().toEpochMilli(); state.responseTime = doc['result.http_request.responseTime'].value;}",
            "combine_script": "return state",
            "reduce_script": "long finalTaskFinishTime = 0L; double finalResponseTime = 0L; for (a in states){if(finalTaskFinishTime < a.taskFinishTime) {finalTaskFinishTime = a.taskFinishTime; finalResponseTime = a.responseTime;}} return finalResponseTime"
          }
        },
        "bucket_sort_temp": {
          "bucket_sort": {
            "sort": [
              {
                "last_response_time.value": {
                  "order": "desc"
                }
              }
            ],
            "size": 5
          }
        }
      }
    }
  }
}

标签：script,doc,long,taskFinishTime,state,ElasticSearch,value,responseTime
来源： https://www.cnblogs.com/musecho/p/15304036.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。