面向传感流数据的实时处理系统
    1.
    发明公开

    公开(公告)号:CN114372084A

    公开(公告)日:2022-04-19

    申请号:CN202011094151.X

    申请日:2020-10-14

    Abstract: 本发明提供了一种面向传感流数据的实时处理系统,包括数据接入模块、流程配置模块、规则解析引擎模块、实时处理模块等模块,解决了现有可视化流处理系统对新算子支持不足,流程配置繁琐和不支持处理结果服务化的问题。本发明还提供上述面向传感流数据的实时处理系统的使用方法。

    一种工作流分布式调度管理系统和方法

    公开(公告)号:CN113434268A

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

    申请号:CN202110644173.7

    申请日:2021-06-09

    Abstract: 本发明实施例提供的一种工作流分布式调度管理系统和方法,该系统包括:流程构建模块用于在网络页面上实现服务方案流程的构建和信息配置;流程解析分割模块用于对服务方案流程解析和分割,生成最优化的切割结果,将切割结果发送至流程重构模块;流程重构模块用于流程的重新装配,包括生成实现工作流分布式流程的元流程及子流程的监听插入。流程调度模块用于生成工作流程分布式调度的相关调度信息及元流程的流程变量的插入和元流程的下发;服务代理模块,用于接收和执行元流程的相关调度任务,实现服务方案流程的分布式执行。本申请能够通过流程解析分割模块和流程重构模块进行流程分割和重构,可以便捷的实现工作流的去中心分布式调度。

    一种面向云环境的工作流调度方法及系统

    公开(公告)号:CN114595914B

    公开(公告)日:2024-06-07

    申请号:CN202110848307.7

    申请日:2021-07-27

    Abstract: 本发明提供一种面向云环境的工作流调度方法,包括:向云环境提交待调度的任务工作流;获取工作流对应的服务需求;基于当前的云环境,按照预设的种群规模随机初始化种群;以工作流对应的服务需求为优化目标,采用第二代非支配排序遗传算法对初始化种群进行多次遗传迭代直至达到预设的最大迭代次数以获得最终种群;在种群迭代过程中云环境发生变化时,基于当前种群中的个体,采用预先训练好的序列到序列模型根据历史云环境中非支配解的变化规律预测发生变化后的云环境对应的新个体,并将新个体放入当前种群中进行下一次遗传迭代直至达到预设的最大迭代次数;选取最终种群中的非支配解以将任务工作流中的任务按照非支配解对应的虚拟机编号序列分配到虚拟机。

    一种面向云环境的工作流调度方法及系统

    公开(公告)号:CN114595914A

    公开(公告)日:2022-06-07

    申请号:CN202110848307.7

    申请日:2021-07-27

    Abstract: 本发明提供一种面向云环境的工作流调度方法,包括:向云环境提交待调度的任务工作流;获取工作流对应的服务需求;基于当前的云环境,按照预设的种群规模随机初始化种群;以工作流对应的服务需求为优化目标,采用第二代非支配排序遗传算法对初始化种群进行多次遗传迭代直至达到预设的最大迭代次数以获得最终种群;在种群迭代过程中云环境发生变化时,基于当前种群中的个体,采用预先训练好的序列到序列模型根据历史云环境中非支配解的变化规律预测发生变化后的云环境对应的新个体,并将新个体放入当前种群中进行下一次遗传迭代直至达到预设的最大迭代次数;选取最终种群中的非支配解以将任务工作流中的任务按照非支配解对应的虚拟机编号序列分配到虚拟机。

Patent Agency Ranking