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

前端之家收集整理的这篇文章主要介绍了golang基础- 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")
}

然后在浏览器查看即可,上面那个截图就是效果

猜你在找的Go相关文章