telegraf/plugins/inputs/ipmi_sensor/ipmi.go

158 lines
3.2 KiB
Go
Raw Normal View History

package ipmi_sensor
2016-03-17 15:45:29 +00:00
import (
"fmt"
"os/exec"
2016-03-17 15:45:29 +00:00
"strconv"
"strings"
"time"
"github.com/influxdata/telegraf"
"github.com/influxdata/telegraf/internal"
2016-03-17 15:45:29 +00:00
"github.com/influxdata/telegraf/plugins/inputs"
)
var (
execCommand = exec.Command // execCommand is used to mock commands in tests.
)
2016-03-17 15:45:29 +00:00
type Ipmi struct {
path string
2016-03-17 15:45:29 +00:00
Servers []string
}
var sampleConfig = `
## optionally specify the path to the ipmitool executable
# path = "/usr/bin/ipmitool"
#
## optionally specify one or more servers via a url matching
2016-03-17 15:45:29 +00:00
## [username[:password]@][protocol[(address)]]
## e.g.
## root:passwd@lan(127.0.0.1)
##
## if no servers are specified, local machine sensor stats will be queried
##
# servers = ["USERID:PASSW0RD@lan(192.168.1.1)"]
2016-03-17 15:45:29 +00:00
`
func (m *Ipmi) SampleConfig() string {
return sampleConfig
}
func (m *Ipmi) Description() string {
return "Read metrics from the bare metal servers via IPMI"
2016-03-17 15:45:29 +00:00
}
func (m *Ipmi) Gather(acc telegraf.Accumulator) error {
if len(m.path) == 0 {
return fmt.Errorf("ipmitool not found: verify that ipmitool is installed and that ipmitool is in your PATH")
2016-03-17 15:45:29 +00:00
}
if len(m.Servers) > 0 {
for _, server := range m.Servers {
err := m.parse(acc, server)
if err != nil {
return err
}
}
} else {
err := m.parse(acc, "")
2016-03-17 15:45:29 +00:00
if err != nil {
return err
}
}
return nil
}
func (m *Ipmi) parse(acc telegraf.Accumulator, server string) error {
opts := make([]string, 0)
hostname := ""
if server != "" {
conn := NewConnection(server)
hostname = conn.Hostname
opts = conn.options()
}
2016-03-17 15:45:29 +00:00
opts = append(opts, "sdr")
cmd := execCommand(m.path, opts...)
out, err := internal.CombinedOutputTimeout(cmd, time.Second*5)
2016-03-17 15:45:29 +00:00
if err != nil {
return fmt.Errorf("failed to run command %s: %s - %s", strings.Join(cmd.Args, " "), err, string(out))
2016-03-17 15:45:29 +00:00
}
// each line will look something like
// Planar VBAT | 3.05 Volts | ok
lines := strings.Split(string(out), "\n")
2016-03-17 15:45:29 +00:00
for i := 0; i < len(lines); i++ {
vals := strings.Split(lines[i], "|")
if len(vals) != 3 {
continue
}
2016-03-17 15:45:29 +00:00
tags := map[string]string{
"name": transform(vals[0]),
}
// tag the server is we have one
if hostname != "" {
tags["server"] = hostname
}
2016-03-17 15:45:29 +00:00
fields := make(map[string]interface{})
if strings.EqualFold("ok", trim(vals[2])) {
fields["status"] = 1
} else {
fields["status"] = 0
}
2016-03-17 15:45:29 +00:00
val1 := trim(vals[1])
if strings.Index(val1, " ") > 0 {
// split middle column into value and unit
valunit := strings.SplitN(val1, " ", 2)
fields["value"] = Atofloat(valunit[0])
if len(valunit) > 1 {
tags["unit"] = transform(valunit[1])
}
} else {
fields["value"] = 0.0
2016-03-17 15:45:29 +00:00
}
acc.AddFields("ipmi_sensor", fields, tags, time.Now())
2016-03-17 15:45:29 +00:00
}
return nil
}
func Atofloat(val string) float64 {
f, err := strconv.ParseFloat(val, 64)
if err != nil {
return 0.0
2016-03-17 15:45:29 +00:00
} else {
return f
2016-03-17 15:45:29 +00:00
}
}
func trim(s string) string {
return strings.TrimSpace(s)
}
func transform(s string) string {
s = trim(s)
s = strings.ToLower(s)
return strings.Replace(s, " ", "_", -1)
}
2016-03-17 15:45:29 +00:00
func init() {
m := Ipmi{}
path, _ := exec.LookPath("ipmitool")
if len(path) > 0 {
m.path = path
}
inputs.Add("ipmi_sensor", func() telegraf.Input {
return &m
2016-03-17 15:45:29 +00:00
})
}