Mercurial > templog
view py/tempserver.py @ 452:25bdf95f0e29
config for sensor IDs
author | Matt Johnston <matt@ucc.asn.au> |
---|---|
date | Thu, 20 Dec 2012 22:26:18 +0800 |
parents | fe729664a5e6 |
children | d03157c7ad60 |
line wrap: on
line source
#!/home/matt/templog/venv/bin/python import sys import os import logging import gevent import gevent.monkey import utils from utils import L,D,EX,W import fridge import config import sensor_ds18b20 import params class Tempserver(object): def __init__(self): self.readings = [] self.current = (None, None) self.fridge = None # don't patch os, fork() is used by daemonize gevent.monkey.patch_all(os=False, thread=False) def __enter__(self): self.params = params.Params() self.fridge = fridge.Fridge(self) self.params.load() self.set_sensors(sensor_ds18b20.DS18B20s(self)) return self def __exit__(self, exc_type, exc_value, traceback): L("Exiting, cleanup handler"); self.fridge.off() def run(self): if self.fridge is None: raise Exception("Tempserver.run() must be within 'with Tempserver() as server'") # XXX do these go here or in __enter_() ? self.start_time = self.now() self.fridge.start() self.sensors.start() # won't return. while True: gevent.sleep(60) def now(self): return utils.monotonic_time() def set_sensors(self, sensors): if hasattr(self, 'sensors'): self.sensors.kill() self.sensors = sensors self.wort_name = sensors.wort_name() self.fridge_name = sensors.fridge_name() def take_readings(self): ret = self.readings self.readings = [] return ret def pushfront(self, readings): """ used if a caller of take_readings() fails """ self.readings = pushback + self.readings # a reading is a map of {sensorname: value}. temperatures # are float degrees def add_reading(self, reading): """ adds a reading at the current time """ self.readings.append( (reading, self.now())) self.current = (reading.get(self.wort_name, None), reading.get(self.fridge_name, None)) def current_temps(self): """ returns (wort_temp, fridge_temp) tuple """ return self.current def setup_logging(): logging.basicConfig(format='%(asctime)s %(message)s', datefmt='%m/%d/%Y %I:%M:%S %p', level=logging.DEBUG) def main(): setup_logging() if '--daemon' in sys.argv: utils.cheap_daemon() with Tempserver() as server: server.run() if __name__ == '__main__': main()