ES聚合分析原理与代码实例讲解

from elasticsearch import Elasticsearch
 
# 连接到Elasticsearch
es = Elasticsearch("http://localhost:9200")
 
# 定义查询函数
def perform_aggregation(index_name, query):
    # 执行聚合查询
    response = es.search(index=index_name, body=query)
    # 打印聚合结果
    print(response['aggregations'])
 
# 定义聚合查询
aggregation_query = {
    "size": 0,
    "aggs": {
        "distinct_values": {
            "terms": {
                "field": "field_name",
                "size": 10
            }
        }
    }
}
 
# 使用索引名称和查询执行聚合分析
perform_aggregation('your_index_name', aggregation_query)

这段代码演示了如何在Elasticsearch中执行基本的聚合分析。它首先连接到Elasticsearch，然后定义了一个查询函数，该函数接受索引名称和查询并打印结果。接着，定义了一个聚合查询，该查询针对特定字段计算不同的值，并通过查询函数执行该聚合分析。这是一个简单的入门示例，展示了如何开始使用Elasticsearch的聚合功能。