go中 elastic 聚合统计(1)

545305939 · · 63 次点击 · · 开始浏览    

go调用elastic使用es聚合统计:

1、查询指定金额的订单数

func queryCount(indexstring) {

client :=getCli()

aggsMatch :=es.NewMatchQuery("amount", 1000)

result, err := client.Search().Index(index).

Size(0).Query(aggsMatch).Do(context.Background())

if err !=nil {

fmt.Println("err:", err)

return

}

fmt.Sprintf("count:%v,%v", result.Hits.TotalHits, err)

}

2、字段值汇总和去重复值

func aggeQueryCount(index string) {

client :=getCli()

aggsMatch :=es.NewValueCountAggregation().Field("amount")

aggsCard :=es.NewCardinalityAggregation().Field("amount")

result, err := client.Search().Index(index).

Size(0).Aggregation("val_count", aggsMatch).Aggregation("val_c", aggsCard).Do(context.Background())

if err !=nil {

fmt.Println("err:", err)

return

}

val, err := result.Aggregations["val_count"].MarshalJSON()

fmt.Sprintf("val:%v,%v", string(val), err)

val, err = result.Aggregations["val_c"].MarshalJSON()

fmt.Sprintf("val:%v,%v", string(val), err)

}

三、stats 统计,最大值、最小值、平均值、求和

func aggeStats(index string) {

client :=getCli()

aggsStats :=es.NewStatsAggregation().Field("amount")

result, err := client.Search().Index(index).Size(0).Aggregation("amount", aggsStats).Do(context.Background())

if err !=nil {

fmt.Println("err:", err)

return

}

val, err := result.Aggregations["amount"].MarshalJSON()

fmt.Sprintf("val:%v,%v", string(val), err)

}

四、extended stats 统计,比status多平方和、方差、标准差、平均值加/减两个标准差的区间

func aggeExtendedStats(index string) {

client :=getCli()

aggsStats :=es.NewExtendedStatsAggregation().Field("amount")

result, err := client.Search().Index(index).Size(0).Aggregation("amount", aggsStats).Do(context.Background())

if err !=nil {

fmt.Println("err:", err)

return

}

val, err := result.Aggregations["amount"].MarshalJSON()

fmt.Sprintf("val:%v,%v", string(val), err)

}

五、占比百分位

func aggsPercentiles(index string) {

client :=getCli()

aggs :=es.NewPercentilesAggregation().Field("amount")

result, err := client.Search().Index(index).Size(0).Aggregation("amount", aggs).Do(context.Background())

if err !=nil {

fmt.Println("err:", err)

return

}

val, err := result.Aggregations["amount"].MarshalJSON()

fmt.Sprintf("val:%v,%v", string(val), err)

}

入群交流(和以上内容无关):Go中文网 QQ 交流群:729884609 或加微信入微信群:274768166 备注:入群;关注公众号:Go语言中文网

63 次点击  
加入收藏 微博
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传