车联网所获取的数据来自交警交管相应系统,并非原始数据,所以通过阶段时间对数据进行模拟计算,模拟交通灯各相位红绿灯三种灯态的有效时长。适用于采集的数据不是原始数据,又需要推算交通灯相位的红绿灯时长,用以车辆网业务应用
从kafka获取到数据在使用之前通过解析脚本将格式化数据解析成各字段(nodeID,TIMESTAMP,PHASE_ID,LIGHT_STATE,START_TIME,likely_end_time 等)。对以上结构化数据做小时,和node_id联合分组,通过对time_stamp 进行数据转换截取等操作,在固定时间内统计每一种phase_id对应的light_state的(likely_end_time-START_TIME )求最大值。以该值作为对应小时和node_id对应的有效灯态时长。因为有三种灯态,所以模拟了路口特定时间下相位交通信号灯的红绿灯时长
| 字段名 | 类型 | 描述 |
|---|---|---|
node_id(路口id) |
-- | -- |
time_stamp(采集时间) |
-- | -- |
phase_id(相位id) |
-- | -- |
light_state(灯态值) |
-- | -- |
start_time(开始时) |
-- | -- |
| fieldName | exampleValue |
|---|---|
| node_id(路口id) | 2102312ETX10KC000109 |
| time_stamp(采集时间) | 2023-10-13T08:59:59.062Z |
| phase_id(相位id) | 1 |
curl -H "Authorization: Bearer YOUR_API_KEY" \
http://localhost:3001/api/v1/datasets/18294