### Arduino与Python配合实现心率传感器数据采集和波形绘制的串口通信多任务解决方案 #### 1. 硬件与软件配置 硬件部分包括Arduino开发板、MAX30100心率传感器以及计算机。MAX30100通过I2C协议与Arduino通信[^1]，而Arduino通过USB串口与计算机连接。Python程序负责接收串口数据并进行实时处理与可视化。 #### 2. Arduino端代码设计 Arduino端代码的主要功能是初始化MAX30100传感器，读取心率数据并通过串口发送给Python程序。以下是一个简化的代码示例： ```cpp #include <Wire.h> #include <Adafruit_MAX30100.h> Adafruit_MAX30100 sensor; void setup() { Serial.begin(9600); if (!sensor.begin()) { Serial.println("MAX30100 没有找到！"); while (1); } } void loop() { if (sensor.available()) { sensor.read(); Serial.print("Heart Rate: "); Serial.print(sensor.getHeartRate()); Serial.println(" bpm"); } delay(500); } ``` 此代码实现了心率数据的读取与发送。 #### 3. Python端代码设计 Python端需要完成以下任务： - 初始化串口通信。 - 实时接收并解析来自Arduino的心率数据。 - 使用`matplotlib`库实现实时波形绘制。 以下是完整的Python代码示例： ```python import serial import matplotlib.pyplot as plt import numpy as np from collections import deque # 初始化串口 ser = serial.Serial('COM3', 9600) # 根据实际串口号修改 print("Serial Port Opened...") data_buffer = deque(maxlen=100) # 创建一个固定长度的数据缓冲区 # 初始化图形界面 plt.ion() # 打开交互模式 fig, ax = plt.subplots() line, = ax.plot([]) def update_plot(): ax.relim() # 更新坐标轴范围 ax.autoscale_view() # 自动缩放视图 line.set_xdata(np.arange(len(data_buffer))) # 设置x轴数据 line.set_ydata(data_buffer) # 设置y轴数据 fig.canvas.draw() fig.canvas.flush_events() try: while True: if ser.in_waiting > 0: line = ser.readline().decode('utf-8').strip() if "Heart Rate" in line: heart_rate = int(line.split(":")[1].split(" ")[0]) # 提取心率数值 data_buffer.append(heart_rate) # 将心率添加到缓冲区 update_plot() # 更新波形图 except KeyboardInterrupt: print("Exiting Program") finally: ser.close() ``` 此代码实现了串口数据的接收与解析，并通过`matplotlib`动态绘制心率波形[^2]。 #### 4. 解决串口通信多任务问题 当需要同时处理多个任务时（例如同时采集心率数据和血氧饱和度数据），可以通过以下方法优化系统架构： - **多线程编程**：在Python中使用`threading`模块创建多个线程，分别处理数据采集与波形绘制任务。 - **队列管理**：使用`queue.Queue`来存储从串口接收到的数据，确保数据在不同线程之间的安全传递。 以下是一个基于多线程的改进版Python代码示例： ```python import serial import threading import queue import matplotlib.pyplot as plt import numpy as np from collections import deque # 初始化串口 ser = serial.Serial('COM3', 9600) data_queue = queue.Queue() # 创建队列用于存储数据 data_buffer = deque(maxlen=100) # 初始化图形界面 plt.ion() fig, ax = plt.subplots() line, = ax.plot([]) def read_serial(): while True: if ser.in_waiting > 0: line = ser.readline().decode('utf-8').strip() if "Heart Rate" in line: try: heart_rate = int(line.split(":")[1].split(" ")[0]) data_queue.put(heart_rate) # 将心率数据放入队列 except ValueError: pass def update_plot(): while True: if not data_queue.empty(): heart_rate = data_queue.get() data_buffer.append(heart_rate) ax.relim() ax.autoscale_view() line.set_xdata(np.arange(len(data_buffer))) line.set_ydata(data_buffer) fig.canvas.draw() fig.canvas.flush_events() try: thread_read = threading.Thread(target=read_serial, daemon=True) thread_plot = threading.Thread(target=update_plot, daemon=True) thread_read.start() thread_plot.start() while True: pass # 主线程保持运行 except KeyboardInterrupt: print("Exiting Program") finally: ser.close() ``` 此代码通过多线程技术解决了串口通信中的多任务问题[^3]。 #### 5. 数据处理与扩展 除了实时波形绘制外，还可以对心率数据进行进一步处理，例如： - **滤波处理**：使用低通滤波器去除高频噪声。 - **频域分析**：计算心率变异性（HRV）以评估心脏健康状况。 - **数据存储**：将心率数据保存到文件或数据库中以便后续分析。 --- ###