1. 项目概述：为什么需要Python作为Arduino与ThingSpeak的桥梁？

如果你玩过Arduino，大概率对ThingSpeak这个物联网平台不陌生。它提供了一个非常直观的界面，让你能把传感器数据上传上去，生成漂亮的图表，甚至还能做一些简单的分析和触发动作。传统的玩法是让Arduino板子（比如ESP8266/ESP32）直接通过Wi-Fi连接ThingSpeak的API，这需要你的Arduino具备网络模块，并且要在代码里写死Wi-Fi密码和API密钥。

但这里有个痛点：很多经典的Arduino开发板，比如Arduino Uno，它本身没有网络功能。你想让它把温湿度数据发到云端，就得额外加一个Wi-Fi或以太网扩展板，不仅增加了硬件成本和复杂度，对代码的稳定性要求也更高。另一个场景是，你的数据采集可能在离线环境下进行（比如用SD卡记录），或者你希望用电脑更强大的算力对数据进行预处理、过滤异常值、与本地数据库同步，然后再上传。这时候，让Python来当这个“中间人”或“数据管家”就非常合适了。

Python脚本运行在你的电脑或树莓派这样的单板计算机上，它可以通过串口（USB）从Arduino读取原始数据，进行解析、计算、打包，然后利用其丰富的网络库（如requests）稳定地发送到ThingSpeak。这种架构解耦了数据采集和网络通信，让Arduino专心做它擅长的实时I/O控制，而把复杂的网络交互和数据处理交给更强大的Python环境。对于数据分析、自动化脚本集成以及需要复杂逻辑后再上报的场景，这种方法提供了极大的灵活性。

2. 系统架构与核心组件选型

2.1 硬件清单与连接方式

这个项目的硬件部分非常简单核心。

  1. Arduino开发板 ：任何型号均可，如Arduino Uno R3是最常见的选择。它的任务就是读取传感器数据，并通过串口发送出来。
  2. 传感器 ：根据你的项目需求选择。例如，要监测环境，可以使用DHT11/DHT22温湿度传感器；监测光照，可以用光敏电阻模块；检测距离，可以用HC-SR04超声波模块。这里以DHT22为例，它精度比DHT11高，且是单总线通信。
  3. 连接线 ：若干杜邦线用于连接Arduino和传感器。
  4. 电脑 ：运行Python脚本的主机。也可以是树莓派，这样就能构成一个常驻的物联网网关。

硬件连接示意图（以Arduino Uno + DHT22为例） ：

  • DHT22 ：
    • VCC 引脚 -> Arduino 5V
    • GND 引脚 -> Arduino GND
    • DATA 引脚 -> Arduino 数字引脚 2 (可更换，需在代码中对应)
  • USB数据线 ：连接Arduino和电脑，用于供电和串口通信。

注意 ：DHT22的数据引脚需要连接一个4.7KΩ - 10KΩ的上拉电阻到VCC，以确保信号稳定。很多现成的模块已经集成了这个电阻，购买时留意一下。

2.2 软件与环境准备

软件栈分为Arduino端和Python端。

Arduino端 ：

  1. Arduino IDE ：用于编写和上传代码到Arduino板。确保已安装，并且安装了对应板型的支持（如Uno默认就有）。
  2. 必要的库 ：对于DHT22传感器，需要安装 DHT sensor library 。在Arduino IDE中，点击“工具” -> “管理库”，搜索“DHT sensor library by Adafruit”并安装。它通常会连带安装 Adafruit Unified Sensor 库。

Python端 ：

  1. Python解释器 ：建议使用Python 3.7及以上版本。可以从Python官网下载安装，安装时务必勾选“Add Python to PATH”。
  2. 包管理工具pip ：通常随Python安装包一同安装。
  3. 必需的Python库 ：我们需要两个核心库。
    • pyserial ：用于通过串口与Arduino通信。
    • requests ：用于发送HTTP POST请求到ThingSpeak API。 打开命令行（CMD或终端），执行以下命令安装：
    pip install pyserial requests
  4. 代码编辑器 ：选择你顺手的即可，如VS Code、PyCharm，甚至记事本。VS Code配合Python插件体验很好。

2.3 ThingSpeak平台配置

这是数据的目的地，需要提前设置好。

  1. 注册与登录 ：访问ThingSpeak官网，用MathWorks账号登录（没有则需注册）。
  2. 创建频道（Channel） ：
    • 点击“Channels” -> “My Channels” -> “New Channel”。
    • 填写频道信息： Name （如“Home Environment”）， Description （可选）。
    • 最关键的是定义字段（Fields）。每个字段对应一个你要上传的数据流。例如，我们上传温度和湿度，就勾选 Field 1 和 Field 2 ，并分别命名为“Temperature”和“Humidity”。你可以创建最多8个字段。
    • 其他设置如地理位置等可选，然后点击“Save Channel”。
  3. 获取API密钥 ：
    • 频道保存后，点击顶部“API Keys”标签页。
    • 这里你会看到两个重要的密钥：
      • Write API Key ：用于向频道写入数据。务必保密！我们的Python脚本将用到它。
      • Read API Key ：用于从频道读取数据，本次项目用不到。
    • 记下你的 Write API Key 和 Channel ID （在频道页面也能看到），后面会写入Python脚本。

3. Arduino端程序设计：稳定可靠的数据源

Arduino端的代码核心任务是：初始化传感器、定时读取数据、格式化并通过串口输出。代码的稳定性和容错性很重要。

3.1 代码实现与解析

以下是完整的Arduino Sketch代码，保存为 arduino_to_serial.ino 。

#include <DHT.h>

// 定义DHT22连接的引脚和类型
#define DHTPIN 2
#define DHTTYPE DHT22

// 初始化DHT传感器对象
DHT dht(DHTPIN, DHTTYPE);

// 设置全局变量和延时
unsigned long previousMillis = 0;
const long interval = 5000; // 读取间隔，单位毫秒（5秒）

void setup() {
  // 启动串口通信，波特率设置为9600
  // 注意：此波特率需与Python端设置一致
  Serial.begin(9600);
  // 等待串口连接稳定，对于USB虚拟串口尤其重要
  while (!Serial) {
    ; // 等待串口端口连接。仅对Leonardo、Micro等原生USB板必需，但对所有板无害。
  }

  // 初始化DHT传感器
  dht.begin();
  Serial.println("Arduino DHT22 Sensor Started.");
  Serial.println("Data Format: temperature,humidity");
}

void loop() {
  unsigned long currentMillis = millis();

  // 使用非阻塞延时，避免delay()函数卡住整个程序
  if (currentMillis - previousMillis >= interval) {
    previousMillis = currentMillis;

    // 读取温湿度数据
    float humidity = dht.readHumidity();
    float temperature = dht.readTemperature(); // 默认为摄氏度

    // 检查读取是否成功（返回NaN表示读取失败）
    if (isnan(humidity) || isnan(temperature)) {
      Serial.println("Failed to read from DHT sensor!");
      // 可以选择发送一个错误标识，如“-999,-999”
      // Serial.println("-999,-999");
      return; // 跳过本次发送，等待下次循环
    }

    // 格式化数据为字符串：温度,湿度
    // 使用两位小数精度，ThingSpeak能很好处理浮点数
    String dataString = String(temperature, 2) + "," + String(humidity, 2);

    // 通过串口发送数据
    Serial.println(dataString); // 使用println自动添加换行符(\n)

    // 可选：在串口监视器中也打印，用于调试
    // Serial.print("Sent: ");
    // Serial.println(dataString);
  }
  // 循环的其他部分可以执行其他任务
}

3.2 关键代码细节与避坑指南

  1. 波特率一致性 ： Serial.begin(9600) 中的 9600 是波特率，表示每秒传输的符号数。 必须确保Python脚本中打开串口时也使用相同的波特率 ，否则接收到的将是乱码。9600是一个通用且稳定的速率，对于这类低频数据绰绰有余。
  2. 非阻塞延时 ：使用 millis() 进行定时，而不是 delay() 。这是Arduino编程的一个好习惯。 delay() 会阻塞整个程序，期间无法响应其他事件（如读取其他传感器）。而 millis() 只是检查时间是否到期，不阻塞，为未来功能扩展留有余地。
  3. 数据校验 ： dht.read 函数可能失败（尤其是上电初期或接线不良）。使用 isnan() 函数检查返回值是否为“非数字”（NaN），是则打印错误并跳过本次发送，避免将无效数据上传到云端。
  4. 数据格式化 ：我们选择用逗号分隔温度和湿度（ “23.50,65.20” ），并以换行符( \n )结尾。这种 CSV 格式简单通用，Python端很容易用 split(‘,’) 进行分割。确保格式稳定，不要有时多一个空格有时少一个。
  5. 上传代码 ：用USB线连接Arduino和电脑，在IDE中选择正确的板型（如Arduino Uno）和端口，点击上传。上传成功后，可以打开IDE的串口监视器（波特率设为9600），应该能看到每5秒打印一行的“温度,湿度”数据。这是第一个关键调试步骤，确保Arduino端工作正常。

实操心得 ：DHT系列传感器对时序要求较严，避免在 loop() 中过于频繁地调用 read 函数，至少间隔2秒。另外，为其数据引脚增加一个上拉电阻（模块已集成则忽略）能极大提高读数稳定性。如果串口监视器看到大量“Failed to read”提示，首先检查接线和电源。

4. Python端脚本开发：数据的中转与上传枢纽

Python脚本承担核心的中转逻辑：监听串口、解析数据、构造HTTP请求、上传至ThingSpeak。我们需要考虑稳定性、异常处理和资源管理。

4.1 完整Python脚本解析

创建一个名为 thingspeak_uploader.py 的文件，将以下代码复制进去，并修改其中的配置参数。

import serial
import requests
import time
from datetime import datetime
import sys

# ==================== 用户配置区域 ====================
# ThingSpeak 配置
THINGSPEAK_API_KEY = 'YOUR_WRITE_API_KEY_HERE'  # 替换为你的Write API Key
THINGSPEAK_CHANNEL_ID = 'YOUR_CHANNEL_ID_HERE' # 替换为你的频道ID
THINGSPEAK_URL = f'https://api.thingspeak.com/update?api_key={THINGSPEAK_API_KEY}'

# 串口配置
SERIAL_PORT = 'COM3'  # Windows系统端口，如 COM3, COM4
# SERIAL_PORT = '/dev/ttyUSB0'  # Linux/macOS系统端口，如 /dev/ttyUSB0, /dev/ttyACM0
BAUD_RATE = 9600  # 必须与Arduino程序中的设置一致

# 数据上传间隔（秒）
# ThingSpeak免费账户限制：每15秒才能更新一次数据
UPLOAD_INTERVAL = 16  # 设置为略高于15秒，确保不超限
# ==================== 配置结束 ====================

def parse_sensor_data(line):
    """
    解析从串口读取的一行数据。
    预期格式: "temperature,humidity" (例如 "23.50,65.20")
    返回: (temperature, humidity) 元组，解析失败返回 (None, None)
    """
    try:
        # 去除字符串首尾的空白字符（包括换行符）
        line = line.strip()
        if not line:
            return None, None

        # 使用逗号分割字符串
        parts = line.split(',')
        if len(parts) != 2:
            print(f"[解析错误] 数据格式不符，期望2个值，得到{len(parts)}个: {line}")
            return None, None

        temp = float(parts[0])
        humi = float(parts[1])

        # 简单的数据合理性校验（DHT22范围）
        if -40 <= temp <= 80 and 0 <= humi <= 100:
            return temp, humi
        else:
            print(f"[数据异常] 数值超出合理范围: Temp={temp}, Humi={humi}")
            return None, None

    except ValueError as e:
        # 如果转换float失败（例如接收到非数字字符）
        print(f"[解析错误] 无法将数据转换为浮点数: {line}, 错误: {e}")
        return None, None
    except Exception as e:
        print(f"[解析错误] 未知错误: {e}")
        return None, None

def upload_to_thingspeak(temperature, humidity):
    """
    将温湿度数据上传到ThingSpeak。
    返回: True如果上传成功，否则False。
    """
    # 构造请求参数
    payload = {
        'api_key': THINGSPEAK_API_KEY,
        'field1': temperature,
        'field2': humidity
    }

    try:
        # 发送HTTP GET请求（ThingSpeak API支持GET和POST）
        response = requests.get(THINGSPEAK_URL, params=payload, timeout=10)
        # 也可以使用 requests.post(THINGSPEAK_URL, data=payload)

        # 检查响应
        if response.status_code == 200:
            # ThingSpeak成功接收后，会返回一个更新ID（大于0）
            update_id = int(response.text)
            if update_id > 0:
                print(f"[{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}] 上传成功! 更新ID: {update_id}")
                return True
            else:
                # 更新ID为0通常表示API Key错误或字段未定义
                print(f"[上传失败] 服务器响应异常: {response.text}")
                return False
        else:
            print(f"[上传失败] HTTP状态码: {response.status_code}, 响应: {response.text}")
            return False

    except requests.exceptions.ConnectionError:
        print("[网络错误] 无法连接到ThingSpeak服务器，请检查网络。")
        return False
    except requests.exceptions.Timeout:
        print("[网络错误] 请求超时，服务器响应过慢。")
        return False
    except Exception as e:
        print(f"[上传错误] 未知错误: {e}")
        return False

def main():
    print("=== Arduino数据上传ThingSpeak脚本启动 ===")
    print(f"串口: {SERIAL_PORT}, 波特率: {BAUD_RATE}")
    print(f"ThingSpeak频道ID: {THINGSPEAK_CHANNEL_ID}")
    print(f"数据上传间隔: {UPLOAD_INTERVAL} 秒")
    print("=" * 50)

    ser = None
    last_upload_time = 0

    try:
        # 1. 初始化串口连接
        ser = serial.Serial(SERIAL_PORT, BAUD_RATE, timeout=1)
        # 等待串口初始化稳定
        time.sleep(2)
        print(f"已连接到串口 {SERIAL_PORT}。等待数据...")

        # 清空可能存在的旧缓冲区数据
        ser.reset_input_buffer()

        while True:
            # 2. 从串口读取一行数据
            if ser.in_waiting > 0:
                try:
                    # 解码字节为字符串，假设编码为'ascii'或'utf-8'
                    line = ser.readline().decode('utf-8').strip()
                except UnicodeDecodeError:
                    # 如果解码失败，尝试忽略错误或使用其他编码
                    line = ser.readline().decode('utf-8', errors='ignore').strip()

                if line:
                    print(f"[原始数据] {line}")
                    # 3. 解析数据
                    temperature, humidity = parse_sensor_data(line)

                    if temperature is not None and humidity is not None:
                        current_time = time.time()
                        # 4. 检查是否达到上传间隔
                        if current_time - last_upload_time >= UPLOAD_INTERVAL:
                            print(f"[准备上传] 温度: {temperature:.2f}°C, 湿度: {humidity:.2f}%")
                            # 5. 上传数据
                            if upload_to_thingspeak(temperature, humidity):
                                last_upload_time = current_time
                            else:
                                print("上传失败，将在下次数据到达时重试。")
                        else:
                            wait_time = UPLOAD_INTERVAL - (current_time - last_upload_time)
                            print(f"[跳过上传] 距离下次上传还需 {wait_time:.1f} 秒。")
                    else:
                        print("[数据无效] 跳过本次数据。")
            else:
                # 没有数据时短暂休眠，降低CPU占用
                time.sleep(0.1)

    except serial.SerialException as e:
        print(f"[严重错误] 无法打开或访问串口 {SERIAL_PORT}: {e}")
        print("请检查：")
        print("  1. Arduino是否通过USB连接？")
        print(f"  2. 端口号 '{SERIAL_PORT}' 是否正确？")
        print("  3. 是否有其他程序（如Arduino IDE串口监视器）占用了该端口？")
    except KeyboardInterrupt:
        print("\n用户中断脚本执行。")
    except Exception as e:
        print(f"[意外错误] 程序运行出错: {e}")
    finally:
        # 6. 清理工作：关闭串口
        if ser and ser.is_open:
            ser.close()
            print("串口连接已关闭。")
        print("脚本退出。")
        sys.exit(0)

if __name__ == "__main__":
    main()

4.2 脚本核心逻辑与配置要点

  1. 配置修改（重中之重） ：

    • THINGSPEAK_API_KEY ：替换为你在ThingSpeak频道页面获取的 Write API Key 。
    • THINGSPEAK_CHANNEL_ID ：替换为你的频道ID。
    • SERIAL_PORT ：这是最容易出错的地方。在Windows上，通常是 COM3 、 COM4 等，可以在设备管理器的“端口（COM和LPT）”下查看。在Linux/macOS上，通常是 /dev/ttyUSB0 或 /dev/ttyACM0 。 务必修改正确 。
    • BAUD_RATE ：必须与Arduino代码中的 Serial.begin(9600) 保持一致。
    • UPLOAD_INTERVAL ：ThingSpeak免费账户对每个频道有更新频率限制（通常是最短15秒更新一次）。设置为16秒是一个安全的选择，避免因频繁请求被拒绝。

  2. 数据解析函数 parse_sensor_data ：这个函数负责将原始的字符串（如 “23.50,65.20\n” ）转换为两个浮点数。它包含了错误处理：

    • strip() ：移除首尾空白字符，特别是换行符 \n 。
    • split(‘,’) ：按逗号分割。
    • float() 转换和 try-except ：确保数据是有效的数字。
    • 合理性校验：检查温湿度是否在DHT22的物理可能范围内，过滤明显错误的数据。

  3. 上传函数 upload_to_thingspeak ：使用 requests 库发送HTTP GET请求。ThingSpeak API通过URL参数接收数据。成功时，服务器会返回一个大于0的更新ID。我们通过检查状态码和返回值来判断是否成功。

  4. 主循环 main() ：

    • 使用 serial.Serial 初始化串口连接， timeout=1 表示读操作最多等待1秒。
    • ser.reset_input_buffer() ：清空连接建立前可能堆积的旧数据，避免处理延迟数据。
    • 核心是一个 while True 循环，不断检查串口缓冲区（ ser.in_waiting ）是否有数据。
    • 使用 readline() 读取直到遇到换行符，然后解码。这里捕获了 UnicodeDecodeError ，增强鲁棒性。
    • 解析成功的数据，会根据 UPLOAD_INTERVAL 决定是否立即上传，避免触发ThingSpeak的速率限制。
    • 使用 try-except-finally 结构确保即使程序出错或被用户中断（Ctrl+C），也能安全关闭串口连接，释放资源。

