物联网时序数据报警系统产品系统

为保障油气生产中物联设备（采油设备、注入设备、计量站场等）平稳运行，需对海量物联数据进行实时分析计算，判断设备异常和故障，报送报警信息，为下游运维和工单系统提供数据源，提升设备故障响应率和维护效率

项目包括物联实时数据订阅模块、报警算子构建模块、流计算报警模块、报警数据持久化及推送模块。根据时序数据中设备类型自动选择适配的报警算子并构建报警计算链条，实现时序数据流式分析和报警数据的并行推送。自研自定义报警规则引擎算子，通过自由搭配运算符以及groovy脚本实现报警规则自由定义，提升工况场景适配度

负责系统整体架构、研发、测试、部署等工作。运用模板方法、责任链、生产者消费者模型等设计模式开发整体框架，借助异步编程、线程池、消息队列、redis队列及lua脚本等方式提升系统整体吞吐量和消费计算能力，实现对亿级物联流式数据的分析计算和报警推送功能