elasticsearch - 在Elasticsearch中给定条件的一堆值求和

Question

给定以下elasticsearch文档，我将如何构造一个搜索，该搜索求和给定datetime范围内的seconds列的值？

请参阅下面的当前查询。

{
  "took": 1,
  "timed_out": false,
  "_shards": {
    "total": 5,
    "successful": 5,
    "failed": 0
  },
  "hits": {
    "total": 2,
    "max_score": 1,
    "hits": [
      {
        "_index": "searchdb",
        "_type": "profile",
        "_id": "1825",
        "_score": 1,
        "_source": {
          "id": 1825,
          "market": "Chicago",
          "geo_location": {
            "lat": 41.1234,
            "lon": -87.5678
          },
          "hourly_values": [
            {
              "datetime": "1997-07-16T19:00:00.00+00:00",
              "seconds": 1200
            },
            {
              "datetime": "1997-07-16T19:20:00.00+00:00",
              "seconds": 1200
            },
            {
              "datetime": "1997-07-16T19:20:00.00+00:00",
              "seconds": 1200
            }
          ]
        }
      },
      {
        "_index": "searchdb",
        "_type": "profile",
        "_id": "1808",
        "_score": 1,
        "_source": {
          "id": 1808,
          "market": "Chicago",
          "geo_location": {
            "lat": 41.1234,
            "lon": -87.5678
          },
          "hourly_values": [
            {
              "datetime": "1997-07-16T19:00:00.00+00:00",
              "seconds": 900
            },
            {
              "datetime": "1997-07-16T19:20:00.00+00:00",
              "seconds": 1200
            },
            {
              "datetime": "1997-07-16T19:20:00.00+00:00",
              "seconds": 800
            }
          ]
        }
      }
    ]
  }

以下是我当前的查询。它的问题是它没有考虑datetime字段。我只需要能够对查询中给定日期时间范围内的秒值求和。

{
    "aggs": {
        "Ids": {
            "terms": {
                "field": "id",
                "size": 0
            },
            "aggs": {
                "Nesting": {
                    "nested": {
                        "path": "hourly_values"
                    },
                    "aggs": {
                        "availability": {
                            "sum": {
                                "field": "hourly_values.seconds"
                            }
                        }
                    }
                }
            }
        }
    }
} 

我知道您可以使用范围，如下所示:

"filter" : {
                "range" : { "timestamp" : { "from" : "now/1d+9.5h", "to" : "now/1d+16h" }}
            }

但我不知道如何将其集成到查询中以获得所需的输出。

为了清楚起见，我想要的输出是返回从查询返回的每个对象以及秒字段的求和值，但是我只想对给定时间范围内的值求和。

Answer 1

我认为可以用filter aggregation完成

试试这个

{
  "aggs": {
    "Ids": {
      "terms": {
        "field": "id",
        "size": 0
      },
      "aggs": {
        "Nesting": {
          "nested": {
            "path": "hourly_values"
          },
          "aggs": {
            "filtered_result": {
              "filter": {
                "query": {
                  "range": {
                    "hourly_values.datetime": {
                      "gt": "1997-07-16T19:10:00.00+00:00",
                      "lt": "1997-07-16T19:22:00.00+00:00"
                    }
                  }
                }
              },
              "aggs": {
                "availability": {
                  "sum": {
                    "field": "hourly_values.seconds"
                  }
                }
              }
            }
          }
        }
      }
    }
  },
  "size": 0
} 

我得到的结果

"aggregations": {
      "Ids": {
         "doc_count_error_upper_bound": 0,
         "sum_other_doc_count": 0,
         "buckets": [
            {
               "key": "1808",
               "doc_count": 1,
               "Nesting": {
                  "doc_count": 3,
                  "filtered_result": {
                     "doc_count": 2,
                     "availability": {
                        "value": 2000
                     }
                  }
               }
            },
            {
               "key": "1825",
               "doc_count": 1,
               "Nesting": {
                  "doc_count": 3,
                  "filtered_result": {
                     "doc_count": 2,
                     "availability": {
                        "value": 2400
                     }
                  }
               }
            }
         ]
      }
   }

这有帮助吗？