Mercurial > templog
annotate py/tempserver.py @ 160:256505f98c4d
uploader works
| author | Matt Johnston <matt@ucc.asn.au> |
|---|---|
| date | Thu, 03 Jan 2013 22:37:33 +0800 |
| parents | 6d799bee3508 |
| children | d73077e8cd67 |
| rev | line source |
|---|---|
| 148 | 1 #!/home/matt/templog/venv/bin/python |
| 141 | 2 |
| 3 import sys | |
| 4 import os | |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
5 import logging |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
6 |
| 141 | 7 import gevent |
| 145 | 8 import gevent.monkey |
| 141 | 9 |
| 10 import utils | |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
11 from utils import L,D,EX,W |
| 145 | 12 import fridge |
| 13 import config | |
| 14 import sensor_ds18b20 | |
| 15 import params | |
| 160 | 16 import uploader |
| 145 | 17 |
| 141 | 18 |
| 19 class Tempserver(object): | |
| 20 def __init__(self): | |
| 21 self.readings = [] | |
| 145 | 22 self.current = (None, None) |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
23 self.fridge = None |
| 145 | 24 |
| 25 # don't patch os, fork() is used by daemonize | |
| 26 gevent.monkey.patch_all(os=False, thread=False) | |
| 141 | 27 |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
28 def __enter__(self): |
| 145 | 29 self.params = params.Params() |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
30 self.fridge = fridge.Fridge(self) |
| 160 | 31 self.uploader = uploader.Uploader(self) |
| 145 | 32 self.params.load() |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
33 self.set_sensors(sensor_ds18b20.DS18B20s(self)) |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
34 return self |
| 141 | 35 |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
36 def __exit__(self, exc_type, exc_value, traceback): |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
37 L("Exiting, cleanup handler"); |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
38 self.fridge.off() |
| 141 | 39 |
| 145 | 40 def run(self): |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
41 |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
42 if self.fridge is None: |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
43 raise Exception("Tempserver.run() must be within 'with Tempserver() as server'") |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
44 |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
45 # XXX do these go here or in __enter_() ? |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
46 self.start_time = self.now() |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
47 self.fridge.start() |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
48 self.sensors.start() |
| 160 | 49 self.uploader.start() |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
50 |
| 145 | 51 # won't return. |
| 52 while True: | |
| 157 | 53 try: |
| 54 gevent.sleep(60) | |
| 55 except KeyboardInterrupt: | |
| 56 break | |
| 145 | 57 |
| 58 def now(self): | |
| 59 return utils.monotonic_time() | |
| 60 | |
| 144 | 61 def set_sensors(self, sensors): |
| 148 | 62 if hasattr(self, 'sensors'): |
| 144 | 63 self.sensors.kill() |
| 64 self.sensors = sensors | |
| 65 self.wort_name = sensors.wort_name() | |
| 66 self.fridge_name = sensors.fridge_name() | |
| 141 | 67 |
| 68 def take_readings(self): | |
| 69 ret = self.readings | |
| 70 self.readings = [] | |
| 71 return ret | |
| 72 | |
| 73 def pushfront(self, readings): | |
| 74 """ used if a caller of take_readings() fails """ | |
| 160 | 75 self.readings = readings + self.readings |
| 141 | 76 |
| 144 | 77 # a reading is a map of {sensorname: value}. temperatures |
| 78 # are float degrees | |
| 141 | 79 def add_reading(self, reading): |
| 80 """ adds a reading at the current time """ | |
| 155 | 81 D("add_reading(%s)" % str(reading)) |
| 145 | 82 self.readings.append( (reading, self.now())) |
| 144 | 83 self.current = (reading.get(self.wort_name, None), |
| 84 reading.get(self.fridge_name, None)) | |
| 160 | 85 if len(self.readings) > config.MAX_READINGS: |
| 86 self.readings = self.readings[-config.MAX_READINGS:] | |
| 141 | 87 |
| 88 def current_temps(self): | |
| 144 | 89 """ returns (wort_temp, fridge_temp) tuple """ |
| 148 | 90 return self.current |
| 145 | 91 |
| 92 def setup_logging(): | |
| 93 logging.basicConfig(format='%(asctime)s %(message)s', | |
| 94 datefmt='%m/%d/%Y %I:%M:%S %p', | |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
95 level=logging.DEBUG) |
| 145 | 96 |
| 97 def main(): | |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
98 setup_logging() |
| 145 | 99 |
| 100 if '--daemon' in sys.argv: | |
| 101 utils.cheap_daemon() | |
|
149
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
102 with Tempserver() as server: |
|
d686b111dab4
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
148
diff
changeset
|
103 server.run() |
| 145 | 104 |
| 105 if __name__ == '__main__': | |
| 106 main() |