用树莓派Pico构建环境数据记录器的完整指南
在物联网和嵌入式系统开发中，可靠的数据采集与存储是许多项目的核心需求。想象一下，您需要在温室中持续监测温湿度变化，或者在野外记录气象数据，甚至只是简单地跟踪家中空气质量——这些场景都需要一个能够长时间独立工作、稳定记录数据的设备。本文将带您一步步构建这样一个系统，使用树莓派Pico开发板、MicroPython编程语言和一些常见传感器模块，打造一个功能完善的环境数据记录器。
1. 硬件准备与连接
1.1 所需组件清单
构建一个完整的数据记录系统需要以下硬件组件：
- 树莓派Pico开发板：RP2040微控制器的核心载体
- MicroSD卡模块：推荐使用SPI接口版本
- 8GB或更大容量的MicroSD卡：建议Class 10以上速度等级
- 环境传感器：根据需求选择DHT11/DHT22(温湿度)、BME280(温湿度气压)或DS18B20(温度)
- 连接线材：公对母杜邦线若干
- 电源供应：可通过Micro USB供电或使用电池组
1.2 硬件连接指南
正确的硬件连接是项目成功的基础。以下是典型的接线方式：
| 模块引脚 | Pico GPIO引脚 | 功能说明 |
|---|---|---|
| MicroSD模块VCC | 3V3(OUT) | 3.3V电源 |
| MicroSD模块GND | GND | 接地 |
| MicroSD模块MISO | GP12 | SPI数据输入 |
| MicroSD模块MOSI | GP11 | SPI数据输出 |
| MicroSD模块SCK | GP10 | SPI时钟 |
| MicroSD模块CS | GP13 | 片选信号 |
对于DHT11温湿度传感器：
DHT11 VCC → 3V3(OUT) DHT11 GND → GND DHT11 DATA → GP15(需上拉4.7K电阻)提示：所有数字信号线建议使用短距离连接(不超过20cm)，长距离传输可能导致信号衰减和数据错误。
2. 软件环境配置
2.1 MicroPython固件与驱动
首先确保您的Pico已刷入最新版MicroPython固件。然后需要准备SD卡驱动文件：
# sdcard.py - MicroPython SD卡驱动 from micropython import const import time _CMD_TIMEOUT = const(100) _R1_IDLE_STATE = const(1 << 0) # ... (完整驱动代码见上文或官方仓库)将上述驱动文件保存为sdcard.py并上传到Pico的文件系统中。对于传感器，通常需要对应的MicroPython库：
# dht.py - DHT传感器驱动 import machine import time class DHT11: def __init__(self, pin): self.pin = machine.Pin(pin, machine.Pin.OUT) # ... 初始化代码2.2 文件系统初始化
在MicroPython中挂载SD卡文件系统：
import machine import uos import sdcard # 初始化SPI和SD卡 spi = machine.SPI(1, sck=machine.Pin(10), mosi=machine.Pin(11), miso=machine.Pin(12)) cs = machine.Pin(13, machine.Pin.OUT) sd = sdcard.SDCard(spi, cs) # 挂载文件系统 vfs = uos.VfsFat(sd) uos.mount(vfs, "/sd") print("SD卡已挂载，内容:", uos.listdir("/sd"))3. 数据记录逻辑实现
3.1 传感器数据采集
不同传感器的数据采集方式各异。以DHT11为例：
def read_dht11(pin): # 实现DHT11数据读取 # 返回温度和湿度元组 (temp, humidity) pass # 或者使用现成的库 from dht import DHT11 dht = DHT11(machine.Pin(15)) temp, humidity = dht.measure()对于更精确的BME280传感器：
from machine import I2C, Pin import bme280 i2c = I2C(0, scl=Pin(17), sda=Pin(16)) bme = bme280.BME280(i2c=i2c) data = bme.values # 返回(temperature, pressure, humidity)3.2 带时间戳的数据记录
为数据添加时间戳可大大提高记录的实用性：
import utime def get_timestamp(): # 获取当前时间戳 year, month, day, hour, minute, second, _, _ = utime.localtime() return f"{year}-{month:02d}-{day:02d} {hour:02d}:{minute:02d}:{second:02d}" def log_data(filename, data): timestamp = get_timestamp() line = f"{timestamp},{','.join(map(str, data))}\n" with open(filename, "a") as f: f.write(line)3.3 文件管理策略
长期运行的数据记录器需要合理的文件管理：
def get_daily_filename(): # 按日期创建新文件 year, month, day, _, _, _, _, _ = utime.localtime() return f"/sd/data_{year}{month:02d}{day:02d}.csv" def init_data_file(filename, headers): # 如果文件不存在，创建并写入表头 try: with open(filename, "r") as f: pass # 文件存在 except: with open(filename, "w") as f: f.write(",".join(headers) + "\n")4. 完整系统集成与优化
4.1 主程序循环
将各个模块整合成一个完整的系统：
def main(): # 初始化硬件 init_sd_card() sensor = DHT11(machine.Pin(15)) # 准备数据文件 filename = get_daily_filename() init_data_file(filename, ["timestamp", "temperature", "humidity"]) # 主循环 while True: try: temp, humidity = sensor.measure() log_data(filename, (temp, humidity)) print(f"记录数据: {temp}C, {humidity}%") except Exception as e: print(f"错误: {e}") # 每5分钟记录一次 utime.sleep(300) if __name__ == "__main__": main()4.2 电源管理与低功耗
对于电池供电的应用，功耗优化至关重要：
from machine import deepsleep def low_power_mode(): # 配置低功耗模式 # 关闭不必要的外设 machine.Pin(25, machine.Pin.OUT).value(0) # 关闭LED # 设置深度睡眠 print("进入深度睡眠，60秒后唤醒") machine.deepsleep(60000) # 60秒4.3 数据完整性保障
确保数据不会因意外断电而丢失：
def safe_write(filename, data): # 安全写入策略 tempname = filename + ".tmp" try: # 先写入临时文件 with open(tempname, "w") as f: f.write(data) # 然后重命名为目标文件 uos.rename(tempname, filename) except: # 出错时尝试删除临时文件 try: uos.remove(tempname) except: pass raise5. 进阶功能扩展
5.1 多传感器融合
结合多种传感器获取更全面的环境数据：
def read_all_sensors(): # 读取所有连接的传感器 results = {} # DHT11数据 try: temp, humidity = dht.measure() results.update({"dht_temp": temp, "dht_humidity": humidity}) except: pass # BME280数据 try: bme_temp, pressure, bme_humidity = bme.values results.update({ "bme_temp": bme_temp, "pressure": pressure, "bme_humidity": bme_humidity }) except: pass return results5.2 数据可视化准备
将原始数据转换为更易分析的格式：
def generate_daily_report(date): # 生成指定日期的数据报告 filename = f"/sd/data_{date}.csv" try: with open(filename, "r") as f: lines = f.readlines() if len(lines) < 2: return None # 解析数据 timestamps = [] temperatures = [] humidities = [] for line in lines[1:]: # 跳过表头 parts = line.strip().split(",") timestamps.append(parts[0]) temperatures.append(float(parts[1])) humidities.append(float(parts[2])) # 计算统计值 stats = { "date": date, "avg_temp": sum(temperatures)/len(temperatures), "max_temp": max(temperatures), "min_temp": min(temperatures), "avg_humidity": sum(humidities)/len(humidities), "samples": len(temperatures) } return stats except: return None5.3 无线数据传输
结合Pico W实现无线数据传输：
import network import urequests def connect_wifi(ssid, password): wlan = network.WLAN(network.STA_IF) wlan.active(True) wlan.connect(ssid, password) # 等待连接 max_wait = 10 while max_wait > 0: if wlan.status() < 0 or wlan.status() >= 3: break max_wait -= 1 time.sleep(1) if wlan.status() != 3: raise RuntimeError("网络连接失败") else: print("已连接，IP:", wlan.ifconfig()[0]) def upload_data(url, data): try: response = urequests.post(url, json=data) return response.status_code == 200 except: return False6. 实际部署注意事项
6.1 外壳与物理保护
长期部署需要考虑物理保护：
- 使用防水防尘外壳保护电子元件
- 确保通风良好以避免传感器读数偏差
- 固定所有连接线防止松动
6.2 数据备份策略
重要数据的备份方案：
def backup_data(source_dir, backup_dir): # 创建备份目录 try: uos.mkdir(backup_dir) except: pass # 备份所有数据文件 for fname in uos.listdir(source_dir): if fname.startswith("data_") and fname.endswith(".csv"): source = f"{source_dir}/{fname}" target = f"{backup_dir}/{fname}" with open(source, "r") as src, open(target, "w") as dst: dst.write(src.read())6.3 长期运行维护
确保系统稳定运行的技巧：
- 定期检查SD卡剩余空间
- 实现自动日志轮转避免单个文件过大
- 添加系统状态LED指示
- 实现看门狗定时器防止程序卡死
from machine import WDT wdt = WDT(timeout=8000) # 8秒看门狗 def main_loop(): while True: # 主循环工作 collect_and_log_data() # 喂狗 wdt.feed()
