一 . 安裝

1.mac肯定是brew安裝啦

brew update
brew install influxdb
ln -sfv /usr/local/opt/influxdb/*.plist ~/Library/LaunchAgents

配置文件在/etc/influxdb/influxdb.conf 蒙谓，如果沒有就將/usr/local/etc/influxdb.conf 拷一個過去
cache-max-memory-size是用來配置緩存的

#啟動服務
launchctl load ~/Library/LaunchAgents/homebrew.mxcl.influxdb.plist

#停止服務
launchctl unload ~/Library/LaunchAgents/homebrew.mxcl.influxdb.plist

#前臺啟動
influxd -config /usr/local/etc/influxdb.conf

#查看influxdb運行配置
influxd config

2.啟動客戶端

influx -precision rfc3339

3.基本操作

• 名詞解釋

  
  
  image.png
  
  

  Point由時間戳（time）、數(shù)據(jù)（field）汽摹、標簽（tags）組成。

  
  
  image.png
  
  這里不得不提另一個名詞[series]：所有在數(shù)據(jù)庫中的數(shù)據(jù)惭蟋，都需要通過圖表來展示苗桂，而這個series表示這個表里面的數(shù)據(jù)，可以在圖表上畫成幾條線：通過tags排列組合算出來告组。

select series from xxx

• 簡單的增

CREATE DATABASE mydb
use mydb
insert weather,altitude=1000,area=北 temperature=11,humidity=-4
#weather ： 表名
#altitude=1000,area=北 ： tag
#temperature=11,humidity=-4 ：field

• 查

SELECT * FROM weather ORDER BY time DESC LIMIT 3

image.png

二 . go調(diào)用

import (
    "encoding/json"
    "fmt"
    "log"
    "time"

    "github.com/influxdata/influxdb1-client/v2"
)

const (
    MyDB          = "test"
    username      = "admin"
    password      = ""
    MyMeasurement = "cpu_usage"
)

func main() {
    conn := connInflux()
    fmt.Println(conn)

    //insert
    WritesPoints(conn)

    //獲取10條數(shù)據(jù)并展示
    qs := fmt.Sprintf("SELECT * FROM %s LIMIT %d", MyMeasurement, 10)
    res, err := QueryDB(conn, qs)
    if err != nil {
        log.Fatal(err)
    }
     fmt.Println("==========",res)
    for i, row := range res[0].Series[0].Values {
        t, err := time.Parse(time.RFC3339, row[0].(string))
        if err != nil {
            log.Fatal(err)
        }
        //fmt.Println(reflect.TypeOf(row[1]))
        valu := row[2].(json.Number)
        log.Printf("[%2d] %s: %s\n", i, t.Format(time.Stamp), valu)
    }
}

func connInflux() client.Client {
    cli, err := client.NewHTTPClient(client.HTTPConfig{
        Addr:     "http://127.0.0.1:8086",
        Username: username,
        Password: password,
    })
    if err != nil {
        log.Fatal(err)
    }
    return cli
}

//query
func QueryDB(cli client.Client, cmd string) (res []client.Result, err error) {
    q := client.Query{
        Command:  cmd,
        Database: MyDB,
    }
    if response, err := cli.Query(q); err == nil {
        if response.Error() != nil {
            return res, response.Error()
        }
        res = response.Results
    } else {
        return res, err
    }
    return res, nil
}

//Insert
func WritesPoints(cli client.Client) {
    bp, err := client.NewBatchPoints(client.BatchPointsConfig{
        Database:  MyDB,
        Precision: "s",
    })
    if err != nil {
        log.Fatal(err)
    }

    tags := map[string]string{"cpu": "ih-cpu"}
    fields := map[string]interface{}{
        "idle":   20.1,
        "system": 43.3,
        "user":   86.6,
    }

    pt, err := client.NewPoint(
        "cpu_usage",
        tags,
        fields,
        time.Now(),
    )
    if err != nil {
        log.Fatal(err)
    }
    bp.AddPoint(pt)

    if err := cli.Write(bp); err != nil {
        log.Fatal(err)
    }
}