复杂嵌套查询，复杂聚合

# (1) 创建测试索引

PUT test/

{

  "mappings": {

    "properties": {

      "id": {

        "type": "keyword"

      },

      "date": {

        "type": "date"

      },

      "count": {

        "type": "long"

      }

    }

  }

}





# (2) 写入测试文档

POST _bulk

{ "index" : { "_index" : "test" } }

{ "id": "10001", "date": "2021-06-01", "count": 1}

{ "index" : { "_index" : "test" } }

{ "id": "10001", "date": "2021-06-02", "count": 3}

{ "index" : { "_index" : "test" } }

{ "id": "10001", "date": "2021-06-03", "count": 2}

{ "index" : { "_index" : "test" } }

{ "id": "10002", "date": "2021-06-01", "count": 1}

{ "index" : { "_index" : "test" } }

{ "id": "10002", "date": "2021-06-02", "count": 3}

{ "index" : { "_index" : "test" } }

{ "id": "10002", "date": "2021-06-03", "count": 3}

{ "index" : { "_index" : "test" } }

{ "id": "10003", "date": "2021-06-01", "count": 1}

# (3) 查询语句

# a21 用于过滤条件: 时间范围过滤 和 count为1

# a22 用于过滤条件: count为2 

# 最终使用 bucket_selector 管道聚合，得到结果

GET test/_search

{

  "size": 0,

  "aggs": {

    "a1": {

      "terms": {

        "field": "id",

        "size": 10

      },

      "aggs": {

        "a21": {

          "filter": {

            "bool": {

              "must": [

                {

                  "range": {

                    "date": {

                      "gte": "2021-05-30",

                      "lte": "2021-06-31"

                    }

                  }

                },

                {

                  "term": {

                    "count": 1

                  }

                }

              ]

            }

          },

          "aggs": {

            "a31": {

              "sum": {

                "field": "count"

              }

            }

          }

        },

        "a22": {

          "filter": {

            "bool": {

              "must": [

                {

                  "term": {

                    "count": 2

                  }

                }

              ]

            }

          },

          "aggs": {

            "a32": {

              "sum": {

                "field": "count"

              }

            }

          }

        },

        "a4": {

          "bucket_selector": {

            "buckets_path": {

              "count1": "a21>a31",

              "count2": "a22>a32"

            },

            "script": "params.count1 > 0 && params.count2 < 1"

          }

        }

      }

    }

  }

}