83 lines
2.1 KiB
Python
Executable File
83 lines
2.1 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
|
|
import numpy as np
|
|
import os, time,socket,sys,json,random
|
|
from meas_data import meas_data
|
|
|
|
pathname = os.path.dirname(sys.argv[0])
|
|
abspath=os.path.abspath(pathname)
|
|
|
|
configfile=abspath+"/config.json"
|
|
try:
|
|
cf=open(configfile,"r")
|
|
except:
|
|
cf=open(configfile+".template","r")
|
|
|
|
log_conf=json.load(cf)
|
|
cf.close()
|
|
|
|
parameter={"device":socket.gethostname(),"deviceid":"FF","mean_count":5,"ring_length":300,"wait":0.1,"cycle":20,"check_last":5,"gpg_keyid":"","digits":4,"store_dir":"/home/pi/log/","var_name":"temperatur","sensor":"CPU","digits":4}
|
|
for n in parameter:
|
|
if n in log_conf:
|
|
parameter[n]=log_conf[n]
|
|
|
|
serhost="localhost"
|
|
serport=24048
|
|
parameter["var_name"]="test1"
|
|
tl1=meas_data(parameter)
|
|
tl1.set_sql(host=serhost,port=serport,min_wait=1)
|
|
#tl1.set_rsa("25A4CF79414F10FD")
|
|
|
|
#if "sqlserver" in log_conf:
|
|
# hostname="banana"
|
|
# if "host" in log_conf['sqlserver']:
|
|
# hostname=log_conf['sqlserver']['host']
|
|
# port=24049
|
|
# if "port" in log_conf['sqlserver']:
|
|
# port=int(log_conf['sqlserver']['port'])
|
|
# cpu_meas.set_sql(host=hostname,port=port)
|
|
|
|
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 bmqtt:
|
|
tl1.set_mqtt(broker=mbroker,port=mport)
|
|
# tl2.set_mqtt(broker=mbroker,port=mport)
|
|
# tl3.set_mqtt(broker=mbroker,port=mport)
|
|
# tl4.set_mqtt(broker=mbroker,port=mport)
|
|
# tl5.set_mqtt(broker=mbroker,port=mport)
|
|
# tl6.set_mqtt(broker=mbroker,port=mport)
|
|
# tl7.set_mqtt(broker=mbroker,port=mport)
|
|
|
|
a = 2
|
|
|
|
|
|
while True:
|
|
# get cpu temperature
|
|
# cpu_meas.append(int(open('/sys/class/thermal/thermal_zone0/temp').read()))
|
|
tl1.append(int(random.random()*2**16))
|
|
# tl2.append(int(random.random()*2**16))
|
|
# tl3.append(int(random.random()*2**16))
|
|
# tl4.append(int(random.random()*2**16))
|
|
# tl5.append(int(random.random()*2**16))
|
|
# tl6.append(int(random.random()*2**16))
|
|
# tl7.append(int(random.random()*2**16))
|
|
|
|
time.sleep(parameter['wait'])
|
|
|
|
|
|
# close the client
|
|
|
|
print("done")
|
|
|
|
|