13518219792
本篇内容主要讲解“go根据配置文件操作influxdb并插入数据的方法”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“go根据配置文件操作influxdb并插入数据的方法”吧!
专注于为中小企业提供成都做网站、成都网站设计服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业嘉峪关免费做网站提供优质的服务。我们立足成都，凝聚了一批互联网行业人才，有力地推动了成百上千家企业的稳健成长，帮助中小企业通过网站建设实现规模扩充和转变。
//配置文件
ip=http://10.102.110.93:8086 name=lbw pwd=123 portOrPid=8080,8086 pidName=java,influx telNetIp=10.102.110.100:3306,www.baidu.com:80
//读取配置文件
func InitConfig(path string) map[string]string {
config := make(map[string]string)
f, err := os.Open(path) defer f.Close() if err != nil { panic(err)
}
r := bufio.NewReader(f) for {
b, _, err := r.ReadLine() if err != nil { if err == io.EOF {break } panic(err)
}
s := strings.TrimSpace(string(b))
index := strings.Index(s, "=") if index < 0 { continue }
key := strings.TrimSpace(s[:index]) if len(key) == 0 { continue }
value := strings.TrimSpace(s[index+1:]) if len(value) == 0 { continue }
config[key] = value
} return config
}//influxdb初始化
func InitFluxdb() client.Client {
config := InitConfig("./config/test.txt")
ip := config["ip"]
name := config["name"]
pwd := config["pwd"]
conn := ConnInflux(ip,name,pwd) return conn
}func ConnInflux(ip string,name string,pwd string) client.Client {
cli, err := client.NewHTTPClient(client.HTTPConfig{
Addr: ip, Username: name, Password: pwd, }) if err != nil { log.Fatal(err)
} return cli
}func InsertDB(cli client.Client,dbName string,tableName string,tags map[string]string,fields map[string]interface{},accuracy string) {
bp, err := client.NewBatchPoints(client.BatchPointsConfig{
Database: dbName, Precision: accuracy, }) if err != nil { log.Fatal(err)
}
pt, err := client.NewPoint(tableName, tags, fields, time.Now()) if err != nil { log.Fatal(err)
}
bp.AddPoint(pt)
err = cli.Write(bp) if err != nil { log.Fatal(err)
} log.Println("insert success")
}//调用
func main() {
hostname:=common.GetHostName()
mem:=common.GetMem()
info, _ := disk.Partitions(true)
cpu:=common.GetCpuPercent()
memup:=mem.UsedPercent
tags := map[string]string{"name": hostname}
fields := map[string]interface{}{ "cpu_used_percent": cpu, "mem_used_percent": memup, } for _,info2:=range info{
disks:=info2
info3, _ := disk.Usage(disks.Device)
fields[strings.ToLower( strings.Replace(disks.Device,":","_used_percent",-1))]=info3.UsedPercent
} common.InsertDB(common.InitFluxdb(),"testdb","host_info",tags,fields,"s")
}到此，相信大家对“go根据配置文件操作influxdb并插入数据的方法”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！
