本篇內(nèi)容主要講解“go根據(jù)配置文件操作influxdb并插入數(shù)據(jù)的方法”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“go根據(jù)配置文件操作influxdb并插入數(shù)據(jù)的方法”吧!

專注于為中小企業(yè)提供成都做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)嘉峪關(guān)免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動(dòng)了成百上千家企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

//配置文件

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")
}

//調(diào)用

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根據(jù)配置文件操作influxdb并插入數(shù)據(jù)的方法”有了更深的了解，不妨來實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！

本文題目：go根據(jù)配置文件操作influxdb并插入數(shù)據(jù)的方法
文章路徑：http://aaarwkj.com/article18/gjdpgp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計(jì)、小程序開發(fā)、外貿(mào)網(wǎng)站建設(shè)、品牌網(wǎng)站設(shè)計(jì)、網(wǎng)站維護(hù)、ChatGPT

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)