122 lines
4.7 KiB
Python
122 lines
4.7 KiB
Python
#!/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,"cycle":10}
|
|
for n in parameter:
|
|
if n in log_conf:
|
|
parameter[n]=log_conf[n]
|
|
|
|
bmqtt=False
|
|
if "mqtt" in log_conf:
|
|
bmqtt=True
|
|
lcmq=log_conf['mqtt']
|
|
mbroker=""
|
|
if 'broker' in lcmq:
|
|
mbroker=lcmq['broker']
|
|
else:
|
|
bmqtt=False
|
|
mport=1883
|
|
if 'port' in lcmq:
|
|
mport=lcmq['port']
|
|
|
|
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'])
|
|
|
|
# configure tristar
|
|
btristar=False
|
|
if "tristar" in log_conf:
|
|
btristar=True
|
|
if "enable" in log_conf['tristar']:
|
|
if log_conf['tristar']['enable'] == 0:
|
|
btristar=False
|
|
if btristar:
|
|
import smbus
|
|
from pymodbus.client.sync import ModbusSerialClient as ModbusClient
|
|
tri_port='/dev/ttyUSB0'
|
|
if "port" in log_conf['tristar']:
|
|
tri_port=log_conf['tristar']['port']
|
|
tri_baud=9600
|
|
if "baud" in log_conf['tristar']:
|
|
tri_baud=log_conf['tristar']['baud']
|
|
tri_timeout=1
|
|
if "timeout" in log_conf['tristar']:
|
|
tri_timeout=log_conf['tristar']['timeout']
|
|
try:
|
|
triclient = ModbusClient(method='rtu', port=tri_port, baudrate=tri_baud, timeout=tri_timeout)
|
|
except:
|
|
btristar=False
|
|
else:
|
|
triclient.connect()
|
|
tsl_sigma=parameter['sigma']
|
|
if "sigma" in log_conf['vedirect']:
|
|
tsl_sigma=int(log_conf['vedirect']['sigma'])
|
|
if tsl_sigma < 1:
|
|
tsl_sigma=1
|
|
for i in ["volt_scale","amp_scale","volt_bat_term","volt_bat_sens","volt_arr","amp_bat","amp_arr","temp_heatsink","temp_bat","ah_res","ah_tot","kwh_res","kwh_tot","watt_in","watt_out","hour_tot","state","volt_sweep_mp","volt_sweep_oc"]:
|
|
channel_info[i]={"meas_data": meas_data(var_name=i,multiplicator=1,mean_count=parameter['cycle'],store_each_cycle=True,ring_length=parameter['ring_length'],device=parameter['device'],sensor="tristar",i2c=0,store_file="/home/pi/log/data_ve",sigma=tsl_sigma)}
|
|
if bmqtt and ("mqtt" in log_conf['ads1x15']):
|
|
channel_info[i]['meas_data'].set_mqtt(broker=mbroker,port=mport)
|
|
if "sqlserver" in log_conf:
|
|
channel_info[i]['meas_data'].set_sql(host=hostname,port=port)
|
|
|
|
if btristar:
|
|
while True:
|
|
|
|
try:
|
|
rr = triclient.read_holding_registers(0,90,unit=1)
|
|
except:
|
|
print("could not get data from tristar")
|
|
else:
|
|
try:
|
|
channel_info["volt_scale"]['meas_data'].append(int(rr.registers[0]*65536+rr.registers[1]))
|
|
except:
|
|
print("could not read from tristar")
|
|
else:
|
|
channel_info["amp_scale"]['meas_data'].append(int(rr.registers[2]*65536+rr.registers[3]))
|
|
channel_info["volt_bat_term"]['meas_data'].append(int(rr.registers[25]))
|
|
channel_info["volt_bat_sens"]['meas_data'].append(int(rr.registers[26]))
|
|
channel_info["volt_arr"]['meas_data'].append(int(rr.registers[27])) # Array voltage
|
|
channel_info["amp_bat"]['meas_data'].append(int(rr.registers[28])) # Battery current
|
|
channel_info["amp_arr"]['meas_data'].append(int(rr.registers[29])) # Array current
|
|
channel_info["temp_heatsink"]['meas_data'].append(int(rr.registers[35])) # Temperature heatsink
|
|
channel_info["temp_bat"]['meas_data'].append(int(rr.registers[36])) # Temperature battery
|
|
channel_info["ah_res"]['meas_data'].append(int(rr.registers[52] * 65536 + rr.registers[53])) # Ah resetable
|
|
channel_info["ah_tot"]['meas_data'].append(int(rr.registers[54] * 65536 + rr.registers[55])) # Ah total
|
|
channel_info["kwh_res"]['meas_data'].append(int(rr.registers[56])) # kwh resetable
|
|
channel_info["kwh_tot"]['meas_data'].append(int(rr.registers[57])) # kwh total
|
|
channel_info["watt_in"]['meas_data'].append(int(rr.registers[58])) # Power in
|
|
channel_info["watt_out"]['meas_data'].append(int(rr.registers[59])) # Power out
|
|
channel_info["hour_tot"]['meas_data'].append(int(rr.registers[42] * 65536 + rr.registers[43])) # hour total
|
|
channel_info["state"]['meas_data'].append(int(rr.registers[50])) # State
|
|
channel_info["volt_sweep_mp"]['meas_data'].append(int(rr.registers[61])) # Array voltage
|
|
channel_info["volt_sweep_oc"]['meas_data'].append(int(rr.registers[62])) # Array voltage
|
|
|
|
|
|
time.sleep(parameter['wait'])
|
|
|
|
|
|
# close the client
|
|
print("done")
|
|
|
|
|