3.写入ElasticSearch
最后更新于：2022-04-02 04:52:13
~~~
package main
import (
"fmt"
"gopkg.in/olivere/elastic.v2"
)
//go get gopkg.in/olivere/elastic.v2
type Tweet struct {
User string
Message string
}
func main() {
client, err := elastic.NewClient(elastic.SetSniff(false), elastic.SetURL("http://192.168.1.103:9200/"))
if err != nil {
fmt.Println("connect es error", err)
return
}
fmt.Println("conn es succ")
for i := 0; i < 20; i++ {
tweet := Tweet{User: "olivere", Message: "Take Five"}
_, err = client.Index().
Index("twitter").
Type("tweet").
Id(fmt.Sprintf("%d", i)).
BodyJson(tweet).
Do()
if err != nil {
// Handle error
panic(err)
return
}
}
fmt.Println("insert succ")
}
~~~
输出结果：
~~~
go run main.go
conn es succ
insert succ
~~~
浏览器配置索引模式：
~~~
http://localhost:5601/app/kibana#/management/kibana/index?_g=()
~~~
配置索引模式：
为了使用Kibana，您必须配置至少一个索引模式。索引模式用于识别运行搜索和分析的Elasticsearch索引。它们也用于配置字段。
索引名称或模式：
~~~
twitter
~~~
点击 Discover 按钮查看数据：
http://localhost:5601/app/kibana#/discover?_g=()&_a=(columns:!(_source),index:twitter,interval:auto,query:(match_all:()),sort:!(_score,desc))
';