### 实现 ESP32 上的传感器数据采集、本地存储与 MQTT 数据推送 要在 ESP32 上使用 MicroPython 实现传感器数据采集、本地存储并通过 MQTT 协议将数据推送到远程服务器，需要按照以下步骤进行开发。 --- #### 1. **传感器数据采集** ESP32 支持多种类型的传感器（如 DHT11/DHT22 温湿度传感器、BME280 环境传感器等），可以通过 I2C、SPI 或 GPIO 引脚进行连接。MicroPython 提供了相应的驱动库用于读取传感器数据。 以 DHT22 为例： ```python import dht from machine import Pin import time # 初始化 DHT22 传感器连接到 GPIO4 d = dht.DHT22(Pin(4)) while True: d.measure() temperature = d.temperature() # 获取温度值 humidity = d.humidity() # 获取湿度值 print("Temperature: {}°C, Humidity: {}%".format(temperature, humidity)) time.sleep(5) # 每隔 5 秒采集一次 ``` --- #### 2. **本地存储数据** ESP32 可以外接 SD 卡模块或使用内部 Flash 存储数据。在 MicroPython 中，可以使用 `os` 和 `ujson` 模块将传感器数据写入文件系统。 示例：将数据保存到 SPIFFS 文件系统中 ```python import os import ujson def save_to_file(data): with open('sensor_data.json', 'a') as f: f.write(ujson.dumps(data) + '\n') # 示例调用 data = {"temperature": 26.5, "humidity": 60, "timestamp": "2023-10-01T12:00:00Z"} save_to_file(data) ``` --- #### 3. **通过 MQTT 推送数据** MicroPython 支持 `umqttsimple` 库来实现 MQTT 客户端功能。通过该库可以连接到 MQTT Broker 并发布传感器数据。 ```python from umqttsimple import MQTTClient import network import time # 连接 Wi-Fi 函数 def connect_wifi(): wlan = network.WLAN(network.STA_IF) wlan.active(True) if not wlan.isconnected(): print('Connecting to WiFi...') wlan.connect('SSID', 'PASSWORD') while not wlan.isconnected(): pass print('Network config:', wlan.ifconfig()) # 连接到 MQTT Broker def connect_mqtt(): client = MQTTClient(client_id="esp32_client", server="broker.emqx.io") client.connect() return client # 发布数据 def publish_data(client, topic, data): client.publish(topic, ujson.dumps(data)) # 主程序 connect_wifi() mqtt_client = connect_mqtt() publish_topic = b"sensor/environment" while True: # 假设获取到传感器数据 sensor_data = {"temperature": 26.5, "humidity": 60} # 本地存储 save_to_file(sensor_data) # MQTT 推送 publish_data(mqtt_client, publish_topic, sensor_data) print("Published:", sensor_data) time.sleep(10) ``` --- #### 4. **安全性与扩展性考虑** 在实际部署中，建议采用以下措施提升系统安全性和稳定性： - 使用 TLS 加密连接 MQTT Broker。 - 启用 QoS 级别为 1 或 2 以确保消息可靠传输。 - 使用唯一设备 ID 和认证机制（如用户名/密码或客户端证书）。 - 对本地存储的数据进行定期清理或同步至云端[^2]。 ---