zydi-lab/data

UDP数据采集服务器

这是一个基于Python异步IO的UDP数据采集服务器，用于接收、处理和转发实验设备的传感器数据。

主要功能

• 接收并解析设备传感器数据
• 自动识别和管理设备序列号
• 实时监控活跃实验状态
• 数据存储到Redis流
• 通过WebSocket实时转发数据
• 支持数据降采样处理
• 自动重连和错误恢复机制

系统要求

• Python 3.7+
• MongoDB
• Redis
• 相关Python包依赖：
  • motor
  • websockets
  • redis
  • asyncio

配置说明

MongoDB配置

mongodb_url = "mongodb://lab:password@host:27017/lab"

Redis配置

redis_url = 'redis://host:6379'
redis_password = 'password'
redis_db = 200

服务器配置

host = '0.0.0.0'
port = 6002

数据流程

1. 设备通过UDP发送数据包到服务器
2. 服务器解析数据包，识别设备序列号
3. 查询设备对应的活跃实验
4. 将数据存储到Redis流
5. 通过WebSocket实时转发处理后的数据

主要类和方法

UDPServer

• init_mongodb(): 初始化MongoDB连接
• init_redis(): 初始化Redis连接
• update_active_experiments(): 更新活跃实验信息
• process_and_forward_data(): 处理和转发数据
• handle_sensor_data(): 处理传感器数据
• batch_redis_write(): 批量写入Redis

运行方式

python data.py

数据格式

传感器数据包格式

WebSocket消息格式

```json
{
    "type": "data_batch",
    "data_points": [
        {
            "sensor_data": {
                "sensor_name": value
            },
            "timestamp": timestamp
        }
    ],
    "serial_number": "device_serial",
    "total_points": count
}
```

错误处理

• 自动重连机制
• 数据校验
• 异常捕获和日志记录
• 优雅关闭处理

注意事项

1. 确保MongoDB和Redis服务正常运行
2. 检查网络防火墙设置，确保UDP端口开放
3. 监控服务器资源使用情况
4. 定期检查日志文件