一种RPA集群机构及基于RPA集群机构的任务处理方法

摘要

本发明实施例提供了一种RPA集群架构及基于RPA集群架构的任务处理方法，涉及物联网技术领域，其中，该集群架构，包括：调度室节点，多个RPA控制端以及多个RPA执行端；调度室节点分别与每个RPA控制端进行通信，调度室节点，用于接收待执行任务，将待执行任务分发至RPA控制端；RPA控制端与RPA执行端之间采用单机控制模式，RPA控制端，用于将待执行任务分发至RPA执行端执行；其中，RPA控制端之间禁止通信；RPA执行端，用于执行待执行任务，并执行结果反馈至对应的RPA控制端；RPA控制端，还用于将执行结果反馈至调度室节点以使调度室节点将执行结果反馈至待执行任务的发送端。本发明实施例提供的技术方案，可以突破RPA执行端的设备数量瓶颈，可以突破性能瓶颈。

说明书

技术领域

本发明实施例涉及物联网技术领域，尤其涉及一种RPA集群架构及RPA集群架构的任务处理方法。

背景技术

随着IT技术的普及，越来越多的企业由原先线下流程转为线上流程，在每天的标准工作时间内要处理的重复性线上工作也随之增加，为了解放这种重复劳作，机器人流程自动化(Robotic Process Automation，RPA)技术应运而生。

其中，RPA技术是一种可以模拟人在电脑上的不同系统之间操作行为，替代人在电脑前执行具有规律与重复性高的办公流程的方法。RPA技术擅长把工作流程中的重复繁琐的操作进行自动化。繁琐流程自动化是企业数字化转型的重要环节。RPA技术能够有效优化传统办公流程，提升协作效率，间接起到优化企业劳动资源配置，助力企业数字化升级。但目前的RPA控制端能够控制RPA执行端的数量存在上限，超过上限后存在性能问题。

发明内容

本发明实施例提供一种RPA集群结构及基于RPA集群结构的任务处理方法，可以突破RPA执行端的设备数量瓶颈，可以突破性能瓶颈。

第一方面，本发明实施例提供了一种机器人流程自动化RPA集群架构，包括：调度室节点，多个RPA控制端以及多个RPA执行端；

所述调度室节点分别与每个RPA控制端进行通信，所述调度室节点，用于接收待执行任务，将所述待执行任务分发至所述RPA控制端；

所述RPA控制端与所述RPA执行端之间采用单机控制模式，所述RPA控制端，用于将所述待执行任务分发至所述RPA执行端执行；其中，所述RPA控制端之间禁止通信；

所述RPA执行端，用于执行所述待执行任务，并执行结果反馈至对应的RPA控制端；

所述RPA控制端，还用于将所述执行结果反馈至所述调度室节点以使所述调度室节点将所述执行结果反馈至所述待执行任务的发送端。

可选的，所述RPA控制端对应至少两个RPA执行端，所述RPA控制端与所述至少两个RPA执行端通信；其中，所述RPA执行端与一个RPA控制端对应。

可选的，所述调度室节点，还用于当判断存在超时的第一目标RPA执行端时，通过对应的RPA控制端控制所述第一目标RPA执行端结束当前的待执行任务，以执行新的待执行任务。

可选的，所述调度室节点，还用于若判断待执行任务分配满量，将没有分配的待执行任务进行排队，以形成任务队列；当判断存在执行任务完毕的第二目标RPA执行端时，将所述任务队列中的待执行任务通过对应的RPA控制端分发至所述第二目标RPA执行端。

可选的，所述方法还包括：

所述RPA控制端，还用于将所述执行结果存储至共享缓存中，以使所述调度室节点进行查询。

可选的，所述调度室节点采用集群模式。

可选的，所述RPA控制端与承载的最大数量的RPA执行端进行通信。

可选的，所述最大数量为50。

第二方面，本发明实施例提供了一种基于RPA集群架构的任务处理方法，所述RPA集群架构包括调度室节点，多个RPA控制端以及多个RPA执行端，所述调度室节点分别与每个RPA控制端进行通信，所述RPA控制端与RPA执行端之间采用单机控制模式，所述RPA控制端之间禁止通信，所述方法包括：

