向elasticSearch中存数据,elasticsearch
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")
}
本站文章为和通数据库网友分享或者投稿,欢迎任何形式的转载,但请务必注明出处.
同时文章内容如有侵犯了您的权益,请联系QQ:970679559,我们会在尽快处理。