AIS 数据采集器搭建全流程日期2026-09-25项目路径C:\ais_projectMQTT 服务器TDengine 数据库ais基于TDengine的数据库存储将从mqttx收到的数据存入超级表中并根据唯一ID创建子表存储便于查询数据。一、环境准备写在最开始默认已经安装好TDengine/Pycharm/MQTTX1.1 安装依赖pip install paho-mqtt taospy1.2 确认 TDengineWindows检查 taosd 服务是否运行可以打开 Windows 服务管理器或按 WinR 输入 services 打开服务窗口检查 taosd 服务是否正在运行。1.3 创建数据库进入 taos CLItaos执行 SQLCREATE DATABASE IF NOT EXISTS ais; USE ais;二、建表2.1 创建四张超级表-- 动态表CREATE STABLE st_dynamic ( ts TIMESTAMP, lon DOUBLE, lat DOUBLE, sog FLOAT, cog FLOAT, heading FLOAT, nav_status INT ) TAGS ( segment NCHAR(16), mmsi BIGINT );-- 静态表CREATE STABLE st_static ( ts TIMESTAMP, ship_name NCHAR(64), imo NCHAR(32), call_sign NCHAR(32), ship_type INT ) TAGS ( segment NCHAR(16), mmsi BIGINT );-- 航次表CREATE STABLE st_sail ( ts TIMESTAMP, event_type NCHAR(32), status NCHAR(32) ) TAGS ( segment NCHAR(16), mmsi BIGINT );-- 状态/错误日志表CREATE STABLE st_status ( ts TIMESTAMP, level NCHAR(16), source NCHAR(32), err_msg NCHAR(512) ) TAGS ( segment NCHAR(16), mmsi BIGINT );2.2 验证建表结果SHOW STABLES;预期输出四行st_dynamic、st_static、st_sail、st_status三、部署采集器3.1 创建采集器文件在 C:\ais_project 或者{你想存放的文件夹}下新建 ais_collector.py3.2 配置连接信息TD_CONFIG {host: localhost,user: root,password: taosdata,database: ais}MQTT_CONFIG {host: 服务器地址,port: 1883,user: ,password: ,topics: [订阅主题]}3.3 启动采集器1.cmd命令行中输入cd C:\ais_project python ais_collector.py2.或者在Pycharm项目文件夹中打开于终端输入python ais_collector.py正常启动后日志示例2026-09-25 17:05:00 | INFO | TDengine 连接成功 2026-09-25 17:05:00 | INFO | MQTT 连接成功 [接收] Topictopic | 数据413772468,2026-09-25 17:05:28,107.100860000,29.769935000,291,511,74,15,-128,0,2,238660,238650 [动态] MMSI413772468 | 写入成功 | 类型dynamic四、常见问题与解决方案问题1MQTT 连接失败 [WinError 10061]原因MQTT 服务器地址或端口配置错误解决检查 MQTT_CONFIG 中的 host 和 port确认用户名密码正确问题2JSON 解析失败 Extra data原因数据是 CSV 格式不是 JSON解决已使用 CSV 解析方式无需处理问题3Invalid column name原因INSERT 语句中的列名与表结构不匹配解决用 DESCRIBE st_xxx; 查看表结构对齐列名问题4Table does not exist原因超级表未创建解决执行第二章的建表语句问题5统计在线船舶数不准原因COUNT(DISTINCT tbname) 在 TDengine 中行为不可靠解决改用 COUNT(DISTINCT mmsi)mmsi 是 TAG统计准确
