Actualizacion para soportar una base de datos remota

.gitignore

@@ -0,0 +1,4 @@
+*.pyc
+.*.swp
+*.log
+config_local.py

config.py

@@ -0,0 +1,23 @@
+# Configuracion para sensor DHTxx
+#
+# Estas variables se sobre escriben en el archivo config_local.py
+# que debe contener estas mismas variables exceptuando las 5 
+# ultimas lineas
+
+# Configuracion del puerto GPIO al cual esta conectado (GPIO 23)
+pin = 23
+
+# Configuracion de la carpeta para la creacion de los archivos log
+log_path = "/var/log/iot/"
+
+# Configuracion credenciales MySQL
+MYSQL_SERVIDOR = "localhost"
+MYSQL_BD = "raspberrypi"
+MYSQL_USUARIO = "raspberrypi"
+MYSQL_CONTRASENA = "contrasena_super_secreta"
+
+# Carga la configuracion local desde el archivo config_local.py
+try:
+	from config_local import *
+except Exception, e:
+	print "ERROR: " + str(e)

dht_mysql.py

@@ -0,0 +1,76 @@
+#!/usr/bin/python
+
+# Internet de las Cosas - http://internetdelascosas.cl
+#
+# Descripcion  : Programa que permite obtener la lectura de un sensor DHT11 y registra los valores
+#				 en una base de datos MySQL
+# Lenguaje     : Python
+# Autor        : Jose Zorrilla <jzorrilla@iot.cl>
+# Dependencias : Libreria de Adafruit https://github.com/adafruit/Adafruit_Python_DHT
+# Web          : http://internetdelascosas.cl/
+
+# Importa las librerias necesarias 
+import time
+import datetime
+import Adafruit_DHT
+import MySQLdb
+
+# Importa la configuracion
+from config import *
+
+# Configuracion del tipo de sensor DHT
+sensor = Adafruit_DHT.DHT11
+
+# Inserta in registro en la base de datos MySQL
+def write_mysql(temperatura, humedad):
+	db = MySQLdb.connect(host=MYSQL_SERVIDOR,
+							user=MYSQL_USUARIO,
+							passwd=MYSQL_CONTRASENA,
+							db=MYSQL_BD)
+
+	# Crea un cursor usando la conexion
+	cursor = db.cursor()
+
+	# Genera la consulta SQL para  insertar el registro
+	sql = "INSERT INTO datos (fecha, temperatura, humedad) values (now(),'" + str(temperatura) + "','" + str(humedad) + "');"
+
+	try:
+		# Ejecuta el sql
+		cursor.execute(sql)
+		db.commit()
+	except:
+		conn.rollback()
+
+	# Cierra cursor y conexion a base de datos
+	cursor.close
+	db.close
+
+# Escribe un archivo log en log_path con el nombre en el formato yyyy-mm-dd_dht.log
+def write_log(text):
+	log = open(log_path + datetime.datetime.now().strftime("%Y-%m-%d") + "_dht.log","a")
+	line = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S") + " " + text + "\n"
+	log.write(line)
+	log.close()
+
+# Intenta ejecutar las siguientes instrucciones, si falla va a la instruccion except
+try:
+	# Ciclo principal infinito
+	while True:
+		# Obtiene la humedad y la temperatura desde el sensor 
+		humedad, temperatura = Adafruit_DHT.read_retry(sensor, pin)
+
+		# Si obtiene una lectura del sensor la registra en el archivo log
+		if humedad is not None and temperatura is not None:
+			write_log("DHT Sensor - Temperatura: %s" % str(temperatura))
+			write_log("DHT Sensor - Humedad:  %s" % str(humedad))
+			write_mysql(temperatura,humedad)
+		else:
+			write_log('Error al obtener la lectura del sensor')
+
+		# Duerme 10 segundos
+		time.sleep(10)
+
+# Se ejecuta en caso de que falle alguna instruccion dentro del try
+except Exception,e:
+	# Registra el error en el archivo log y termina la ejecucion
+	write_log(str(e))

sql/create_data.sql

@@ -0,0 +1,10 @@
+--
+-- Crea tabla `datos`
+--
+
+CREATE TABLE `datos` (
+  `id` bigint(20) UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY,
+  `fecha` datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
+  `temperatura` decimal(10,2),
+  `humedad` decimal(10,2)
+);