摘要：本文给出了一种用于监控燃气用户用气量的系统架构和相应算法.该系统以燃气公司普遍使用的关系型数据库为基础,通过数据抽取、数据清洗和数据转换(ETL)的过程,将实时业务数据转换进以hadoop生态圈为代表的分布式系统中.系统基于Spark自建分类算法和预测算法完成用户端的气量监控,并将异常结果返还至客户端.对成都城市燃气公司、华油天然气股份有限公司工商用户的监控结果表明,该系统具有高效、准确的优点.