go-elasticsearch.go

/**
    @author: huChao
    @since: 2022/8/9
    @desc: //TODO The official go进阶14讲 client for Elasticsearch
**/
package main

import (
	"log"
	"strings"
)

func main() {
	es, err := elasticsearch.NewClient(elasticsearch.Config{
		Addresses: []string{"http://localhost:9200"},
	})

	body := `{
		"query": {
			"match": { "message": "myProduct" }		
		},
		"aggregations": {
			"top_10_states": { "terms": {"field": "state", "size":
		10 } }
			}
		}`

	res, err := es.Search(
		es.Search.WithIndex("social-*"),
		es.Search.WithBody(strings.NewReader(body)),
		es.Search.WithPretty(),
	)
	if err != nil {
		log.Fatalf("Error getting response:  %s", err)
	}

	defer res.Body.Close()
}