通过调度室节点接收待执行任务，将所述待执行任务分发至RPA控制端；

通过所述RPA控制端将所述待执行任务分发至所述RPA执行端执行；

通过所述RPA执行端执行所述待执行任务，并执行结果反馈至对应的RPA控制端；

通过RPA控制端将所述执行结果反馈至所述调度室节点以使所述调度室节点将所述执行结果反馈至所述待执行任务的发送端。

可选的，所述方法还包括：

通过所述调度室节点当判断存在超时的第一目标RPA执行端时，通过对应的RPA控制端控制所述第一目标RPA执行端结束当前的待执行任务，以执行新的待执行任务。

可选的，所述方法还包括：

通过所述调度室节点若判断待执行任务分配满量，将没有分配的待执行任务进行排列，以形成任务队列；

通过所述调度室节点当判断存在执行任务完毕的第二目标RPA执行端时，将所述任务队列中的待执行任务通过对应的RPA控制端分发至所述第二目标RPA执行端。

可选的，所述将待执行任务进行排列，以形成任务队列，包括：

将所述待执行任务按照时间顺序或者按照优先级进行排列，以形成任务队列。

可选的，所述方法还包括：

通过所述RPA控制端将执行结果存储至共享缓存中，以使所述调度室节点进行查询。

可选的，所述通过调度室节点接收待执行任务，将所述待执行任务分发至RPA控制端，包括：

通过调度室节点接收任务，并将所述待执行任务发送至当前最少任务量对应的RPA控制端。

可选的，所述RPA控制端与RPA执行端之间采用单机控制模式，包括：

按照所述RPA控制端部署最大数量的RPA执行端的方式部署单机控制模式。

本发明实施例提供的技术方案，集群架构通过包括调度室节点，多个RPA控制端以及与多个RPA执行端，其中，调度室节点分别与每个RPA控制端进行通信，RPA控制端与RPA执行端之间采用单机控制模式，RPA控制端之间禁止通信，即通过包括多个RPA控制端以及多个RPA执行端，RPA控制端与RPA执行端之间采用单机控制模式，可以突破RPA执行端的设备数量的瓶颈，从而突破性能瓶颈，通过引入调度室节点以及控制RPA控制端之间禁止通信，可以使执行结果直接通过RPA控制端反馈至调度室节点，缩短执行结果的反馈时间，在成规模要求时效高的场景中可以尽快完成结果反馈，突破性能瓶颈。

附图说明

图1a是本发明实施例提供的RPA集群结构示意图；

图1b是相关技术中的RPA集群架构示意图；

图1c是相关技术中的RPA集群架构示意图；

图2是本发明实施例提供的一种基于RPA集群架构的任务处理方法流程图；

图3是本发明实施例提供的一种基于RPA集群架构的任务处理方法流程图；

图4是本发明实施例提供的一种任务处理方法流程图；

图5是本发明实施例提供的一种任务处理装置结构框图。

具体实施方式

下面结合附图和实施例对本发明作进一步的详细说明。可以理解的是，此处所描述的具体实施例仅仅用于解释本发明，而非对本发明的限定。另外还需要说明的是，为了便于描述，附图中仅示出了与本发明相关的部分而非全部结构。

图1a是本发明实施例提供的一种机器人流程自动化RPA集群架构示意图，如图1a所示，该集群架构包括调度室节点，多个RPA控制端以及与多个RPA执行端。

其中，调度室节点分别与每个RPA控制端进行通信，调度室节点，用于接收待执行任务，将待执行任务分发至RPA控制端；RPA控制端与RPA执行端之间采用单机控制模式，RPA控制端，用于将待执行任务分发至RPA执行端执行；其中，RPA控制端之间禁止通信；RPA执行端，用于执行待执行任务，并将执行结果反馈至对应的RPA控制端；RPA控制端，还用于将执行结果反馈至调度室节点以使调度室节点将执行结果反馈至待执行任务的发送端。

在本发明实施例中，可选的，调度室节点可以采用集群模式，即调度室节点可以是多个设备形成的集群。可选的，调度室节点也可以是一个设备形成的节点。RPA控制端可以理解是RPA控制设备，RPA执行端可以理解是RPA执行设备，例如，RPA机器人。

在本发明实施例中，单机控制模式可以是一个RPA控制端控制一个或者多个RPA执行端的模式。可选的，RPA控制端对应至少两个RPA执行端，RPA控制端与该至少两个RPA执行端通信；其中，RPA执行端与一个RPA控制端对应。可选的，RPA控制端可以控制至少两个RPA执行端，且RPA执行端仅仅由一个RPA控制端进行控制，每个RPA执行端之间禁止通信，每任意两个RPA控制端之间禁止通信。由此，通过RPA控制端之间禁止通信，可以避免RPA之间通信造成的处理延迟，提高处理效率。

在本发明实施例的一个实施方式中，可选的，所述RPA控制端与承载的最大数量的RPA执行端进行通信。可选的，最大数量可以根据RPA控制端的设备性能来进行确定，目前行业内的经验值是4C16G的单机控制量为50，故最大数量可以是50。其中，每个RPA控制端部署最大数量的RPA执行端，从而使集群架构部署部署较多数量的RPA执行端，可以提高性能。

在本发明实施例的一个实施方式中，可选的，调度室节点可以分别与每个RPA控制端进行通信，调度室节点接收外部的待执行任务，将待执行任务分发至RPA控制端。其中，调度室节点可以将待执行任务发送至当前最少任务量对应的RPA控制端。具体的，调度室节点可以统计每个RPA控制端分发待执行任务的数量，将待执行任务分发给最少任务量对应的RPA控制端。

在本发明实施例的一个实施方式中，可选的，调度室节点，还用于当判断存在超时的第一目标RPA执行端时，通过对应的RPA控制端控制第一目标RPA执行端结束当前的待执行任务，以执行新的待执行任务。其中，RPA执行端执行待执行任务完毕后，将执行结果通过RPA控制端反馈给调度室节点，调度室节点通过接收到执行结果的情况判断RPA执行端是否执行完毕待执行任务，当调度室节点判断第一目标RPA执行端执行待执行任务的时间超过设定时间，则判断第一目标RPA执行端超时，则通过对应的RPA控制端控制第一目标RPA执行端结束当前的待执行任务，以使第一目标RPA执行端执行新的待执行任务。

由此，通过判断超时的第一目标RPA执行端，并将超时的第一目标RPA执行端结束当前的待执行任务，可以提高处理任务的效率。

在本发明实施例的一个实施方式中，可选的，调度室节点，还用于若判断待执行任务分配满量，将没有分配的待执行任务进行排队，以形成任务队列；当判断存在执行任务完毕的第二目标RPA执行端时，将任务队列中的待执行任务通过对应的RPA控制端分发至第二目标RPA执行端。其中，若调度室节点分配待执行任务之后，每个RPA执行端均在执行待执行任务，可以理解为待执行任务分配满量，则将待执行任务进行排队，以形成任务队列。可选的，可以按照时间顺序或者优先级进行排列，以形成任务队列。其中，可以将待执行任务按照任务的类别、紧急程度等进行优先级的排列。当调度室节点判断第二目标RPA执行端执行任务完毕时，将任务队列中的待执行任务通过对应的RPA控制端分发值第二目标RPA执行端，以使该第二目标RPA执行端执行待执行任务。

由此，调度室节点通过将待执行任务形成任务队列，并当判断第二目标RPA执行端执行完毕任务时，将任务队列中的待执行任务通过对应的RPA控制端将待执行任务分发至该第二目标RPA执行端，可以合理处理待执行任务，提高任务的处理效率。

在本发明实施例的一个实施方式中，可选的，RPA控制端，还用于将执行结果存储至共享缓存中，以使所述调度室节点进行查询。其中RPA控制端之间禁止通信，可以将执行结果反馈到调度室节点，并将执行结果保存在共享缓存中，可以缩短执行结果反馈的时间，可以便于对执行结果的查询。

