type Tweet struct {
	User    string
	Message string
}

func main() {
	client, err := elastic.NewClient(elastic.SetSniff(false), elastic.SetURL("http://192.168.31.177:9200/"))
	if err != nil {
		fmt.Println("connect es error", err)
		return
	}

	fmt.Println("conn es success")

	tcy := Tweet{User: "tcy1", Message: "hello"}
	_, err = client.Index().
		Index("twitter").    //一个索引
		Type("tweet").			//类似表格
		Id("1").
		BodyJson(tcy).
		Do(context.Background())
	if err != nil {
		// Handle error
		panic(err)
		return
	}

	fmt.Println("insert succ")
}