You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
123 lines
3.4 KiB
123 lines
3.4 KiB
import socket
|
|
import pickle
|
|
import time
|
|
import sys
|
|
from influxdb import InfluxDBClient
|
|
import yagmail
|
|
|
|
class Conditions:
|
|
def __init__(self):
|
|
self.temperature = None
|
|
self.air_humidity = None
|
|
self.soil_humidity = None
|
|
self.air_speed = None
|
|
|
|
def calculate_dif(temp, percentage):
|
|
temp.sort()
|
|
if (temp[4] - temp[0]) / temp[0] >= percentage:
|
|
return True
|
|
else:
|
|
return False
|
|
|
|
def gmail_send(code):
|
|
|
|
with open("gmail_credentials.txt") as f:
|
|
data = f.readlines()
|
|
|
|
username = data[0].strip('\n')
|
|
password = data[1].strip('\n')
|
|
receiver = data[2].strip('\n')
|
|
|
|
yag = yagmail.SMTP(username, password)
|
|
temperature_content = "Attention! Atmos weather device detected a radical change of temperature. Please check the enviroment."
|
|
humidity_content = "Attention! Atmos weather device detected a radical change of air humidity. Please check the enviroment."
|
|
subject = "Atmos Urgent Notification"
|
|
|
|
if code == 1:
|
|
yag.send(receiver, subject, temperature_content)
|
|
else:
|
|
yag.send(receiver, subject, humidity_content)
|
|
|
|
|
|
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
port = 3125
|
|
s.bind(('0.0.0.0', port))
|
|
print ('Socket binded to port 3125')
|
|
|
|
s.listen(3)
|
|
print ('socket is listening')
|
|
|
|
c, addr = s.accept()
|
|
print ('Got connection from ' + str(addr) + ' \n')
|
|
|
|
client = InfluxDBClient(host='localhost', port=8086)
|
|
databases = client.get_list_database()
|
|
exists = False
|
|
|
|
for i in databases:
|
|
if('atmos' in i['name']):
|
|
exists = True
|
|
|
|
if(exists):
|
|
client.switch_database('atmos')
|
|
print("Switched to 'atmos' database\n")
|
|
else:
|
|
client.create_database('atmos')
|
|
print("Created database 'atmos'\n")
|
|
client.switch_database('atmos')
|
|
|
|
|
|
received = 0
|
|
temperature_array = []
|
|
airhumidity_array = []
|
|
|
|
while True:
|
|
|
|
unpickled_object = pickle.loads(c.recv(4096))
|
|
received += 1
|
|
|
|
temperature_array.append(unpickled_object.temperature)
|
|
airhumidity_array.append(unpickled_object.air_humidity)
|
|
|
|
if(received == 5 ):
|
|
is_temp = calculate_dif(temperature_array, 0.4)
|
|
is_hum = calculate_dif(airhumidity_array, -0.5)
|
|
|
|
if is_temp:
|
|
print("\nTemperature critical difference!!!")
|
|
print("Will now send notification email.\n")
|
|
gmail_send(1)
|
|
if is_hum:
|
|
print("\nHumidity critical difference!!!")
|
|
print("Will now send notification email.\n")
|
|
gmail_send(2)
|
|
|
|
#resetting values
|
|
temperature_array.clear()
|
|
airhumidity_array.clear()
|
|
received = 0
|
|
|
|
json_body = [
|
|
{
|
|
"measurement": "tablePython",
|
|
"tags": {
|
|
"location": "Athens"
|
|
},
|
|
"fields": {
|
|
"temperature": str(int(unpickled_object.temperature)),
|
|
"soil_humidity": str(int(unpickled_object.soil_humidity*100)),
|
|
"air_humidity": str(int(unpickled_object.air_humidity*100)),
|
|
"air_speed": str(unpickled_object.air_speed)
|
|
}
|
|
}
|
|
]
|
|
|
|
client.write_points(json_body)
|
|
|
|
print("Current temperature: " + str(int(unpickled_object.temperature)) + " Celcius")
|
|
print("Current soil humidity: " + str(int(unpickled_object.soil_humidity*100)) + " %")
|
|
print("Current air humidity: " + str(int(unpickled_object.air_humidity*100)) + "%")
|
|
print("Current air speed: " + str(unpickled_object.air_speed) + " km/h\n")
|
|
|
|
|
|
c.close()
|