blynk/collector.py at master · jose3ww/blynk · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
#!/usr/bin/env python

"""A simple python script template.
"""

from __future__ import print_function
import os
import sys
import subprocess
import sqlite3
import re
import datetime
import parse
from contextlib import closing
#import argparse

def main(arguments):

    dbname = '/home/pi/blynk/sensordata.sqlite'
    with closing(sqlite3.connect(dbname)) as conn:
        cur = conn.cursor()

	timestamp = datetime.datetime.now()

# sensor 2
#        result = subprocess.check_output(['/home/pi/blynk/read_bme280.py', '--dump', '1', '0x76'])
#        sys.stderr.write(result)
#	m = parse.parse('{:f} {:f} {:f}', result)
#        if m[0] is not None and m[1] is not None:
#            temperature = m[0]
#            humidity = m[1]
#            sys.stderr.write(str(temperature))
#            sys.stderr.write(str(humidity))
#	    cur.execute('insert into temperatures(id, datetime, temperature, humidity) values(?, ?, ?, ?)', [0, timestamp, temperature, humidity])
#            conn.commit()

# sensor 1
#        result = subprocess.check_output(['/home/pi/blynk/read_dht', '--dump', '22', '4'])
#        sys.stderr.write(result)
#	m = parse.parse('{:f} {:f}', result)
#        if m[0] is not None and m[1] is not None:
#            temperature = m[0]
#            humidity = m[1]
#            sys.stderr.write(str(temperature))
#            sys.stderr.write(str(humidity))
#	    cur.execute('insert into temperatures(id, datetime, temperature, humidity) values(?, ?, ?, ?)', [1, timestamp, temperature, humidity])
#            conn.commit()

# sensor 0
        result = subprocess.check_output(['/home/pi/blynk/read_dht', '--dump', '22', '17'])
        sys.stderr.write(result)
	m = parse.parse('{:f} {:f}', result)
        if m[0] is not None and m[1] is not None:
            temperature = m[0]
            humidity = m[1]
            sys.stderr.write(str(temperature))
            sys.stderr.write(str(humidity))
	    cur.execute('insert into temperatures(id, datetime, temperature, humidity) values(?, ?, ?, ?)', [0, timestamp, temperature, humidity])
            conn.commit()

# sensor 1
        result = subprocess.check_output(['/home/pi/blynk/read_dht', '--dump', '22', '18'])
        sys.stderr.write(result)
	m = parse.parse('{:f} {:f}', result)
        if m[0] is not None and m[1] is not None:
            temperature = m[0]
            humidity = m[1]
            sys.stderr.write(str(temperature))
            sys.stderr.write(str(humidity))
	    cur.execute('insert into temperatures(id, datetime, temperature, humidity) values(?, ?, ?, ?)', [1, timestamp, temperature, humidity])
            conn.commit()

# sensor 2
        result = subprocess.check_output(['/home/pi/blynk/read_dht', '--dump', '22', '22'])
        sys.stderr.write(result)
	m = parse.parse('{:f} {:f}', result)
        if m[0] is not None and m[1] is not None:
            temperature = m[0]
            humidity = m[1]
            sys.stderr.write(str(temperature))
            sys.stderr.write(str(humidity))
	    cur.execute('insert into temperatures(id, datetime, temperature, humidity) values(?, ?, ?, ?)', [2, timestamp, temperature, humidity])
            conn.commit()

# sensor 3
        result = subprocess.check_output(['/home/pi/blynk/read_dht', '--dump', '22', '23'])
        sys.stderr.write(result)
	m = parse.parse('{:f} {:f}', result)
        if m[0] is not None and m[1] is not None:
            temperature = m[0]
            humidity = m[1]
            sys.stderr.write(str(temperature))
            sys.stderr.write(str(humidity))
	    cur.execute('insert into temperatures(id, datetime, temperature, humidity) values(?, ?, ?, ?)', [3, timestamp, temperature, humidity])
            conn.commit()


if __name__ == '__main__':
    sys.exit(main(sys.argv[1:]))