通道选择方法、系统、装置、电子设备和存储介质.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115361331A(43)申请公布日2022.11.18(21)申请号202210887128.9(22)申请日2022.07.26(71)申请人北京奇艺世纪科技有限公司地址100080北京市海淀区北一街2号鸿城拓展大厦10、11层(72)发明人袁玮玮吴桐(74)专利代理机构北京华夏泰和知识产权代理有限公司11662专利代理师韩月玲(51)Int.Cl.H04L45/12(2022.01)H04L45/121(2022.01)H04L45/125(2022.01)H04L45/00(2022.01)权利要求书2页说明书9页附图3页(54)发明名称通道选择方法、系统、装置、电子设备和存储介质(57)摘要本申请涉及一种通道选择方法、系统、装置、电子设备和存储介质，应用于数据处理技术领域，其中，方法包括：获取工作流中工作节点间各通道的通道运行数据，所述工作节点间包括至少两个所述通道；基于所述通道运行数据，确定所述工作节点间路由代价最小的目标通道；将待处理任务按照所述目标通道在所述工作节点间进行传输和处理。以解决现有技术中，通道任务分配不均，易造成系统崩溃的情况的问题。CN115361331ACN115361331A权利要求书1/2页1.一种通道选择方法，其特征在于，包括：获取工作流中工作节点间各通道的通道运行数据，所述工作节点间包括至少两个所述通道；基于所述通道运行数据，确定所述工作节点间路由代价最小的目标通道；将待处理任务按照所述目标通道在所述工作节点间进行传输和处理。2.根据权利要求1所述的通道选择方法，其特征在于，所述基于所述通道运行数据，确定所述工作节点间路由代价最小的目标通道，包括：基于所述通道运行数据，确定所述工作节点间的路由信息，所述路由信息中包括路由通道的数量和通过所述路由通道所需的路由参数；基于所述路由通道的数量和所述路由参数确定所述目标通道。3.根据权利要求2所述的通道选择方法，其特征在于，所述基于所述通道运行数据，确定所述工作节点间的路由信息，包括：控制所述工作流中的第一节点向第二节点发送泛洪广播信息，所述第一节点和所述第二节点均为所述工作流中的工作节点；基于所述通道运行数据，确定所述第二节点从各通道接收到所述泛洪广播信息的路由参数；确定所述第一节点到第二节点的通道为路由通道；确定所述路由参数和所述路由通道为所述路由信息。4.根据权利要求3所述的通道选择方法，其特征在于，所述第一节点和所述第二节点为所述工作流中相邻的两工作节点；所述控制所述工作流中的第一节点向第二节点发送泛洪广播信息，包括：控制所述工作流中的各所述第一节点向与其相邻的所述第二节点同时发送所述泛洪广播信息；或，所述第一节点为开始节点，所述第二节点为终止节点，所述工作流中还包括中间节点；所述控制所述工作流中的第一节点向第二节点发送泛洪广播信息，包括：控制所述第一节点通过所述中间节点向所述第二节点发送所述泛洪广播信息，直至所述第二节点接收到所述泛洪广播信息。5.根据权利要求3所述的通道选择方法，其特征在于，所述通道运行数据包括通道执行时长、通道排队时长；所述基于所述通道运行数据，确定所述第二节点从各通道接收到所述泛洪广播信息的路由参数，包括：确定所述通道排队时长为所述第二节点从各所述通道接收到所述泛洪广播信息的路由时长；根据所述通道执行时长和所述通道排队时长，确定所述工作节点间的平均流量数据；确定所述路由时长和/或所述平均流量数据为所述路由参数。6.根据权利要求5所述的通道选择方法，其特征在于，所述根据所述通道执行时长和所述通道排队时长，确定所述工作节点间的平均流量数据，包括：根据所述通道排队时长和所述通道执行时长，确定所述通道的平均任务处理量；确定所述平均任务处理量为所述平均流量数据。7.根据权利要求2所述的通道选择方法，其特征在于，所述路由参数包括路由时长和/2CN115361331A权利要求书2/2页或路由平均流量；所述基于所述路由通道的数量和所述路由参数确定所述目标通道，包括：判断所述路由参数是否满足预设路由条件，所述预设路由条件包括所述路由时长超过预设时长阈值，和/或，所述路由平均流量大于预设流量阈值；若不满足，确定路由时长最短或路由平均流量最小的路由通道为所述目标通道；若满足，判断所述路由通道的数量是否达到通道阈值；若路由通道的数量未达到通道阈值，在所述工作节点间创建新的路由通道。8.一种通道选择系统，其特征在于，包括：工作流平台和工作流管控平台；所述工作流平台，用于向所述工作流管控平台发送工作流中工作节点间各通道的通道运行数据，所述工作节点间包括至少两个所述通道；所述工作流管控平台，用于获取工作流中工作节点间各通道的通道运行数据；基于所述通道运行数据，确定所述工作节点间路