Leserlicher Name in die csv geschrieben
[chrisu/seepark.git] / 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()