登录
首页 >  Golang >  Go问答

用golang编写简单的ES avg聚合

来源:stackoverflow

时间:2024-02-22 17:45:26 333浏览 收藏

小伙伴们有没有觉得学习Golang很有意思?有意思就对了!今天就给大家带来《用golang编写简单的ES avg聚合》,以下内容将会涉及到,若是在学习中对其中部分知识点有疑问,或许看了本文就能帮到你!

问题内容

我一直在尝试在 go 中编写一个简单的 es avg 聚合,但即使这听起来我不知道如何解析结果:

ctx, cancel := context.WithTimeout(context.Background(), defaultTimeout)
     defer cancel()
     query := elastic.NewAvgAggregation().Field("Assignment.HomeworkSize")
     ss := elastic.NewSearchSource().Query(query)
     searchResult, err := c.ES.Search().Index(StudentIndex).SearchSource(ss).Do(ctx)
     if err != nil {
         return 0, err
     }
     // Parse Results
     aggs := searchResult.Aggregations

但我不确定如何解析 searchresult 来获取此聚合的结果。基本上我想解析代表学生的大量文档并获取作业的平均大小。


正确答案


我通常使用 http 来访问弹性。因此,我将结果作为地图返回,并且可以使用调试器检查您的结果是什么并从那里开始工作。

var resp map[string]interface{}
err := c.handlerequest(http.methodget, tag, req, &resp)

其中 tag 是您的索引,req - 您对弹性执行的请求,response 是响应

内部处理程序看起来像这样:

req, err := http.newrequest(method, c.endpoint+tag, bytes.newreader(jsonbody))

其中 jsonbody 是您传递给处理程序的请求 其他一切都是用 go 发送 http 的常用方式

还要记住的一件事是在结果映射中处理类型(类型断言),如下所示:

for index, hit := range resp["hits"].(map[string]interface{})["hits"].([]interface{}) {

        Source := hit.(map[string]interface{})["_source"].(map[string]interface{})

        items[index] = someType{
            SomeField: Source["app_name"].(string),
        }
    }

终于介绍完啦!小伙伴们,这篇关于《用golang编写简单的ES avg聚合》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识,快来关注吧!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>