seewasser.py

   1 #! /usr/bin/python3
   2
   3 import logging
   4 import datetime
   5 import re
   6 import sys
   7 import csv
   8 import os
   9 import configparser
  10 from sqlalchemy import create_engine
  11
  12 #May 27 21:32 /sys/bus/w1/devices/28-0416a1bab9ff
  13 #May 27 21:33 /sys/bus/w1/devices/28-0416a1ac66ff
  14 #May 27 21:35 /sys/bus/w1/devices/28-0516a207a4ff
  15 #May 27 21:38 /sys/bus/w1/devices/28-0316a2193bff
  16 #May 27 21:38 /sys/bus/w1/devices/28-0316a21383ff
  17
  18 # Eine Funktion:
  19 # einen Sensor auslesen
  20 #/sys/bus/w1/devices/
  21
  22 class ReadsensorError(RuntimeError):
  23     pass
  24
  25
  26 def readsensor(sensor_id):
  27     sensorfile = "/sys/bus/w1/devices/28-{}/w1_slave".format(sensor_id)
  28     file = open(sensorfile)
  29
  30     # Inhalt des Sensors:
  31     # 64 01 4b 46 7f ff 0c 10 01 : crc=01 YES
  32     # 64 01 4b 46 7f ff 0c 10 01 t=22250
  33
  34     # Suche nach YES
  35     linecrc = file.readline()
  36     match = re.search(": crc=[0-9a-f]{2} (YES|NO)",linecrc)
  37
  38     yesno = match.group(1)
  39     if yesno != "YES":
  40         raise ReadsensorError('Could not evaluate sensorfile "{}"'.format(sensorfile))
  41
  42     # Temperatur raus
  43     linetemp = file.readline()
  44     match = re.search(" t=([-0-9]+)",linetemp)
  45
  46     temp_raw = match.group(1)
  47     temp = float(temp_raw)/1000
  48
  49     file.close()
  50     jetzt = datetime.datetime.now()
  51
  52     return jetzt, temp_raw, temp
  53
  54
  55 def writesensordatacsv(config, sensor_id, sensor_name, timestamp, value_type, value_raw, value):
  56     # Schreiben des csv-files
  57     file = open(config.get("csv", "filename"), "a", newline = "")
  58     writer = csv.writer(file, dialect = "excel")
  59     writer.writerow([timestamp.strftime("%Y-%m-%d %H:%M"), sensor_id, sensor_name, "{:.1f}".format(value)])
  60
  61     file.close()
  62
  63
  64 def writesensordatadb(config, sensor_id, sensor_name, timestamp, value_type, value_raw, value):
  65     # Schreiben des db-files
  66     user = config.get('database', 'user')
  67     pwd = config.get('database','password')
  68     host = config.get('database','hostname')
  69     db = config.get('database','database')
  70
  71     engine = create_engine('mysql+mysqldb://{}:{}@{}/{}'.format(user, pwd, host, db), echo=False)
  72     conn = engine.connect()
  73     conn.execute("insert into sensors (sensor_id, sensor_name, value_type, value_raw, value, timestamp) values (%s,%s,%s,%s,%s,%s)", sensor_id, sensor_name, value_type, value_raw, value, timestamp)
  74     conn.close()
  75
  76
  77 def main():
  78     config = configparser.ConfigParser()
  79     config.read(os.path.expanduser('~/seewasser.ini'))
  80
  81     value_type = "Wassertemperatur"
  82     for sensor_id, sensor_name in config.items('temperature'):
  83         timestamp, value_raw, value = readsensor(sensor_id)
  84         writesensordatacsv(config, sensor_id, sensor_name, timestamp, value_type, value_raw, value)
  85         writesensordatadb(config, sensor_id, sensor_name, timestamp, value_type, value_raw, value)
  86         logging.info('Sensor {}: {:.1f}°C'.format(sensor_id, value))
  87
  88
  89 main()