ausgabe bei Fehelrn über stderr
This commit is contained in:
parent
b375bf096f
commit
c08f86cf8f
6 changed files with 30 additions and 31 deletions
|
|
@ -144,11 +144,11 @@ class Buffer(object):
|
||||||
|
|
||||||
def update_buffer(self):
|
def update_buffer(self):
|
||||||
#ToDo
|
#ToDo
|
||||||
None
|
pass
|
||||||
|
|
||||||
def init_buffer(self):
|
def init_buffer(self):
|
||||||
#ToDo
|
#ToDo
|
||||||
None
|
pass
|
||||||
|
|
||||||
class API(object):
|
class API(object):
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -33,7 +33,7 @@ class CANFilter(Thread):
|
||||||
|
|
||||||
self.queue = Queue()
|
self.queue = Queue()
|
||||||
|
|
||||||
self.pcan = PcanAdapter(PcanAdapter.Baudrate[self.conf['can_baud']],
|
self.pcan = PcanAdapter(PcanAdapter.Baudrate[self.conf['can_baudrate']],
|
||||||
debug = self.conf['config_debug'])
|
debug = self.conf['config_debug'])
|
||||||
self.pcan.initialize()
|
self.pcan.initialize()
|
||||||
|
|
||||||
|
|
@ -70,8 +70,8 @@ class CANFilter(Thread):
|
||||||
self.pcan.Messages['dc_pv'].addSignal( current )
|
self.pcan.Messages['dc_pv'].addSignal( current )
|
||||||
self.pcan.Messages['dc_pv'].addSignal( voltage )
|
self.pcan.Messages['dc_pv'].addSignal( voltage )
|
||||||
|
|
||||||
self.pcan.Messages['dc_charging'].addSignal( current )
|
self.pcan.Messages['dc_charger'].addSignal( current )
|
||||||
self.pcan.Messages['dc_charging'].addSignal( voltage )
|
self.pcan.Messages['dc_charger'].addSignal( voltage )
|
||||||
|
|
||||||
def mean(self, l):
|
def mean(self, l):
|
||||||
return float(sum(l))/len(l) if len(l) > 0 else 0
|
return float(sum(l))/len(l) if len(l) > 0 else 0
|
||||||
|
|
|
||||||
|
|
@ -3,6 +3,9 @@ Created on 21.11.2013
|
||||||
|
|
||||||
@author: rauchp
|
@author: rauchp
|
||||||
'''
|
'''
|
||||||
|
from sys import stderr
|
||||||
|
config = "config\ems.conf"
|
||||||
|
|
||||||
class Config():
|
class Config():
|
||||||
_instance = None
|
_instance = None
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,4 @@
|
||||||
#### DATENBANK ####
|
#### DATENBANK ####
|
||||||
|
|
||||||
mySQL_server = localhost
|
mySQL_server = localhost
|
||||||
mySQL_port = 3306 # default 3306
|
mySQL_port = 3306 # default 3306
|
||||||
mySQL_user = smoke
|
mySQL_user = smoke
|
||||||
|
|
@ -9,31 +8,28 @@ mySQL_table = battery, grid, pv, charger
|
||||||
mySQL_speed = 0.1 # time between two query's in sec
|
mySQL_speed = 0.1 # time between two query's in sec
|
||||||
|
|
||||||
#### FLASK ####
|
#### FLASK ####
|
||||||
|
|
||||||
flask_server = 0.0.0.0 # 0.0.0.0 for public access
|
flask_server = 0.0.0.0 # 0.0.0.0 for public access
|
||||||
flask_port = 5000
|
flask_port = 5000
|
||||||
flask_debug = True
|
flask_debug = True
|
||||||
|
|
||||||
#### CONFIG ####
|
#### CONFIG ####
|
||||||
|
|
||||||
config_debug = True
|
config_debug = True
|
||||||
|
|
||||||
#### CAN ####
|
#### CAN ####
|
||||||
|
|
||||||
#possible Baud Rates: 100k, 125k, 250k, 500k, 1000k
|
#possible Baud Rates: 100k, 125k, 250k, 500k, 1000k
|
||||||
can_baud = 250k
|
can_baudrate = 250k
|
||||||
|
|
||||||
#can_messages = dc_battery, dc_grid, dc_pv, dc_charger
|
#can_messages = dc_battery, dc_grid, dc_pv, dc_charger
|
||||||
#'dc_battery = id:0x3A4, length:8, time:50
|
#'dc_battery = id:0x3A4, length:8, time:50
|
||||||
#'dc_grid = id:0x3A5, length:8, time:50
|
#'dc_grid = id:0x3A5, length:8, time:50
|
||||||
#'dc_pv = id:0x3A6, length:8, time:50
|
#'dc_pv = id:0x3A6, length:8, time:50
|
||||||
#'dc_charger = id:0x3A7, length:8, time:50
|
#'dc_charger = id:0x3A7, length:8, time:50
|
||||||
|
#
|
||||||
#can_signales = current, voltage, capacity, isMaster, isFeed, isCharging, isOn
|
#can_signales = current, voltage, capacity, isMaster, isFeed, isCharging, isOn
|
||||||
#'current = begin:0, length:16, offset:0, scaling:0.001, data:0
|
#'current = begin:0, length:16, offset:0, scaling:0.001, data:0
|
||||||
#'voltage = begin:16, length:16, offset:0, scaling:0.01, data:0
|
#'voltage = begin:16, length:16, offset:0, scaling:0.01, data:0
|
||||||
#'capacity = begin:32, length:11, offset:0, scaling:0.05, data:0
|
#'capacity = begin:32, length:11, offset:0, scaling:0.05, data:0
|
||||||
#'isMaster = begin:56, length:1, offset:0, scaling:1, data:0
|
#'isMaster = begin:56, length:1, offset:0, scaling:1, data:0
|
||||||
#'isFeed = begin:57, length:1, offset:0, scaling:1, data:0
|
#'isFeed = begin:57, length:1, offset:0, scaling:1, data:0
|
||||||
#'isCharging = begin:57, length:1, offset:0, scaling:1, data:0
|
#'isCharging = begin:57, length:1, offset:0, scaling:1, data:0
|
||||||
#'isOn = begin:58, length:1, offset:0, scaling:1, data:0
|
#'isOn = begin:58, length:1, offset:0, scaling:1, data:0
|
||||||
|
|
|
||||||
13
src/ems.py
13
src/ems.py
|
|
@ -4,9 +4,9 @@ Created on 15.11.2013
|
||||||
@author: Philipp Rauch
|
@author: Philipp Rauch
|
||||||
@version: 0.02
|
@version: 0.02
|
||||||
'''
|
'''
|
||||||
|
from sys import stderr
|
||||||
from threading import Thread
|
from threading import Thread
|
||||||
from switch import Switch, MYSQL
|
from switch import Switch, MYSQL
|
||||||
from config import Config
|
from config import Config
|
||||||
|
|
||||||
### LOAD CONFIG ###
|
### LOAD CONFIG ###
|
||||||
|
|
@ -62,13 +62,13 @@ class ems(Thread):
|
||||||
|
|
||||||
## Test of valid push message ##
|
## Test of valid push message ##
|
||||||
if not isinstance(push, dict):
|
if not isinstance(push, dict):
|
||||||
print 'error wrong parameter: Type', push.__class__.__name__, 'expect Type dict'
|
stderr.write('error wrong parameter: Type is %s expect dict' % push.__class__.__name__)
|
||||||
return
|
return
|
||||||
if len(push.keys()) not in [1]:
|
if len(push.keys()) not in [1]:
|
||||||
print 'error wrong number of arguments:', len(push.keys()), 'expect 1'
|
stderr.write('error wrong number of arguments: %s expect 1' % len(push.keys()))
|
||||||
return
|
return
|
||||||
if not isinstance(push.get(push.keys()[0]) ,dict):
|
if not isinstance(push.get(push.keys()[0]) ,dict):
|
||||||
print 'error value is not dict'
|
stderr.write('error value is not dict')
|
||||||
return
|
return
|
||||||
|
|
||||||
key = push.keys()[0]
|
key = push.keys()[0]
|
||||||
|
|
@ -82,11 +82,10 @@ class ems(Thread):
|
||||||
try:
|
try:
|
||||||
sys = sys[key]
|
sys = sys[key]
|
||||||
except KeyError:
|
except KeyError:
|
||||||
print 'error wrong path'
|
stderr.write('error wrong path: %s' % key)
|
||||||
return
|
return
|
||||||
|
|
||||||
sys.update(value)
|
sys.update(value)
|
||||||
pass
|
|
||||||
|
|
||||||
def getRequest(self):
|
def getRequest(self):
|
||||||
#TODO: get Request from buffer
|
#TODO: get Request from buffer
|
||||||
|
|
|
||||||
|
|
@ -15,11 +15,12 @@ conf = c.readConf()
|
||||||
|
|
||||||
|
|
||||||
### CAN test ###
|
### CAN test ###
|
||||||
print 'starte CAN mit Baud von', conf['can_baud']
|
print 'starte CAN mit Baud von', conf['can_baudrate']
|
||||||
can = CANFilter.CANFilter()
|
can = CANFilter.CANFilter()
|
||||||
can.start()
|
can.start()
|
||||||
|
|
||||||
### EMS test ###
|
### EMS test ###9
|
||||||
|
|
||||||
# buffer = {}
|
# buffer = {}
|
||||||
# print 'starte EMS'
|
# print 'starte EMS'
|
||||||
# th = ems.ems(buffer)
|
# th = ems.ems(buffer)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue