一种任务调度方法、存储介质及设备与流程

本发明涉及生成引擎优化，具体地涉及一种任务调度方法、存储介质及设备。

背景技术：

1、生成引擎优化geo服务如果以项目制交付，难以沉淀统一指标、模板、监测任务和订阅运营能力。多客户共用平台时，又必须解决租户数据隔离、权限边界、资源配额、功能分级和指标计算任务调度问题。

2、然而，现有的saas架构未面向geo业务对象和ai答案监测流程设计，尤其是在租户管理中，难以保证各个租户之间的数据隔离，无法更好地对各个租户进行权限管理。

技术实现思路

1、本发明实施例的目的是提供一种任务调度方法、存储介质及设备，用于实现各个租户之间的数据隔离和权限管理。

2、为了实现上述目的，第一方面，本发明实施例提供一种任务调度方法，所述方法用于geo行业saas化平台，所述方法包括：接收用户的任务指令，并确定所述用户对应的租户标识和品牌；基于所述任务指令，生成任务编号和时间窗口，并读取版本配置，其中，所述版本配置包括原始样本的采样平台和隔离策略版本；基于所述时间窗口和所述采样平台，采集所述品牌的原始样本，基于所述租户标识和所述隔离策略版本，对所述原始样本执行数据隔离校验，得到隔离校验结果；若所述隔离校验结果为通过，则计算任务优先级；基于所述任务优先级，对所述任务指令对应的计算任务进行调度；基于调度结果，执行所述计算任务，得到任务执行结果；以及基于所述任务编号、时间窗口、原始样本、隔离校验结果、任务优先级和任务执行结果，生成可追溯的任务日志。

3、可选的，所述计算任务包括多个维度的指标值的计算、品牌geo全域健康度指数ghi和短板维度的定位，其中，所述多个维度包括提及率、首推率、情感指数、事实一致性、结构化质量、品牌信任指数和竞品压力中的两种以上维度的组合。

4、可选的，基于所述租户标识和所述隔离策略版本，对所述原始样本执行数据隔离校验，得到隔离校验结果包括：基于所述租户标识，确定所述隔离策略版本中预先配置的独立数据命名空间和资源范围；对所述用户、租户标识和原始样本进行校验，判断所述用户、租户标识和原始样本是否符合权限要求，并判断所述原始样本是否属于所述独立数据命名空间和资源范围；以及若所述校验结果为符合权限要求，且属于所述独立数据命名空间和资源范围，则判定为校验通过。

5、可选的，所述版本配置还包括订阅等级，若所述隔离校验结果为通过，所述方法还包括：根据所述租户标识，确定所述租户标识对应的订阅等级；基于所述订阅等级，确定所述订阅等级对应的套餐配额；获取所述租户标识对配额的当前用量；基于所述套餐配额和所述当前用量，计算剩余配额；以及判断所述剩余配额是否满足所述任务指令对应的指标计算任务的配额需求，若不满足，则触发超额限制，停止计算任务优先级，并向用户发送超额预警。

6、可选的，所述任务优先级的计算公式包括：

7、taskpriority = planweight × urgency × datafreshness / cost，

8、其中，taskpriority为任务优先级，planweight为订阅权重，urgency为紧急程度，datafreshness为数据新鲜度，cost为任务成本。

9、可选的，所述任务成本通过以下方式确定：基于所述计算任务对应的任务类型、采样量、目标平台数量和租户等级，从历史任务耗时数据中匹配得到所述任务成本；或将所述计算任务对应的任务类型、采样量、目标平台数量和租户等级输入预先训练的回归模型，得到所述任务成本，其中，所述回归模型基于历史任务耗时数据训练得到。

10、可选的，所述方法还包括：当所述租户标识对应的版本配置发生变化时，基于变化后的版本配置生成候选版本；从历史任务中抽取预设数量的标准化测试题，并基于抽取的标准化测试题获取采样平台的返回结果，构成样本回放集；基于所述样本回放集，分别在旧版本和所述候选版本上执行计算任务；对所述旧版本和所述候选版本对应的任务执行结果进行对比，得到新旧版本差异；以及若所述新旧版本差异未超过预设容忍区间，则发布所述候选版本。

