树莓派使用DHT22温湿度传感器记录数据并使用flask、Echarts展示.zip

import pymysql from flask import Flask,render_template, url_for import json from flask import request import time import Adafruit_DHT # 生成Flask实例 app = Flask(__name__) @app.route('/ht/') # 为匹配nginx的转发，多加一个/ def index(): return render_template('statistics_template.html') # /getData路由。 获取统计图是json数据 @app.route('/ht/getData',methods=["GET", "POST"]) def get_data(): if request.method == "POST": time = request.form.get("time") range = request.form.get("range") else: time = request.args.get("time") range = request.args.get("range") return(get_jsondata(int(range),int(time))) # /getNowHT路由。 获取当前温湿度 @app.route('/ht/getNowHT',methods=["GET", "POST"]) def get_now_ht(): sensor = Adafruit_DHT.DHT22 pin = 4 #GPIO4 humidity, temperature = Adafruit_DHT.read_retry(sensor, pin) humidity = '{0:0.1f}'.format(humidity) temperature = '{0:0.1f}'.format(temperature) # 整理成json格式 jsonData = {} jsonData['temperature'] = temperature jsonData['humidity'] = humidity result = json.dumps(jsonData) return(result) def conn_db(): con = pymysql.connect( host = 'localhost', port = 3306, user = 'root', password = 'iloveu521', db = 'statistics', charset = 'utf8' ) return con # 查询几分钟以内的数据，默认一小时之内的 def get_jsondata(range=1,n=20): con = conn_db() cur = con.cursor() result = cur.execute("SELECT id,temperature,humidity,create_time FROM ht WHERE DATE_FORMAT(create_time,'%%i')%%%s = 0 AND create_time >= DATE_SUB(NOW(), INTERVAL %s MINUTE) order by create_time " %(range,n)) u=cur.fetchall() con.close() print(u) # 整理成json格式 jsonData = {} xTime = [] yHvalues = [] yTvalues = [] for data in u: # xdays.append(str(data[0])) # xTime.append(data[3].strftime('%Y-%m-%d %H:%M:%S')) xTime.append(time.mktime(data[3].timetuple())) yHvalues.append(data[2]) yTvalues.append(data[1]) jsonData['xTime']=xTime jsonData['yHvalues'] = yHvalues jsonData['yTvalues'] = yTvalues result = json.dumps(jsonData) return(result) if __name__ == '__main__': app.run(host='0.0.0.0',port=5000)