Compare commits

...

3 Commits

Author SHA1 Message Date
166c414af1 more debugging for database issue
All checks were successful
ci/woodpecker/push/woodpecker Pipeline was successful
ci/woodpecker/tag/woodpecker Pipeline was successful
2024-12-12 23:23:32 +01:00
cedb1dfa5a more debugging for database issue
Some checks failed
ci/woodpecker/push/woodpecker Pipeline failed
2024-12-12 23:21:09 +01:00
a21fae4f8a view
All checks were successful
ci/woodpecker/push/woodpecker Pipeline was successful
2024-12-04 13:17:06 +01:00
9 changed files with 23 additions and 3 deletions

View File

@ -118,3 +118,14 @@ create or replace view router_v as
cast(values->'wan-out'->>'value' as int) as wanOutOctetsPerSeconds cast(values->'wan-out'->>'value' as int) as wanOutOctetsPerSeconds
from measurements from measurements
where application = 'SNMP' and device = '172.16.3.1'; where application = 'SNMP' and device = '172.16.3.1';
create or replace view lora_sht21_v as
select time,
cast(values->'Humidity'->>'value' as float) as humidity,
cast(values->'Temperature'->>'value' as float) as temperature,
m.device as device,
d.attributes->>'Label' as label
from measurements m, devices d
where m.application = 'de-hottis-app01' and
m.attributes->>'DeviceType' = 'hottis-gy21' and
m.device = d.label;

View File

@ -25,7 +25,7 @@ func NewDatabaseHandle() *DatabaseHandle {
} else { } else {
db.dbh = conn db.dbh = conn
db.initialized = true db.initialized = true
//log.Println("Database connection opened") log.Println("Database connection opened")
} }
return &db return &db
} }
@ -44,7 +44,7 @@ func (self *DatabaseHandle) StoreMeasurement(measurement *Measurement) {
return return
} }
//log.Println("Successfully stored measurement") log.Println("Successfully stored measurement")
counter.S("Stored") counter.S("Stored")
} }

View File

@ -38,6 +38,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
t.Id = id t.Id = id
t.dbh = database.NewDatabaseHandle() t.dbh = database.NewDatabaseHandle()
log.Printf("Handler DT1T %d initialized", id)
t.ready = true t.ready = true
return t return t
} }

View File

@ -31,6 +31,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
} }
t.Id = id t.Id = id
t.dbh = database.NewDatabaseHandle() t.dbh = database.NewDatabaseHandle()
log.Printf("Handler Locative %d initialized", id)
return t return t
} }

View File

@ -2,6 +2,7 @@ package mbgw3
import ( import (
"time" "time"
"log"
"strconv" "strconv"
"encoding/json" "encoding/json"
"udi/config" "udi/config"
@ -31,6 +32,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
} }
t.Id = id t.Id = id
t.dbh = database.NewDatabaseHandle() t.dbh = database.NewDatabaseHandle()
log.Printf("Handler MBGW3 %d initialized", id)
return t return t
} }

View File

@ -3,6 +3,7 @@ package pv
import ( import (
"reflect" "reflect"
"time" "time"
"log"
"encoding/json" "encoding/json"
"udi/config" "udi/config"
"udi/handlers/handler" "udi/handlers/handler"
@ -41,6 +42,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
} }
t.Id = id t.Id = id
t.dbh = database.NewDatabaseHandle() t.dbh = database.NewDatabaseHandle()
log.Printf("Handler PV %d initialized", id)
return t return t
} }

View File

@ -2,7 +2,7 @@ package snmp
import ( import (
"time" "time"
// "log" "log"
"encoding/json" "encoding/json"
"udi/config" "udi/config"
"udi/handlers/handler" "udi/handlers/handler"
@ -33,6 +33,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
} }
t.Id = id t.Id = id
t.dbh = database.NewDatabaseHandle() t.dbh = database.NewDatabaseHandle()
log.Printf("Handler SNMP %d initialized", id)
return t return t
} }

View File

@ -111,6 +111,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
t.Id = id t.Id = id
t.ready = true t.ready = true
t.dbh = database.NewDatabaseHandle() t.dbh = database.NewDatabaseHandle()
log.Printf("Handler SVER %d initialized", id)
return t return t
} }

View File

@ -55,6 +55,7 @@ func New(id string, config config.HandlerConfigT) handler.Handler {
} }
t.Id = id t.Id = id
t.dbh = database.NewDatabaseHandle() t.dbh = database.NewDatabaseHandle()
log.Printf("Handler Z2M %d initialized", id)
return t return t
} }