influx

Documentation

Index

• func Connect(address, userName, password, dbName string)
• func FixInfluxType(fields map[string]interface{}, limit float32)
• func Query(cmd string) ([]map[string]interface{}, error)
• func Select(body, table, option string, andQuery []string) (cmd string)
• func Write(measurement string, tags map[string]string, fields map[string]interface{}) (err error)

Functions

func Connect

func Connect(address, userName, password, dbName string)

除了需要指定连接的用户名、密码、地址，还需要指定db

func FixInfluxType

func FixInfluxType(fields map[string]interface{}, limit float32)

解决influx对float和uint64支持不良的问题 @param limit 误差范围

func Query

func Query(cmd string) ([]map[string]interface{}, error)

func Select

func Select(body, table, option string, andQuery []string) (cmd string)

func Write

func Write(measurement string, tags map[string]string, fields map[string]interface{}) (err error)