流程处理方法、系统及电子设备.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115033349A(43)申请公布日2022.09.09(21)申请号202210482075.2(22)申请日2022.05.05(71)申请人阿里巴巴（中国）有限公司地址310023浙江省杭州市余杭区五常街道文一西路969号3幢5层554室(72)发明人徐永进付一凡杨征宽王晰(74)专利代理机构北京太合九思知识产权代理有限公司11610专利代理师柴艳波刘戈(51)Int.Cl.G06F9/46(2006.01)权利要求书2页说明书15页附图4页(54)发明名称流程处理方法、系统及电子设备(57)摘要本申请实施例提供一种流程处理方法、系统及电子设备。其中，方法包括：监听事件总线上发布的事件；若监听到与目标任务流程有关的第一事件，则获取与第一事件关联的第一节点的节点信息；其中，目标任务流程包括顺序执行的多个流程节点，第一节点为多个流程节点中的一个；根据节点信息，执行第一节点对应的节点任务；在节点任务执行过程中或节点任务执行完后，触发第二事件并将第二事件发布至事件总线上，以利用第二事件触发执行第一节点下游的第二节点对应的节点任务。本申请实施例提供的技术方案，是基于事件总线来调度目标任务流程的流动节点的，这既实现了对流程节点的解耦，又使得流程节点统一运维，能有效保证任务流程处理的稳定性。CN115033349ACN115033349A权利要求书1/2页1.一种流程处理方法，其特征在于，包括：监听事件总线上发布的事件；若监听到与目标任务流程有关的第一事件，则获取与所述第一事件关联的第一节点的节点信息；其中，所述目标任务流程包括顺序执行的多个流程节点，所述第一节点为所述多个流程节点中的一个；根据所述节点信息，执行所述第一节点对应的节点任务；在所述节点任务执行过程中或所述节点任务执行完后，触发第二事件并将所述第二事件发布至所述事件总线上，以利用所述第二事件触发执行所述第一节点下游的第二节点对应的节点任务。2.根据权利要求1所述的方法，其特征在于，获取与所述第一事件关联的第一节点的节点信息，包括：根据注册信息，确定与所述第一事件所属事件类型关联的第一节点；获取所述第一节点对应的至少一个任务执行单元；其中，所述节点信息包括所述至少一个任务执行单元。3.根据权利要求2所述的方法，其特征在于，获取所述第一节点对应的至少一个任务执行单元，包括：获取所述第一节点对应的至少一个通用执行单元；根据所述目标任务流程的任务类型，从所述第一节点预配置的至少一个扩展执行单元中查找与所述任务类型适配的扩展执行单元；其中，所述至少一个任务执行单元包括：所述至少一个通用执行单元和/或至少一个与所述任务类型适配的扩展执行单元。4.根据权利要求2或3所述的方法，其特征在于，还包括：响应于将所述第一节点注册至事件总线的指令，遍历所述第一节点对应的至少一个任务执行单元；根据所述至少一个任务执行单元，为所述第一节点注册一适配的事件类型；将所述第一节点的节点标识及其适配的事件类型，存入所述注册信息。5.根据权利要求1至3中任一项所述的方法，其特征在于，还包括：对所述节点任务执行过程进行监测；若监测到所述节点任务执行失败，则重新启动执行所述节点任务，并在重新启动执行中启用幂等处理，以保证所述节点任务执行结果的一致性。6.根据权利要求1所述的方法，其特征在于，还包括：响应于目标任务流程的创建指令，在节点池中查询所述目标任务流程所需的多个流程节点；若在所述节点池中均能查询到所述多个流程节点，则获取所述多个流程节点，并对所述多个流程节点进行执行顺序的编排。7.根据权利要求6所述的方法，其特征在于，还包括：若所述多个流程节点中的部分或全部流程节点在所述节点池中查询不到，则为所述目标任务流程创建流程节点；将已创建的流程节点注册到所述节点池中，以等待流程节点的编排。2CN115033349A权利要求书2/2页8.一种流程处理方法，其特征在于，包括：响应于一渠道引入的数据，创建目标任务流程；其中，所述目标任务流程包括顺序执行的多个流程节点；分别将所述多个流程节点注册至事件总线，使得各流程节点通过所述事件总线发布和订阅相应事件；基于所述事件总线，顺序调度所述多个流程节点以执行相应的节点任务。9.根据权利要求8所述的方法，其特征在于，还包括：基于所述事件总线，监测各流程节点对应节点任务的执行过程，以下一节点任务执行失败时重新启动执行。10.根据权利要求9所述的方法，其特征在于，创建目标任务流程，包括：在节点池中查询所述目标任务流程所需的多个流程节点；若在所述节点池中均能查询到所述多个流程节点，则获取所述多个流程节点，并对所述多个流程节点进行执行顺序的编排。11.根据权利要求8至10中任一项所述的方法，其特征在于，基于所述事件总线，顺