基于条件的平均弹性搜索查询答案

【问题标题】：Elastic search query for avg on basis of condition基于条件的平均弹性搜索查询
【发布时间】：2020-01-09 20:33:18
【问题描述】：

我写了一个弹性搜索查询，payload看起来像

"userData": [ { "sub":1234, "value":678,"condition" :"A" },{ "sub":1234, "value":678,"condition" : "B" }]

查询：

{ 
  "aggs": { 
    "student_data": { 
      "date_histogram": { 
        "field":"@timestamp",
        "calendar_interval":"minute"
      },
      "aggs": { 
        "user_avg": { 
          "avg": { 
            "field":"value"
          }
        }
      }
    }
  }
}

结果给出了两个值的平均值，即条件 A 和条件 B，但我真正想要的是基于最小间隔时间段的条件 B 的平均值。

【问题讨论】：

这是您正在执行的唯一查询吗？
@Kapil 是的，它是我正在执行的查询的一部分
请分享您的映射。
@Kapil: 查询将获取条件 B 存在的所有文档，因此 A 条件将被考虑到聚合中，你必须在里面添加一个 agg_filter （请不要我在里面放一个术语过滤器，我们需要映射来知道我们是否必须使用查询字符串、术语或其他东西。我们还需要映射来测试，因为我认为我们需要将其映射为嵌套字段
{ "query":{ "query_string":{ "query":"condition:B" } }, "aggs":{ "student_data":{ "date_histogram":{ "field": “@timestamp”、“calendar_interval”：“分钟”}、“aggs”：{“condition_B”：{“filter”：{“term”：{“condition”：“b”}}、“aggs”：{“ user_avg" : { "avg" : { "field" : "value" } } } } } } }

标签： java elasticsearch kibana dsl

【解决方案1】：

根据您的有效负载，我假设 userData 是 nested 类型。

这是一个如何平均每个条件（嵌套内部）的工作示例：

映射

PUT my_index
{
  "mappings": {
    "properties": {
      "@timestamp": {
        "type": "date"
      },
      "userData": {
        "type": "nested",
        "properties": {
          "condition": {
            "type": "text",
            "fields": {
              "keyword": {
                "type": "keyword",
                "ignore_above": 256
              }
            }
          },
          "sub": {
            "type": "long"
          },
          "value": {
            "type": "long"
          }
        }
      }
    }
  }
}

索引少量文档

PUT my_index/_doc/1
{
  "@timestamp": "2019-11-08T11:15:24.188Z",
  "userData": [
    {
      "sub": 1234,
      "value": 678,
      "condition": "A"
    },
    {
      "sub": 1234,
      "value": 620,
      "condition": "B"
    }
  ]
}

PUT my_index/_doc/2
{
  "@timestamp": "2019-11-08T11:15:44.188Z",
  "userData": [
    {
      "sub": 1234,
      "value": 680,
      "condition": "A"
    },
    {
      "sub": 1234,
      "value": 640,
      "condition": "B"
    }
  ]
}

搜索查询

GET my_index/_search
{
  "size": 0,
  "aggs": {
    "student_data": {
      "date_histogram": {
        "field": "@timestamp",
        "calendar_interval": "minute"
      },
      "aggs": {
        "data": {
          "nested": {
            "path": "userData"
          },
          "aggs": {
            "condition": {
              "terms": {
                "field": "userData.condition.keyword"
              }, 
              "aggs": {
                "user_avg": {
                  "avg": {
                    "field": "userData.value"
                  }
                }
              }
            }
          }
        }
      }
    }
  }
}

结果

"student_data" : {
  "buckets" : [
    {
      "key_as_string" : "2019-11-08T11:15:00.000Z",
      "key" : 1573211700000,
      "doc_count" : 2,
      "data" : {
        "doc_count" : 4,
        "condition" : {
          "doc_count_error_upper_bound" : 0,
          "sum_other_doc_count" : 0,
          "buckets" : [
            {
              "key" : "A",
              "doc_count" : 2,
              "user_avg" : {
                "value" : 679.0
              }
            },
            {
              "key" : "B",
              "doc_count" : 2,
              "user_avg" : {
                "value" : 630.0
              }
            }
          ]
        }
      }
    }
  ]
}

希望对你有帮助

【讨论】：

Assael Azran 谢谢。查询有效。你能帮我获取所有在数组中给出平均值的元素吗