add ve direct as sensor
parent
5be36eb98f
commit
8b64d3e120
|
@ -0,0 +1,81 @@
|
|||
#!/usr/bin/env python
|
||||
|
||||
import numpy as np
|
||||
import os, serial,time,socket,sys,json,logging,requests,getopt
|
||||
from meas_data import meas_data
|
||||
# import the server implementation
|
||||
# import ADC
|
||||
#import vedirect
|
||||
#import upload_osm
|
||||
|
||||
configfile="config.json"
|
||||
cf=open(configfile,"r")
|
||||
log_conf=json.load(cf)
|
||||
cf.close()
|
||||
|
||||
channel_names=[]
|
||||
channel_info={}
|
||||
|
||||
parameter={"device":socket.gethostname(),"mean_count":5,"ring_length":10,"wait":0.5,"sigma":2}
|
||||
for n in parameter:
|
||||
if n in log_conf:
|
||||
parameter[n]=log_conf[n]
|
||||
|
||||
if "sqlserver" in log_conf:
|
||||
hostname="banana"
|
||||
if "host" in log_conf['sqlserver']:
|
||||
hostname=log_conf['sqlserver']['host']
|
||||
port=24048
|
||||
if "port" in log_conf['sqlserver']:
|
||||
port=int(log_conf['sqlserver']['port'])
|
||||
|
||||
# declare ve mppt
|
||||
bve=False
|
||||
if "vedirect" in log_conf:
|
||||
from vedirect import vedirect
|
||||
bve=True
|
||||
if "enable" in log_conf['vedirect']:
|
||||
if log_conf['vedirect']['enable'] == 0:
|
||||
bve=False
|
||||
if "port" in log_conf['vedirect']:
|
||||
bve_port=log_conf['vedirect']['port']
|
||||
else:
|
||||
bve_port='/dev/serial/by-id/usb-VictronEnergy_BV_VE_Direct_cable_VE1SSBVT-if00-port0'
|
||||
print(bve_port)
|
||||
try:
|
||||
ve=vedirect(bve_port,60)
|
||||
except:
|
||||
bve=False
|
||||
else:
|
||||
tsl_sigma=parameter['sigma']
|
||||
if "sigma" in log_conf['vedirect']:
|
||||
tsl_sigma=int(log_conf['vedirect']['sigma'])
|
||||
if tsl_sigma < 1:
|
||||
tsl_sigma=1
|
||||
varnames={"volt_bat_ve":"V","volt_arr_ve":"VPV","amp_ve":"I","watt_ve":"PPV","days_ve":"HSDS"}
|
||||
for i in varnames:
|
||||
channel_info[i]={"meas_data": meas_data(var_name=i,ring_length=parameter['ring_length'],device=parameter['device'],sensor="VEdirect",i2c=0,store_file="/home/pi/log/data_ve",sigma=tsl_sigma)}
|
||||
if "sqlserver" in log_conf:
|
||||
channel_info[i]['meas_data'].set_sql(host=hostname,port=port)
|
||||
|
||||
|
||||
if badc:
|
||||
while True:
|
||||
|
||||
try:
|
||||
vedata=ve.read_data_single()
|
||||
except:
|
||||
print("could not read VE")
|
||||
else:
|
||||
for i in varnames:
|
||||
cn=varnames[i]
|
||||
if cn in vedata:
|
||||
channel_info[i]['meas_data'].append(int(vedata[cn]))
|
||||
|
||||
time.sleep(parameter['wait'])
|
||||
|
||||
|
||||
# close the client
|
||||
print("done")
|
||||
|
||||
|
|
@ -80,6 +80,7 @@ class vedirect:
|
|||
callbackFunction(packet)
|
||||
else:
|
||||
break
|
||||
|
||||
def print_data_callback(data):
|
||||
print data
|
||||
# end import vedirect
|
||||
|
|
Loading…
Reference in New Issue