Elasticsearch-获取所有文档的所有嵌套对象

Question

让我们想象一下Elasticsearch索引，其中每个文档代表一个国家。Country具有城市字段，该字段定义为嵌套的。

示例映射（为了本示例的简洁性而简化）：

{
  "properties": {
    "name": {
      "type": "text",
      "fields": {
        "keyword": {
          "type": "keyword",
          "ignore_above": 256
        }
      } 
    },
    "cities": {
      "type": "nested",
      "properties": {
        "name": {
          "type": "text",
          "fields": {
            "keyword": {
              "type": "keyword",
              "ignore_above": 256
            }
          }
        }
        // other properties are omitted for brevity
      }
    }
  }
}

我插入到索引中的文档如下所示：

{
  "name": "Slovakia",
  "cities": [
    {
      "name": "Bratislava"
    },
    {
      "name": "Zilina"
    },
    ...
  ]
}

{
  "name": "Czech Republic",
  "cities": [
    {
      "name": "Praha"
    },
    {
      "name": "Brno"
    },
    ...
  ]
}

是否可以组成一个返回所有城市（所有国家）并支持排序的查询

第一个返回页面（回复）将包含捷克共和国的10个城市，第二个页面将包含10个城市，其中四个（最后一个）来自捷克共和国，六个来自斯洛伐克。

我正在研究复合聚合，但我不知道如何将国家名称添加到来源：

{
  "query": {
    "match_all": {}
  },
  "aggs": {
    "nested_aggs": {
      "nested": {
        "path": "cities"
      },
      "aggs": {
        "by_name": {
          "composite": {
            "sources": [
              {
                "cityName": {
                  "terms": {
                    "field": "cities.name.keyword",
                    "order": "asc"
                  }
                }
              }
            ]
          }
        }
      }
    }
  }
}

是否可以在不修改Elasticsearch映射的情况下组合这样的查询？

Answer 1

最简单的选择是首先对国家进行汇总，然后对城市进行汇总：

{
  "size": 0,
  "aggs": {
    "by_country": {
      "terms": {
        "field": "name.keyword",
        "size": 10
      },
      "aggs": {
        "nested_cities": {
          "nested": {
            "path": "cities"
          },
          "aggs": {
            "by_cities": {
              "terms": {
                "field": "cities.name.keyword",
                "size": 10
              }
            }
          }
        }
      }
    }
  }
}

{
  "size": 0,
  "aggs": {
    "by_name": {
      "composite": {
        "sources": [
          {
            "countryName": {
              "terms": {
                "field": "name.keyword",
                "order": "asc"
              }
            }
          },
          {
            "cityName": {
              "terms": {
                "field": "cities.name.keyword",
                "order": "asc"
              }
            }
          }
        ]
      }
    }
  }
}

可以很容易地分页。

结果如下：

...
"aggregations" : {
  "by_name" : {
    "after_key" : {
      "countryName" : "Slovakia",
      "cityName" : "Zilina"
    },
    "buckets" : [
      {
        "key" : {
          "countryName" : "Czech Republic",
          "cityName" : "Brno"
        },
        "doc_count" : 1
      },
      {
        "key" : {
          "countryName" : "Czech Republic",
          "cityName" : "Praha"
        },
        "doc_count" : 1
      },
      {
        "key" : {
          "countryName" : "Slovakia",
          "cityName" : "Bratislava"
        },
        "doc_count" : 1
      },
      {
        "key" : {
          "countryName" : "Slovakia",
          "cityName" : "Zilina"
        },
        "doc_count" : 1
      }
    ]
  }
}