Problem with comparison.
/Designs/Measuring_instruments/ISMS01A/SW/button/button_monitor.py
0,0 → 1,61
#!/usr/bin/python
import hid
import time
from time import sleep
import os, sys
 
def init():
global h
print "Opening device"
h = hid.device()
h.open(0x10C4, 0xEA90)
 
print "Manufacturer: %s" % h.get_manufacturer_string()
print "Product: %s" % h.get_product_string()
print "Serial No: %s" % h.get_serial_number_string()
 
h.write([0x02, 0b00000110, 0x00, 0x00, 0x00]) # setup io pin direction
sleep( 1.00 )
 
 
def light(timea):
h.write([0x04, 0xFF, 0xFF])
time.sleep(timea)
 
def dark(timea):
h.write([0x04, 0x00, 0xFF])
time.sleep(timea)
 
def blik():
dark(0.8)
light(1)
 
def check_button():
response = h.get_feature_report(0x03,2)
return response[1]
 
def main():
init()
while True:
try:
 
while True:
inputs = check_button()
print bin(inputs)
if not (inputs & 0b00000001) and (0b00000001):
blik()
 
time.sleep(0.5)
 
except IOError, ex:
print ex
 
except KeyboardInterrupt:
print "Closing device"
h.close()
 
print "Done"
 
 
if __name__ == "__main__":
main()
Property changes:
Added: svn:executable
+*
\ No newline at end of property
/Designs/Measuring_instruments/ISMS01A/SW/ISMS_read.py
0,0 → 1,135
#!/usr/bin/python
 
#uncomment for debbug purposes
#import logging
#logging.basicConfig(level=logging.DEBUG)
 
import time
import datetime
import sys
import os
import minimalmodbus
 
from pymlab import config
from mlabutils import ejson
 
parser = ejson.Parser()
 
#### Script Arguments ###############################################
 
if len(sys.argv) != 3:
sys.stderr.write("Invalid number of arguments.\n")
sys.stderr.write("Usage: %s PORT_ADDRESS CONFIG_FILE\n" % (sys.argv[0], ))
sys.exit(1)
 
 
port = eval(sys.argv[1])
 
value = parser.parse_file(sys.argv[2])
path = value['data_path']
interval = value['raw_sample_interval']
stationName = value['origin']
 
 
 
if (interval<5) or (interval>3600):
sys.stderr.write("Invalid sample interval arguments.\n")
sys.stderr.write("The interval has to be in the range from 5 to 3600 seconds\n")
sys.exit(2)
 
#### Sensor Configuration ###########################################
# I2C
cfg = config.Config(
i2c = {
"port": port,
},
bus = [
{
"name": "current_sensor1",
"type": "vcai2c01",
"address": 0x68,
},
],
)
cfg.initialize()
 
# modbus
instrument = minimalmodbus.Instrument('/dev/ttyUSB0', 1) # port name, slave address (in decimal)
 
instrument.serial.port # this is the serial port name
instrument.serial.baudrate = 9600 # Baud
instrument.serial.bytesize = 8
instrument.serial.stopbits = 2
instrument.serial.timeout = 0.5 # seconds
 
instrument.mode = minimalmodbus.MODE_RTU # rtu or ascii mode
 
 
sys.stdout.write("Current loop and modbus sensor example \r\n")
sys.stdout.write("Time, water-level, temp1, conduc, salinity, tds_kcl, temp2, pH, redox \r\n")
#sys.stdout.write("Time, channel #1, channel #2, channel #3 , channel #4, channel #5 channel #6 , channel #7, channel #8 \r\n")
sensor1 = cfg.get_device("current_sensor1")
#time.sleep(0.5)
 
#### Data Logging ###################################################
 
while True:
try:
before = time.time()-interval
while True:
filename = path + time.strftime("%Y%m%d%H", time.gmtime()) +"0000_"+ stationName + "_data.csv"
now = time.time()
if (now - before >= interval - 2.5): # 0.5*5 channels= 2.5s
with open(filename, "a") as f:
##Measuremment settings
sensor1.setADC(channel = 1, gain = 1, sample_rate = 3.75);
instrument.address = 0x1E # this is the slave address number (1E-conductivity)
instrument.write_register(0x01, 0x1F, 0) # Registernumber, value, number of decimals for storage
instrument.address = 0x14 # this is the slave address number (14 - pH)
instrument.write_register(0x01, 0x1F, 0) # Registernumber, value, number of decimals for storage
time.sleep(0.5)
 
##Reading
## Read data from analog sensors ##
channel1 = sensor1.readCurrent();
channel1 = 0.2488*channel1-0.8892; # transformation from mA to meters
 
## Read data from conductivity sensor ##
instrument.address = 0x1E # this is the slave address number (1E-conductivity)
 
temperature1 = instrument.read_float(0x53, 3, 2) # Registernumber, number of decimals
conductivity = instrument.read_float(0x55, 3, 2) # Registernumber, number of decimals
salinity = instrument.read_float(0x57, 3, 2) # Registernumber, number of decimals
tds_kcl = instrument.read_float(0x59, 3, 2) # Registernumber, number of decimals
## Read data from pH sensor ##
instrument.address = 0x14 # this is the slave address number (14 - pH)
temperature2 = instrument.read_float(0x53, 3, 2) # Registernumber, number of decimals
pH = instrument.read_float(0x55, 3, 2) # Registernumber, number of decimals
redox = instrument.read_float(0x57, 3, 2) # Registernumber, number of decimals
 
