用树莓派Pico和MicroPython打造一个简易数据记录器：从环境传感器到SD卡存储

用树莓派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模块VCC3V3(OUT)3.3V电源MicroSD模块GNDGND接地MicroSD模块MISOGP12SPI数据输入MicroSD模块MOSIGP11SPI数据输出MicroSD模块SCKGP10SPI时钟MicroSD模块CSGP13片选信号对于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, sckmachine.Pin(10), mosimachine.Pin(11), misomachine.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, sclPin(17), sdaPin(16)) bme bme280.BME280(i2ci2c) 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, jsondata) 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(timeout8000) # 8秒看门狗 def main_loop(): while True: # 主循环工作 collect_and_log_data() # 喂狗 wdt.feed()