一种资源与算力动态匹配的自协商方法及设备与流程

本申请涉及资源自协商，尤其涉及一种资源与算力动态匹配的自协商方法及设备。

背景技术：

1、随着云计算、边缘计算和算力网络的发展，业务任务不再固定由单一服务器或固定节点执行，而是可以根据任务的计算量、存储需求、网络链路状态和节点负载情况，在多个算力节点之间进行动态分配。

2、然而，现有资源与算力动态匹配的自协商方案在接收到资源请求后直接执行正式资源锁定，缺乏二次校验流程，导致部分场景下任务发起端发送资源请求后，可能会出现调整任务参数等情况，但算力节点已完成资源锁定，造成算力资源被无效占用。

技术实现思路

1、本申请提供一种资源与算力动态匹配的自协商方法及设备，以解决现有技术中在接收到资源请求后直接执行正式资源锁定，造成算力资源被无效占用的问题。

2、为实现上述目的，本申请实施例提供了一种资源与算力动态匹配的自协商方法，应用于任务发起端，包括：

3、根据待执行任务的需求资源量，生成资源协商请求报文并发送至至少一个候选算力节点；

4、接收至少一个候选算力节点返回试锁资源凭证；

5、在预设时长内，对所述待执行任务的有效性以及需求资源量进行校验；

6、若校验通过，则依次向返回试锁资源凭证的候选算力节点发送试锁确认报文，直至接收到任意一个候选算力节点返回的协商确认凭证为止；其中，所述试锁确认报文用于候选算力节点进行试锁资源凭证的一致性校验，以在一致性校验通过后将所述待执行任务的试锁资源记录转为确认锁资源记录，并返回协商确认凭证；

7、若校验未通过，则向返回试锁资源凭证的候选算力节点发送试锁撤销报文，用于撤销所述待执行任务的试锁资源记录。

8、作为上述方案的改进，在所述根据待执行任务的需求资源量，生成资源协商请求报文并发送至至少一个候选算力节点之前，所述方法还包括：

9、获取所述待执行任务的安全等级；

10、根据所述安全等级确认至少一个所述候选算力节点。

11、作为上述方案的改进，所述需求资源量包括以下中的至少一种：保底需求算力量、目标需求算力量、需求内存量、需求存储量、需求带宽量；其中，所述保底需求算力量和目标需求算力量通过以下步骤获取：

12、根据所述待执行任务的预计计算量、输入数据量和任务完成截止时间，计算所述待执行任务的基准需求算力量；

13、根据所述待执行任务的基准需求算力量，得到所述保底需求算力量和目标需求算力量。

14、作为上述方案的改进，所述若校验通过，则依次向返回试锁资源凭证的候选算力节点发送试锁确认报文，直至接收到任意一个候选算力节点返回的协商确认凭证为止，包括：

15、若校验通过，则按照预设顺序依向返回试锁资源凭证的候选算力节点发送包括自身返回的试锁资源凭证的试锁确认报文，直至接收到任意一个候选算力节点返回的协商确认凭证为止；

16、其中，所述预设顺序为：

17、候选算力节点的可用算力量与所述目标需求算力量的差值从小到大的顺序；

18、作为上述方案的改进，在所述根据待执行任务的需求资源量，生成资源协商请求报文并发送至至少一个候选算力节点之后，所述方法还包括：

19、当接收到所有所述候选算力节点返回的资源冲突报文时，根据所述需求资源量，重新生成资源协商请求报文并发送至至少一个候选算力节点。

20、为实现上述目的，本申请实施例还提供了一种资源与算力动态匹配的自协商方法，应用于算力节点端，包括：

21、接收并解析任务发起端发送的本轮次的资源协商请求报文，得到待执行任务的需求资源量；

22、判断所述需求资源量是否与所述算力节点的资源账本发生资源冲突；其中，所述资源账本包括：确认锁资源记录和试锁资源记录；所述确认锁资源记录用于记录一致性校验通过后对应的资源，所述试锁资源记录用于记录需要进行一致性校验对应的资源；

23、若没有发生资源冲突，则生成所述待执行任务的试锁资源记录和试锁资源凭证，并返回所述试锁资源凭证；

24、接收所述任务发起端发送的试锁确认报文，对所述试锁确认报文和所述试锁资源凭证进行一致性校验，检验通过后将所述试锁资源记录转为确认锁资源记录，并返回协商确认凭证。

25、作为上述方案的改进，通过以下步骤生成所述试锁资源凭证：

26、提取所述试锁资源记录的预设关键信息并进行拼接，得到拼接信息；

