一种基于实时地理位置数据流处理方法

摘要

本发明涉及交通信息技术领域，提供了一种基于分布式计算的实时地理位置数据流处理方法，实现了对实时交通数据的大规模可靠的实时计算处理，包括：以一个包含了多个逻辑处理节点的特定拓扑结构来表示处理框架，实时数据流将会在该拓扑结构中以特定的方法流经各个逻辑处理节点，各个逻辑处理节点包含了数据流接收节点、数据流解析节点、数据修正节点、数据一致性保证节点、数据计算与写入节点。本发明还提供了一种基于分布式计算的实时地理位置数据流处理系统。本发明能够实时地清洗、修正、计算处理大量的实时地理位置数据，保证了数据结果的时效性，而且保证了数据计算的可靠性、数据一致性、和计算规模的可扩展性。