在相关技术中，为了部署简便，如图1b所示，RPA控制端与RPA执行端采用单机控制模式，即一个RPA控制端控制一个或者多个RPA执行端，由于RPA控制端所部署的设备是有限的，所以单机控制模式存在设备数量瓶颈。本发明实施例通过引入调度室节点，并且包括多个控制端以及多个RPA执行端，每个RPA控制端与RPA执行端之间采用单机控制模式，可以实现调度室节点对任务的分配，可以部署较多数量的RPA执行端，突破RPA执行端的设备数量瓶颈，从而突破性能瓶颈。

相关技术中，如图1c所示，为了实现高可用，RPA控制端和RPA执行端采用传统的集群模式，集群间存在通信，具体的，一个RPA执行端可以与多个RPA控制端进行通信，各个RPA控制端之间可以进行通信，RPA执行端将执行结果需要经过多级的RPA控制端，从而反馈至任务的发送端，在成规模的集群中，执行结果的反馈会花费较多的时间，在要求时效性高的场景中，往往存在性能瓶颈。本发明实施例通过引入调度室节点将任务分发至RPA控制端，通过RPA控制端控制RPA执行端执行任务，并且RPA控制端之间禁止通信，可以将执行结果直接通过RPA控制端反馈至调度室节点，从而反馈至任务的发送端，实现对执行结果的及时反馈，对于较大规模的集群，大大缩短时间，更加适应时效要求高的场景，并且可以降低RPA控制端的部署难度。

本发明实施例提供的技术方案，集群架构通过包括调度室节点，多个RPA控制端以及与多个RPA执行端，其中，调度室节点分别与每个RPA控制端进行通信，RPA控制端与RPA执行端之间采用单机控制模式，RPA控制端之间禁止通信，即通过引入调度室节点，并且包括多个RPA控制端以及多个RPA执行端，RPA控制端与RPA执行端之间采用单机控制模式，可以突破RPA执行端的设备数量的瓶颈，从而突破性能瓶颈，通过引入调度室节点以及控制RPA控制端之间禁止通信，可以使执行结果直接通过RPA控制端直接反馈至调度室节点，缩短执行结果的反馈时间，在成规模要求时效高的场景中可以尽快完成结果反馈，突破性能瓶颈。

图2是本发明实施例提供的一种基于RPA集群架构的任务处理方法流程图，其中，该方法通过RPA集群架构来执行，RPA集群架构包括调度室节点，多个RPA控制端以及与多个RPA执行端，调度室节点分别与每个RPA控制端进行通信，RPA控制端与RPA执行端之间采用单机控制模式，RPA控制端之间禁止通信，如图2所示，所述方法包括：

S210：通过调度室节点接收待执行任务，将所述待执行任务分发至RPA控制端。

在本发明实施例中，调度室节点可以采用集群模式，即调度室节点可以是多个设备形成的集群。可选的，调度室节点也可以是一个设备形成的节点。

S220：通过所述RPA控制端将所述待执行任务分发至RPA执行端执行。

在本发明实施例的一个实施方式中，可选的，所述通过调度室节点接收待执行任务，将所述待执行任务分发至RPA控制端，包括：通过调度室节点接收任务，并将所述待执行任务发送至当前最少任务量对应的RPA控制端。其中，调度室节点可以将待执行任务发送至当前最少任务量对应的RPA控制端。具体的，调度室节点可以统计每个RPA控制端分发待执行任务的数量，将待执行任务分发给最少任务量对应的RPA控制端。

S230：通过所述RPA执行端执行所述待执行任务，并执行结果反馈至对应的RPA控制端。

S240：通过RPA控制端将所述执行结果反馈至所述调度室节点以使所述调度室节点将所述执行结果反馈至所述待执行任务的发送端。

可选的，所述方法还包括：

