针对气象机器学习算法运行的优先级调度方法、系统、电子设备和计算机程序产品

    公开(公告)号:CN116643860A

    公开(公告)日:2023-08-25

    申请号:CN202310462061.9

    申请日:2023-04-26

    IPC分类号: G06F9/48 G06F9/50

    摘要: 本发明公开针对气象机器学习算法运行的优先级调度方法、系统、设备及其计算机程序产品,其中方法包括:根据用户业务特性,将用户配置到相应优先级群组中;当计算任务所需的资源规格大于当前集群的空闲资源时,根据用户所在优先级群组,生成优先级队列;根据优先级队列以及外部沟通情况对资源进行调度和回收;系统包括:优先级信息配置模块,优先级队列生成模块,调度模块和操作模块;电子设备包括存储器、处理器和计算机程序;处理器执行计算机程序时实现上述优先级调度方法;计算机程序产品,被处理器执行时实现上述优先级调度方法的步骤。本发明主要针对气象机器学习训练场景,能够兼顾资源充足时的按需调度以及资源不足时的优先级调度。

    一种气象模式数据解码处理方法
    3.
    发明公开

    公开(公告)号:CN116010525A

    公开(公告)日:2023-04-25

    申请号:CN202310051735.6

    申请日:2023-02-02

    IPC分类号: G06F16/27 G06F16/22 G06F9/54

    摘要: 本发明公开一种气象模式数据解码处理方法,包括如下步骤:采用多线程方式,读取模式数据源文件;将所述模式数据源文件拆分成模式单场文件;将拆分的所述模式单场文件进行解析,解析完成后得到模式数据属性和模式数据内容;根据气象服务需求,将解析得到的所述模式数据属性和所述模式数据内容,重新存储入分布式表格数据库,和/或重组生成模式产品文件后入分布式文件库+索引表;待数据处理和入库完成后,将入库数据的DI信息发送至“天镜”监控系统。本发明能处理和接入几乎所有现有业务中的GRIB格式的模式数据,以支撑不同的模式数据服务需求。本发明采用java语言开发,可扩展性强,平台移植性高,能同时在不同平台运行。

    气象格点数据管理方法和装置

    公开(公告)号:CN116126973B

    公开(公告)日:2024-09-24

    申请号:CN202211725278.6

    申请日:2022-12-29

    摘要: 本发明公开了一种气象格点数据管理方法和装置,属于气象信息处理领域。本发明提供基于MPP分布式数据库的气象格点数据存储管理方案,同时针对常见分析算法实现了分布式并行优化,有效提升了格点数据的访问性能。通过PostGrid数据库插件的形式,在数据库内部原生支持格点数据的存储;通过SQL实现对格点数据的操作,包括数据写入、简单查询和复杂分析;充分利用并行处理的优势,针对部分聚合函数实现分布式执行优化;将格点数据以关系模型的方式管理,继承了关系型数据库相比于文件系统的诸多优点,如事务支持,SQL支持,多用户共享等。

    一种气象模式数据解码处理方法

    公开(公告)号:CN116010525B

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

    申请号:CN202310051735.6

    申请日:2023-02-02

    IPC分类号: G06F16/27 G06F16/22 G06F9/54

    摘要: 本发明公开一种气象模式数据解码处理方法,包括如下步骤:采用多线程方式,读取模式数据源文件;将所述模式数据源文件拆分成模式单场文件;将拆分的所述模式单场文件进行解析,解析完成后得到模式数据属性和模式数据内容;根据气象服务需求,将解析得到的所述模式数据属性和所述模式数据内容,重新存储入分布式表格数据库,和/或重组生成模式产品文件后入分布式文件库+索引表;待数据处理和入库完成后,将入库数据的DI信息发送至“天镜”监控系统。本发明能处理和接入几乎所有现有业务中的GRIB格式的模式数据,以支撑不同的模式数据服务需求。本发明采用java语言开发,可扩展性强,平台移植性高,能同时在不同平台运行。

    气象格点数据管理方法和装置

    公开(公告)号:CN116126973A

    公开(公告)日:2023-05-16

    申请号:CN202211725278.6

    申请日:2022-12-29

    摘要: 本发明公开了一种气象格点数据管理方法和装置,属于气象信息处理领域。本发明提供基于MPP分布式数据库的气象格点数据存储管理方案,同时针对常见分析算法实现了分布式并行优化,有效提升了格点数据的访问性能。通过PostGrid数据库插件的形式,在数据库内部原生支持格点数据的存储;通过SQL实现对格点数据的操作,包括数据写入、简单查询和复杂分析;充分利用并行处理的优势,针对部分聚合函数实现分布式执行优化;将格点数据以关系模型的方式管理,继承了关系型数据库相比于文件系统的诸多优点,如事务支持,SQL支持,多用户共享等。