elasticsearch 是一个开源的分布式搜索引擎，广泛应用于各种搜索和数据分析场景。与此同时，go语言作为一种高效而便捷的编程语言，也受到越来越多的开发者的喜爱和使用。针对 elasticsearch 的高性能查询和数据分析功能，go 也提供了一些方便的查询库和框架。本文将对 go 语言查询 elasticsearch 的相关知识进行详细介绍，帮助大家更好地实现 elasticsearch 查询。
一、Go语言库介绍
Go 语言中已有了一些成熟的 Elasticsearch 查询库，下面根据各自的特点简要介绍它们。
- go-elasticsearch
go-elasticsearch 是 Elasticsearch 官方推出的一个由 Go 语言实现的 Elasticsearch 客户端，同时也包含 Elasticsearch 的查询和分析功能。尤其在 Elasticsearch 7.x 版本之后，go-elasticsearch 已经成为了 Elasticsearch 官方推荐的 Go 语言库。go-elasticsearch 可以运行在多个操作系统平台上，并且已经支持了 Elasticsearch 6.x 以及 7.x 版本。它的具体使用方式可以参考官方文档。
- go-es
go-es 是一款由小米公司开源的 Elasticsearch Go 客户端，由于其简便易用、功能全面，已经成为国内大型互联网企业中得到广泛应用的 Elasticsearch 客户端库之一。go-es 库中的各种查询 API 的参数设计简单明了，并且语法与 Elasticsearch 的查询语法十分接近，因此可以直接使用 Elasticsearch 查询 DSL 进行查询。关于该库的详细使用方式，可以参考其 Github 仓库。
立即学习“go语言免费学习笔记（深入）”；
- kingim/goes
goes 是一种简便易用的 Elasticsearch Go 客户端库。它极大地减少了 Elasticsearch 基础操作的学习成本，并支持接口和对象两种使用方式。除了查询和分析功能，goes 还提供了一个简单的地理坐标计算库，支持计算两个经纬度之间的距离和角度值。关于 kingim/goes 的详细使用方式，可以参考其 Github 仓库。
- olivere/elastic
olivere/elastic 是 Elasticsearch 的 Go 客户端库。类似于 go-elasticsearch 和 go-es，它们都为 Elasticsearch 提供了非常方便的查询 API。但是 olivere/elastic 更加注重查询结果的序列化和反序列化，支持多种输出格式（如Json、Xml等）的封装、筛选，适用于前后端结果交互等场景。您可以查看 olivere/elastic 的 Github 仓库获取更多使用细节。
二、查询 Elasticsearch
在 Go 语言中，通过 Elasticsearch Go 客户端库，可以非常方便地进行 Elasticsearch 相关的查询、搜索和分析操作。从接口调用上来看，各个库的使用方法有些差异，但是基本的查询功能、语法和逻辑大同小异。下面我们举几个例子，介绍在 Go 中如何查询 Elasticsearch。
- 查询所有文档
es 官方文档推荐使用以下方式：
Package main
import (
"context"
"fmt"
"github.com/elastic/go-elasticsearch/v7"
"github.com/elastic/go-elasticsearch/v7/esapi"
"github.com/elastic/go-elasticsearch/v7/esutil"
)
func main() {
es, _ := elasticsearch.NewDefaultClient()
req := esapi.SearchRequest{
Body: esutil.NewJSONReader(map[string]interface{}{"query": map[string]interface{}{"match_all": map[string]interface{}{}}}),
Index: []string{"my-index-000001"},
TrackTotalHits: true,
}
res, err := req.Do(context.Background(), es)
fmt.Println(res, err)
}-
查询包含某个词的文档
q := elastic.NewTermQuery("content", "hello") searchResult, err := client.Search(). Index("twitter"). Query(q). Do(ctx) if err != nil { log.Fatalln(err) } -
查询一定范围内的文档
terms := []string{"world", "how", "are", "you"} q1 := elastic.NewTermsQuery("content", terms...) q2 := elastic.NewRangeQuery("publish_time").Gte("2021-01-01").Lte("2021-02-01") query := elastic.NewBoolQuery().Must(q1).Filter(q2) searchResult, err := client.Search(). Index("twitter"). Query(query). From(0).Size(10). Do(ctx) if err != nil { log.Fatalln(err) } -
使用聚合函数实现分类统计
agg := elastic.NewTermsAggregation().Field("category").Size(10000) query := elastic.NewMatchAllQuery() searchResult, err := client.Search().Index("goods").Size(0).Query(query).Aggregation("by_category", agg).Do(ctx) if err != nil { log.Fatalln(err) } bucketDateHists := searchResult.Aggregations.Terms("by_category") for _, bucket := range bucketDateHists.Buckets { fmt.Printf("%v: %d\n", bucket.Key, int(bucket.DocCount)) }
三、总结
通过以上介绍，我们可以看到，Go 语言提供的 Elasticsearch 查询库非常丰富，并且操作起来也非常简单、高效。无论是在数据搜索还是数据分析，Go 语言都可以胜任其中的重要角色。当然，如果您想要更加深入地了解 Elasticsearch 或 Go 语言的相关知识，建议多阅读官方文档和源码，加深自己的理解和认识。
