您的位置:首页 > 编程语言 > Go语言

golang基础- ElasticSearch搜索引擎、kibana可视化工具、向ES输出数据

2017-11-27 18:36 676 查看
安装ElasticSearch

安装kibana

向es输出数据

安装ElasticSearch

ElasticSearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎,基于RESTful web接口。Elasticsearch是用Java开发的,并作为Apache许可条款下的开放源码发布,是当前流行的企业级搜索引擎。

1、下载ES,下载地:https://www.elastic.co/downloads

2、修改config/elasticsearch.ymal配置

cluster.name: my-application

node.name: node-1

network.host: 192.168.21.17

3、启动es, ./bin/elasticsearch.bat



4、浏览器测试



安装kibana

Kibana是一个开源的分析与可视化平台,设计出来用于和Elasticsearch一起使用的。你可以用kibana搜索、查看、交互存放在Elasticsearch索引里的数据,使用各种不同的图表、表格、地图等kibana能够很轻易地展示高级数据分析与可视化。

1、下载kibana,下载地:https://www.elastic.co/downloads

2、修改config/kibana.yml配置

elasticsearch.url: “http://192.168.21.17:9200

3、启动kibana, ./bin/kibana.bat



4、浏览器测试



向es输出数据

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.21.17: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")
}


然后在浏览器查看即可,上面那个截图就是效果图
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: