Stefan/evcc-io
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

InfluxDB: add vehicle tag (#889)

Browse source
This commit is contained in:
andig 2021-04-25 09:46:13 +02:00 • committed by GitHub
parent 85c960408e
commit c1e8badaec
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

12
server/influxdb.go
View file

@ -83,8 +83,19 @@ func (m *Influx) Run(loadPoints []core.LoadPointAPI, in <-chan util.Param) {
}
}()
// track active vehicle per loadpoint
vehicles := make(map[int]string)
// add points to batch for async writing
for param := range in {
// vehicle name
if param.LoadPoint != nil {
if name, ok := param.Val.(string); ok && param.Key == "socTitle" {
vehicles[*param.LoadPoint] = name
continue
}
}
if !m.supportedType(param) {
continue
}
@ -92,6 +103,7 @@ func (m *Influx) Run(loadPoints []core.LoadPointAPI, in <-chan util.Param) {
tags := map[string]string{}
if param.LoadPoint != nil {
tags["loadpoint"] = loadPoints[*param.LoadPoint].Name()
tags["vehicle"] = vehicles[*param.LoadPoint]
}
fields := map[string]interface{}{}