123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151 |
- #!/usr/bin/env python
- import numpy as np
- import os, serial,time,socket,sys,json
- from meas_data import meas_data
- # import the server implementation
- sensor="bme680"
- pathname = os.path.dirname(sys.argv[0])
- abspath=os.path.abspath(pathname)
- idfile=abspath+"/id.json"
- id_conf=0
- try:
- idf=open(idfile,"r")
- id_conf=json.load(idf)['id']
- idf.close()
- except:
- id_conf=0
- 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":10,"wait":0.5,"cycle":10,"check_last":15,"check_last_shrinking":0.9,"gpg_keyid":"","digits":5,"store_dir":"/home/pi/log/","multiplicator":1000,"sensor":"BME680","sigma":3}
- for n in parameter:
- if n in log_conf:
- parameter[n]=log_conf[n]
- # config of bme680 sensor
- # use pip install bme680 for library
- meas_types=["temperature","humidity","pressure","voc"]
- bbme=False
- if sensor in log_conf:
- bbme=True
- if "enable" in log_conf[sensor]:
- if log_conf[sensor]['enable'] == 0:
- bbme=False
- 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 bbme:
- import bme680
- for n in parameter:
- if n in log_conf[sensor]:
- parameter[n]=log_conf[sensor][n]
- if "port" in log_conf[sensor]:
- bme_port=log_conf[sensor]['port']
- else:
- bme_port=1
- if "address" in log_conf[sensor]:
- parameter["i2c"]=int(log_conf[sensor]['address'],16)
- else:
- parameter["i2c"]=0x77
- try:
- sensor=bme680.BME680(i2c_addr=parameter["i2c"])
- except:
- bbme=False
- else:
- sensor.set_humidity_oversample(bme680.OS_2X)
- sensor.set_temperature_oversample(bme680.OS_2X)
- sensor.set_pressure_oversample(bme680.OS_2X)
- sensor.set_filter(bme680.FILTER_SIZE_3)
- sensor.set_gas_status(bme680.ENABLE_GAS_MEAS)
- sensor.set_gas_heater_temperature(320)
- sensor.set_gas_heater_duration(150)
- sensor.select_gas_heater_profile(0)
- bme_sigma=3
- if "sigma" in log_conf[sensor]:
- parameter["sigma"]=int(log_conf[sensor]['sigma'])
- if parameter["sigma"] < 1:
- parameter["sigma"]=1
- partemp=parameter
- partemp["var_name"]="temperature"
- bme_temp=meas_data(partemp)
- parhum=parameter
- parhum["var_name"]="humidity"
- bme_hum=meas_data(parhum)
- parpress=parameter
- parpress["var_name"]="pressure"
- bme_press=meas_data(parpress)
- parvoc=parameter
- parvoc["var_name"]="voc"
- bme_voc=meas_data(parpress)
- if ("mqtt" in log_conf[sensor]) and bmqtt:
- bme_temp.set_mqtt(broker=mbroker,port=mport)
- bme_hum.set_mqtt(broker=mbroker,port=mport)
- bme_press.set_mqtt(broker=mbroker,port=mport)
- 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'])
- bme_temp.set_sql(host=hostname,port=port)
- bme_hum.set_sql(host=hostname,port=port)
- bme_press.set_sql(host=hostname,port=port)
- bme_voc.set_sql(host=hostname,port=port)
- if "opensensemap" in log_conf[sensor]:
- osm=log_conf['bme680']['opensensemap']
- if "sensebox_id" in osm:
- sid=osm['sensebox_id']
- if "sensors" in osm:
- if "temperature" in osm['sensors']:
- bme_temp.set_sensebox(sid,osm['sensors']['temperature'])
- if "humidity" in osm['sensors']:
- bme_hum.set_sensebox(sid,osm['sensors']['humidity'])
- if "pressure" in osm['sensors']:
- bme_press.set_sensebox(sid,osm['sensors']['pressure'])
- if "voc" in osm['sensors']:
- bme_voc.set_sensebox(sid,osm['sensors']['voc'])
-
- if bbme:
- while True:
-
- # read bme280 (temperature, humidity, pressure)
- if sensor.get_sensor_data():
- bme_temp.append(sensor.data.temperature)
- bme_hum.append(sensor.data.humidity)
- bme_press.append(sensor.data.pressure)
- # print(sensor.data.temperature)
- if sensor.data.heat_stable:
- bme_voc.append(sensor.data.gas_resistance)
- # print(sensor.data.gas_resistance)
- time.sleep(parameter['wait'])
- # close the client
- print("done")
|