Advertisement
Guest User

Untitled

a guest
Sep 30th, 2018
95
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 1.80 KB | None | 0 0
  1. #!/usr/bin/python
  2. import sys
  3. import Adafruit_DHT
  4.  
  5. import subprocess
  6. import re
  7. import os
  8. import time
  9. import MySQLdb as mdb
  10. import datetime
  11.  
  12. databaseUsername="root"
  13. databasePassword="Admin33556"
  14. databaseName="WordPressDB"
  15.  
  16. sensor=Adafruit_DHT.DHT22
  17. pinNum=4
  18.  
  19. def saveToDatabase(temperature,humidity):
  20.  
  21.     con=mdb.connect("localhost", databaseUsername, databasePassword, databaseName)
  22.         currentDate=datetime.datetime.now().date()
  23.  
  24.         now=datetime.datetime.now()
  25.         midnight=datetime.datetime.combine(now.date(),datetime.time())
  26.         minutes=((now-midnight).seconds)/60 #minutes after midnight, use datead$
  27.  
  28.    
  29.         with con:
  30.                 cur=con.cursor()
  31.        
  32.                 cur.execute("INSERT INTO temperatures (temperature,humidity, dateMeasured, hourMeasured) VALUES (%s,%s,%s,%s)",(temperature,humidity,currentDate, minutes))
  33.  
  34.         print "Saved temperature"
  35.         return "true"
  36.  
  37.  
  38. def readInfo():
  39.  
  40.     humidity, temperature = Adafruit_DHT.read_retry(sensor, pinNum)
  41.  
  42.     print "Temperature: %.1f C" % temperature
  43.     print "Humidity:    %s %%" % humidity
  44.  
  45.     if humidity is not None and temperature is not None:
  46.         return saveToDatabase(temperature,humidity) #success, save the readings
  47.     else:
  48.         print 'Failed to get reading. Try again!'
  49.         sys.exit(1)
  50.  
  51.  
  52. try:
  53.     queryFile=file("createTable.sql","r")
  54.  
  55.     con=mdb.connect("localhost", databaseUsername,databasePassword,databaseName)
  56.         currentDate=datetime.datetime.now().date()
  57.  
  58.         with con:
  59.         line=queryFile.readline()
  60.         query=""
  61.         while(line!=""):
  62.             query+=line
  63.             line=queryFile.readline()
  64.        
  65.         cur=con.cursor()
  66.         cur.execute(query) 
  67.  
  68.         queryFile.close()
  69.             os.rename("createTable.sql","createTable.sql.bkp")
  70.    
  71.  
  72. except IOError:
  73.     pass #table has already been created
  74.    
  75.  
  76. status=readInfo()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement