diff --git a/docs/operations/go-vehicle-gateway-verification-result-2026-07-01.md b/docs/operations/go-vehicle-gateway-verification-result-2026-07-01.md index 32d346a1..ac534929 100644 --- a/docs/operations/go-vehicle-gateway-verification-result-2026-07-01.md +++ b/docs/operations/go-vehicle-gateway-verification-result-2026-07-01.md @@ -485,3 +485,79 @@ device_rows=72 ``` 说明:`jt808_registration.phone` 保存 808 包头原始 phone;`vehicle_identity_binding.phone` 中已有部分去前导零 phone。Go resolver 会同时查询原始 phone 和去前导零 phone。 + +## 2026-07-01 23:28 生产链路与指标清理复验 + +本轮复验目标: + +- 确认 Go gateway 的 Kafka durable spool 是重启窗口残留,而不是持续发布失败。 +- 确认 stat-writer / history-writer / realtime-api 的 Kafka consumer group 无 lag。 +- 确认真实 808 车辆 registration、TDengine RAW/里程点、Redis 实时查询均在持续更新。 +- 清理之前生产合成回放产生的 JT808 当日指标测试数据。 + +Kafka topic / consumer group: + +```text +vehicle.raw.go.jt808.v1 有持续 offset +vehicle.raw.go.gb32960.v1 有持续 offset +vehicle.event.go.unified.v1 有持续 offset + +go-stat-writer LAG=0 +go-history-writer LAG=0 +go-realtime-api LAG=0 +``` + +TDengine: + +```text +raw_frames: +JT808 2922 +GB32960 27 + +vehicle_mileage_points: +JT808 2050 +GB32960 2 +``` + +Redis 实时查询样例: + +```text +GET /api/realtime/vehicles/LKLG7C4E3NA774736 +vin=LKLG7C4E3NA774736 +source_endpoint=222.66.200.68:29646 +plate=沪A06788F +longitude=119.556866 +latitude=29.047911 +total_mileage_km=12345.6 +``` + +说明:该 Redis merged 快照保留了此前有效 `total_mileage_km=12345.6`,后续真实 808 位置帧上报的 `total_mileage_km=0` 不会覆盖该字段。TDengine 中该 VIN 后续真实里程点的 `total_mileage_km` 均为 0,因此 stat-writer 按“只统计正总里程”的规则不再写 JT808 每日指标。 + +MySQL 指标清理: + +```text +删除前: +LKLG7C4E2NA774775 | JT808 | 2026-07-01 | daily_mileage_km | first=0 | latest=0 | sample_count=7 +LKLG7C4E2NA774775 | JT808 | 2026-07-01 | daily_total_mileage_km | first=0 | latest=0 | sample_count=7 +LKLG7C4E3NA774736 | JT808 | 2026-07-01 | daily_mileage_km | first=12345.6 | latest=12345.6 | sample_count=13 +LKLG7C4E3NA774736 | JT808 | 2026-07-01 | daily_total_mileage_km | first=12345.6 | latest=12345.6 | sample_count=13 + +删除后等待真实流量窗口: +JT808 2026-07-01 metric rows = 0 +``` + +清理原因: + +- `LKLG7C4E3NA774736` 的 12345.6 来自此前生产连通性合成回放,不是真实平台上报。 +- `LKLG7C4E2NA774775` 的 0 指标来自旧逻辑污染,当前 stat-writer 已跳过非正总里程。 + +Kafka spool: + +```text +23:24 spool_count=904 +23:25 spool_count=862 +23:28 spool_count=722 +new_spool_1min=0 +``` + +说明:spool 正在回放下降,且最近 1 分钟没有新增文件;生产 gateway 日志未见 `Incorrect string value`、Kafka publish error 或 replay error。