wsy182
0a123ba210
- 将主应用改为同时启动MQTT订阅入库和WITS数据发送两个服务 - 实现WITS发送器的自动重连机制和连接状态管理 - 添加日志记录到log/app.log和错误日志到log/error.log - 更新WITS通道映射定义并支持字符串类型的日期时间字段 - 修改数据入库逻辑以支持空值处理和类型转换容错 - 移除命令行子命令模式，改为配置文件驱动的参数设置 - 添加.vscode和log目录到.gitignore忽略列表
31 lines
709 B
Markdown
31 lines
709 B
Markdown
# tdEngine_mqtt_mock需求
|
||
|
||
## 功能
|
||
|
||
### wits数据模拟
|
||
|
||
1. 读取config.yaml中的server-ip和端口将模拟的wits数据发送到这个地址。wits数据要尽可能的拟真。
|
||
2. 发送间隔两秒一条。
|
||
|
||
|
||
|
||
|
||
|
||
### mqtt消息订阅和入库
|
||
|
||
1. 订阅指定topic的消息，将消息写入tdengine数据库，tdengine的配置在config.yaml的tdengine。mqtt的配置在config.yaml的mqtt。
|
||
|
||
|
||
|
||
## 要求
|
||
|
||
程序启动入口main.py,使用logging记录日志。
|
||
|
||
启动是同时启动wits数据模拟和mqtt消息订阅和入库。不需要选择功能。
|
||
|
||
将业务对象抽取到model包下。
|
||
|
||
数据库实体放在model包下。
|
||
|
||
将日志记录到log/app.log,错误日志记录到log/error.log
|