以围绕客户的物理业务管理“对象”(关键人、关键物)提供场景化联结服务;提供一站式的场景落地物联解决方案和服务,平台内“纵向贯通端边云网,闭环物联场景的落地实施;全周期、全链路的物联运维运营服务,保障业务场景持续可靠、可用、好用; 沉淀行业knowhow的“物联模型”、“特色场景”、“专业智能算法”。
告警中心:提供面向物联海量时序数据根据配置规则进行业务告警、告警消息触达(短信、邮件、消息队列)、告警合并、告警恢复。
数据质量保障平台:提供面向物联海量时序数据根据配置规则进行数据质量校验、处理以及数据质量告警触达(短信、邮件、消息队列)、智能分析(综合监控、多维分析、预测性维护、使用行为分析)。
指标计算平台:提供面向物联海量时序数据根据配置规则进行业务指标、统计报表计算。
物联知识图谱平台:以设备和事件处置为核心、立足于物联设备管理、管控,数字孪生体构建、业务流程、业务规则,目标支撑项目、场景级的知识复用,并提供告警、故障的诊断,定位、自动处置,事件及应急事件的处置支撑等核心主题域,提升规划、开发、测试、运维、实施的效率和效果。
1.项目参与人12人,分为前端web应用系统及后端大数据服务,我主要负责:物联平告警中心、数据质量保障平台、指标计算平台、物联知识图谱平台相关产品架构及研发、测试、部署、上线。包括saas环境、项目私有化环境的支持。
2.基于Kafka+redis+Flink+TDengine+StarRocks的架构 对数据进行接入和预处理;
基于Flink、Janusgraph组件作为基础计算引擎;
基于Flink实时接收和处理数据,对数据进行提取、清洗、关联、标识,以及对象抽取等操作;
基于FLink 和Janusgraph 图计算进行对象化分析和标注;
基于FLink、TDengine和进行业务建模和分析;
基于FLink+StarRocks/ClickHouse实时数仓,数据分析;
基于Elasticsearch建立非结构化文本数据的索引,支持关键词检索;建立结构化数据和对象数据 的结构化索引,支持复杂条件的查询和检索;
基于Spring Cloud Alibaba、Spring Boot前台应用微服务架构;