elasticsearch_dsl分组查询

Elasticsearch DSL (Domain Specific Language) 是一个用于构建复杂搜索查询和数据聚合的工具，它允许你在 Elasticsearch 中编写动态、灵活的查询语句。对于分组查询，你可以使用 `Aggregations` 部分。

在Elasticsearch DSL 中，分组查询（Grouping）通常通过 `terms` 或 `bucket_script` 等聚合器实现。`terms` 聚合器基于一个字段值对文档进行分组，返回每个组的数量；而 `bucket_script` 则可以让你自定义计算分组依据，例如按某个表达式结果进行分组。

例如，如果你想根据用户的 'location' 字段进行分组并获取每个地点的文档数量，你可以这样写：

from elasticsearch_dsl import Search, TermsAggregation

s = Search(index="your_index_name").query("match_all")
aggs = s.aggs.bucket('user_locations', Terms('location'))
response = s.execute()

for bucket in response.aggregations.user_locations.buckets:
    print(f"Location: {bucket.key}, Docs Count: {bucket.doc_count}")