通过所述调度室节点当判断存在超时的第一目标RPA执行端时，通过对应的RPA控制端控制所述第一目标RPA执行端结束当前的待执行任务，以执行新的待执行任务。

其中，RPA执行端执行待执行任务完毕后，将执行结果通过RPA控制端反馈给调度室节点，调度室节点通过接收到执行结果的情况判断RPA执行端是否执行完毕待执行任务，当调度室节点判断第一目标RPA执行端执行待执行任务的时间超过设定时间，则判断第一目标RPA执行端超时，则通过对应的RPA控制端控制第一目标RPA执行端结束当前的待执行任务，以使第一目标RPA执行端执行新的待执行任务。

由此，通过判断超时的第一目标RPA执行端，并将超时的第一目标RPA执行端结束当前的待执行任务，可以提高处理任务的效率。

可选的，所述方法还包括：

通过所述调度室节点若判断待执行任务分配满量，将没有分配的待执行任务进行排列，以形成任务队列；

通过所述调度室节点当判断存在执行任务完毕的第二目标RPA执行端时，将所述任务队列中的待执行任务通过对应的RPA控制端分发至所述第二目标RPA执行端。

可选的，所述将待执行任务进行排列，以形成任务队列，包括：

将所述待执行任务按照时间顺序或者按照优先级进行排列，以形成任务队列。

其中，若调度室节点分配待执行任务之后，每个RPA执行端均在执行待执行任务，可以理解为待执行任务分配满量，则将待执行任务进行排队，以形成任务队列。可选的，可以按照时间顺序或者优先级进行排列，以形成任务队列。其中，可以将待执行任务按照任务的类别、紧急程度等进行优先级的排列。当调度室节点判断第二目标RPA执行端执行任务完毕时，将任务队列中的待执行任务通过对应的RPA控制端分发值第二目标RPA执行端，以使该第二目标RPA执行端执行待执行任务。

由此，调度室节点通过将待执行任务形成任务队列，并当判断第二目标RPA执行端执行完毕任务时，将任务队列中的待执行任务通过对应的RPA控制端将待执行任务分发至该第二目标RPA执行端，可以合理处理待执行任务，提高任务的处理效率。

可选的，所述方法还包括：

通过所述RPA控制端将执行结果存储至共享缓存中，以使所述调度室节点进行查询。其中RPA控制端之间禁止通信，可以将执行结果反馈到调度室节点，并将执行结果保存在共享缓存中，可以缩短执行结果反馈的时间，可以便于对执行结果的查询。相关技术中，集群机构模式往往通过Redis等中间件来缓存来保存共享数据，部署复杂且容易出错，本发明实施例通过引入调度室节点作为中间层，通过RPA控制端将数据进行共享缓存，降低部署难度。

可选的，所述RPA控制端与RPA执行端之间采用单机控制模式，包括：按照所述RPA控制端部署最大数量的RPA执行端的方式部署单机控制模式。可选的，RPA控制端与承载的最大数量的RPA执行端进行通信。可选的，最大数量可以是50。其中，每个RPA控制端部署最大数量的RPA执行端，从而使集群架构部署部署较多数量的RPA执行端，可以支持无限多的RPA执行端，可以提高性能。

本发明实施例提供的技术方案，通过集群架构包括调度室节点，多个RPA控制端以及与多个RPA执行端，其中，调度室节点分别与每个RPA控制端进行通信，RPA控制端与RPA执行端之间采用单机控制模式，RPA控制端之间禁止通信，通过调度室节点将待执行任务分发至RPA控制端，通过RPA控制端将待执行任务分发至RPA执行端，通过RPA执行端执行待执行任务，并将执行结果反馈至RPA控制端，通过RPA控制端将执行结果反馈至调度室节点，以使调度室节点将执行结果发送至待执行任务的发送端；即通过引入调度室节点，通过调度室节点控制待执行任务分发至RPA控制端，并通过RPA控制端将待执行任务分发至RPA执行端执行，通过包括多个RPA控制端以及多个RPA执行端，RPA控制端与RPA执行端之间采用单机控制模式，可以突破RPA执行端的设备数量的瓶颈，从而突破性能瓶颈，通过引入调度室节点以及控制RPA控制端之间禁止通信，可以使执行结果直接通过RPA控制端直接反馈至调度室节点，缩短执行结果的反馈时间，在成规模要求时效高的场景中可以尽快完成结果反馈，突破性能瓶颈。

