在线时间:8:00-16:00
132-9538-2358
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
package main import ( "github.com/heatxsink/go-logstash" ) //将go 的错误日志推送的elk var logs *logstash.Logstash //使用单例模式创建redis client func GetInstance(opt redis.Options) *redis.Client { once.Do(func() { redisdb = redis.NewClient(&opt) }) return redisdb } func initLogstash() { logs := logstash.New("192.168.3.10", 5000, 5) conn, err := logs.Connect() if err != nil { fmt.Println(err) } err = logs.Writeln("{ 'foo' : 'bar' }") if err != nil { fmt.Println(err) } defer conn.Close() } func main() { initLogstash() select{} }
添加索引模式,把logstash 索引按照配置添加
打开Discover 界面即可看到logstash 记录的日志。
这里看到的数据都是交杂在一起的。如果要更方便查询则需要使用到logstash filter
评论
请发表评论