11、可选的，所述方法还包括异常处理，所述异常处理包括：在方法执行过程中，若出现预设异常情况，则触发对应的异常代码，所述预设异常情况包括样本数量不足、格式错误、来源不可访问、模型拒答、事实冲突、指标突变、阈值越界和权限不匹配中的一种或多种，其中，所述样本数量不足包括空样本和重复样本，所述格式错误包括字段缺失、字段格式非法和结构化代码不可解析；将所述异常代码与原始样本、触发所述异常代码的处理模块、触发时间和版本配置共同写入待复核记录；以及基于所述待复核记录进行复核。

12、可选的，基于所述待复核记录进行复核包括：若所述待复核记录的异常代码对应的异常情况为样本数量不足、格式错误、来源不可访问和权限不匹配中的一种或多种，则执行自动规则复核，得到复核结论；若所述待复核记录的异常代码对应的异常情况为模型拒答、事实冲突、指标突变和阈值越界中的一种或多种，则执行人工复核，得到复核结论；若所述复核结论为确认无误，则保存复核结论和复核版本，所述复核版本包括当前版本配置；以及

13、若所述复核结论为存在问题，则将对应的所述原始样本作为异常证据保存，不用于执行所述计算任务。

14、可选的，所述方法还包括：基于预设周期重复执行所述计算任务，每次执行时，复用上一次执行的版本配置，更新所述时间窗口和所述原始样本；将每次得到的任务执行结果与上一次得到的任务执行结果进行比较，得到比较结果；以及基于所述比较结果确定两次执行的差异来源，并记录归因，所述差异来源包括订阅变更、配额变更、任务成本变化和任务属性变化中的至少一种。

15、第二方面，本发明实施例提供一种机器可读存储介质，该机器可读存储介质上存储有指令，该指令用于使得机器执行所述的方法。

16、第三方面，本发明实施例提供一种用于任务调度的设备，该设备包含存储器及处理器，所述处理器用于运行程序，其中，所述程序被运行时用于执行所述的方法。

17、通过上述技术方案，针对geo平台多租户隔离、订阅和任务调度缺乏专用架构这一问题，构建了从数据采集、隔离校验、优先级计算、任务调度、任务执行到结果输出的连续处理链路。在执行调度时，先判断用户对应的租户标识和品牌，从而在saas化平台多租户的订阅调度方案中保护租户的权限边界，实现通用资源隔离和权限管理。此外，本发明通过连续处理链路和可追溯的任务日志，避免了只停留在抽象的运营目标或展示界面，使后续修复、复算和审计具有确定的数据入口。

18、本发明实施例的其它特征和优点将在随后的具体实施方式部分予以详细说明。

1.一种任务调度方法，所述方法用于geo行业saas化平台，其特征在于，所述方法包括：

2.根据权利要求1所述的方法，其特征在于，所述计算任务包括多个维度的指标值的计算、品牌geo全域健康度指数ghi和短板维度的定位，

3.根据权利要求1所述的方法，其特征在于，基于所述租户标识和所述隔离策略版本，对所述原始样本执行数据隔离校验，得到隔离校验结果包括：

4.根据权利要求1所述的方法，其特征在于，所述版本配置还包括订阅等级，

5.根据权利要求1所述的方法，其特征在于，所述任务优先级的计算公式包括：

6.根据权利要求5所述的方法，其特征在于，所述任务成本通过以下方式确定：

7.根据权利要求1所述的方法，其特征在于，所述方法还包括：

8.根据权利要求1所述的方法，其特征在于，所述方法还包括异常处理，所述异常处理包括：

9.根据权利要求8所述的方法，其特征在于，基于所述待复核记录进行复核包括：

10.根据权利要求1所述的方法，其特征在于，所述方法还包括：

11.一种机器可读存储介质，该机器可读存储介质上存储有指令，该指令用于使得机器执行如权利要求1-10中任一项所述的方法。

12.一种用于任务调度的设备，该设备包含存储器及处理器，其特征在于，所述处理器用于运行程序，其中，所述程序被运行时用于执行：如权利要求1-10任一项所述的方法。