从零构建物联网数据上报系统Air724UG与Python实战指南在万物互联的时代物联网技术正悄然改变着我们的生活和工作方式。想象一下您只需轻点手机就能实时查看千里之外温湿度数据或是远程监控设备运行状态提前预警潜在故障。这种看似科幻的场景如今借助4G模块和简单编程就能实现。本文将带您从零开始使用Air724UG 4G模块和Python语言构建一套完整的物联网数据上报系统。这个项目特别适合那些已经掌握基础编程知识但渴望将零散技能整合为实际应用的开发者。不同于单纯的理论讲解我们将聚焦于端到端的实现过程——从硬件连接到云端展示每个环节都配有可落地的代码和配置说明。无论您是希望快速验证创意的极客还是需要实际部署监测系统的工程师都能从中获得实用价值。1. 硬件准备与环境搭建1.1 所需材料清单构建这套系统需要以下硬件组件Air724UG 4G模块支持LTE Cat1具备TCP/IP协议栈STM32/51单片机开发板作为数据采集终端SIM卡支持移动/联通/电信的物联网卡或普通流量卡温湿度传感器如DHT11或更精确的SHT30USB转TTL模块用于调试4G模块杜邦线若干用于各组件间连接提示购买Air724UG时注意选择带有IPEX天线接口的版本确保信号稳定性1.2 硬件连接示意图将各组件按以下方式连接[单片机] --(UART)-- [Air724UG] |--(I2C/GPIO)-- [温湿度传感器]具体接线参考下表组件接口连接目标引脚说明单片机TXAir724UG RX数据发送端单片机RXAir724UG TX数据接收端单片机GNDAir724UG GND共地连接单片机3.3VAir724UG VCC电源输入单片机SCL传感器SCLI2C时钟线单片机SDA传感器SDAI2C数据线1.3 开发环境配置在开始编程前需要准备好以下软件环境Python 3.8用于服务器端开发# 检查Python版本 python --versionPyCharm/VSCode推荐使用的IDEKeil MDK/STM32CubeIDE单片机开发环境串口调试工具如SecureCRT或Putty安装必要的Python库pip install pyserial flask sqlalchemy2. 4G模块配置与网络连接2.1 Air724UG基础AT指令测试通过USB转TTL模块连接电脑和Air724UG使用串口工具发送以下指令测试模块状态AT ATCPIN? # 查询SIM卡状态 ATCSQ # 检查信号强度 ATCOPS? # 查询当前运营商正常响应应类似AT OK CPIN: READY CSQ: 24,0 COPS: 0,0,CHINA MOBILE2.2 配置TCP/IP参数建立网络连接需要配置APN接入点名称不同运营商APN不同运营商APN设置指令中国移动ATCGDCONT1,IP,CMNET中国联通ATCGDCONT1,IP,UNINET中国电信ATCGDCONT1,IP,CTNET激活网络连接ATCGATT1 # 附着网络 ATNETOPEN # 打开网络 ATIPSTATUS # 查看网络状态2.3 建立TCP连接假设服务器IP为192.168.1.100端口为8080ATCIPOPEN0,TCP,192.168.1.100,8080 ATCIPSEND0,15 # 准备发送15字节数据 Hello,Server! # 输入要发送的数据成功连接后模块会返回CIPOPEN:0,0 CIPSEND:0,15,153. Python服务器开发3.1 TCP服务器实现创建一个简单的TCP服务器接收4G模块数据import socket def start_tcp_server(host0.0.0.0, port8080): with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s: s.bind((host, port)) s.listen() print(fServer listening on {host}:{port}) while True: conn, addr s.accept() with conn: print(fConnected by {addr}) while True: data conn.recv(1024) if not data: break print(fReceived: {data.decode()}) # 简单响应 conn.sendall(bACK: data) if __name__ __main__: start_tcp_server()3.2 数据解析与存储定义数据格式并存储到SQLite数据库from sqlalchemy import create_engine, Column, Integer, Float, DateTime from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.orm import sessionmaker from datetime import datetime Base declarative_base() class SensorData(Base): __tablename__ sensor_data id Column(Integer, primary_keyTrue) temperature Column(Float) humidity Column(Float) timestamp Column(DateTime, defaultdatetime.now) engine create_engine(sqlite:///iot_data.db) Base.metadata.create_all(engine) Session sessionmaker(bindengine) def parse_and_store(raw_data): try: # 示例数据格式: T25.6H50.2 temp float(raw_data.split(T)[1].split(H)[0]) humi float(raw_data.split(H)[1]) session Session() new_data SensorData(temperaturetemp, humidityhumi) session.add(new_data) session.commit() return True except Exception as e: print(fError parsing data: {e}) return False3.3 Web数据展示界面使用Flask创建简单的数据可视化页面from flask import Flask, render_template import pandas as pd from sqlalchemy import create_engine app Flask(__name__) app.route(/) def show_data(): engine create_engine(sqlite:///iot_data.db) df pd.read_sql(SELECT * FROM sensor_data ORDER BY timestamp DESC LIMIT 100, engine) return render_template(dashboard.html, tables[df.to_html(classesdata)], titlesdf.columns.values) if __name__ __main__: app.run(debugTrue)对应的HTML模板templates/dashboard.html!DOCTYPE html html head title物联网数据监控/title script srchttps://cdn.plot.ly/plotly-latest.min.js/script /head body h1环境数据实时监控/h1 div idtempChart stylewidth:600px;height:250px;/div div idhumiChart stylewidth:600px;height:250px;/div script var tempData { x: {{ timestamps|safe }}, y: {{ temperatures|safe }}, type: scatter }; var humiData { x: {{ timestamps|safe }}, y: {{ humidities|safe }}, type: scatter }; Plotly.newPlot(tempChart, [tempData], {title: 温度变化曲线}); Plotly.newPlot(humiChart, [humiData], {title: 湿度变化曲线}); /script /body /html4. 单片机端程序开发4.1 传感器数据采集以STM32 HAL库为例读取SHT30温湿度传感器数据#include sht30.h #include stdio.h #define SHT30_ADDR 0x441 void SHT30_Read(float *temp, float *humi) { uint8_t cmd[2] {0x2C, 0x06}; uint8_t data[6]; HAL_I2C_Master_Transmit(hi2c1, SHT30_ADDR, cmd, 2, 100); HAL_Delay(10); HAL_I2C_Master_Receive(hi2c1, SHT30_ADDR, data, 6, 100); uint16_t temp_raw (data[0] 8) | data[1]; uint16_t humi_raw (data[3] 8) | data[4]; *temp -45 175 * (temp_raw / 65535.0); *humi 100 * (humi_raw / 65535.0); }4.2 数据格式化与发送将采集到的数据格式化为字符串并通过串口发送void Send_Sensor_Data(float temp, float humi) { char buffer[32]; sprintf(buffer, T%.1fH%.1f, temp, humi); HAL_UART_Transmit(huart1, (uint8_t*)buffer, strlen(buffer), 100); }4.3 与4G模块通信单片机通过串口向Air724UG发送AT指令void Send_AT_Command(const char *cmd) { HAL_UART_Transmit(huart2, (uint8_t*)cmd, strlen(cmd), 100); HAL_UART_Transmit(huart2, (uint8_t*)\r\n, 2, 100); } void Connect_To_Server() { Send_AT_Command(ATCGATT1); HAL_Delay(1000); Send_AT_Command(ATNETOPEN); HAL_Delay(2000); Send_AT_Command(ATCIPOPEN0,\TCP\,\192.168.1.100\,8080); HAL_Delay(3000); }5. 系统集成与调试5.1 数据流验证完整的系统数据流向如下传感器采集环境数据单片机格式化数据通过串口发送到4G模块4G模块通过TCP传输到服务器服务器解析并存储数据Web界面展示历史数据5.2 常见问题排查遇到连接问题时可以按照以下步骤检查SIM卡状态确认SIM卡已正确插入且未欠费信号强度使用ATCSQ检查数值应大于10APN配置确保与所用运营商匹配服务器连接检查服务器IP和端口是否正确确认服务器防火墙允许该端口通信在服务器使用netstat -tulnp查看端口监听状态5.3 性能优化建议数据压缩在单片机端将浮点数转换为整型减少传输量心跳机制定期发送心跳包保持TCP连接本地缓存在网络不可用时暂存数据恢复后补传睡眠模式在不采集时让模块进入低功耗状态在实际部署中我发现最影响稳定性的因素是网络信号质量。当模块处于信号边缘区域时可以尝试以下改进更换更高增益的天线调整模块位置寻找最佳信号点增加网络连接重试机制降低数据上报频率减轻网络负担