sys.stdout.write("%s \t %0.3f \t %0.3f \t %0.3f \t %0.3f \t %0.3f \t %0.3f \t %0.3f \t %0.3f \t \n" % (datetime.datetime.now().isoformat(), channel1, temperature1, conductivity, salinity, tds_kcl, temperature2, pH, redox))
 
f.write("%d;%0.3f;%0.3f;%0.3f;%0.3f;%0.3f;%0.3f;%0.3f;%0.3f\n" % (time.time(), channel1, temperature1, conductivity, salinity, tds_kcl, temperature2, pH, redox))
f.flush()
 
sys.stdout.flush()
before = time.time()
else:
time.sleep(0.1)
 
except KeyboardInterrupt:
f.close()
sys.exit(0)
except Exception as e:
sys.stdout.write(e)
time.sleep(5)
 
 
/Designs/Measuring_instruments/ISMS01A/SW/average.py
0,0 → 1,95
#!/usr/bin/python
 
import pandas as pd
import sys
import os
import time
import datetime
 
from pymlab import config
from mlabutils import ejson
 
parser = ejson.Parser()
 
#### Script Arguments ###############################################
 
if len(sys.argv) != 2:
sys.stderr.write("Invalid number of arguments.\n")
sys.stderr.write("Usage: %s CONFIG_FILE\n" % (sys.argv[0], ))
sys.exit(1)
 
value = parser.parse_file(sys.argv[1])
dataSource = value['data_path']
dataArchive = value['data_archive']
dataUpload = value['data_upload']
stationName = value['origin']
 
loop = 1
 
 
while True:
try:
print("Start")
## Create sorted list of csv files
listOfDataFiles = list() #empty list
listOfSpecDataFiles = list() #empty list
files = list() #empty list
falg = False # is computation needed
files = sorted(os.listdir(dataSource)) # list of all files and folders in directory
for idx, val in enumerate(files): #goes through files
if val.endswith("data.csv"): # in case of *data.csv
listOfDataFiles.append(val) #add file to listOfFiles
 
## Find the newest and oldest and compare them. If they are from different day, compute the average of all measurement from oldest day
if len(listOfDataFiles)>=2: # if there are more than 2 data files
first = listOfDataFiles[0] # get first of them
last = listOfDataFiles[-1] # get last of them
if time.mktime(datetime.datetime.strptime(last[:8], "%Y%m%d").timetuple()) > time.mktime(datetime.datetime.strptime(first[:8], "%Y%m%d").timetuple()): # if the last is older than first
flag = True # computation needed
print("Computing...")
print(loop)
loop +=1
listOfSpecDataFiles = list() # empty list
for file in listOfDataFiles: # go through data files and create lis of data files measured on same day
# if the day is same like the first one
if time.mktime(datetime.datetime.strptime(first[:8], "%Y%m%d").timetuple()) == time.mktime(datetime.datetime.strptime(file[:8], "%Y%m%d").timetuple()):
listOfSpecDataFiles.append(file)
for file in listOfSpecDataFiles:
df=pd.read_csv(dataSource + file, sep=';', header=None) # read current csv
dim=df.shape # gets data file dimensions
rowsInd=dim[0] # maximal index of rows
columnsInd=dim[1] # maximal index of columns
values=pd.DataFrame() # empty DataFrame
 
for x in range(0,columnsInd): # for each column
values = values.set_value(0,x,round(df[x].mean(),3),0) #calculates mean value for all cloumns and round it by 3
filename = dataUpload + first[:8]+'000000_' + stationName + '_data_mean.csv'
outfile = open(filename, 'a')
values.to_csv(filename, sep=';', header=None, index=False, mode='a') # save (add) DataFrame to csv
outfile.close()
# move files to archive structure
for file in listOfSpecDataFiles:
year = file[:4]
month = file[4:6]
day = file[6:8]
directory = dataArchive + year + "/" + month + "/" + day + "/"
if not os.path.exists(directory):
os.makedirs(directory)
os.rename(dataSource + file, dataArchive + year + "/" + month + "/" + day + "/" + file) # move file
else:
flag = False # computation is not needed
else:
flag = False # computation is not needed
if flag == False:
time.sleep(10) #long sleep, because is nothing to process
except ValueError:
print ValueError
/Designs/Measuring_instruments/ISMS01A/SW/modbus_test.py
0,0 → 1,32
#!/usr/bin/env python
import minimalmodbus
import time
 
instrument = minimalmodbus.Instrument('/dev/ttyUSB0', 1) # port name, slave address (in decimal)
 
instrument.serial.port # this is the serial port name
instrument.serial.baudrate = 9600 # Baud
instrument.serial.bytesize = 8
instrument.serial.stopbits = 2
instrument.serial.timeout = 0.5 # seconds
 
instrument.address = 0x1E # this is the slave address number
instrument.mode = minimalmodbus.MODE_RTU # rtu or ascii mode
 
instrument.write_register(0x01, 0x1F, 0) # Registernumber, value, number of decimals for storage
 
time.sleep(0.5)
 
## Read temperature (PV = ProcessValue) ##
temperature = instrument.read_float(0x53, 3, 2) # Registernumber, number of decimals
print temperature
conductivity = instrument.read_float(0x55, 3, 2) # Registernumber, number of decimals
print conductivity
salinity = instrument.read_float(0x57, 3, 2) # Registernumber, number of decimals
print salinity
tds_kcl = instrument.read_float(0x59, 3, 2) # Registernumber, number of decimals
print tds_kcl
 
 
## Change temperature setpoint (SP) ##
 
Property changes:
Added: svn:executable
+*
\ No newline at end of property