elasticsearch 是一个开源的分布式搜索引擎,广泛应用于各种搜索和数据分析场景。与此同时,go语言作为一种高效而便捷的编程语言,也受到越来越多的开发者的喜爱和使用。针对 elasticsearch 的高性能查询和数据分析功能,go 也提供了一些方便的查询库和框架。本文将对 go 语言查询 elasticsearch 的相关知识进行详细介绍,帮助大家更好地实现 elasticsearch 查询。
一、go语言库介绍
go 语言中已有了一些成熟的 elasticsearch 查询库,下面根据各自的特点简要介绍它们。
go-elasticsearchgo-elasticsearch 是 elasticsearch 官方推出的一个由 go 语言实现的 elasticsearch 客户端,同时也包含 elasticsearch 的查询和分析功能。尤其在 elasticsearch 7.x 版本之后,go-elasticsearch 已经成为了 elasticsearch 官方推荐的 go 语言库。go-elasticsearch 可以运行在多个操作系统平台上,并且已经支持了 elasticsearch 6.x 以及 7.x 版本。它的具体使用方式可以参考官方文档。
go-esgo-es 是一款由小米公司开源的 elasticsearch go 客户端,由于其简便易用、功能全面,已经成为国内大型互联网企业中得到广泛应用的 elasticsearch 客户端库之一。go-es 库中的各种查询 api 的参数设计简单明了,并且语法与 elasticsearch 的查询语法十分接近,因此可以直接使用 elasticsearch 查询 dsl 进行查询。关于该库的详细使用方式,可以参考其 github 仓库。
kingim/goesgoes 是一种简便易用的 elasticsearch go 客户端库。它极大地减少了 elasticsearch 基础操作的学习成本,并支持接口和对象两种使用方式。除了查询和分析功能,goes 还提供了一个简单的地理坐标计算库,支持计算两个经纬度之间的距离和角度值。关于 kingim/goes 的详细使用方式,可以参考其 github 仓库。
olivere/elasticolivere/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 语言的相关知识,建议多阅读官方文档和源码,加深自己的理解和认识。
以上就是聊聊go语言查询elasticsearch关知识的详细内容。
