流计算任务并行度优化方法、装置、电子设备及存储介质

    公开(公告)号:CN114816691B

    公开(公告)日:2025-03-14

    申请号:CN202110127729.5

    申请日:2021-01-29

    Inventor: 张力 刘玮哲

    Abstract: 本发明公开了一种流计算任务并行度优化方法、装置、电子设备及存储介质,属于大数据领域。其中方法包括:获取流计算中各计算节点的性能参数值和各任务预设的任务优先级,其中性能参数值包括各计算节点的CPU、内存、网络带宽和/或任务吞吐量的参数值;基于任务并行度模型,确定在当前运行的所有流计算任务总价值最大时各任务的并行度,其中,任务并行度模型是通过任务收益与任务开销的差值确定任务的价值,任务收益由预设的任务优先级和任务吞吐量确定,任务开销由任务消耗的资源确定,该资源包括CPU、内存和/或网络带宽,任务吞吐量和任务消耗的资源是关于任务并行度的函数;根据所确定的各任务的并行度对当前运行的各任务的并行度进行调整。

    流计算任务并行度优化方法、装置、电子设备及存储介质

    公开(公告)号:CN114816691A

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

    申请号:CN202110127729.5

    申请日:2021-01-29

    Inventor: 张力 刘玮哲

    Abstract: 本发明公开了一种流计算任务并行度优化方法、装置、电子设备及存储介质,属于大数据领域。其中方法包括:获取流计算中各计算节点的性能参数值和各任务预设的任务优先级,其中性能参数值包括各计算节点的CPU、内存、网络带宽和/或任务吞吐量的参数值;基于任务并行度模型,确定在当前运行的所有流计算任务总价值最大时各任务的并行度,其中,任务并行度模型是通过任务收益与任务开销的差值确定任务的价值,任务收益由预设的任务优先级和任务吞吐量确定,任务开销由任务消耗的资源确定,该资源包括CPU、内存和/或网络带宽,任务吞吐量和任务消耗的资源是关于任务并行度的函数;根据所确定的各任务的并行度对当前运行的各任务的并行度进行调整。

    单用户登录的检测方法、装置、电子设备及存储介质

    公开(公告)号:CN118827110A

    公开(公告)日:2024-10-22

    申请号:CN202311798111.7

    申请日:2023-12-25

    Inventor: 张力

    Abstract: 本申请公开了一种单用户登录的检测方法、装置、电子设备及存储介质。该方法包括:在目标前端页面通过目标账号与目标服务节点建立连接时,从存储多个服务节点发送的连接消息的消息队列中获取第一连接消息,连接消息包括登录服务节点的账号及用于连接服务节点与前端页面的连接通道的通道标识;对第一连接消息与目标通道集合中的目标通道对象进行匹配,得到匹配结果,目标通道集合用于存储前端页面与目标服务节点连接后生成的通道对象,目标通道对象至少包括连接通道的目标通道标识以及目标账号;根据匹配结果确定是否生成连接关闭指令。本申请所提供的方案在实现单用户登录的同时降低了前端Web和后端服务节点的性能损耗。

    一种确定卸载比率的方法、装置、设备及存储介质

    公开(公告)号:CN116963188A

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

    申请号:CN202210785423.3

    申请日:2022-07-05

    Abstract: 本申请实施例公开了一种确定卸载比率的方法、装置、设备及存储介质。该方法包括:获取任务请求、设备的设备计算能力信息和设备用于执行第一任务的资源信息;根据任务请求、设备的设备计算能力信息、设备用于执行第一任务的资源信息和预测模型,确定卸载策略;根据卸载策略和评估模型,确定卸载策略中的目标卸载策略,目标策略表示时延最小的卸载策略,目标卸载策略包括本地设备向边缘服务器中的第一边缘服务器卸载应用程序的第一卸载比率,以及第一边缘服务器向边缘服务器中的协作边缘服务器卸载应用程序的第二卸载比率。本申请实施例提供的方法能够减小时延,提升用户体验。

    一种数据处理方法、装置及电子设备

    公开(公告)号:CN115994041A

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

    申请号:CN202111216798.X

    申请日:2021-10-19

    Abstract: 本发明实施例公开了一种数据处理方法、装置及电子设备,所述方法包括:在基于目标通讯账号的第一网元数据和第一业务数据确定所述目标通讯账号存在数据不一致的情况下,获取所述目标通讯账号对应的已开通的目标业务;基于所述目标业务、所述第一网元数据和所述第一业务数据,确定数据修复策略中与所述目标通讯账号对应的目标修复策略,所述数据修复策略为基于通讯账号的已开通业务、网元数据以及业务数据确定的用于对网元数据和/或业务数据进行一致性修复的策略;基于所述目标修复策略,对所述目标通讯账号的第一网元数据和/或第一业务数据进行一致性修复。通过本方法,可以通过目标修复对数据进行一致性修复,以提高数据修复的效率和准确性。

    任务调度方法及其装置、设备、存储介质和程序产品

    公开(公告)号:CN116938938A

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

    申请号:CN202210356172.7

    申请日:2022-04-06

    Abstract: 本申请公开了一种任务调度方法及其装置、设备、存储介质和程序产品。该任务调度方法,边缘服务器能够将第一任务分配至与边缘服务器连接的第一物联网设备;然后获取第一物联网设备中的至少一个未完成任务的任务信息;基于至少一个未完成任务的任务信息,确定各未完成任务的计算资源分配比例;向第一物联网设备发送各未完成任务的计算资源分配比例,以使第一物联网设备分配与各计算资源分配比例对应的计算资源,对与计算资源分配比例对应的未完成任务进行处理。充分利用物联网设备中的闲置计算资源,解决了边缘服务器计算资源不足的问题。

Patent Agency Ranking