josh/sungrow
1
0
Fork 0
Code Issues Releases Activity

try multiple addresses

Browse source
This commit is contained in:
Josh Deprez 2021-02-07 17:52:20 +11:00
parent ad38fcaf8d
commit fbfda3b144
1 changed files with 9 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
main.go
View file

@ -8,6 +8,7 @@ import (
"fmt" "fmt"
"log" "log"
"net/http" "net/http"
"strings"
"time" "time"
"github.com/DrJosh9000/sungrow/modbus" "github.com/DrJosh9000/sungrow/modbus"
@ -18,7 +19,7 @@ import (
var ( var (
httpAddr = flag.String("http-addr", ":9455", "Address to listen on") httpAddr = flag.String("http-addr", ":9455", "Address to listen on")
inverterAddr = flag.String("inverter-addr", "rakmodule_00DBC1:502", "Address of inverter") inverterAddrs = flag.String("inverter-addrs", "rakmodule_00DBC1:502,192.168.86.6:502", "Comma-separated list of inverter addresses (modbus-tcp with 'encryption')")
scrapeInterval = flag.Duration("scrape-interval", 15*time.Second, "Period of modbus scraping loop") scrapeInterval = flag.Duration("scrape-interval", 15*time.Second, "Period of modbus scraping loop")
registerGauges = make(map[uint16]prometheus.Gauge) registerGauges = make(map[uint16]prometheus.Gauge)
@ -137,11 +138,14 @@ func main() {
flag.Parse() flag.Parse()
// Is the inverter reachable? // Is the inverter reachable?
sgc, err := dialSungrow(*inverterAddr) for _, addr := range strings.Split(*inverterAddrs, ",") {
sgc, err := dialSungrow(addr)
if err != nil { if err != nil {
log.Fatalf("Couldn't dial inverter: %v", err) log.Fatalf("Couldn't dial inverter: %v", err)
} }
defer sgc.Close() defer sgc.Close()
break
}
// HTTP setup // HTTP setup
http.Handle("/metrics", promhttp.Handler()) http.Handle("/metrics", promhttp.Handler())