### 实现方案 以下是基于STM32、ESP8266和Flask框架的数据采集与存储系统的具体实现方法。 #### 1. STM32端代码示例 STM32负责读取传感器数据并通过串口发送给ESP8266模块。以下是一个完整的代码示例： ```c #include "stm32f1xx_hal.h" // 定义全局变量 float temperature, humidity; // DHT11数据读取函数 void DHT11_Read_Data(float *temp, float *humi); // ESP8266数据发送函数 void ESP8266_Send_Data(char *data); int main(void) { // 初始化HAL库 HAL_Init(); SystemClock_Config(); MX_GPIO_Init(); MX_USART1_UART_Init(); // 初始化DHT11 DHT11_Init(); while (1) { // 读取温湿度数据 DHT11_Read_Data(&temperature, &humidity); // 格式化数据为字符串形式 char data[50]; sprintf(data, "temperature=%.1f&humidity=%.1f", temperature, humidity); // 将数据通过串口发送给ESP8266 ESP8266_Send_Data(data); // 延迟5秒再次采集数据 HAL_Delay(5000); } } // 模拟DHT11初始化函数 void DHT11_Init() { // 初始化逻辑省略... } // 模拟DHT11数据读取函数 void DHT11_Read_Data(float *temp, float *humi) { // 模拟返回固定值 *temp = 25.0; *humi = 60.0; } // 模拟ESP8266数据发送函数 void ESP8266_Send_Data(char *data) { // 使用USART发送数据到ESP8266 HAL_UART_Transmit(&huart1, (uint8_t *)data, strlen(data), HAL_MAX_DELAY); } ``` 此部分实现了从DHT11传感器获取数据，并将其格式化为`key=value`的形式，最后通过串口发送给ESP8266模块[^1]。 --- #### 2. ESP8266 AT指令配置 为了使ESP8266能够正常工作并将数据发送至Flask后端，需执行如下AT指令序列： | **命令** | **功能描述** | |-----------------------------------|------------------------------------------------------------------------------| | `AT+RESTORE` | 恢复出厂设置 | | `AT+CWMODE=1` | 设置WiFi模式为Station模式 | | `AT+CWJAP="SSID","PASSWORD"` | 连接指定的WiFi热点 | | `AT+CIPMUX=0` | 配置单连接模式 | | `AT+CIPSTART="TCP","SERVER_IP",PORT` | 开启TCP连接，目标地址为Flask服务器的IP和端口号 | | `AT+CIPSEND=<length>` | 发送数据长度 | 例如，假设Flask服务器运行在本地局域网中的`192.168.1.100`，监听端口为`8080`，则可以使用以下命令建立连接并发送数据： ```plaintext AT+CIPSTART="TCP","192.168.1.100",8080 OK > temperature=25.0&humidity=60.0 ``` 完成数据发送后，可以通过输入`CTRL-Z`结束当前会话[^2]。 --- #### 3. Flask后端代码示例 Flask应用程序用于接收来自ESP8266的数据，并将其保存到数据库中。以下是具体的实现代码： ```python from flask import Flask, request import mysql.connector app = Flask(__name__) # 数据库连接配置 db_config = { 'host': 'localhost', 'user': 'root', 'password': 'your_password', 'database': 'sensor_data' } @app.route('/store', methods=['POST']) def store_sensor_data(): try: # 获取请求参数 temperature = request.args.get('temperature') humidity = request.args.get('humidity') if not temperature or not humidity: return "Missing parameters!", 400 # 插入数据到MySQL数据库 connection = mysql.connector.connect(**db_config) cursor = connection.cursor() query = "INSERT INTO sensor_readings (temperature, humidity) VALUES (%s, %s)" values = (temperature, humidity) cursor.execute(query, values) connection.commit() cursor.close() connection.close() return "Data stored successfully!" except Exception as e: return f"Error: {str(e)}", 500 if __name__ == '__main__': app.run(host='0.0.0.0', port=8080) ``` 在此代码中，当ESP8266向`http://<server_ip>:8080/store?temperature=25.0&humidity=60.0`发起HTTP POST请求时，Flask将解析查询参数并将其存入MySQL数据库[^3]。 --- #### 4. 数据库存储结构 创建一个名为`sensors_data`的数据库以及对应的表来存储传感器数据。SQL语句如下所示： ```sql CREATE DATABASE IF NOT EXISTS sensor_data; USE sensor_data; CREATE TABLE IF NOT EXISTS sensor_readings ( id INT AUTO_INCREMENT PRIMARY KEY, timestamp DATETIME DEFAULT CURRENT_TIMESTAMP, temperature FLOAT NOT NULL, humidity FLOAT NOT NULL ); ``` 该表记录每次传感器数据的时间戳及其对应的具体数值[^1]。 --- ###