a. 统一采集和存储水厂数据 b. 数据加工、清洗在数据中心完成,保持数据完整性和统一性 c. 提供高效的数据查询服务,以满足各业务对数据的需求 d. 提供数据展示层,以图表形式呈现数据 e. 将数据抽象成事件,并提供数据事件订阅服务 f. 数据预警事件,提供事件订阅服务 目录结构: . ├── app 应用目录 │ ├── alarms 报警 │ ├── api http 数据接口服务 │ ├── cleansing 数据清洗 │ ├── events 事件 │ └── organization 数据维度整理 ├── bin 外部脚本执行 ├── common 公用工具类 ├── config 通用配置文件 └── deploy 部署相关 python 依赖安装: pip install psycopg2 schedule pandas sshtunnel sqlalchemy pymysql redis