构建高并发电池遥测数据接入服务 #81

New Issue

dingshuo · 2026-03-26T11:09:39+08:00

dingshuo commented

2026-03-26 11:09:39 +08:00

溯源

Parent: FEAT_BMS_001

任务上下文

实现车端到云端的高吞吐数据接入通道，支持 50k TPS，确保数据零丢失、低延迟、正确解析。

验收标准

集成 Kafka Producer 实现数据上报（TPS >= 50,000）
实现数据包解析逻辑（单体电压、温度、电流、SOC 等字段）
实现异常值自动过滤（电压>50V 或温度<-40℃）并记录脏数据日志
实现乱序数据重排序（基于时间戳）
验证端到端延迟 < 500ms
提供按 VIN+ 时间范围查询接口（响应 < 5 秒）

NFRs

性能: 吞吐量 >= 50k TPS，P99 延迟 < 500ms
安全: 传输层 TLS 1.3，入库前调用脱敏中间件

技术实现思路

使用 Netty 或 Go 高性能网络框架
协议解析采用 Protobuf 或自定义二进制协议
集成 ENAB_MONITOR_001 监控仪表盘

📋 SAFe 元数据

溯源 (Parent Reference): FEAT_BMS_001
预估工时: 24 小时
标签: type/story, domain/cloud, priority/high, status/todo

## 溯源 - Parent: FEAT_BMS_001 ## 任务上下文实现车端到云端的高吞吐数据接入通道，支持 50k TPS，确保数据零丢失、低延迟、正确解析。 ## 验收标准 - [ ] 集成 Kafka Producer 实现数据上报（TPS >= 50,000） - [ ] 实现数据包解析逻辑（单体电压、温度、电流、SOC 等字段） - [ ] 实现异常值自动过滤（电压>50V 或温度<-40℃）并记录脏数据日志 - [ ] 实现乱序数据重排序（基于时间戳） - [ ] 验证端到端延迟 < 500ms - [ ] 提供按 VIN+ 时间范围查询接口（响应 < 5 秒） ## NFRs - 性能: 吞吐量 >= 50k TPS，P99 延迟 < 500ms - 安全: 传输层 TLS 1.3，入库前调用脱敏中间件 ## 技术实现思路 - 使用 Netty 或 Go 高性能网络框架 - 协议解析采用 Protobuf 或自定义二进制协议 - 集成 ENAB_MONITOR_001 监控仪表盘 --- ## 📋 SAFe 元数据 - **溯源 (Parent Reference)**: `FEAT_BMS_001` - **预估工时**: 24 小时 - **标签**: type/story, domain/cloud, priority/high, status/todo

dingshuo added the

labels 2026-03-26 11:09:39 +08:00

Sign in to join this conversation.

1 Participants

Notifications

Due Date

No due date set.

Dependencies

No dependencies set.

Reference: Bosch_Demo/git_file_ops_test#81