图3是本发明实施例提供的一种基于RPA集群架构的任务处理方法流程图，在本实施例中，待执行任务包括打开浏览器的任务。

如图3所示，本发明实施例提供的技术方案包括：

S310：通过调度室节点接收打开浏览器的任务，将所述任务分发至RPA控制端。

S320：通过所述RPA控制端将所述任务分发至RPA执行端执行。

S330：通过所述RPA执行端执行打开浏览器的任务，并执行结果反馈至对应的RPA控制端。

S340：通过RPA控制端将所述执行结果反馈至所述调度室节点以使所述调度室节点将所述执行结果反馈至所述待执行任务的发送端。

需要说明的是，待执行任务除了包括打开浏览器的任务之外，还可以包括其他需要重复执行的任务，并待执行任务的类型并不作限定。本实施例仅仅是本发明的一种示例，在本发明的其他实施例中，还可以采用本发明提供的RPA集群架构执行其他需要重复执行的任务。

图4是本发明实施例提供的一种任务处理方法流程图，所述方法可以由任务处理装置来执行，所述装置可以由软件和/或硬件来实现，所述装置可以配置在调度室节点中，所述调度室节点可以是多个设备形成的集群，或者也可以是由一个设备形成的节点。

如图4所示，本发明实施例提供的任务处理方法包括：

S410:接收待执行任务，将待执行任务按照分发至RPA控制端以通过RPA控制端将所述待执行任务分发至RPA执行端执行。

S420：接收RPA执行端通过RPA控制端反馈的执行结果，并将所述执行结果反馈至待执行任务的发送端。

可选的，所述方法还可以包括：当判断存在超时的第一目标RPA执行端时，通过对应的RPA控制端控制所述第一目标RPA执行端结束当前的待执行任务，以执行新的待执行任务。、

可选的，所述方法还可以包括：若判断待执行任务分配满量，将没有分配的待执行任务进行排队，以形成任务队列；当判断存在执行任务完毕的第二目标RPA执行端时，将所述任务队列中的待执行任务通过对应的RPA控制端分发至所述第二目标RPA执行端。

上述步骤的介绍可以参考上述实施例的介绍。

图5是本发明实施例提供的一种任务处理装置的结构框图，如图5所示，所述装置包括发送模块510和接收模块520。

其中，发送模块510，用于接收待执行任务，将待执行任务按照分发至RPA控制端以通过RPA控制端将所述待执行任务分发至RPA执行端执行；

接收模块520，用于接收RPA执行端通过RPA控制端反馈的执行结果，并将所述执行结果反馈至待执行任务的发送端。

可选的，所述装置还可以包括控制模块，用于当判断存在超时的第一目标RPA执行端时，通过对应的RPA控制端控制所述第一目标RPA执行端结束当前的待执行任务，以执行新的待执行任务。

可选的，所述装置还包括：

排列模块，用于若判断待执行任务分配满量，将没有分配的待执行任务进行排队，以形成任务队列；

分发模块，用于当判断存在执行任务完毕的第二目标RPA执行端时，将所述任务队列中的待执行任务通过对应的RPA控制端分发至所述第二目标RPA执行端。

上述装置执行本发明实施例提供的任务处理方法，具有相应的功能模块和技术效果。

注意，上述仅为本发明的较佳实施例及所运用技术原理。本领域技术人员会理解，本发明不限于这里所述的特定实施例，对本领域技术人员来说能够进行各种明显的变化、重新调整和替代而不会脱离本发明的保护范围。因此，虽然通过以上实施例对本发明进行了较为详细的说明，但是本发明不仅仅限于以上实施例，在不脱离本发明构思的情况下，还可以包括更多其他等效实施例，而本发明的范围由所附的权利要求范围决定。