一种电力时序数据实时清洗方法和系统

    公开(公告)号:CN115237902A

    公开(公告)日:2022-10-25

    申请号:CN202211014207.5

    申请日:2022-08-23

    摘要: 本发明提出一种电力时序数据实时清洗方法和系统。其中,方法包括:利用属性Id、Key、历史数据构建数据异常判断临时表;获取已通过协议解析,并经IOT设备实时传输的实时时序数据;消息中间件Kafka接收到时序数据后,Flink组件实时获取实时时序数据,并与数据异常判断临时表进行比较计算,得出实时时序数据的有效性进行判断,应用判断结果对数据进行字段标识。本发明提出的方案,通过构建数据异常判断临时表并动态更新,实现了实时数据的异常清洗仅依赖于临时表和上一条数据,节省了实时计算资源,满足高速数据流下的性能要求。

    一种云边协同直流微网显示幕墙系统

    公开(公告)号:CN115262825A

    公开(公告)日:2022-11-01

    申请号:CN202211043531.X

    申请日:2022-08-29

    摘要: 本申请公开了一种云边协同直流微网显示幕墙系统,包括显示模块、控制模块、充放电模块以及光伏电池组,其中显示模块与控制模块通信连接,所述充放电模块与所述控制模块通信连接,所述光伏电池组与充放电模块电连接;光伏电池组,用于接收太阳光并转换为电能;充放电模块用于接收光伏电池组发出的电能并整流处理后为所述控制模块和显示模块供电;控制模块用于接收控制信号并将处理后的控制信号发送至显示模块;显示模块响应于所述控制模块的信号用于显示所述控制模块传输的数据。本申请具有配合云端控制,实现灵活控制单个或多块幕墙形成组合显示,甚至可以进行整个城市幕墙显示管理,进而实现将光伏发电与楼宇显示结合,形成光伏建筑一体化。