27、对所述拼接信息进行哈希处理，得到所述试锁资源凭证。

28、作为上述方案的改进，所述判断所述需求资源量是否与所述算力节点的资源账本发生资源冲突，包括：

29、获取所述算力节点的总资源量和所述待执行任务的预计任务开始时间和预计任务结束时间；

30、从所述确认锁资源记录中，获取与所述预计任务开始时间和所述预计任务结束时间存在时间重叠的第一资源量；

31、从所述试锁资源记录中，获取与所述预计任务开始时间和所述预计任务结束时间存在时间重叠的第二资源量；

32、根据所述总资源量、所述第一资源量和所述第二资源量，计算所述算力节点的可用资源量；

33、根据所述算力节点的可用资源量，判断所述需求资源量是否和所述算力节点的资源账本发生资源冲突。

34、作为上述方案的改进，所述方法还包括：

35、若发生资源冲突，则生成资源冲突报文并返回。

36、为实现上述目的，本申请实施例还提供了一种资源与算力动态匹配的自协商设备，包括处理器、存储器以及存储在所述存储器中且被配置为由所述处理器执行的计算机程序，所述处理器在执行所述计算机程序时实现如上述的资源与算力动态匹配的自协商方法。

37、为实现上述目的，本申请实施例还提供了一种计算机可读存储介质，所述计算机可读存储介质包括存储的计算机程序；其中，所述计算机程序在运行时控制所述计算机可读存储介质所在的设备执行如上述的资源与算力动态匹配的自协商方法。

38、与现有技术相比，本申请实施例提供的一种资源与算力动态匹配的自协商方法及设备，任务发起端通过根据待执行任务的需求资源量，生成资源协商请求报文并发送至至少一个候选算力节点；接收至少一个候选算力节点返回试锁资源凭证；在预设时长内，对所述待执行任务的有效性以及需求资源量进行校验；若校验通过，则依次向返回试锁资源凭证的候选算力节点发送试锁确认报文，直至接收到任意一个候选算力节点返回的协商确认凭证为止；其中，所述试锁确认报文用于候选算力节点进行试锁资源凭证的一致性校验，以在一致性校验通过后将所述待执行任务的试锁资源记录转为确认锁资源记录，并返回协商确认凭证；若校验未通过，则向返回试锁资源凭证的候选算力节点发送试锁撤销报文，用于撤销所述待执行任务的试锁资源记录。由此可见，本申请实施例在待执行任务的有效性以及需求资源量校验通过后将待执行任务的试锁资源记录转为确认锁资源记录，能够避免算力资源被无效占用。

1.一种资源与算力动态匹配的自协商方法，其特征在于，应用于任务发起端，包括：

2.如权利要求1所述的资源与算力动态匹配的自协商方法，其特征在于，在所述根据待执行任务的需求资源量，生成资源协商请求报文并发送至至少一个候选算力节点之前，所述方法还包括：

3.如权利要求1所述的资源与算力动态匹配的自协商方法，其特征在于，所述需求资源量包括以下中的至少一种：保底需求算力量、目标需求算力量、需求内存量、需求存储量、需求带宽量；其中，所述保底需求算力量和目标需求算力量通过以下步骤获取：

4.如权利要求3所述的资源与算力动态匹配的自协商方法，其特征在于，所述若校验通过，则依次向返回试锁资源凭证的候选算力节点发送试锁确认报文，直至接收到任意一个候选算力节点返回的协商确认凭证为止，包括：

5.如权利要求1所述的资源与算力动态匹配的自协商方法，其特征在于，在所述根据待执行任务的需求资源量，生成资源协商请求报文并发送至至少一个候选算力节点之后，所述方法还包括：

6.一种的资源与算力动态匹配的自协商方法，其特征在于，应用于算力节点端，包括：

7.如权利要求6所述的资源与算力动态匹配的自协商方法，其特征在于，通过以下步骤生成所述试锁资源凭证：

8.如权利要求6所述的资源与算力动态匹配的自协商方法，其特征在于，所述判断所述需求资源量是否与所述算力节点的资源账本发生资源冲突，包括：

9.如权利要求6所述的资源与算力动态匹配的自协商方法，其特征在于，所述方法还包括：

10.一种资源与算力动态匹配的自协商设备，其特征在于，包括处理器、存储器以及存储在所述存储器中且被配置为由所述处理器执行的计算机程序，所述处理器在执行所述计算机程序时实现如权利要求1~9任一项所述的资源与算力动态匹配的自协商方法。