5. 系统联调与故障排除实录

将两部分代码分别部署后，就可以进行整体测试了。这个过程通常会遇到一些典型问题。

5.1 分步调试流程

  1. 第一步：独立测试Arduino 。

    • 上传Arduino代码后，不要运行Python脚本。
    • 打开Arduino IDE的串口监视器（波特率设为9600）。
    • 观察是否每5秒稳定输出一行 温度,湿度 格式的数据。如果输出 Failed to read from DHT sensor! ，检查DHT22的接线、电源和上拉电阻。确保传感器周围环境不是极端温湿度。

  2. 第二步：独立测试Python串口读取 。

    • 暂时注释掉 upload_to_thingspeak 函数调用和相关的间隔判断。
    • 在 main() 函数里，收到有效数据后，只打印不上传。
    • 运行Python脚本。你应该能看到它不断打印出从串口读取的原始数据以及解析后的温湿度值。如果这里收不到数据或数据是乱码，问题出在串口连接上。

  3. 第三步：独立测试ThingSpeak上传 。

    • 可以写一个简单的测试脚本，或者临时修改主脚本，手动构造一组温度湿度数据（如 25.0, 50.0 ），直接调用 upload_to_thingspeak 函数。
    • 运行后查看控制台输出。如果返回“上传成功”并带有更新ID，说明网络和API配置正确。如果失败，根据错误信息排查（通常是API Key错误、网络不通）。

  4. 第四步：全系统集成测试 。

    • 恢复所有代码，确保 UPLOAD_INTERVAL 设置正确（≥15秒）。
    • 运行Python脚本。观察控制台日志，应该能看到“原始数据”、“准备上传”、“上传成功”的完整流程。
    • 打开你的ThingSpeak频道页面，在“Private View”标签页下，应该能看到Field 1和Field 2的图表开始有数据点出现。

5.2 常见问题与解决方案速查表

下表总结了联调过程中最常见的问题、可能原因和解决方法。

