(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210689842.7 (22)申请日 2022.06.17 (71)申请人 特赞 （上海） 信息科技有限公司 地址 200000 上海市浦东 新区中国 （上海） 自由贸易试验区张衡路20 0号2幢3层 (72)发明人 范凌　王喆　李佳楠　赵珂飞　 (74)专利代理 机构 北京知果之信知识产权代理 有限公司 1 1541 专利代理师 苏利 (51)Int.Cl. G06F 9/50(2006.01) G06F 9/54(2006.01) G06F 16/182(2019.01) (54)发明名称 子任务序列的触发执行方法、 系统及电子设 备 (57)摘要 本发明公开了一种子任务序列的触发执行 方法、 系统及电子设备， 其中方法包括： 将每个文 件处理能力独立封装为子任务， 基于所有子任务 编排任务链路； 根据所述任务链路， 构建分布式 异步消息队列的可执行序列对象； 执行所述可执 行序列对象， 触发执行子任务序列。 本发明实施 例可以编排任务链路， 并触发执行子任务， 通过 将所有子任务编排任务链路， 可以得到子任务的 在完整任务链路中的具体位置和上下游的子任 务， 使得子任务在数据较多时依然可以准确定 位， 避免子任务丢失。 权利要求书2页 说明书9页 附图3页 CN 115098254 A 2022.09.23 CN 115098254 A 1.一种子任务序列的触发执 行方法， 其特 征在于， 包括： 将每个文件处 理能力独立封装为子任务， 基于所有子任务编排任务链路； 根据所述任务链路， 构建 分布式异步消息队列的可 执行序列对象； 执行所述可执行序列对象， 触发执 行子任务序列。 2.根据权利要求1所述的方法， 其特征在于， 所述基于所有子任务编排任务链路， 包括 按照第一周期重复执 行下述步骤： 基于所有子任务， 获取 各个子任务对应的子任务数据； 根据所述子任务数据， 按照第二周期 构建子任务链路图； 根据所述子任务链路图， 构建每 个子任务的执 行链路。 3.根据权利要求2所述的方法， 其特征在于， 所述基于所有子任务， 获取各个子任务对 应的子任务数据， 包括： 每个执行端启动时， 按照第 三周期向消息队列发送所述执行端承载的所有子任务对应 的心跳数据； 消息队列按照第四周期向指挥端同步所述心跳数据； 其中， 心跳数据包括每个执行端承载的所有子任务的元信息， 所述元信息包括能力名 称、 能力版本、 前置依赖和支持文件类型。 4.根据权利要求2所述的方法， 其特征在于， 所述根据所述子任务数据， 按照第二周期 构建子任务链路图， 包括： 指挥端根据接收的心跳数据构建子任务有向无环图； 基于所述子任务有向无环图， 提取每 个子任务的最短执 行链路； 从根节点向子任务节点触发执 行所述最短执行链路； 如果所述最短执行链路包含 并行链路， 则在子任务节点的所有前置并行任务都触发执 行后， 所述子任务节点被正常触发执 行。 5.根据权利要求2所述的方法， 其特征在于， 所述根据所述子任务链路图， 构建每个子 任务的执 行链路， 包括： 根据子任务有向无环图， 得到每个子任务的执行链路， 并提取每个子任务的树状依赖 关系， 其中， 树状依赖 关系中的每个子任务节点存放子任务的标识符， 所述标识符包括元信 息中的能力名称和能力版本； 将每个子任务的执行链路封装为二进制数据， 并将所述二进制数据存储在消息队列 中， 以在触发执 行时调用。 6.根据权利要求1所述的方法， 其特征在于， 所述根据所述任务链路， 构建分布式异步 消息队列的可 执行序列对象， 包括： 基于执行链路， 构造所述执 行链路对应的子任务类； 确定执行链路中最初触发执行的最初子任务节点， 并配置所述最初子任务节点的最初 节点参数； 确定执行链路中最终触发执行的最终子任务节点， 并动态传入所述最终子任务节点的 最终节点 参数； 通过所述子任务类构造子任务对象， 并基于所述子任务对象、 最初子任务节点、 最初节 点参数、 最终子任务节点和最终节点参数， 构建分布式异步消息队列celery 的可执行序列权　利　要　求　书 1/2 页 2 CN 115098254 A 2对象。 7.根据权利要求1所述的方法， 其特征在于， 在触发执行子任务序列之后， 所述方法还 包括： 确定触发执 行的触发方式， 所述触发方式包括同步触发和异步触发； 如果触发方式是同步触发， 则阻塞等待结果返回， 收到结果后， 响应至调用端； 如果触发方式是异步触发， 则将触发记录绑定到唯一的uuid， 将所述触发执行订阅到 消息队列对应的频道， 不阻塞触发执行； 当执行链路中的所有子任务节点全部执行完成后， 订阅的频道接收发行信息， 发送回调请求， 将触发执 行的结果发送到调用端。 8.一种子任务序列的触发执 行系统， 其特 征在于， 包括： 编排单元， 用于将每个文件处理能力独立封装为子任务， 基于所有子任务编排任务链 路； 构建单元， 用于根据所述任务链路， 构建 分布式异步消息队列的可 执行序列对象； 触发执行单元， 用于执 行所述可执行序列对象， 触发执 行子任务序列。 9.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机指 令， 所述计算机指令用于使计算机执行权利要求1 ‑7任意一项所述的子任务序列的触发执 行方法。 10.一种电子设备， 其特征在于， 所述电子设备包括： 至少一个处理器； 以及与 所述至少 一个处理器通信连接的存储器； 其中， 所述存储器存储有可被所述至少一个处理器执行 的 计算机程序， 所述计算机程序被所述至少一个处理器执行， 以使所述至少一个处理器执行 权利要求1 ‑7任意一项所述的子任务序列的触发执 行方法。权　利　要　求　书 2/2 页 3 CN 115098254 A 3