随着环境保护形势的日趋严峻,各大能源企业开始建设内部的污染源监测系统。污染源监测数据的采集、存储和计算要求极高,数据属性具有典型的大数据特征。在管理实际中,需要科学的算法排除异常数据,实时、真实地反映现场实际。流式计算的技术特性与污染源监测数据的计算处理的业务场景匹配度极高,对于能源企业内部环保管理的业务支撑可以发挥传统技术不可替代的作用。