-
Notifications
You must be signed in to change notification settings - Fork 1
/
temperature.py
61 lines (52 loc) · 2 KB
/
temperature.py
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
import os
import time
from sense_hat import SenseHat
import json
from datetime import datetime
# Import SDK packages
from AWSIoTPythonSDK.MQTTLib import AWSIoTMQTTClient
# get CPU temperature
def get_cpu_temp():
res = os.popen("vcgencmd measure_temp").readline()
t = float(res.replace("temp=","").replace("'C\n",""))
return(t)
# use moving average to smooth readings
def get_smooth(x):
if not hasattr(get_smooth, "t"):
get_smooth.t = [x,x,x]
get_smooth.t[2] = get_smooth.t[1]
get_smooth.t[1] = get_smooth.t[0]
get_smooth.t[0] = x
xs = (get_smooth.t[0]+get_smooth.t[1]+get_smooth.t[2])/3
return(xs)
sense = SenseHat()
sense.clear()
# For certificate based connection
# TODO replace the client name
myMQTTClient = AWSIoTMQTTClient("YOUR-CLIENT-NAME")
# For TLS mutual authentication
# TODO replace the url
myMQTTClient.configureEndpoint("YOUR-AMAZON-ENDPOINT-URL", 8883)
myMQTTClient.configureCredentials("cert/aws_root.pem", "cert/private.pem.key", "cert/certificate.pem.crt")
myMQTTClient.configureOfflinePublishQueueing(-1) # Infinite offline Publish queueing
myMQTTClient.configureDrainingFrequency(2) # Draining: 2 Hz
myMQTTClient.configureConnectDisconnectTimeout(10) # 10 sec
myMQTTClient.configureMQTTOperationTimeout(5) # 5 sec
# connect to mqtt broker
myMQTTClient.connect()
while True:
for event in sense.stick.get_events():
print("The joystick was {} {}".format(event.action, event.direction))
if event.action == "pressed" and event.direction == "up" :
t1 = sense.get_temperature_from_humidity()
t2 = sense.get_temperature_from_pressure()
t_cpu = get_cpu_temp()
t = (t1+t2)/2
t_corr = t - ((t_cpu-t)/1.5)
t_corr = get_smooth(t_corr)
msg = "%s C" % int(round(t_corr))
sense.show_message(msg)
timestamp = datetime.now().strftime("%Y%m%d-%H:%M:%S")
result_json = {'temperature' : t_corr , 'timestamp' : timestamp }
# TODO replace the topic
myMQTTClient.publish("TOPIC-TO-PUBLISH", json.dumps(result_json) , 0)