树莓派连接DHT11通过python采集温湿度存入MySQL数据库

过程略过,代码如下:

#!/usr/bin/python  
#-*- coding: UTF-8 -*- 



import RPi.GPIO as GPIO  
import time
import datetime
import MySQLdb


conn= MySQLdb.connect(
        host='localhost',
        port = 3306,
        user='root',
        passwd='password',
        db ='pi',
        )

cur = conn.cursor()
cur.execute("create table t_h(temperature int ,humidity varchar(30),nowtime text(300))")
'''
if cur.execute("show table like '%t_h%'"):
    print "存在"
    cur.close()

else:
    print "不存在"
    cur.execute("create table t_h(temperature int ,humidity varchar(30),nowtimetime text(30))")

  
#cur.execute("insert into t values('1','Tom')")
#cur.execute("create table ee(h int ,t varchar(20))")
#cur.execute("insert into uu values('1','Tom')")
'''


q = 0

while q < 1000:

    cur = conn.cursor()

    channel = 16            #引脚号16  
    data = []           #温湿度值  
    j = 0               #计数器  
#    nowtime = time.strftime('%H%M%S',time.localtime(time.time()))
    nowtime = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
    GPIO.setmode(GPIO.BCM)      #以BCM编码格式  

    time.sleep(1)           #时延一秒  
      
    GPIO.setup(channel, GPIO.OUT)  
      
    GPIO.output(channel, GPIO.LOW)  
    time.sleep(0.02)        #给信号提示传感器开始工作  
    GPIO.output(channel, GPIO.HIGH)  
      
    GPIO.setup(channel, GPIO.IN)  
      
    while GPIO.input(channel) == GPIO.LOW:  
        continue  
      
    while GPIO.input(channel) == GPIO.HIGH:  
        continue  
      
    while j < 40:  
        k = 0  
        while GPIO.input(channel) == GPIO.LOW:  
            continue  
          
        while GPIO.input(channel) == GPIO.HIGH:  
            k += 1  
            if k > 100:  
                break  
          
        if k < 11:  
            data.append(0)  
        else:  
            data.append(1)  
      
        j += 1  
      
    print "sensor is working."  
#    print data              #输出初始数据高低电平  
      
    humidity_bit = data[0:8]        #分组  
    humidity_point_bit = data[8:16]  
    temperature_bit = data[16:24]  
    temperature_point_bit = data[24:32]  
    check_bit = data[32:40]  
      
    humidity = 0  
    humidity_point = 0  
    temperature = 0  
    temperature_point = 0  
    check = 0  
      
    for i in range(8):  
        humidity += humidity_bit[i] * 2 ** (7 - i)              #转换成十进制数据  
        humidity_point += humidity_point_bit[i] * 2 ** (7 - i)  
        temperature += temperature_bit[i] * 2 ** (7 - i)  
        temperature_point += temperature_point_bit[i] * 2 ** (7 - i)  
        check += check_bit[i] * 2 ** (7 - i)  
      
    tmp = humidity + humidity_point + temperature + temperature_point       #十进制的数据相加  
      
    if check == tmp:                                #数据校验,相等则输出  
        print "温度: ", temperature, "'C, 湿度: " , humidity,"%","时间:",nowtime
        cur.execute("insert into t_h values('%s','%s','%s')"%(temperature,humidity,nowtime))#这里一定要注意,%s必须用单引号括起来,否则时间变量传过来的值因包含空格和“:”无法插入到数据库,只能接收数值。
    else:                                       #错误输出错误信息,和校验数据  
        print "wrong"  
        print "temperature : ", temperature, ", humidity : " , humidity, " check : ", check, " tmp : ", tmp  
	
    GPIO.cleanup()                                  #重置针脚
#    time.sleep(5)
    cur.close()
    conn.commit()
    q += 1

conn.close()