作者 | 吉科软食安产研中心工程师,王兴美
当下,随着物流供应链的不断发展,冷链物流正变得越来越重要。通过数字化、平台化和生态化的智慧冷链监管平台,企业可以更好地掌握运输车辆的位置,及时发现并处理异常事件,有效提升客户满意度和信任度,同时也有助于降低冷链运输成本,提高企业市场竞争力。在这一背景下,某冷链项目利用追溯技术和监控预警功能,可以实现对冷链运输各个环节的高效监管,提高运输安全性和产品质量,为冷链运输行业带来极大的赋能作用。
在具体业务中,轨迹数据的传输形式主要有两种,正常情况下设备会实时向服务端推送数据,但当设备无信号时就会出现离线数据,车辆联网后会将离线数据再次进行推送。利用这些推送数据,我们需要计算运输车辆超时停车预警。
这一需求实现的难点在于实时数据计算停车停留时间后,离线数据上传,离线数据可能存在实时数据的中间,所以停留时间需要重新计算,数据量大,计算量大,复杂度也高,准确性低。
对于实时数据,可以直接计算每个轨迹点的停留时间,并根据预设的超时阈值进行判断,是否需要发出超时停车预警。同时使用 Redis 内存数据库或者是使用分布式缓存系统进行缓存优化,将计算结果进行缓存,避免重复计算;
对于离线数据,可以在车辆重新联网后,将离线数据与实时数据进行合并,并根据时间戳进行排序,从而保证数据顺序的正确性。然后根据新的轨迹点数据重新计算超时停车预警,避免离线数据对预警结果造成影响。
在原有方案中,我们通过对已接收的数据进行实时计算,以此确定每个轨迹点是离线还是在线状态。但这一方案存在两点缺陷:
-
-
因有离线数据,需要考虑离线数据与实时数据结合,可能有超时停车的情况出现,导致计算量复杂程度倍增
后面经过数据库选型,我们选择了时序数据库(Time Series Database) TDengine 存储车辆轨迹数据,它能够很好地实时分析并记录车辆的位置、速度和行驶方向等信息,为 B 端客户提供实时车辆运输位置跟踪。
时序数据通常都是实时产生的,需要实时存储和分析,TDengine 作为一款面向时序数据的高性能数据库,对时序数据的处理正是它的强项。相比于传统的关系型数据库,TDengine 采用了列式存储和压缩算法等技术来提高数据存储和查询的效率,从而可以更好地满足高频率、高容量、高并发的数据处理需求。在了解 TDengine 的过程中,我发现它除了高性能的时序数据库功能外,还支持了流式计算和数据订阅等功能。
使用 TDengine 的流式计算功能进行数据处理和分析时,用户可以按照当前流入的数据进行实时计算,而且当离线数据到达后,也可以重新计算,从而满足统计超时停车数据的需求。具体到我们的业务来说,可以通过在 TDengine 中建立超时停车数据模型,定义超时停车的规则和阈值,并将实时收集的轨迹数据与之进行对比,从而实现实时预警和统计。
为了满足统计车辆超时停车业务展示的相关需求,我们可以从轨迹开始时间、轨迹结束时间、时长、最新位置、运行状态和轨迹点数等方面对数据进行统计和展示:
轨迹开始时间:记录车辆行驶轨迹开始的时间,精确到秒级别。这个时间可以用于计算车辆是否存在超时停车的情况。
轨迹结束时间:记录车辆行驶轨迹结束的时间,同样精确到秒级别,用于计算车辆行驶时长。
时长:通过轨迹开始时间和结束时间的计算,可以得到车辆行驶轨迹的时长,以秒为单位,对于B端客户非常有用。
最新位置:记录车辆最新的位置,可以实现实时跟踪车辆位置和行驶状态。这个信息可以在地图上进行展示,帮助客户更好地了解车辆的行驶情况。
运行状态:根据流式计算技术实时处理的结果,可以确定车辆的运行状态,例如停车或行驶等。这个信息也可以以图标或颜色等方式在地图上进行展示,方便客户快速了解车辆的运行情况。
轨迹点数:通过统计轨迹经过的点数,可以判断车辆的行驶轨迹是否正常。如果轨迹点数明显增多,则可能是因为车辆发生了异常情况,例如线路拥堵等。
插入数据(实时):
插入实时数据,观察流式计算结果 select * from overtime_parking_output_stb;,如下:
通过应用 TDengine 流式计算功能,我们可以将行驶和超时停车的数据分别存储,并记录对应轨迹和时长,方便查找和分析正常行驶和超时停车的情况。
在车辆行驶过程中,TDengine 流式计算引擎能够实时判断车辆的运行状态,区分出行驶和停车的状态,并将这些数据实时处理并存储到不同的数据库表或者数据流中。在数据存储的过程中,也会记录对应轨迹和时长等信息,为后续的数据分析提供依据。
对于超时停车的情况,通过 TDengine 流式计算可以实时监控车辆的运行状态和位置信息,如果发现车辆停留时间过长,就可以将其标记为超时停车,并及时进行预警和管控。同时,利用这一功能,我们也可以通过对行驶和停车数据进行分析,进一步优化路线规划和运营管理,提升运输效率和安全性。
插入离线数据(实时数据的中间部分,观察流式计算结果):
插入离线数据,观察流式计算结果select * from overtime_parking_output_stb;,如下:
在离线数据上传后,TDengine 流式计算引擎会将这些数据在对应的时间点上进行数据计算处理,按照数据的时间顺序进行处理,并且完全满足轨迹按时间排序计算的正常顺序,确保不会出现漏洞或者混乱的情况。这样一来,离线数据与实时数据就不会再出现错误计算的问题,我们也能够为 B 端客户提供更准确、实时、有效的运营数据和报表。
总之,TDengine 流式计算功能不仅帮助我们实现了车辆行驶数据的实时处理和分类,也很好地实现了运输车辆超时停车预警,减轻了服务端的计算压力,满足业务需求的同时帮助我们极大节省了数据处理成本,提高了车辆的运输效率和安全性。
在运行 TDengine 过程中,涛思数据团队始终以客户需求为导向,为我们提供高效、可靠的数据处理和分析服务,满足了不断升级的业务需求,我们也非常感谢他们。未来我们还有计划将 TDengine 引入到其他业务中进行时序数据的处理,在实践中推进时序数据库技术的发展,实现共赢。
👇
点击阅读原文,快速体验 TDengine 3.0 !