问题现象 可能原因 排查步骤与解决方案
Python脚本报错： SerialException: could not open port ‘COM3’ 1. 端口号错误。
2. 端口被其他程序占用。
3. 驱动未安装。		 1. 检查端口号 ：在设备管理器（Windows）或 ls /dev/tty* （Linux/macOS）中确认Arduino连接的端口。关闭Arduino IDE的串口监视器。
2. 关闭占用程序 ：任何打开了该串口的程序（如另一个终端、旧的Python脚本、其他串口工具）都必须关闭。
3. 安装驱动 ：对于某些克隆板，可能需要手动安装CH340/CH341 USB转串口驱动。
Python脚本能连接串口，但读不到数据或数据乱码 1. 波特率不匹配。
2. 串口读取/解码方式错误。
3. Arduino未正确发送数据。		 1. 核对波特率 ：确保Python的 BAUD_RATE 与Arduino代码的 Serial.begin() 完全一致。
2. 检查代码 ：确认Arduino使用 Serial.println() 发送（带换行符），Python使用 readline() 读取。
3. 先测试Arduino ：用串口监视器确认Arduino本身输出正常。
控制台显示“上传失败”或HTTP错误码 1. API Key或Channel ID错误。
2. 网络连接问题。
3. 更新频率超限。		 1. 核对密钥 ：仔细检查 THINGSPEAK_API_KEY 和 THINGSPEAK_CHANNEL_ID 是否复制完整，有无多余空格。
2. 测试网络 ：在浏览器中手动访问 https://api.thingspeak.com/update?api_key=YOUR_KEY&field1=1 ，看能否返回更新ID。
3. 调整间隔 ：将 UPLOAD_INTERVAL 增加到20秒以上再试。免费账户限制严格。
ThingSpeak图表有数据，但更新非常慢或不规律 1. Python脚本的上传间隔 UPLOAD_INTERVAL 设置不当。
2. 网络延迟或丢包。
3. Arduino数据发送间隔与Python上传间隔不协调。		 1. 遵守平台限制 ：确保 UPLOAD_INTERVAL ≥ 15秒。可以设置为16-20秒以留有余地。
2. 增加重试机制 ：可以在 upload_to_thingspeak 函数内加入简单的重试逻辑（如失败后等待2秒重试一次）。
3. 优化节奏 ：确保Arduino发送数据的频率（如5秒一次）高于Python的上传频率（16秒一次），这样Python每次上传的都是相对最新的数据。
DHT22读数经常失败（输出NaN） 1. 电源不稳定或电压不足。
2. 信号线过长或干扰。
3. 传感器物理损坏。
4. 代码中读取间隔太短。		 1. 确保供电 ：使用开发板的5V引脚，并确保USB线或电源适配器能提供足够电流。尝试在VCC和GND之间并联一个100uF的电容滤波。
2. 缩短连线 ：数据线尽量短，并确保连接牢固。 必须使用上拉电阻 （4.7KΩ-10KΩ）。
3. 更换传感器 ：如果可能，换一个传感器测试。
4. 遵守时序 ：DHT22两次读取之间至少需要2秒间隔，我们的5秒间隔是足够的。

5.3 进阶优化与扩展思路

当基础功能稳定运行后，可以考虑以下优化，让项目更健壮、更实用：

  1. 本地数据日志 ：在Python脚本中，在解析数据后，除了上传，还可以将数据连同时间戳写入本地的CSV文件或SQLite数据库。这样即使网络中断，数据也不会丢失，后续可以补传或用于离线分析。

    import csv
def log_to_csv(temp, humi):
    with open('sensor_data.csv', 'a', newline='') as f:
        writer = csv.writer(f)
        writer.writerow([datetime.now().isoformat(), temp, humi])

  2. 增加传感器与字段 ：如果你想监控更多参数，比如光照和土壤湿度。

    • Arduino端 ：连接新传感器，读取数据，并修改数据格式。例如，改为 “温度,湿度,光照,土壤湿度” 。
    • ThingSpeak端 ：在频道设置中启用 Field 3 和 Field 4 ，并命名。
    • Python端 ：修改 parse_sensor_data 函数以解析4个值，并在 upload_to_thingspeak 的 payload 中添加 ‘field3’: light, ‘field4’: soil_moisture 。

  3. 异常处理与自动重连 ：网络和串口连接可能意外断开。可以在Python脚本的主循环外层增加一个 while 循环，如果串口异常断开，则尝试重新初始化连接；如果HTTP请求连续失败多次，则暂停一段时间后重试。

  4. 部署为后台服务 ：在树莓派或旧电脑上，可以使用 systemd （Linux）或任务计划程序（Windows）将Python脚本配置为开机自启的后台服务，实现24小时无人值守运行。

  5. 数据预处理 ：在Python端，你可以轻松实现Arduino难以完成的复杂计算，比如计算移动平均线以平滑数据、检测数据突变并触发本地警报（如发送邮件）、或者将摄氏温度转换为华氏温度后再上传。

这个项目搭建的管道是通用的。一旦跑通，你可以替换任何Arduino兼容的传感器，只需稍作修改，就能将各种物理世界的数据源源不断地输送到云端，为你的物联网应用打下坚实的基础。

Logo
亚马逊云科技技术品牌专区

更多推荐

cover

【会议征稿通知 | 兰州交通大学主办 | IEEE出版 | EI 、Scopus稳定检索】第七届物联网、人工智能与电气能源国际学术会议（IoTAIEE 2026）

avatar 亚马逊云科技技术品牌专区
cover

【无标题】

avatar 亚马逊云科技技术品牌专区
cover

互联网大厂 Java 求职面试：从音视频场景到云原生的技术挑战

avatar 亚马逊云科技技术品牌专区