一种基于计算用时不同的流处理任务的数据实时集成方法

    公开(公告)号:CN117033485A

    公开(公告)日:2023-11-10

    申请号:CN202311004732.3

    申请日:2023-08-10

    Abstract: 本发明提出一种基于计算用时不同的流处理任务的数据实时集成方法,属于数据实时集成技术领域。包括:S1、预执行待集成的各流处理任务获得计算用时,将任务分为计算用时秒级和计算用时非秒级;S2、获取不同来源的待集成数据;S3、定义集成后的数据大小;S4、定义数据暂存区的存储结构;S5、将待集成数据输入数据暂存区进行数据集成;S6、判断计算用时秒级的数据集成是否完成;S7、非秒级流处理任务集成完成时,直接更新数据库中存储的同一时间戳下的数据条目,进行数据集成。解决计算用时不同,无法同时结束的流处理任务功能模块实时集成问题,支持跨功能模块进行全量生产数据实时随机查询和历史下载。

    一种电除尘器点阵式节能优化运行控制方法和控制系统

    公开(公告)号:CN117123370A

    公开(公告)日:2023-11-28

    申请号:CN202311102093.4

    申请日:2023-08-29

    Abstract: 本发明提出一种电除尘器点阵式节能优化运行控制方法和控制系统,属于大气污染物治理技术领域。包括以下步骤:S1.根据电除尘器的室数和电场数为基准建立点阵式控制模块;S2.收集点阵式控制模块的运行数据构建节能优化运行数据库,运行数据包括电源参数、烟气参数和输灰参数;S3.构建优化计算模型,输出计算结果;S4.根据计算结果判断是否满足约束条件,输出是否满足结果;S5.输出结果为满足约束条件验证,则调整运行参数,电除尘器运行优化完成;输出结果为不满足约束条件验证,则返回S2,直至结果满足约束条件验证。解决现有技术中存在的缺少电除尘器运行优化调控以及缺少烟气参数、输灰参数对电除尘器性能和能耗影响技术问题。

    一种基于流处理任务的数据实时集成方法

    公开(公告)号:CN117041342A

    公开(公告)日:2023-11-10

    申请号:CN202311004727.2

    申请日:2023-08-10

    Abstract: 本发明提出一种基于流处理任务的数据实时集成方法,属于数据实时集成技术领域。包括:S1、获取不同来源的待集成数据,规范待集成数据格式;S2、定义集成后的数据大小,数据大小用键的数量进行表征;S3、定义数据暂存区的存储结构,存储不同来源正在集成的数据;S4、通过数据传输接口将规范后的待集成数据输入数据暂存区进行数据集成;S5、判断数据集成是否完成,若集成完成,将数据暂存区中Key下集成的数据以字典格式存入MongoDB数据库,并从数据暂存区中删除数据;若集成未完成,不进行任何操作。解决无法支持用户跨模块的对全量生产信息进行实时随机查询和历史数据下载的问题。

    一种基于流处理任务和定时任务的数据实时集成方法

    公开(公告)号:CN117033484A

    公开(公告)日:2023-11-10

    申请号:CN202311004725.3

    申请日:2023-08-10

    Abstract: 本发明提出一种基于流处理任务和定时任务的数据实时集成方法,属于数据实时集成技术领域。包括:S1、获取不同来源的待集成数据,规范待集成数据格式;S2、定义集成后的数据大小,数据大小用键的数量进行表征;S3、定义数据暂存区的存储结构,存储不同来源正在集成的数据;S4、通过数据传输接口将规范后的待集成数据输入数据暂存区进行数据集成;S5、判断数据集成是否完成,若集成完成,将数据暂存区中Key下集成的数据以字典格式存入MongoDB数据库,并从数据暂存区中删除数据;若集成未完成,不进行任何操作。解决无法实现流处理任务和定时任务的实时数据集成,无法支持用户对全量生产信息实时随机查询和历史数据下载的问题。

Patent Agency Ranking