Don't try to send potentially corrupted data
This commit is contained in:
parent
6e2170f337
commit
8ec656f71a
|
@ -487,6 +487,7 @@ func (vcenter *VCenter) Query(config Configuration, InfluxDBClient influxclient.
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
errlog.Println(err)
|
errlog.Println(err)
|
||||||
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, base := range perfres.Returnval {
|
for _, base := range perfres.Returnval {
|
||||||
|
@ -585,6 +586,7 @@ func (vcenter *VCenter) Query(config Configuration, InfluxDBClient influxclient.
|
||||||
pt, err := influxclient.NewPoint(entityName, tags, fields, nowTime)
|
pt, err := influxclient.NewPoint(entityName, tags, fields, nowTime)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
errlog.Println(err)
|
errlog.Println(err)
|
||||||
|
continue
|
||||||
}
|
}
|
||||||
bp.AddPoint(pt)
|
bp.AddPoint(pt)
|
||||||
|
|
||||||
|
@ -594,6 +596,7 @@ func (vcenter *VCenter) Query(config Configuration, InfluxDBClient influxclient.
|
||||||
pt2, err := influxclient.NewPoint(measurement, specialTags[measurement][name][instance], value, time.Now())
|
pt2, err := influxclient.NewPoint(measurement, specialTags[measurement][name][instance], value, time.Now())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
errlog.Println(err)
|
errlog.Println(err)
|
||||||
|
continue
|
||||||
}
|
}
|
||||||
bp.AddPoint(pt2)
|
bp.AddPoint(pt2)
|
||||||
}
|
}
|
||||||
|
@ -625,10 +628,10 @@ func (vcenter *VCenter) Query(config Configuration, InfluxDBClient influxclient.
|
||||||
err = InfluxDBClient.Write(bp)
|
err = InfluxDBClient.Write(bp)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
errlog.Println(err)
|
errlog.Println(err)
|
||||||
} else {
|
return
|
||||||
stdlog.Println("sent data to Influxdb")
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
stdlog.Println("sent data to Influxdb")
|
||||||
}
|
}
|
||||||
|
|
||||||
func min(n ...int64) int64 {
|
func min(n ...int64) int64 {
|
||||||
|
|
Loading…
Reference in New Issue