基于流窗口实现的实时流数据处理方法及装置

摘要

本发明公开了一种基于流窗口实现的实时流数据处理方法及装置，该方法包括：从至少一个数据源获取实时流数据，实时流数据包含运单流数据及配送设施流数据；对运单流数据及配送设施流数据进行数据联接处理，得到数据宽表；接收用于表征压力平衡状态的单量指标数据的计算任务，根据单量指标数据的数据特性调用相应的流窗口的处理进程，由流窗口的处理进程对数据宽表内的数据进行聚合计算，得到对应的单量指标数据。本发明实施例提供的方案，对于不同时间定义的单量指标数据，能够通过调用相应的流窗口的处理进程实现个性化地聚合计算单量指标数据，从而方便根据所计算的单量指标数据进行压力平衡，实现运单合理调度的需求。