myweather/scheduler.py

92 lines
2.7 KiB
Python
Raw Normal View History

2015-04-19 20:03:40 +00:00
#!/usr/bin/python
import subprocess
import re
import os
import sys
import time
import MySQLdb as mdb
import datetime
from weather import *
2015-04-19 20:03:40 +00:00
2015-06-05 20:44:20 +00:00
databaseUsername="XXXXX"
databasePassword="XXXXX"
databaseName="XXXXX" #do not change unless you named the Wordpress database with some other name
databaseHost="www.xxx.de"
2015-04-19 20:03:40 +00:00
#check if table is created or if we need to create one
try:
queryFile=file("createTable.sql","r")
2015-04-19 20:03:40 +00:00
con=mdb.connect(databaseHost,databaseUsername,databasePassword,databaseName)
currentDate=datetime.datetime.now().date()
2015-04-19 20:03:40 +00:00
with con:
line=queryFile.readline()
query=""
while(line!=""):
query+=line
line=queryFile.readline()
2015-04-19 20:03:40 +00:00
cur=con.cursor()
cur.execute(query)
2015-04-19 20:03:40 +00:00
#now rename the file, because we do not need to recreate the table everytime this script is run
queryFile.close()
os.rename("createTable.sql","createTable.sql.bkp")
2015-04-19 20:03:40 +00:00
except IOError:
pass #table has already been created
2015-04-19 20:03:40 +00:00
def saveToDatabase(temp1, temp2, temp3, temp4, humidity, pressure, sea_pressure, altitude):
#print "SaveToDatabase Hit"
2015-04-19 20:03:40 +00:00
con=mdb.connect(databaseHost, databaseUsername, databasePassword, databaseName)
currentDate=datetime.datetime.now().date()
print currentDate
now=datetime.datetime.now()
midnight=datetime.datetime.combine(now.date(),datetime.time())
minutes=((now-midnight).seconds)/60 #minutes after midnight, use datead$
2015-06-05 20:44:20 +00:00
print "Minutes",minutes
2015-04-19 20:03:40 +00:00
with con:
cur=con.cursor()
query = ("INSERT INTO `temperatures`(`temperature_1`, `temperature_2`, `temperature_3`, `temperature_4`, `humidity`, `dateMeasured`, `hourMeasured`, `pressure`, `pressure_sea`, `altitude`)"
"VALUES (%s,%s,%s,%s,%s,'%s',%s,%s,%s,%s)"% (temp1, temp2, temp3, temp4, humidity, currentDate, minutes, pressure, sea_pressure, altitude))
cur.execute(query)
2015-04-19 20:03:40 +00:00
print "Saved temperature"
return "false"
2015-04-19 20:03:40 +00:00
def readInfo():
#print "ReadInfo Hit"
temperatureSaved="false"
while(temperatureSaved=="false"):
temp1 = Temp1
temp2 = Temp2
temp3 = Temp3
temp4 = Temp4
humidity=Humidity
altitude = Altitude
pressure = Pressure
sea_pressure = Sea_pressure
2015-06-05 20:44:20 +00:00
print "Temp1 : ",temp1
print "Temp2 : ",temp2
print "Temp3 : ",temp3
print "Temp4 : ",temp4
print "Humidity : ",humidity
print "Altitude : ",altitude
print "Pressure : ",pressure
print "Sea Pressure : ",sea_pressure
#return "false"
#temperatureSaved="true"
return saveToDatabase(temp1, temp2, temp3, temp4, humidity, pressure, sea_pressure, altitude)
2015-04-19 20:03:40 +00:00
status=readInfo()
2015-04-19 20:03:40 +00:00