[go: up one dir, main page]

CN112015524A - Workflow deployment method, device, system and storage medium - Google Patents

Workflow deployment method, device, system and storage medium Download PDF

Info

Publication number
CN112015524A
CN112015524A CN201910452307.8A CN201910452307A CN112015524A CN 112015524 A CN112015524 A CN 112015524A CN 201910452307 A CN201910452307 A CN 201910452307A CN 112015524 A CN112015524 A CN 112015524A
Authority
CN
China
Prior art keywords
workflow
execution unit
resource domain
target resource
node
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Granted
Application number
CN201910452307.8A
Other languages
Chinese (zh)
Other versions
CN112015524B (en
Inventor
匡大虎
李鹏
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Alibaba Group Holding Ltd
Original Assignee
Alibaba Group Holding Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Alibaba Group Holding Ltd filed Critical Alibaba Group Holding Ltd
Priority to CN201910452307.8A priority Critical patent/CN112015524B/en
Publication of CN112015524A publication Critical patent/CN112015524A/en
Application granted granted Critical
Publication of CN112015524B publication Critical patent/CN112015524B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Classifications

    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46Multiprogramming arrangements
    • G06F9/48Program initiating; Program switching, e.g. by interrupt
    • G06F9/4806Task transfer initiation or dispatching
    • G06F9/4843Task transfer initiation or dispatching by program, e.g. task dispatcher, supervisor, operating system
    • G06F9/4881Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46Multiprogramming arrangements
    • G06F9/50Allocation of resources, e.g. of the central processing unit [CPU]
    • G06F9/5083Techniques for rebalancing the load in a distributed system

Landscapes

  • Engineering & Computer Science (AREA)
  • Software Systems (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Storage Device Security (AREA)
  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

本申请实施例提供一种工作流部署方法、设备、系统及存储介质。在本申请实施例中,将工作流部署与可为不同租户服务的分布式计算系统相结合,允许租户在其资源域中部署工作流;在工作流部署过程中,为工作流执行单元指定运行时使用的系统身份标识,以区分不同工作流执行单元对分布式计算系统中共享存储资源的访存权限,每个工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对系统中的共享存储资源进行访存,可在不同租户之间实现读写隔离,保证共享存储资源中数据的安全性。

Figure 201910452307

Embodiments of the present application provide a workflow deployment method, device, system, and storage medium. In the embodiment of the present application, the workflow deployment is combined with a distributed computing system that can serve different tenants, allowing tenants to deploy workflows in their resource domains; in the workflow deployment process, the workflow execution unit is designated to run The system identity used when the workflow execution unit is used to distinguish the access rights of different workflow execution units to the shared storage resources in the distributed computing system. It can implement read-write isolation between different tenants and ensure the security of data in the shared storage resources.

Figure 201910452307

Description

工作流部署方法、设备、系统及存储介质Workflow deployment method, device, system and storage medium

技术领域technical field

本申请涉及互联网技术领域,尤其涉及一种工作流部署方法、设备、系统及存储介质。The present application relates to the field of Internet technologies, and in particular, to a workflow deployment method, device, system, and storage medium.

背景技术Background technique

面对工作流(WorkFlow)存在的高并发问题,一些云容器厂商开始关注Kubernetes的分布式集群,在基于Kubernetes的分布式集群中部署工作流,借助Kubernetes的调度能力可实现工作流的控制和运行。In the face of the high concurrency problem of WorkFlow, some cloud container manufacturers have begun to pay attention to the distributed cluster of Kubernetes, and deploy the workflow in the distributed cluster based on Kubernetes. With the help of the scheduling capability of Kubernetes, the control and operation of the workflow can be realized. .

但是,在基于Kubernetes的分布式集群中部署工作流也面临一些有待解决的问题,其中,如何在多租户计算环境下保证共享存储空间中数据的访存安全便是有待解决的问题之一。However, deploying workflows in Kubernetes-based distributed clusters also faces some problems to be solved. One of the problems to be solved is how to ensure the security of data access in the shared storage space in a multi-tenant computing environment.

发明内容SUMMARY OF THE INVENTION

本申请的多个方面提供一种工作流部署方法、设备、系统及存储介质,用以在多租户计算环境下部署工作流,并保证共享存储空间中数据的安全性。Various aspects of the present application provide a workflow deployment method, device, system and storage medium for deploying workflows in a multi-tenant computing environment and ensuring data security in a shared storage space.

本申请实施例提供一种分布式计算系统,包括:主控节点、工作流管理节点以及不同租户对应的资源域;An embodiment of the present application provides a distributed computing system, including: a master control node, a workflow management node, and resource domains corresponding to different tenants;

所述工作流管理节点,用于根据目标资源域中的工作流部署信息,获取工作流执行单元运行时使用的系统身份标识;将所述工作流执行单元运行时使用的系统身份标识传输给所述主控节点;The workflow management node is configured to obtain the system identity used when the workflow execution unit is running according to the workflow deployment information in the target resource domain; and transmit the system identity used when the workflow execution unit is running to the the main control node;

所述主控节点,用于在所述工作流执行单元运行时使用的系统身份标识属于所述目标资源域有权使用的系统身份标识的情况下,将所述工作流执行单元部署到所述目标资源域中的工作节点上;其中,所述工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对所述分布式计算系统的共享存储资源进行访存。The master control node is configured to deploy the workflow execution unit to the On the working node in the target resource domain; wherein, the workflow execution unit fetches the shared storage resources of the distributed computing system based on the fetching authority corresponding to the system identity used by the workflow execution unit when it runs.

本申请实施例还提供一种基于容器编排调度系统实现的分布式计算系统,包括:主控节点、工作流管理节点以及不同租户对应的命名空间;The embodiments of the present application also provide a distributed computing system based on a container orchestration and scheduling system, including: a master control node, a workflow management node, and namespaces corresponding to different tenants;

所述工作流管理节点,用于根据目标命名空间中的工作流部署信息,获取待部署工作流所需的容器运行时使用的系统身份标识;将所述容器运行时使用的系统身份标识传输给所述主控节点;The workflow management node is configured to acquire, according to the workflow deployment information in the target namespace, the system identity used by the container runtime required by the to-be-deployed workflow; and transmit the system identity used by the container runtime to the the master control node;

所述主控节点,用于在所述容器运行时使用的系统身份标识属于所述目标命名空间有权使用的系统身份标识的情况下,将所述容器部署到所述目标命名空间下的工作节点上;其中,所述容器基于其运行时使用的系统身份标识对应的访存权限对所述分布式计算系统的共享存储资源进行访存。The master control node is used for deploying the container to work under the target namespace when the system identity used when the container is running belongs to the system identity that the target namespace has the right to use On the node; wherein, the container fetches the shared storage resources of the distributed computing system based on the fetch authority corresponding to the system identity used by the container when it runs.

本申请实施例还提供一种工作流部署方法,适用于工作流管理节点,所述方法包括:根据目标资源域中的工作流部署信息,获取工作流执行单元运行时使用的系统身份标识;将所述工作流执行单元运行时使用的系统身份标识传输给所述工作流管理节点所属分布式计算系统中的主控节点,以供所述主控节点在所述工作流执行单元运行时使用的系统身份标识属于所述目标资源域有权使用的系统身份标识的情况下,将所述工作流执行单元部署到所述目标资源域中的工作节点上;其中,所述工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对所述分布式计算系统的共享存储资源进行访存。The embodiment of the present application also provides a workflow deployment method, which is applicable to a workflow management node. The method includes: obtaining a system identity used by the workflow execution unit when the workflow execution unit is running according to the workflow deployment information in the target resource domain; The system identity used when the workflow execution unit is running is transmitted to the master control node in the distributed computing system to which the workflow management node belongs, so as to be used by the master control node when the workflow execution unit is running. In the case that the system ID belongs to the system ID that the target resource domain has the right to use, the workflow execution unit is deployed on the worker nodes in the target resource domain; wherein, the workflow execution unit is based on the The fetch authority corresponding to the system identity used at runtime fetches the shared storage resources of the distributed computing system.

本申请实施例还提供一种工作流部署方法,适用于主控节点,所述方法包括:接收工作流管理节点发送的工作流执行单元运行时使用的系统身份标识,所述工作流执行单元是需要在目标资源域中部署的工作流的执行单元;在所述工作流执行单元运行时使用的系统身份标识属于所述目标资源域有权使用的系统身份标识的情况下,将所述工作流执行单元部署到所述目标资源域中的工作节点上;其中,所述工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对所述分布式计算系统的共享存储资源进行访存。The embodiment of the present application further provides a workflow deployment method, which is applicable to a master control node. The method includes: receiving a system identity identifier used by a workflow execution unit when running a workflow execution unit sent by a workflow management node, where the workflow execution unit is a The execution unit of the workflow that needs to be deployed in the target resource domain; in the case that the system identity used when the workflow execution unit is running belongs to the system identity that the target resource domain has the right to use, the workflow The execution unit is deployed on the worker node in the target resource domain; wherein, the workflow execution unit accesses the shared storage resources of the distributed computing system based on the memory access authority corresponding to the system identity used during its runtime. live.

本申请实施例还提供一种工作管理节点,包括存储器和处理器;所述存储器用于存储计算机程序;当所述计算机程序被所述处理器执行时,致使所述处理器实现本申请实施例中可由工作管理节点执行的方法中的步骤。An embodiment of the present application further provides a work management node, including a memory and a processor; the memory is used to store a computer program; when the computer program is executed by the processor, the processor is caused to implement the embodiment of the present application The steps in a method executable by a work management node.

本申请实施例还提供一种存储有计算机程序的计算机可读存储介质,当所述计算机程序被处理器执行时,致使所述处理器实现本申请实施例中可由工作管理节点执行的方法中的步骤。The embodiments of the present application further provide a computer-readable storage medium storing a computer program, when the computer program is executed by the processor, the processor is caused to implement the method in the embodiments of the present application that can be executed by the work management node. step.

本申请实施例还提供一种主控节点,包括存储器和处理器;所述存储器用于存储计算机程序;当所述计算机程序被所述处理器执行时,致使所述处理器实现本申请实施例中可由主控节点执行的方法中的步骤。The embodiments of the present application further provide a master control node, including a memory and a processor; the memory is used to store a computer program; when the computer program is executed by the processor, the processor is caused to implement the embodiments of the present application Steps in a method executable by a master node.

本申请实施例还提供一种存储有计算机程序的计算机可读存储介质,当所述计算机程序被处理器执行时,致使所述处理器实现本申请实施例中可由主控节点执行的方法中的步骤。Embodiments of the present application further provide a computer-readable storage medium storing a computer program, and when the computer program is executed by a processor, the processor causes the processor to implement one of the methods in the embodiments of the present application that can be executed by a master control node. step.

在本申请实施例中,将工作流部署与可为不同租户服务的分布式计算系统相结合,允许租户在其资源域中部署工作流;在工作流部署过程中,为工作流执行单元指定运行时使用的系统身份标识,以区分不同工作流执行单元对分布式计算系统中共享存储资源的访存权限,每个工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对系统中的共享存储资源进行访存,可在不同租户之间实现读写隔离,保证共享存储资源中数据的安全性。In the embodiment of the present application, the workflow deployment is combined with a distributed computing system that can serve different tenants, allowing tenants to deploy workflows in their resource domains; during the workflow deployment process, the workflow execution unit is designated to run The system identity used when the workflow execution unit is used to distinguish the access rights of different workflow execution units to the shared storage resources in the distributed computing system. It can implement read-write isolation between different tenants and ensure the security of data in the shared storage resources.

附图说明Description of drawings

此处所说明的附图用来提供对本申请的进一步理解,构成本申请的一部分,本申请的示意性实施例及其说明用于解释本申请,并不构成对本申请的不当限定。在附图中:The drawings described herein are used to provide further understanding of the present application and constitute a part of the present application. The schematic embodiments and descriptions of the present application are used to explain the present application and do not constitute an improper limitation of the present application. In the attached image:

图1a为本申请示例性实施例提供的一种分布式计算系统的结构示意图;FIG. 1a is a schematic structural diagram of a distributed computing system provided by an exemplary embodiment of the present application;

图1b为本申请示例性实施例提供的基于Kubernetes的分布式计算系统的结构示意图;Fig. 1b is a schematic structural diagram of a distributed computing system based on Kubernetes provided by an exemplary embodiment of the present application;

图2a为本申请示例性实施例提供的一种工作流部署方法的流程示意图;Fig. 2a is a schematic flowchart of a workflow deployment method provided by an exemplary embodiment of the present application;

图2b为本申请示例性实施例提供的另一种工作流部署方法的流程示意图;FIG. 2b is a schematic flowchart of another workflow deployment method provided by an exemplary embodiment of the present application;

图3为本申请示例性实施例提供的一种工作流管理节点的结构示意图;FIG. 3 is a schematic structural diagram of a workflow management node according to an exemplary embodiment of the present application;

图4为本申请示例性实施例提供的一种主控节点的结构示意图。FIG. 4 is a schematic structural diagram of a master control node according to an exemplary embodiment of the present application.

具体实施方式Detailed ways

为使本申请的目的、技术方案和优点更加清楚,下面将结合本申请具体实施例及相应的附图对本申请技术方案进行清楚、完整地描述。显然,所描述的实施例仅是本申请一部分实施例,而不是全部的实施例。基于本申请中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都属于本申请保护的范围。In order to make the objectives, technical solutions and advantages of the present application clearer, the technical solutions of the present application will be clearly and completely described below with reference to the specific embodiments of the present application and the corresponding drawings. Obviously, the described embodiments are only a part of the embodiments of the present application, but not all of the embodiments. Based on the embodiments in the present application, all other embodiments obtained by those of ordinary skill in the art without creative efforts shall fall within the protection scope of the present application.

针对现有技术中在多租户计算环境下部署工作流所面临的共享存储资源中数据的访存安全问题,在本申请一些实施例中,将工作流部署与可为不同租户服务的分布式计算系统相结合,允许租户在其资源域中部署工作流;在工作流部署过程中,为工作流执行单元指定运行时使用的系统身份标识,以区分不同工作流执行单元对分布式计算系统中共享存储资源的访存权限,每个工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对系统中的共享存储资源进行访存,可在不同租户之间实现读写隔离,保证共享存储资源中数据的安全性。In view of the security problem of data access in shared storage resources faced by deploying workflows in a multi-tenant computing environment in the prior art, in some embodiments of the present application, workflow deployment is combined with distributed computing that can serve different tenants. The system is combined to allow tenants to deploy workflows in their resource domains; during the workflow deployment process, specify the system identity used at runtime for the workflow execution units to distinguish between different workflow execution units and the distributed computing system. Access permissions for storage resources. Each workflow execution unit accesses the shared storage resources in the system based on the access permissions corresponding to the system identity used by the workflow execution unit. Security of data in shared storage resources.

以下结合附图,详细说明本申请各实施例提供的技术方案。The technical solutions provided by the embodiments of the present application will be described in detail below with reference to the accompanying drawings.

图1a为本申请示例性实施例提供的一种分布式计算系统10的结构示意图。如图1a所示,该分布式计算系统10包括:主控节点11、工作流管理节点13以及不同租户对应的资源域14。FIG. 1a is a schematic structural diagram of a distributed computing system 10 provided by an exemplary embodiment of the present application. As shown in FIG. 1a, the distributed computing system 10 includes: a master control node 11, a workflow management node 13, and resource domains 14 corresponding to different tenants.

本实施例的分布式计算系统10包括多种资源,例如计算资源、存储资源和网络资源等,这些资源可由分布式计算系统中的物理设备提供。分布式计算系统10中的物理设备包括但不限于:计算机设备、传感器设备、存储设备、常规服务器、云服务器或服务器阵列等。本实施例的分布式计算系统10,一方面可以向租户提供各种资源,另一方面还允许租户在这些资源上部署所需的服务。The distributed computing system 10 of this embodiment includes a variety of resources, such as computing resources, storage resources, and network resources, and these resources may be provided by physical devices in the distributed computing system. Physical devices in distributed computing system 10 include, but are not limited to, computer devices, sensor devices, storage devices, conventional servers, cloud servers, or server arrays, and the like. The distributed computing system 10 of this embodiment, on the one hand, can provide various resources to the tenant, and on the other hand allows the tenant to deploy required services on these resources.

其中,不同租户可在分布式计算系统10中申请自己的资源域,并在自己的资源域中部署所需的各种服务。每个租户可以申请一个或多个资源域。对每个租户来说,可在不同资源域中部署不同服务,也可以在不同资源域中部署相同服务。任一租户的资源域中包括该租户可独享的各种资源,例如可为该租户提供相应服务的工作节点、部署在工作节点上的各种服务程序等。本申请实施例并不限定服务程序的实现形式,例如可以包括各类应用程序和/或操作系统等。Wherein, different tenants can apply for their own resource domains in the distributed computing system 10, and deploy various required services in their own resource domains. Each tenant can apply for one or more resource domains. For each tenant, different services can be deployed in different resource domains, or the same service can be deployed in different resource domains. The resource domain of any tenant includes various resources that the tenant can exclusively enjoy, such as worker nodes that can provide corresponding services for the tenant, various service programs deployed on the worker nodes, and the like. The embodiments of the present application do not limit the implementation form of the service program, for example, various application programs and/or operating systems may be included.

其中,不同租户具有不同的用户身份凭证,每个租户的用户身份凭证可唯一标识该租户。租户的用户身份凭证可以任何能够唯一标识该租户的信息,例如可以是租户在分布式计算系统10中的ID,也可以是租户在分布式计算系统10中注册的租户名称、账号、电话号码、电子邮箱和/或家庭住址等。另外,为了区分不同租户的资源域以及同一租户的不同资源域,每个资源域也有自己的标识,每个资源域的标识可唯一标识该资源域。资源域的标识可以是任何能够唯一标识该资源域的信息,例如可以是资源域在分布式计算系统10中的ID、名称和/或申请时间等。在本实施例中,维护有租户的用户身份凭证与租户的资源域的标识之间的对应关系。Wherein, different tenants have different user identity credentials, and the user identity credentials of each tenant can uniquely identify the tenant. The user identity credential of the tenant can be any information that can uniquely identify the tenant, for example, the tenant's ID in the distributed computing system 10, or the tenant's name, account number, phone number, Email address and/or home address, etc. In addition, in order to distinguish resource domains of different tenants and different resource domains of the same tenant, each resource domain also has its own identifier, and the identifier of each resource domain can uniquely identify the resource domain. The identifier of the resource domain may be any information that can uniquely identify the resource domain, for example, the ID, name and/or application time of the resource domain in the distributed computing system 10 . In this embodiment, a correspondence relationship between the tenant's user identity credential and the identifier of the tenant's resource domain is maintained.

为了更好地服务租户,分布式计算系统10包括:主控(Master)节点11。主控节点11是分布式计算系统10中的管控节点,主要负责分布式计算系统10中的资源管理、服务调度、节点管控、安全控制、系统监控和纠错等中至少一种管理。可选地,主控节点11上可以运行与系统管控相关的一系列进程,这些进程可实现分布式计算系统10中的资源管理、服务调度、节点管控、安全控制、系统监控和纠错等管理能力。主控节点11的数量可以是一个或多个。主控节点11可以部署在分布式计算系统10中的物理设备或虚拟机上。在主控节点11为多个的情况下,多个主控节点11可以分散部署在多台物理设备或虚拟机上。In order to better serve the tenants, the distributed computing system 10 includes: a master (Master) node 11 . The main control node 11 is a management and control node in the distributed computing system 10 , and is mainly responsible for at least one management of resource management, service scheduling, node management and control, security control, system monitoring, and error correction in the distributed computing system 10 . Optionally, a series of processes related to system management and control can be run on the master control node 11, and these processes can implement management such as resource management, service scheduling, node management and control, security control, system monitoring, and error correction in the distributed computing system 10. ability. The number of master nodes 11 may be one or more. The master node 11 may be deployed on a physical device or a virtual machine in the distributed computing system 10 . In the case where there are multiple master control nodes 11, the multiple master control nodes 11 may be distributed and deployed on multiple physical devices or virtual machines.

除了主控节点11,分布式计算系统10还包括工作节点12。工作节点12是分布式计算系统10中可为租户提供所需服务的服务节点。工作节点12的数量可以是一个或多个。可选地,在工作节点12为多个的情况下,多个工作节点12可以集中部署在同一台物理设备或虚拟机上,也可以分散部署在多台物理设备或虚拟机上。分布式计算系统10中的工作节点12分布在不同租户的资源域14中,用以承载租户部署的服务程序或进程等可执行单元。In addition to master node 11 , distributed computing system 10 also includes worker nodes 12 . The worker nodes 12 are service nodes in the distributed computing system 10 that can provide tenants with required services. The number of worker nodes 12 may be one or more. Optionally, in the case where there are multiple working nodes 12, the multiple working nodes 12 may be centrally deployed on the same physical device or virtual machine, or may be deployed scatteredly on multiple physical devices or virtual machines. The worker nodes 12 in the distributed computing system 10 are distributed in the resource domains 14 of different tenants, and are used to carry executable units such as service programs or processes deployed by the tenants.

在本实施例中,租户可以在其资源域中部署工作流,为了便于租户部署工作流,分布式计算系统10还包括工作流管理节点13。工作流管理节点13可以集中部署在分布式计算系统10中的一台或多台物理机上,或者也可以分散部署在多台物理设备或虚拟机上。工作流管理节点13主要为不同租户提供工作流部署能力,供不同租户在自己的资源域14中部署工作流。其中,工作流部署主要是指根据租户提供的工作流部署信息确定具有执行顺序的工作流执行单元,并将工作流执行单元部署到租户的资源域14中的工作节点12上的过程。进一步,工作流管理节点13还可以在工作流部署成功之后,对工作流执行单元进行监控和管理等。其中,工作流执行单元是指完成工作流所需的执行单元。In this embodiment, the tenant can deploy the workflow in its resource domain. In order to facilitate the tenant to deploy the workflow, the distributed computing system 10 further includes a workflow management node 13 . The workflow management node 13 can be centrally deployed on one or more physical machines in the distributed computing system 10, or can be deployed on multiple physical devices or virtual machines in a distributed manner. The workflow management node 13 mainly provides workflow deployment capabilities for different tenants, so that different tenants can deploy workflows in their own resource domains 14 . The workflow deployment mainly refers to the process of determining workflow execution units with execution order according to the workflow deployment information provided by the tenant, and deploying the workflow execution units to the worker nodes 12 in the resource domain 14 of the tenant. Further, the workflow management node 13 can also monitor and manage the workflow execution unit after the workflow is deployed successfully. The workflow execution unit refers to the execution unit required to complete the workflow.

在分布式计算系统10中,除了包括每个租户独享的资源域之外,还包括一些可供不同租户共享的全局共享资源。在本实施例中,全局共享资源主要是指可供不同租户共享的共享存储资源。共享存储资源可以是本地存储资源,也可以是网络存储资源,例如网络附属存储(Network Attached Storage,NAS)。例如,不同租户的数据可存储在共享存储资源中,并且不同租户均可以访问分布式计算系统10中的共享存储资源。为了保证共享存储资源中数据的访存安全,有必要在不同租户之间实现读写隔离,确保共享存储资源中数据的访存安全。In the distributed computing system 10 , in addition to the resource domains that are exclusively shared by each tenant, it also includes some global shared resources that can be shared by different tenants. In this embodiment, the global shared resources mainly refer to shared storage resources that can be shared by different tenants. The shared storage resource may be a local storage resource or a network storage resource, such as a network attached storage (Network Attached Storage, NAS). For example, data of different tenants may be stored in shared storage resources, and different tenants may access the shared storage resources in distributed computing system 10 . In order to ensure the security of data access in shared storage resources, it is necessary to implement read-write isolation between different tenants to ensure the security of data access in shared storage resources.

在本实施例中,分布式计算系统10基于系统身份标识对其共享存储资源进行访存管理,每个系统身份标识对应一定的访存权限。基于此,在工作流部署过程中,为工作流执行单元指定运行时使用的系统身份标识,这样可以区分不同工作流执行单元对分布式计算系统10中共享存储资源的访存权限。每个工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对系统中的共享存储资源进行访存,可在不同租户之间实现读写隔离,保证共享存储资源中数据的安全性。系统身份标识可以是用户标识(Uid),也可以是用户组标识(Gid)。Gid标识一组用户。In this embodiment, the distributed computing system 10 performs fetch management on its shared storage resources based on the system identity, and each system identity corresponds to a certain fetch authority. Based on this, in the workflow deployment process, the system identity used at runtime is specified for the workflow execution unit, so that the access rights of different workflow execution units to the shared storage resources in the distributed computing system 10 can be distinguished. Each workflow execution unit fetches the shared storage resources in the system based on the fetching authority corresponding to the system identity used during its runtime, which can realize read-write isolation between different tenants and ensure the security of the data in the shared storage resources. sex. The system ID can be a user ID (Uid) or a user group ID (Gid). Gid identifies a group of users.

具体地,对于在目标资源域中部署工作流的场景,工作流管理节点13可根据目标资源域中的工作流部署信息,获取工作流执行单元运行时使用的系统身份标识;将工作流执行单元运行时使用的系统身份标识传输给主控节点11。其中,目标资源域可以是目标租户申请的任一资源域,目标租户可以是系统中任一租户。目标租户可以是个人、企业、公司或公司的部门等。工作流执行单元一般为多个,当然,也可以是一个。工作流执行单元可以是任何可实现一定功能,且具有执行能力的服务单元,例如可以是容器、虚拟机、进程或线程等。Specifically, for the scenario of deploying the workflow in the target resource domain, the workflow management node 13 can obtain the system identity used by the workflow execution unit when running the workflow execution unit according to the workflow deployment information in the target resource domain; The system identity used at runtime is transmitted to the master node 11 . The target resource domain can be any resource domain applied by the target tenant, and the target tenant can be any tenant in the system. Target tenants can be individuals, businesses, companies, or divisions of companies, etc. Generally, there are multiple workflow execution units, and of course, it can also be one. The workflow execution unit may be any service unit that can implement certain functions and has execution capability, such as a container, a virtual machine, a process, or a thread.

在主控节点11侧,预先维护有目标资源域有权使用的系统身份标识。基于此,主控节点11接收到工作流管理节点13发送的工作流执行单元运行时使用的系统身份标识的情况下,可以判断工作流执行单元运行时使用的系统身份标识是否属于目标资源域有权使用的系统身份标识;并在判断出工作流执行单元运行时使用的系统身份标识属于目标资源域有权使用的系统身份标识的情况下,将工作流执行单元部署到目标资源域中的工作节点12上。对工作流执行单元来说,在其运行过程中可基于其运行时使用的系统身份标识对应的访存权限对分布式计算系统10的共享存储资源进行访存。On the side of the master control node 11, the system identity that the target resource domain has the right to use is maintained in advance. Based on this, when the master control node 11 receives the system ID used by the workflow execution unit when it is running, sent by the workflow management node 13, it can determine whether the system ID used when the workflow execution unit is running belongs to the target resource domain. When it is judged that the system identity used when the workflow execution unit is running belongs to the system identity that the target resource domain has the right to use, deploy the workflow execution unit to the work of the target resource domain on node 12. For the workflow execution unit, the shared storage resource of the distributed computing system 10 can be accessed during its running process based on the access authority corresponding to the system identity used by the workflow execution unit.

在本申请实施例中,若要成功地将工作流执行单元部署到相应工作节点12上,除了需要工作流执行单元运行时使用的系统身份标识之外,还需要有工作流执行单元。在一种可选实施例中,租户可以将工作流执行单元直接提供给主控节点11,则主控节点11直接获取租户提交的工作流执行单元。或者,在另一可选实施例中,由工作流管理节点13从工作流部署信息中获取具有执行顺序的工作流执行单元,并将所获取的工作流执行单元提供给主控节点11,对租户来说,在部署工作流过程中只需与工作流管理节点13进行交互,操作相对简单。In this embodiment of the present application, to successfully deploy the workflow execution unit to the corresponding worker node 12, in addition to the system identity used when the workflow execution unit is running, a workflow execution unit is also required. In an optional embodiment, the tenant may directly provide the workflow execution unit to the master control node 11, and the master control node 11 directly obtains the workflow execution unit submitted by the tenant. Or, in another optional embodiment, the workflow management node 13 acquires the workflow execution units with the execution order from the workflow deployment information, and provides the acquired workflow execution units to the master control node 11, For the tenant, in the process of deploying the workflow, it only needs to interact with the workflow management node 13, and the operation is relatively simple.

进一步可选地,若主控节点11以工作流执行单元为粒度进行管理,则工作流管理节点13可以从工作流部署信息中获取工作流执行单元,并按照工作流执行单元之间的先后执行顺序将工作流执行单元传输给主控节点11。或者,Further optionally, if the master control node 11 manages with the workflow execution unit as the granularity, the workflow management node 13 can obtain the workflow execution unit from the workflow deployment information, and execute the workflow execution units in sequence. The workflow execution units are sequentially transmitted to the master node 11 . or,

进一步可选地,主控节点11以工作流执行单元模型为单位进行管理,则工作流管理节点13可以根据工作流部署信息生成主控节点11可识别的至少一个工作流执行单元模型,每个工作流执行单元模型包含至少一个工作流执行单元;按照至少一个工作流执行单元模型之间的时序依赖关系,依次将至少一个工作流执行单元模型发送给主控节点11,以供主控节点11以工作流执行单元模型为单位对工作流执行单元进行部署。其中,工作流执行单元模型是工作流执行单元的管理模型。Further optionally, if the master control node 11 manages the workflow execution unit model as a unit, the workflow management node 13 may generate at least one workflow execution unit model identifiable by the master control node 11 according to the workflow deployment information. The workflow execution unit model includes at least one workflow execution unit; according to the time sequence dependency between the at least one workflow execution unit model, the at least one workflow execution unit model is sequentially sent to the master control node 11 for the master control node 11 The workflow execution unit is deployed in units of the workflow execution unit model. The workflow execution unit model is a management model of the workflow execution unit.

对主控节点11来说,可以接收工作流管理节点13依次发送的至少一个工作流执行单元模型;针对每个工作流执行单元模型,判断该工作流执行单元模型中的工作流执行单元运行时使用的系统身份标识是否均属于目标资源域有权使用的系统身份标识;若判断结果为是,将该工作流执行单元模型中的工作流执行单元部署到目标资源域中的工作节点上。在该过程中,主控节点11可对目标资源域中的工作节点进行调度,以便成功将每个工作流执行单元模型中的工作流执行单元部署到相应工作节点上。其中,对任一工作节点的调度过程可以是通知该工作节点需要部署工作流执行单元,并将需要部署到该工作节点上的工作流执行单元发送给该工作节点。其中,通知过程和发送工作流执行单元的过程可以是同一通信过程,也可以是不同的通信过程。For the master control node 11, it can receive at least one workflow execution unit model sequentially sent by the workflow management node 13; for each workflow execution unit model, determine the runtime of the workflow execution unit in the workflow execution unit model. Whether the used system identities belong to the system identities that the target resource domain has permission to use; if the judgment result is yes, deploy the workflow execution unit in the workflow execution unit model to the worker nodes in the target resource domain. In this process, the master control node 11 can schedule the worker nodes in the target resource domain, so as to successfully deploy the workflow execution units in each workflow execution unit model to the corresponding worker nodes. The scheduling process for any worker node may be to notify the worker node that the workflow execution unit needs to be deployed, and send the workflow execution unit to be deployed on the worker node to the worker node. The notification process and the process of sending the workflow execution unit may be the same communication process, or may be different communication processes.

在一可选实施例中,工作流部署信息中除了包含工作流执行单元以及工作流执行单元运行时使用的系统身份标识之外,还可以包含目标资源域的标识以及申请部署工作流的用户身份凭证。其中,目标资源域的标识用于标识需要在哪个资源域中部署工作流;用户身份凭证用于标识是哪个租户申请部署工作流。考虑到不同租户具有自己的资源域,工作流管理节点13还可以从工作流部署信息中获取目标资源域的标识以及申请部署工作流的用户身份凭证;将目标资源域的标识和用户身份凭证发送给主控节点11,以供主控节点11确定目标资源域的标识和用户身份凭证是否对应,即进行资源域合法性的校验;以及接收主控节点11返回的确定结果。进一步,在主控节点11确定目标资源域的标识和用户身份凭证对应的情况下,再按照至少一个工作流执行单元模型之间的时序依赖关系,依次将至少一个工作流执行单元模型发送给主控节点11。In an optional embodiment, in addition to the workflow execution unit and the system identity used when the workflow execution unit runs, the workflow deployment information may also include the identity of the target resource domain and the identity of the user who applies for deploying the workflow. certificate. The identifier of the target resource domain is used to identify the resource domain in which the workflow needs to be deployed; the user identity credential is used to identify which tenant applies for deploying the workflow. Considering that different tenants have their own resource domains, the workflow management node 13 can also obtain the identifier of the target resource domain and the user identity credential for applying to deploy the workflow from the workflow deployment information; send the identifier of the target resource domain and the user identity credential to the To the main control node 11 , for the main control node 11 to determine whether the identifier of the target resource domain corresponds to the user identity certificate, that is, to verify the validity of the resource domain; and to receive the determination result returned by the main control node 11 . Further, when the master control node 11 determines that the identifier of the target resource domain corresponds to the user identity credential, the at least one workflow execution unit model is sequentially sent to the master according to the time sequence dependency between the at least one workflow execution unit model. control node 11.

对主控节点11来说,还会维护不同租户的资源域的标识与不同租户的用户身份凭证之间的对应关系。基于该对应关系,主控节点11在接收工作流管理节点13发送的目标资源域的标识和用户身份凭证后,可以查询所维护的对应关系,确定目标资源域的标识和用户身份凭证是否对应,并向工作流管理节点13返回确定结果。For the master node 11, the corresponding relationship between the identifiers of the resource domains of different tenants and the user identity credentials of different tenants is also maintained. Based on the corresponding relationship, after receiving the identifier of the target resource domain and the user identity credential sent by the workflow management node 13, the master control node 11 can query the maintained correspondence to determine whether the identifier of the target resource domain corresponds to the user identity credential, And return the determination result to the workflow management node 13 .

进一步可选地,工作流管理节点13可以在主控节点11确定目标资源域的标识和用户身份凭证对应的情况下,根据至少一个工作流执行单元模型之间的时序依赖关系,依次将至少一个工作流执行单元模型发送给主控节点11,以供主控节点11以工作流执行单元模型为单位对工作流执行单元进行部署。对主控节点11而言,在确定目标资源域的标识和用户身份凭证对应的情况下,可继续接收工作流管理节点13依次发送的至少一个工作流执行单元模型;针对每个工作流执行单元模型,判断该工作流执行单元模型中的工作流执行单元运行时使用的系统身份标识是否均属于目标资源域有权使用的系统身份标识;若判断结果为是,将该工作流执行单元模型中的工作流执行单元部署到目标资源域中的工作节点上。Further optionally, when the master control node 11 determines that the identifier of the target resource domain corresponds to the user identity credential, the workflow management node 13 may, according to the time-series dependency between at least one workflow execution unit model, sequence the at least one The workflow execution unit model is sent to the master control node 11 for the master control node 11 to deploy the workflow execution unit by using the workflow execution unit model as a unit. For the master control node 11, in the case of determining that the identifier of the target resource domain corresponds to the user identity credential, it can continue to receive at least one workflow execution unit model sequentially sent by the workflow management node 13; for each workflow execution unit model, to determine whether the system identities used by the workflow execution units in the workflow execution unit model are all system identities that the target resource domain has the right to use; if the judgment result is yes, the workflow execution unit model The workflow execution unit is deployed to the worker nodes in the target resource domain.

在一可选实施例中,每个租户包括运维管理人员和工作流部署人员。运维管理人员相当于该租户在分布式计算系统10中的管理员,具有全局配置和管理权限,例如可以向分布式计算系统10申请资源域、配置资源域的安全参数、为不同工作流部署人员配置使用权限、下发相关参数等。工作流部署人员主要负责在资源域中部署工作流。可选地,主控节点11可以面向租户的运维管理人员提供资源域安全配置界面,供运维管理人员配置资源域的安全参数。其中,资源域的安全参数可以包括但不限于:资源域的用户身份凭证、资源域的标识以及资源域有权使用的系统身份标识等。对运维管理人员来说,可通过主控节点11提供的资源域安全配置界面,配置资源域的安全参数。主控节点11获取运维管理人员配置的资源域的安全参数之后,可以建立这些安全参数之间的对应关系,主要是指资源域的用户身份凭证、资源域的标识以及资源域有权使用的系统身份标识之间的对应关系。In an optional embodiment, each tenant includes operation and maintenance management personnel and workflow deployment personnel. The operation and maintenance manager is equivalent to the administrator of the tenant in the distributed computing system 10, and has global configuration and management authority. For example, he can apply to the distributed computing system 10 for resource domains, configure security parameters of resource domains, and deploy for different workflows. Personnel configuration access rights, distribution of related parameters, etc. Workflow deployers are primarily responsible for deploying workflows in resource domains. Optionally, the master control node 11 may provide a resource domain security configuration interface for the operation and maintenance management personnel of the tenant, for the operation and maintenance management personnel to configure the security parameters of the resource domain. The security parameters of the resource domain may include, but are not limited to, the user identity credentials of the resource domain, the identifier of the resource domain, and the system identifier that the resource domain has the right to use, and the like. For the operation and maintenance manager, the security parameters of the resource domain can be configured through the resource domain security configuration interface provided by the master control node 11 . After acquiring the security parameters of the resource domain configured by the operation and maintenance manager, the master control node 11 can establish the corresponding relationship between these security parameters, which mainly refers to the user identity credentials of the resource domain, the identifier of the resource domain, and the resource domain that the resource domain has the right to use. The correspondence between system identities.

对目标资源域来说,将其对应的租户称为目标租户。主控节点11也会面向目标租户的运维管理人员提供资源域安全配置界面。例如,主控节点11可根据目标租户的运维管理人员发出的请求访问资源域安全配置界面的触发操作,向运维管理人员展示资源域安全配置界面。其中,资源域安全配置界面可以是web页面,应用页面或命令窗口等。根据资源域安全配置界面实现方式的不同,运维管理人员请求访问资源域安全配置界面的触发操作也会有所不同。以资源域安全配置界面是web页面为例,运维管理人员可以在其使用的终端设备上的浏览器中输入该web页面的链接,点击访问控件进入登录页面,并在登录页面上输入登录账号和密码,然后在其使用的终端设备的浏览器展示该web页面。For the target resource domain, the corresponding tenant is called the target tenant. The master control node 11 also provides a resource domain security configuration interface for the operation and maintenance manager of the target tenant. For example, the master control node 11 may display the resource domain security configuration interface to the operation and maintenance manager according to a trigger operation of requesting access to the resource domain security configuration interface issued by the operation and maintenance manager of the target tenant. The resource domain security configuration interface may be a web page, an application page, or a command window, and the like. Depending on how the security configuration interface of the resource domain is implemented, the trigger actions for the operation and maintenance administrator to request access to the security configuration interface of the resource domain will also be different. Taking the resource domain security configuration interface as a web page as an example, operation and maintenance managers can enter the link of the web page in the browser on the terminal device they use, click the access control to enter the login page, and enter the login account on the login page. and password, and then display the web page in the browser of the terminal device it uses.

资源域安全配置界面上包含与目标资源域相关的安全参数的配置项。在看到资源域安全配置界面之后,目标租户的运维管理人员可以通过资源域安全配置界面上的配置项配置目标资源域的安全参数,例如目标资源域的用户身份凭证、目标资源域的标识以及目标资源域有权使用的系统身份标识等。其中,目标资源域有权使用的系统身份标识可以是一个系统身份标识范围,也可以是一系列具体的系统身份标识。The resource domain security configuration interface contains configuration items of security parameters related to the target resource domain. After seeing the resource domain security configuration interface, the operation and maintenance manager of the target tenant can configure the security parameters of the target resource domain through the configuration items on the resource domain security configuration interface, such as the user identity credentials of the target resource domain and the identifier of the target resource domain. And the system identity that the target resource domain is authorized to use, etc. Wherein, the system identification that the target resource domain has the right to use may be a range of system identifications, or may be a series of specific system identifications.

主控节点11获取目标租户的运维管理人员配置的目标资源域的安全参数之后,可以建立这些安全参数之间的对应关系,主要是指建立目标资源域的用户身份凭证、目标资源域的标识以及目标资源域有权使用的系统身份标识之间的对应关系。进而,在工作流部署过程中,可基于目标资源域有权使用的系统身份标识,校验工作流执行单元运行时使用的系统身份标识是否合法等。After acquiring the security parameters of the target resource domain configured by the operation and maintenance manager of the target tenant, the master control node 11 can establish the corresponding relationship between these security parameters, which mainly refers to establishing the user identity credentials of the target resource domain and the identifier of the target resource domain. and the corresponding relationship between the system identities that the target resource domain has the right to use. Furthermore, in the workflow deployment process, based on the system identity that the target resource domain has the right to use, it is possible to verify whether the system identity used when the workflow execution unit is running is legal or not.

在本申请实施例中,并不限定工作流管理节点13获取工作流部署信息的方式。例如,工作流管理节点13可以向工作流部署人员提供工作流部署界面,以供工作流部署人员在工作流部署界面上配置工作流部署信息;并获取工作流部署人员在工作流部署界面上配置的工作流部署信息。这里的工作流部署信息主要可以包括:需要部署工作流的目标资源域的标识、申请部署工作流的用户身份凭证和工作流执行单元运行时使用的系统身份标识等。In this embodiment of the present application, the manner in which the workflow management node 13 obtains the workflow deployment information is not limited. For example, the workflow management node 13 may provide the workflow deployment personnel with a workflow deployment interface, so that the workflow deployment personnel can configure the workflow deployment information on the workflow deployment interface; and obtain the configuration configured by the workflow deployment personnel on the workflow deployment interface. workflow deployment information. The workflow deployment information here may mainly include: the identifier of the target resource domain where the workflow needs to be deployed, the user identity credential for applying to deploy the workflow, and the system identity used when the workflow execution unit runs.

对目标租户的工作流部署人员来说,在需要部署工作流的情况下,可发出请求访问工作流部署界面的触发操作。对工作流管理节点13来说,可根据目标租户的工作流部署人员发出的请求访问工作流部署界面的触发操作,向工作流部署人员展示工作流部署界面。工作流部署界面上包含有部署工作流所需的配置项。目标租户的工作流部署人员可以通过工作流部署界面上的配置项配置工作流部署信息,例如需要部署工作流的目标资源域的标识、申请部署工作流的用户身份凭证和工作流执行单元运行时使用的系统身份标识等。For the workflow deployer of the target tenant, when the workflow needs to be deployed, a trigger operation requesting to access the workflow deployment interface can be issued. For the workflow management node 13, the trigger operation of accessing the workflow deployment interface can be accessed according to the request issued by the workflow deployment personnel of the target tenant, and the workflow deployment interface can be displayed to the workflow deployment personnel. The workflow deployment interface contains configuration items required to deploy the workflow. The workflow deployer of the target tenant can configure the workflow deployment information through the configuration items on the workflow deployment interface, such as the identifier of the target resource domain where the workflow needs to be deployed, the user credentials for applying to deploy the workflow, and the runtime of the workflow execution unit System identities used, etc.

其中,工作流部署界面可以是web页面,应用页面或命令窗口等。根据工作流部署界面实现方式的不同,工作流部署人员请求访问工作流部署界面的触发操作也会有所不同。The workflow deployment interface may be a web page, an application page, or a command window, and the like. Depending on how the workflow deployment interface is implemented, the triggering action for the workflow deployer to request access to the workflow deployment interface will also be different.

在一可选实施例中,在获取工作流部署信息之后,工作流管理节点13可从工作流部署信息中获取目标资源域的标识、申请部署工作流的用户身份凭证和工作流执行单元运行时使用的系统身份标识等信息。首先,将目标资源域的标识和用户身份凭证发送给主控节点11,以供主控节点11确定目标资源域的标识和用户身份凭证是否对应,即进行资源域合法性的校验;以及接收主控节点11返回的确定结果。进一步,在主控节点11确定目标资源域的标识和用户身份凭证对应的情况下,生成主控节点11可识别的至少一个工作流执行单元模型,每个工作流执行单元模型包含至少一个工作流执行单元;按照至少一个工作流执行单元模型之间的时序依赖关系,依次将至少一个工作流执行单元模型以及工作流执行单元模型中的工作流执行单元运行时使用的系统身份标识发送给主控节点11。主控节点11接收工作流管理节点13依次发送的至少一个工作流执行单元模型;针对每个工作流执行单元模型,判断该工作流执行单元模型中的工作流执行单元运行时使用的系统身份标识是否均属于目标资源域有权使用的系统身份标识;若判断结果为是,将该工作流执行单元模型中的工作流执行单元部署到目标资源域中的工作节点上。In an optional embodiment, after acquiring the workflow deployment information, the workflow management node 13 may acquire, from the workflow deployment information, the identifier of the target resource domain, the user identity credential for applying for deploying the workflow, and the runtime of the workflow execution unit. Information such as the system identity used. First, the identifier of the target resource domain and the user identity credential are sent to the master control node 11, so that the master control node 11 can determine whether the identifier of the target resource domain corresponds to the user identity credential, that is, to verify the validity of the resource domain; and receive The determination result returned by the master control node 11. Further, when the master control node 11 determines that the identifier of the target resource domain corresponds to the user identity credential, at least one workflow execution unit model identifiable by the master control node 11 is generated, and each workflow execution unit model includes at least one workflow Execution unit; according to the time sequence dependency between at least one workflow execution unit model, sequentially send at least one workflow execution unit model and the system identity used by the workflow execution unit in the workflow execution unit model to the master controller Node 11. The master control node 11 receives at least one workflow execution unit model sequentially sent by the workflow management node 13; for each workflow execution unit model, determines the system identity used by the workflow execution unit in the workflow execution unit model when running Whether they all belong to the system identities that the target resource domain has the right to use; if the judgment result is yes, deploy the workflow execution unit in the workflow execution unit model to the worker nodes in the target resource domain.

在本申请实施例中,将工作流部署与可为不同租户服务的分布式计算系统相结合,允许租户在其资源域中部署工作流;在工作流部署过程中,为工作流执行单元指定运行时使用的系统身份标识,以区分不同工作流执行单元对分布式计算系统中共享存储资源的访存权限,每个工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对系统中的共享存储资源进行访存,可在不同租户之间实现读写隔离,保证共享存储资源中数据的安全性。In the embodiment of the present application, the workflow deployment is combined with a distributed computing system that can serve different tenants, allowing tenants to deploy workflows in their resource domains; during the workflow deployment process, the workflow execution unit is designated to run The system identity used when the workflow execution unit is used to distinguish the access rights of different workflow execution units to the shared storage resources in the distributed computing system. It can implement read-write isolation between different tenants and ensure the security of data in the shared storage resources.

值得说明的是,在本申请实施例的分布式计算系统10中,工作节点可以是容器化的应用程序,基于此,在该系统中可以采用容器编排调度系统,对系统中的工作节点进行创建、管理、发现、访问和配置等操作,从而将系统的运维人员解放出来。容器编排调度系统是指可自动部署、扩展和管理容器化应用程序的系统,例如可以采用Kubernetes(简称为K8s),但不限于此。另外,本申请实施例的分布式计算系统10可以应用到各种应用场景中,如依托云计算的基因测序场景中。It is worth noting that in the distributed computing system 10 of the embodiment of the present application, the worker nodes may be containerized application programs. Based on this, a container orchestration and scheduling system may be used in the system to create worker nodes in the system. , management, discovery, access, and configuration operations, thereby liberating system operation and maintenance personnel. A container orchestration and scheduling system refers to a system that can automatically deploy, expand, and manage containerized applications, such as Kubernetes (referred to as K8s), but not limited to this. In addition, the distributed computing system 10 of the embodiment of the present application can be applied to various application scenarios, such as a gene sequencing scenario relying on cloud computing.

依托云计算天然的资源弹性优势,基因行业在数据存储和基于海量数据的大规模计算成本上有了更为明显的下降。而在本申请实施例中,可以将Kubernetes技术和工作流部署相结合,可为基因测序提供工作流解决方案,有利于提升基因测序计算过程中所依赖的高并发处理,资源调度,大文件存储等关键能力。Relying on the natural resource elasticity advantages of cloud computing, the gene industry has seen a more significant reduction in data storage and large-scale computing costs based on massive data. In the embodiment of the present application, Kubernetes technology and workflow deployment can be combined to provide a workflow solution for gene sequencing, which is conducive to improving the high concurrent processing, resource scheduling, and large file storage that are relied on in the gene sequencing calculation process. and other key capabilities.

基于上述,本申请实施例还提供一种基于容器编排调度系统实现的分布式计算系统,如图1b所示。该分布式计算系统20包括:主控节点21、不同租户对应的命名空间(namespace)24以及工作流管理节点23。其中,每个命名空间24包含工作节点22。Based on the above, an embodiment of the present application further provides a distributed computing system implemented based on a container orchestration and scheduling system, as shown in FIG. 1b. The distributed computing system 20 includes: a master node 21 , namespaces 24 corresponding to different tenants, and a workflow management node 23 . Of these, each namespace 24 contains worker nodes 22 .

在本实施例中,采用容器编排调度系统,例如Kubernetes,可从逻辑上将分布式计算系统20中的物理设备划分为主控(Master)节点21和工作节点22。其中,主控节点21和工作节点22部署在分布式计算系统20中的物理设备上。可选地,主控节点21与工作节点22部署在不同物理设备上。为便于图示,在图1b中以基于Kubernetes实现的分布式计算系统为例进行图示。其中,主控节点21可作为容器编排调度系统的管控系统,在主控节点21上运行着集群管理相关的一组进程,以Kubernetes为例,这些进程包括但不限于:kube-apiserver、kube-controller-manager和kube-scheduler等,这些进程实现了整个集群的资源管理、容器组(例如Kubernetes中的Pod)调度、弹性伸缩、安全控制、系统监控和纠错等管理能力,并且都是全自动完成的。工作节点22作为分布式计算系统20中的服务节点,运行容器化的应用程序,这些工作节点22分布在不同租户的命名空间24中。在工作节点22上,容器组是容器编排调度系统管理的最小运行单元,该容器组包含至少一个容器。以Kubernetes为例,Kubernetes管理的最小运行单元是Pod。Pod直译为豆荚,在本实施例中,是指一组容器的集合,即前面所述的容器组。工作节点22上运行着容器编排调度系统中与容器组相关的进程,以Kubernetes为例,与容器组相关的进程包括但不限于:Kubernetes的kubelet和kube-proxy服务进程,这些服务进程负责容器组(如Pod)的创建、启动、监控、重启、销毁以及实现软件模式的负载均衡器。In this embodiment, a container orchestration and scheduling system, such as Kubernetes, can be used to logically divide the physical devices in the distributed computing system 20 into a master node 21 and a worker node 22 . The master node 21 and the worker node 22 are deployed on physical devices in the distributed computing system 20 . Optionally, the master node 21 and the worker node 22 are deployed on different physical devices. For the convenience of illustration, a distributed computing system based on Kubernetes is used as an example for illustration in FIG. 1b. Among them, the master control node 21 can be used as the management and control system of the container orchestration and scheduling system. A group of processes related to cluster management run on the master control node 21. Taking Kubernetes as an example, these processes include but are not limited to: kube-apiserver, kube- Controller-manager and kube-scheduler, etc., these processes realize the resource management of the entire cluster, container group (such as Pod in Kubernetes) scheduling, elastic scaling, security control, system monitoring and error correction management capabilities, and are fully automatic Completed. The worker nodes 22 serve as service nodes in the distributed computing system 20, running containerized applications, and these worker nodes 22 are distributed in namespaces 24 of different tenants. On the worker node 22, a container group is the smallest running unit managed by the container orchestration and scheduling system, and the container group includes at least one container. Taking Kubernetes as an example, the smallest running unit managed by Kubernetes is Pod. A Pod is literally translated as a pod, and in this embodiment, refers to a collection of a group of containers, that is, the container group described above. The worker node 22 runs the processes related to the container group in the container orchestration and scheduling system. Taking Kubernetes as an example, the processes related to the container group include but are not limited to: the kubelet and kube-proxy service processes of Kubernetes. These service processes are responsible for the container group. (e.g. Pod) creation, startup, monitoring, restart, destruction and load balancer implementing software mode.

其中,在容器编排调度系统中使用基于角色的权限访问控制(Role-Based AccessControl,RBAC)授权策略,基于RBAC授权策略每个租户在分布式系统20中具有不同的用户身份凭证以及各自的命名空间,每个租户的用户身份凭证可唯一标识该租户。租户的用户身份凭证可以任何能够唯一标识该租户的信息,例如可以是租户在分布式系统20中的ID,也可以是租户在分布式系统20中注册的租户名称、账号、电话号码、电子邮箱和/或家庭住址等。命名空间是容器编排调度系统,如Kubernetes中一个重要的概念,通过将分布式系统20内部的对象“分配”到不同的Namespace中,形成逻辑上分组的不同项目、小组或用户组,便于不同的分组在共享使用整个系统的资源的同时还能被分别管理。例如,租户在分布式计算系统20中创建的容器组(如Pod)、RC、服务(Service)都被会创建到租户对应的Namespace中。每个命名空间都有自己的标识,例如ID或名称。在本实施例中,维护有租户的用户身份凭证与其对应的命名空间的标识之间的对应关系。Among them, the role-based access control (Role-Based Access Control, RBAC) authorization policy is used in the container orchestration and scheduling system, and each tenant has different user identity credentials and respective namespaces in the distributed system 20 based on the RBAC authorization policy , each tenant's user credentials uniquely identify that tenant. The user identity credential of the tenant can be any information that can uniquely identify the tenant, for example, it can be the ID of the tenant in the distributed system 20 , or can be the tenant name, account number, phone number, email address registered by the tenant in the distributed system 20 and/or home address, etc. Namespace is a container orchestration and scheduling system, such as an important concept in Kubernetes. By "assigning" the objects inside the distributed system 20 to different Namespaces, different logically grouped projects, groups or user groups are formed, which is convenient for different Groups can be managed separately while sharing resources that use the entire system. For example, container groups (eg, Pods), RCs, and services (Services) created by the tenant in the distributed computing system 20 are all created in the namespace corresponding to the tenant. Each namespace has its own identity, such as an ID or a name. In this embodiment, a correspondence relationship between the tenant's user identity credential and the identifier of the corresponding namespace is maintained.

在分布式计算系统20中,除了包括每个租户独享的私有资源之外,还包括一些可供不同租户共享的全局共享资源。在本实施例中,全局共享资源主要是指可供不同租户共享的共享存储资源。共享存储资源可以是本地存储资源,也可以是网络存储资源,例如NAS。在本实施例中,租户对共享存储资源的请求身份是基于容器运行时刻的系统身份标识的,每个系统身份标识对应一定的访存权限。值得说明的是,在容器编排调度系统,如Kubernetes框架下,容器运行时刻的系统身份标识与容器编排调度系统(如Kubernetes)原生的RBAC的访问控制下的用户身份凭证属于两个不同的账号系统。In the distributed computing system 20, in addition to the private resources that each tenant can share exclusively, it also includes some global shared resources that can be shared by different tenants. In this embodiment, the global shared resources mainly refer to shared storage resources that can be shared by different tenants. Shared storage resources can be local storage resources or network storage resources, such as NAS. In this embodiment, the identity of the tenant's request for the shared storage resource is based on the system identity at the time when the container is running, and each system identity corresponds to a certain access authority. It is worth noting that under the container orchestration and scheduling system, such as the Kubernetes framework, the system identity of the container running time and the user identity credential under the access control of the native RBAC of the container orchestration and scheduling system (such as Kubernetes) belong to two different account systems. .

在本实施例中,不同租户可借助系统中的工作流管理节点23在自己的命名空间中部署工作流,即需要在工作节点22上部署工作流所需的容器,而且,基于容器编排调度系统(如Kubernetes)原生的RBAC授权策略,在命名空间上可实现多租户场景下部署工作流的逻辑隔离。但是,容器编排调度系统(如Kubernetes)原生框架中并没有容器运行过程对共享存储资源读写的安全隔离能力,而针对基因测序场景下海量数据读写和基因自身隐私性的特点以及其它类似场景,容器运行过程中对共享存储资源读写的安全隔离性是迫切解决的问题。基于此,在本实施例中,通过在工作流部署过程中扩展出指定用户层的方式,为工作流所需的容器指定运行时使用的系统身份标识,同时结合容器编排调度系统(如Kubernetes)原生的(PodSecurityPolicy,PSP)模型对绑定命名空间下的容器运行时使用的安全参数的校验,确保为容器指定的运行时使用的系统身份标识的正确性,进而实现多租户场景下不同容器在运行时刻对共享存储资源读写的安全隔离性。In this embodiment, different tenants can use the workflow management node 23 in the system to deploy the workflow in their own namespace, that is, the container required for the workflow needs to be deployed on the worker node 22, and the container-based orchestration and scheduling system The native RBAC authorization policy (such as Kubernetes) can implement logical isolation of deployment workflows in multi-tenant scenarios on the namespace. However, the native framework of the container orchestration and scheduling system (such as Kubernetes) does not have the security isolation capability of the container operation process to read and write shared storage resources, but for the characteristics of massive data read and write and the privacy of genes in the gene sequencing scenario and other similar scenarios , the security isolation of read and write of shared storage resources during container operation is an urgent problem to be solved. Based on this, in this embodiment, by extending the specified user layer during the workflow deployment process, the system identity used at runtime is specified for the containers required by the workflow, and at the same time, the container orchestration and scheduling system (such as Kubernetes) The native (PodSecurityPolicy, PSP) model verifies the security parameters used by the container runtime in the bound namespace to ensure the correctness of the system identity specified for the container to be used at runtime, thereby realizing different containers in a multi-tenant scenario. Secure isolation of reads and writes to shared storage resources at runtime.

基于上述,以在任一租户在其任一命名空间中部署工作流为例,对分布式计算系统20中的工作流部署原理进行说明。为便于描述和区分,将该任一租户称为目标租户,将该租户的任一命名空间称为目标命名空间,则分布式计算系统20中的工作流部署原理如下:Based on the above, the workflow deployment principle in the distributed computing system 20 is described by taking the deployment of a workflow in any of the tenants in any of its namespaces as an example. For the convenience of description and distinction, any tenant is referred to as a target tenant, and any namespace of the tenant is referred to as a target namespace, and the workflow deployment principle in the distributed computing system 20 is as follows:

工作流管理节点23根据目标命名空间中的工作流部署信息,获取待部署工作流所需的容器运行时使用的系统身份标识;将容器运行时使用的系统身份标识传输给主控节点21;主控节点21将容器运行时使用的系统身份标识与目标命名空间有权使用的系统身份标识进行比较;并在所述容器运行时使用的系统身份标识属于所述目标命名空间有权使用的系统身份标识的情况下,将容器部署到目标命名空间下的工作节点上。这样,容器可基于其运行时使用的系统身份标识对应的访存权限对分布式计算系统20的共享存储资源进行访存。The workflow management node 23 obtains, according to the workflow deployment information in the target namespace, the system identity used when the container is running required for the workflow to be deployed; transmits the system identity used when the container is running to the master control node 21; The control node 21 compares the system identity used when the container is running with the system identity that the target namespace has the right to use; and the system identity used when the container is running belongs to the system identity that the target namespace has the right to use If identified, deploy the container to the worker node under the target namespace. In this way, the container can fetch the shared storage resources of the distributed computing system 20 based on the fetching authority corresponding to the system identity used by the container at runtime.

在一可选实施例中,考虑到容器编排调度系统的最小运行单元是容器组,则工作流管理节点还用于:根据工作流部署信息生成主控节点21可识别的至少一个容器组模型,每个容器组模型包含至少一个容器;按照至少一个容器组模型之间的时序依赖关系,依次将至少一个容器组模型发送给主控节点21,以供主控节点21以容器组模型为单位对容器进行部署。主控节点21可接收工作流管理节点23依次发送的至少一个容器组模型;针对接收到的每个容器组模型,判断该容器组模型中的容器运行时使用的系统身份标识是否均属于目标命名空间有权使用的系统身份标识,若判断结果为是,将容器组模型中的容器部署到目标命名空间下的工作节点上。其中,以Kubernetes为例,其管理的最小运行单元是Pod,上述容器组模型可以为Pod模型。In an optional embodiment, considering that the minimum running unit of the container orchestration and scheduling system is a container group, the workflow management node is further configured to: generate at least one container group model identifiable by the master control node 21 according to the workflow deployment information, Each container group model contains at least one container; according to the time-series dependencies between the at least one container group model, the at least one container group model is sent to the master control node 21 in turn, so that the master control node 21 can use the container group model as a unit to compare Containers are deployed. The master control node 21 can receive at least one container group model sent in turn by the workflow management node 23; for each received container group model, determine whether the system identities used when the containers in the container group model are run belong to the target naming The system identity that the space has the right to use. If the judgment result is yes, the container in the container group model is deployed to the worker node under the target namespace. Among them, taking Kubernetes as an example, the smallest running unit managed by Kubernetes is a Pod, and the above container group model can be a Pod model.

在一可选实施例中,工作流部署信息中除了包含工作流所需的容器以及容器运行时使用的系统身份标识之外,还可以包含目标命名空间的标识以及申请部署工作流的用户身份凭证。其中,目标命名空间的标识用于标识需要在哪个命名空间中部署工作流;用户身份凭证用于标识是哪个租户申请部署工作流。考虑到不同租户具有自己的命名空间,工作流管理节点13还可以从工作流部署信息中获取目标命名空间的标识以及申请部署工作流的用户身份凭证;将目标命名空间的标识和用户身份凭证发送给主控节点11,以供主控节点11确定目标命名空间的标识和用户身份凭证是否对应,即进行命名空间合法性的校验;以及接收主控节点11返回的确定结果。In an optional embodiment, in addition to the container required by the workflow and the system identity used when the container is running, the workflow deployment information may also include the identity of the target namespace and the user identity credentials for applying to deploy the workflow. . Among them, the identifier of the target namespace is used to identify the namespace in which the workflow needs to be deployed; the user identity credentials are used to identify which tenant applies for the deployment of the workflow. Considering that different tenants have their own namespaces, the workflow management node 13 can also obtain the identifier of the target namespace and the user identity credential for applying to deploy the workflow from the workflow deployment information; send the identifier of the target namespace and the user identity credential to the To the main control node 11 , so that the main control node 11 can determine whether the identifier of the target namespace corresponds to the user identity certificate, that is, verify the validity of the namespace; and receive the determination result returned by the main control node 11 .

对主控节点11来说,还会维护不同租户的命名空间的标识与不同租户的用户身份凭证之间的对应关系。基于该对应关系,主控节点11在接收工作流管理节点13发送的目标命名空间的标识和用户身份凭证后,可以查询所维护的对应关系,确定目标命名空间的标识和用户身份凭证是否对应,并向工作流管理节点13返回确定结果。For the master node 11, the corresponding relationship between the identifiers of the namespaces of different tenants and the user identity credentials of different tenants is also maintained. Based on the corresponding relationship, after receiving the identifier of the target namespace and the user identity credential sent by the workflow management node 13, the master control node 11 can query the maintained correspondence to determine whether the identifier of the target namespace and the user identity credential correspond to each other, And return the determination result to the workflow management node 13 .

进一步可选地,工作流管理节点13可以在主控节点11确定目标命名空间的标识和用户身份凭证对应的情况下,根据至少一个容器组模型(如Pod模型)之间的时序依赖关系,依次将至少一个容器组模型发送给主控节点11,以供主控节点11以容器组模型为单位对容器进行部署。对主控节点11而言,在确定目标命名空间的标识和用户身份凭证对应的情况下,可继续接收工作流管理节点13依次发送的至少一个容器组模型;针对每个容器组模型,判断该容器组模型中的容器运行时使用的系统身份标识是否均属于目标命名空间有权使用的系统身份标识;若判断结果为是,将该容器组模型中的容器部署到目标命名空间中的工作节点上。Further optionally, when the master control node 11 determines that the identifier of the target namespace corresponds to the user identity credential, the workflow management node 13 may, according to the time sequence dependency between at least one container group model (such as the Pod model), sequentially The at least one container group model is sent to the master control node 11, so that the master control node 11 deploys containers by using the container group model as a unit. For the master control node 11, when it is determined that the identifier of the target namespace corresponds to the user identity credential, it can continue to receive at least one container group model sequentially sent by the workflow management node 13; for each container group model, determine the Whether the system identities used when the containers in the container group model are run belong to the system identities that the target namespace has permission to use; if the judgment result is yes, deploy the containers in the container group model to the worker nodes in the target namespace superior.

在一可选实施例中,目标租户包括运维管理人员和工作流部署人员。运维管理人员相当于目标租户在分布式计算系统20中的管理员,具有全局配置和管理权限,例如可以向分布式计算系统20申请命名空间、配置命名空间的安全参数、为不同工作流部署人员配置使用权限、下发相关参数等。工作流部署人员主要负责在命名空间中部署工作流。可选地,主控节点11可以面向目标租户的运维管理人员提供命名空间安全配置界面,供运维管理人员配置目标命名空间的安全参数。其中,目标命名空间的安全参数可以包括但不限于:目标命名空间的用户身份凭证、目标命名空间的标识以及目标命名空间有权使用的系统身份标识等。对运维管理人员来说,可通过主控节点11提供的命名空间安全配置界面,配置目标命名空间的安全参数。主控节点11获取运维管理人员配置的目标命名空间的安全参数之后,可以建立这些安全参数之间的对应关系,主要是指目标命名空间的用户身份凭证、目标命名空间的标识以及目标命名空间有权使用的系统身份标识之间的对应关系。In an optional embodiment, the target tenants include operation and maintenance managers and workflow deployment personnel. The operation and maintenance manager is equivalent to the administrator of the target tenant in the distributed computing system 20, and has global configuration and management authority. For example, he can apply to the distributed computing system 20 for a namespace, configure the security parameters of the namespace, and deploy for different workflows Personnel configuration access rights, distribution of related parameters, etc. Workflow deployers are primarily responsible for deploying workflows in namespaces. Optionally, the master control node 11 may provide a namespace security configuration interface for the operation and maintenance management personnel of the target tenant, for the operation and maintenance management personnel to configure the security parameters of the target namespace. The security parameters of the target namespace may include, but are not limited to: user identity credentials of the target namespace, an identifier of the target namespace, and a system identity that the target namespace has the right to use, and the like. For operation and maintenance managers, the security parameters of the target namespace can be configured through the namespace security configuration interface provided by the master control node 11 . After obtaining the security parameters of the target namespace configured by the operation and maintenance manager, the master control node 11 can establish the corresponding relationship between these security parameters, which mainly refers to the user identity credentials of the target namespace, the identifier of the target namespace, and the target namespace Correspondence between system identities that are authorized to use.

其中,命名空间安全配置界面可以是web页面,应用页面或命令窗口等。根据命名空间安全配置界面实现方式的不同,运维管理人员请求访问命名空间安全配置界面的触发操作也会有所不同。以命名空间安全配置界面是web页面为例,运维管理人员可以在其使用的终端设备上的浏览器中输入该web页面的链接,点击访问控件进入登录页面,并在登录页面上输入登录账号和密码,然后在其使用的终端设备的浏览器展示该web页面。The namespace security configuration interface may be a web page, an application page, or a command window. Depending on how the namespace security configuration interface is implemented, the trigger actions for the operation and maintenance administrator to request access to the namespace security configuration interface will also be different. Taking the namespace security configuration interface as a web page as an example, operation and maintenance managers can enter the link of the web page in the browser on the terminal device they use, click the access control to enter the login page, and enter the login account on the login page. and password, and then display the web page in the browser of the terminal device it uses.

在本申请实施例中,并不限定工作流管理节点23获取工作流部署信息的方式。例如,工作流管理节点23还用于:面向目标租户的工作流部署人员提供工作流部署界面,并获取工作流部署人员在所述工作流部署界面上配置的工作流部署信息。这里的工作流部署信息包括目标命名空间的标识、申请部署工作流的用户身份凭证和待部署工作流所需的容器运行时使用的系统身份标识。In this embodiment of the present application, the manner in which the workflow management node 23 obtains the workflow deployment information is not limited. For example, the workflow management node 23 is further configured to: provide a workflow deployment interface for the workflow deployment personnel of the target tenant, and obtain the workflow deployment information configured by the workflow deployment personnel on the workflow deployment interface. The workflow deployment information here includes the identifier of the target namespace, the user credentials for applying to deploy the workflow, and the system identifier used by the container runtime required by the workflow to be deployed.

对目标租户的工作流部署人员来说,在需要部署工作流的情况下,可发出请求访问工作流部署界面的触发操作。对工作流管理节点23来说,可根据目标租户的工作流部署人员发出的请求访问工作流部署界面的触发操作,向工作流部署人员展示工作流部署界面。工作流部署界面上包含有部署工作流所需的配置项。目标租户的工作流部署人员可以通过工作流部署界面上的配置项配置工作流部署信息,例如需要部署工作流的目标命名空间的标识、申请部署工作流的用户身份凭证和容器运行时使用的系统身份标识等。For the workflow deployer of the target tenant, when the workflow needs to be deployed, a trigger operation requesting to access the workflow deployment interface can be issued. For the workflow management node 23, the trigger operation of accessing the workflow deployment interface can be accessed according to the request issued by the workflow deployment personnel of the target tenant, and the workflow deployment interface can be displayed to the workflow deployment personnel. The workflow deployment interface contains configuration items required to deploy the workflow. The workflow deployer of the target tenant can configure the workflow deployment information through the configuration items on the workflow deployment interface, such as the identifier of the target namespace where the workflow needs to be deployed, the user credentials for applying to deploy the workflow, and the system used when the container is running identification, etc.

其中,工作流部署界面可以是web页面,应用页面或命令窗口等。根据工作流部署界面实现方式的不同,工作流部署人员请求访问工作流部署界面的触发操作也会有所不同。The workflow deployment interface may be a web page, an application page, or a command window, and the like. Depending on how the workflow deployment interface is implemented, the triggering action for the workflow deployer to request access to the workflow deployment interface will also be different.

在一可选实施例中,在获取工作流部署信息之后,工作流管理节点23可从工作流部署信息中获取目标命名空间的标识、申请部署工作流的用户身份凭证和容器运行时使用的系统身份标识等信息。首先,将目标命名空间的标识和用户身份凭证发送给主控节点21,以供主控节点21确定目标命名空间的标识和用户身份凭证是否对应,即进行命名空间合法性的校验;以及接收主控节点21返回的确定结果。进一步,在主控节点21确定目标命名空间的标识和用户身份凭证对应的情况下,工作流管理节点23根据工作流部署信息生成主控节点21可识别的至少一个容器组模型如(Pod模型),每个容器组模型包含至少一个容器;按照至少一个容器组模型之间的时序依赖关系,依次将至少一个容器组模型以及容器组模型中的容器运行时使用的系统身份标识发送给主控节点21。主控节点21接收工作流管理节点13依次发送的至少一个容器组模型;针对每个容器组模型,判断该容器组模型中的容器运行时使用的系统身份标识是否均属于目标命名空间有权使用的系统身份标识;若判断结果为是,将该容器组模型中的容器部署到目标命名空间中的工作节点上。In an optional embodiment, after acquiring the workflow deployment information, the workflow management node 23 may acquire, from the workflow deployment information, the identifier of the target namespace, the user identity credentials for applying for deploying the workflow, and the system used when the container is running. identity information, etc. First, the identifier of the target namespace and the user identity credential are sent to the master control node 21, so that the master control node 21 can determine whether the identifier of the target namespace and the user identity credential correspond, that is, to verify the validity of the namespace; and receive The determination result returned by the master control node 21. Further, when the master control node 21 determines that the identifier of the target namespace corresponds to the user identity credential, the workflow management node 23 generates at least one container group model that the master control node 21 can identify according to the workflow deployment information, such as (Pod model) , each container group model contains at least one container; according to the time-series dependencies between the at least one container group model, the at least one container group model and the system identity used by the containers in the container group model are sent to the master node in turn twenty one. The master control node 21 receives at least one container group model sent in turn by the workflow management node 13; for each container group model, it is judged whether the system identities used when the containers in the container group model are running belong to the target namespace and have the right to use them If the judgment result is yes, deploy the container in the container group model to the worker node in the target namespace.

值得说明的是,本实施例的工作流管理节点23可以采用但不限于:argo工作流引擎。在采用argo工作流引擎的情况下,可根据本申请工作流管理节点23的功能对argo工作流引擎进行功能扩展。其中,通过扩展原生的argo工作流引擎,增加将容器运行时使用的系统身份标识下传至容器的功能,并通过修改部署容器时的PSP校验功能,可避免容器编排调度系统(如Kubernetes)原生PSP校验对容器组模型中的容器的安全校验的限制,使得可以为容器指定运行时使用的系统身份标识并完成安全校验,只有满足PSP模型中规定的安全参数的容器才会通过校验并允许部署,同时可解决了容器运行时刻对共享存储资源中存储目录的访问权限,实现了多租户环境下对共享存储资源读写访问的安全隔离。It should be noted that, the workflow management node 23 in this embodiment may adopt, but is not limited to, an argo workflow engine. In the case of using the argo workflow engine, the functions of the argo workflow engine can be extended according to the functions of the workflow management node 23 of the present application. Among them, by extending the native argo workflow engine, adding the function of downloading the system identity used when the container is running to the container, and modifying the PSP verification function when deploying the container, the container orchestration and scheduling system (such as Kubernetes) can be avoided. The native PSP verification limits the security verification of containers in the container group model, so that the system identity used at runtime can be specified for the container and the security verification can be completed. Only the containers that meet the security parameters specified in the PSP model will pass. Verifying and allowing deployment, at the same time, it can solve the access rights to the storage directory in the shared storage resource at the runtime of the container, and realize the security isolation of read and write access to the shared storage resource in a multi-tenant environment.

图1b所示分布式计算系统20可以作为图1a所示分布式计算系统10的一种具体实现,一些内容与图1a所示分布式计算系统10相同或相似,本实施例中未涉及的内容,可参见前述实施例的描述,在此不再赘述。The distributed computing system 20 shown in FIG. 1b can be used as a specific implementation of the distributed computing system 10 shown in FIG. 1a, and some contents are the same or similar to the distributed computing system 10 shown in FIG. 1a, and the contents not involved in this embodiment are , reference may be made to the descriptions of the foregoing embodiments, which will not be repeated here.

图2a为本申请示例性实施例提供的一种工作流部署方法的流程示意图。该实施例是从工作流管理节点的角度进行的描述,如图2a所示,该方法包括:FIG. 2a is a schematic flowchart of a workflow deployment method provided by an exemplary embodiment of the present application. This embodiment is described from the perspective of a workflow management node. As shown in Figure 2a, the method includes:

201a、根据目标资源域中的工作流部署信息,获取工作流执行单元运行时使用的系统身份标识;其中,工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对工作流管理节点所属分布式计算系统的共享存储资源进行访存。201a, according to the workflow deployment information in the target resource domain, obtain the system identity used by the workflow execution unit when it runs; wherein, the workflow execution unit manages the workflow based on the access authority corresponding to the system identity used by the workflow execution unit when it runs. The shared storage resource of the distributed computing system to which the node belongs is fetched.

202a、将工作流执行单元运行时使用的系统身份标识传输给分布式计算系统中的主控节点,以供主控节点在工作流执行单元运行时使用的系统身份标识属于目标资源域有权使用的系统身份标识的情况下,将工作流执行单元部署到目标资源域中的工作节点上。202a. Transmit the system identity used when the workflow execution unit is running to the master node in the distributed computing system, so that the system identity used by the master node when the workflow execution unit is running belongs to the target resource domain and has the right to use it The workflow execution unit is deployed to the worker node in the target resource domain under the condition of the system identity of the target resource domain.

图2b为本申请示例性实施例提供的一种工作流部署方法的流程示意图。该实施例是从主控节点的角度进行的描述,如图2b所示,该方法包括:FIG. 2b is a schematic flowchart of a workflow deployment method provided by an exemplary embodiment of the present application. This embodiment is described from the perspective of the master node. As shown in Figure 2b, the method includes:

201b、接收工作流管理节点发送的工作流执行单元运行时使用的系统身份标识,工作流执行单元是需要在目标资源域中部署的工作流的执行单元。201b. Receive a system identity used when a workflow execution unit is running and sent by the workflow management node, where the workflow execution unit is an execution unit of the workflow that needs to be deployed in the target resource domain.

202b、在工作流执行单元运行时使用的系统身份标识属于目标资源域有权使用的系统身份标识的情况下,将工作流执行单元部署到目标资源域中的工作节点上;其中,工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对分布式计算系统的共享存储资源进行访存。202b, in the case that the system identity used when the workflow execution unit is running belongs to the system identity that the target resource domain has the right to use, deploy the workflow execution unit on the worker node in the target resource domain; wherein, the workflow execution The unit fetches the shared storage resources of the distributed computing system based on the fetching authority corresponding to the system identity used by the unit when it runs.

在本申请实施例中,分布式计算系统中的主控节点和工作流管理节点相互配合,允许租户在其资源域中部署工作流,并且在工作流部署过程中,可为工作流执行单元指定运行时使用的系统身份标识,以区分不同工作流执行单元对分布式计算系统中共享存储资源的访存权限,每个工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对系统中的共享存储资源进行访存,可在不同租户之间实现读写隔离,保证共享存储资源中数据的安全性。In the embodiment of the present application, the master control node and the workflow management node in the distributed computing system cooperate with each other, allowing the tenant to deploy the workflow in its resource domain, and during the workflow deployment process, the workflow execution unit can be specified The system identity used at runtime to distinguish the access rights of different workflow execution units to the shared storage resources in the distributed computing system. Each workflow execution unit is based on the access rights corresponding to the system identity used at runtime. The shared storage resources in the system are accessed for storage, which can realize read-write isolation between different tenants and ensure the security of data in the shared storage resources.

在一可选实施例中,在上述方法实施例中,工作流管理节点还可以根据工作流部署信息生成主控节点可识别的至少一个工作流执行单元模型,每个工作流执行单元模型包含至少一个工作流执行单元;按照至少一个工作流执行单元模型之间的时序依赖关系,依次将至少一个工作流执行单元模型发送给主控节点,以供主控节点以工作流执行单元模型为单位对工作流执行单元进行部署。相应地,主控节点还可接收工作流管理节点依次发送的至少一个工作流执行单元模型,每个工作流执行单元模型包含至少一个工作流执行单元;针对每个工作流执行单元模型,判断该工作流执行单元模型中的工作流执行单元运行时使用的系统身份标识是否均属于目标资源域有权使用的系统身份标识,若判断结果为是,将该工作流执行单元模型中的工作流执行单元部署到目标资源域中的工作节点上。In an optional embodiment, in the above method embodiment, the workflow management node may further generate at least one workflow execution unit model identifiable by the master control node according to the workflow deployment information, and each workflow execution unit model includes at least one workflow execution unit model. A workflow execution unit; according to the time-series dependencies between at least one workflow execution unit model, at least one workflow execution unit model is sequentially sent to the master control node, so that the master control node uses the workflow execution unit model as a unit to The workflow execution unit is deployed. Correspondingly, the master control node can also receive at least one workflow execution unit model sequentially sent by the workflow management node, and each workflow execution unit model includes at least one workflow execution unit; for each workflow execution unit model, determine the Whether the system identities used by the workflow execution units in the workflow execution unit model belong to the system identities that the target resource domain has the right to use, if the judgment result is yes, the workflow execution unit model in the workflow execution unit model is executed. Cells are deployed on worker nodes in the target resource domain.

在一可选实施例中,在上述方法实施例中,工作流管理节点还可以从工作流部署信息中获取目标资源域的标识以及申请部署工作流的用户身份凭证;将目标资源域的标识和用户身份凭证发送给主控节点,以供主控节点确定目标资源域的标识和用户身份凭证是否对应;以及接收主控节点返回的目标资源域的标识和用户身份凭证是否对应的确定结果。相应地,主控节点还可接收工作流管理节点发送的目标资源域的标识以及申请部署工作流的用户身份凭证;根据预先维护的资源域的标识与用户身份凭证之间的对应关系,确定目标资源域的标识和用户身份凭证是否对应,并向工作流管理节点返回确定结果。In an optional embodiment, in the above method embodiment, the workflow management node can also obtain the identifier of the target resource domain and the user identity credential for applying for deploying the workflow from the workflow deployment information; The user identity credential is sent to the main control node, so that the main control node can determine whether the identifier of the target resource domain corresponds to the user identity credential; and the determination result of whether the identifier of the target resource domain and the user identity credential is returned by the main control node is received. Correspondingly, the master control node can also receive the identifier of the target resource domain sent by the workflow management node and the user identity credential for applying to deploy the workflow; according to the correspondence between the identifier of the resource domain and the user identity credential maintained in advance, determine the target. Check whether the identifier of the resource domain corresponds to the user's identity credential, and return the confirmation result to the workflow management node.

进一步,在上述方法实施例中,工作流管理节点可以在主控节点确定目标资源域的标识和用户身份凭证对应的情况下,根据至少一个工作流执行单元模型之间的时序依赖关系,依次将至少一个工作流执行单元模型发送给主控节点,以供主控节点以工作流执行单元模型为单位对工作流执行单元进行部署。对主控节点而言,在确定目标资源域的标识和用户身份凭证对应的情况下,可继续接收工作流管理节点依次发送的至少一个工作流执行单元模型;针对每个工作流执行单元模型,判断该工作流执行单元模型中的工作流执行单元运行时使用的系统身份标识是否均属于目标资源域有权使用的系统身份标识;若判断结果为是,将该工作流执行单元模型中的工作流执行单元部署到目标资源域中的工作节点上。Further, in the above method embodiment, when the master control node determines that the identifier of the target resource domain corresponds to the user identity credential, the workflow management node may, according to the time sequence dependency between at least one workflow execution unit model, sequentially At least one workflow execution unit model is sent to the master control node, so that the master control node deploys the workflow execution unit with the workflow execution unit model as a unit. For the master control node, in the case of determining that the identifier of the target resource domain corresponds to the user identity credential, it can continue to receive at least one workflow execution unit model sequentially sent by the workflow management node; for each workflow execution unit model, Determine whether the system identities used by the workflow execution unit in the workflow execution unit model are all system identities that the target resource domain has the right to use; if the judgment result is yes, the work in the workflow execution unit model is determined. Stream execution units are deployed on worker nodes in the target resource domain.

在一可选实施例中,在上述方法实施例中,工作流管理节点还可以面向目标租户的工作流部署人员提供工作流部署界面,并获取工作流部署人员在工作流部署界面上配置的工作流部署信息;其中,工作流部署信息包括需要部署工作流的目标资源域的标识、申请部署工作流的用户身份凭证和工作流执行单元运行时使用的系统身份标识;目标租户与目标资源域对应。In an optional embodiment, in the above method embodiment, the workflow management node may further provide a workflow deployment interface for the workflow deployment personnel of the target tenant, and obtain the work flow configured by the workflow deployment personnel on the workflow deployment interface. Flow deployment information; wherein, the workflow deployment information includes the identifier of the target resource domain where the workflow needs to be deployed, the user identity credential for applying to deploy the workflow, and the system identity used when the workflow execution unit runs; the target tenant corresponds to the target resource domain .

在一可选实施例中,在上述方法实施例中,主控节点还可以面向目标租户的运维管理人员提供资源域安全配置界面,以供运维管理人员配置目标资源域的安全参数;安全参数包括目标资源域的用户身份凭证、目标资源域的标识以及目标资源域有权使用的系统身份标识;建立目标资源域的用户身份凭证、目标资源域的标识以及目标资源域有权使用的运行用户身份标识范围之间的对应关系;其中,目标租户与目标资源域对应。In an optional embodiment, in the above method embodiment, the master control node may also provide a resource domain security configuration interface for the operation and maintenance management personnel of the target tenant, so that the operation and maintenance management personnel can configure the security parameters of the target resource domain; The parameters include the user identity credentials of the target resource domain, the identity of the target resource domain, and the system identity that the target resource domain has the right to use; establish the user identity credentials of the target resource domain, the identity of the target resource domain, and the runtime that the target resource domain has the right to use. Correspondence between user ID ranges; among them, the target tenant corresponds to the target resource domain.

需要说明的是,在上述实施例及附图中的描述的一些流程中,包含了按照特定顺序出现的多个操作,但是应该清楚了解,这些操作可以不按照其在本文中出现的顺序来执行或并行执行,操作的序号如201a、202a等,仅仅是用于区分开各个不同的操作,序号本身不代表任何的执行顺序。另外,这些流程可以包括更多或更少的操作,并且这些操作可以按顺序执行或并行执行。需要说明的是,本文中的“第一”、“第二”等描述,是用于区分不同的消息、设备、模块等,不代表先后顺序,也不限定“第一”和“第二”是不同的类型。It should be noted that, in some of the processes described in the above embodiments and the accompanying drawings, multiple operations appearing in a specific order are included, but it should be clearly understood that these operations may not be performed in accordance with the order in which they appear in this document Or in parallel, the sequence numbers of the operations, such as 201a, 202a, etc., are only used to distinguish different operations, and the sequence numbers themselves do not represent any execution order. Additionally, these flows may include more or fewer operations, and these operations may be performed sequentially or in parallel. It should be noted that the descriptions such as "first" and "second" in this document are used to distinguish different messages, devices, modules, etc., and do not represent a sequence, nor do they limit "first" and "second" are different types.

图3为本申请示例性实施例提供的一种节点设备的结构示意图。该节点设备可作为前述实施例中的工作流管理节点实现,如图3所示,该节点设备包括:存储器31、处理器32以及通信组件33。FIG. 3 is a schematic structural diagram of a node device according to an exemplary embodiment of the present application. The node device can be implemented as the workflow management node in the foregoing embodiment. As shown in FIG. 3 , the node device includes: a memory 31 , a processor 32 and a communication component 33 .

存储器31,用于存储计算机程序,并可被配置为存储其它各种数据以支持在节点设备上的操作。这些数据的示例包括用于在节点设备上操作的任何应用程序或方法的指令,联系人数据,电话簿数据,消息,图片,视频等。The memory 31 is used to store computer programs and may be configured to store various other data to support operations on the node device. Examples of such data include instructions for any application or method operating on the node device, contact data, phonebook data, messages, pictures, videos, etc.

处理器32,与存储器31耦合,用于执行存储器31中的计算机程序,以用于:A processor 32, coupled to the memory 31, is used to execute a computer program in the memory 31 for:

根据目标资源域中的工作流部署信息,获取工作流执行单元运行时使用的系统身份标识;According to the workflow deployment information in the target resource domain, obtain the system identity used when the workflow execution unit is running;

通过通信组件33将工作流执行单元运行时使用的系统身份标识传输给工作流管理节点所属分布式计算系统中的主控节点,以供主控节点在工作流执行单元运行时使用的系统身份标识属于目标资源域有权使用的系统身份标识的情况下,将工作流执行单元部署到目标资源域中的工作节点上;其中,工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对分布式计算系统的共享存储资源进行访存。The system identity used when the workflow execution unit is running is transmitted to the master node in the distributed computing system to which the workflow management node belongs through the communication component 33, so that the system identity used by the master node when the workflow execution unit is running In the case of belonging to the system identity that the target resource domain has the right to use, deploy the workflow execution unit to the worker node in the target resource domain; wherein, the workflow execution unit is based on the fetch corresponding to the system identity used during its runtime. Permission to access the shared storage resources of the distributed computing system.

在一可选实施例中,处理器32还用于:根据工作流部署信息生成主控节点可识别的至少一个工作流执行单元模型,每个工作流执行单元模型包含至少一个工作流执行单元;按照至少一个工作流执行单元模型之间的时序依赖关系,通过通信组件33依次将至少一个工作流执行单元模型发送给主控节点,以供主控节点以工作流执行单元模型为单位对工作流执行单元进行部署。In an optional embodiment, the processor 32 is further configured to: generate at least one workflow execution unit model identifiable by the master control node according to the workflow deployment information, and each workflow execution unit model includes at least one workflow execution unit; According to the time sequence dependency between the at least one workflow execution unit model, the at least one workflow execution unit model is sequentially sent to the master control node through the communication component 33, so that the master control node can use the workflow execution unit model as a unit for the workflow execution unit model. The execution unit is deployed.

在一可选实施例中,处理器32还用于:在依次将至少一个工作流执行单元模型发送给主控节点之前,从工作流部署信息中获取目标资源域的标识以及申请部署工作流的用户身份凭证;通过通信组件33将目标资源域的标识和用户身份凭证发送给主控节点,以供主控节点确定目标资源域的标识和用户身份凭证是否对应;以及接收主控节点返回的目标资源域的标识和用户身份凭证是否对应的确定结果。In an optional embodiment, the processor 32 is further configured to: before sequentially sending the at least one workflow execution unit model to the master control node, obtain the identifier of the target resource domain and the application for deploying the workflow from the workflow deployment information. User identity credential; send the identification of the target resource domain and the user identity credential to the main control node through the communication component 33, so that the main control node determines whether the identification of the target resource domain and the user identity credential correspond; and receive the target returned by the main control node The result of determining whether the identifier of the resource domain corresponds to the user's identity credential.

在一可选实施例中,处理器32还用于:面向目标租户的工作流部署人员提供工作流部署界面,并获取工作流部署人员在工作流部署界面上配置的工作流部署信息;其中,工作流部署信息包括需要部署工作流的目标资源域的标识、申请部署工作流的用户身份凭证和工作流执行单元运行时使用的系统身份标识;目标租户与目标资源域对应。In an optional embodiment, the processor 32 is further configured to: provide a workflow deployment interface for the workflow deployment personnel of the target tenant, and obtain the workflow deployment information configured by the workflow deployment personnel on the workflow deployment interface; wherein, The workflow deployment information includes the identifier of the target resource domain where the workflow needs to be deployed, the user identity credentials for applying for deploying the workflow, and the system identity used when the workflow execution unit runs; the target tenant corresponds to the target resource domain.

进一步,如图3所示,该节点设备还包括:显示器34、电源组件35、音频组件36等其它组件。图3中仅示意性给出部分组件,并不意味着节点设备只包括图3所示组件。另外,根据节点设备实现形态的不同,图3中带虚线框的组件为可选组件,而非必选组件。Further, as shown in FIG. 3 , the node device further includes: a display 34 , a power supply component 35 , an audio component 36 and other components. Only some components are schematically shown in FIG. 3 , which does not mean that the node device only includes the components shown in FIG. 3 . In addition, according to different implementation forms of node devices, components with dotted boxes in FIG. 3 are optional components, not mandatory components.

相应地,本申请实施例还提供一种存储有计算机程序的计算机可读存储介质,计算机程序被执行时能够实现上述方法实施例中可由工作流管理节点执行的各步骤。Correspondingly, the embodiments of the present application further provide a computer-readable storage medium storing a computer program, and when the computer program is executed, each step that can be executed by the workflow management node in the foregoing method embodiments can be implemented.

图4为本申请示例性实施例提供的另一种节点设备的结构示意图。该节点设备可作为前述实施例中的主控节点实现,如图4所示,该节点设备包括:存储器41、处理器42以及通信组件43。FIG. 4 is a schematic structural diagram of another node device according to an exemplary embodiment of the present application. The node device may be implemented as the master control node in the foregoing embodiment. As shown in FIG. 4 , the node device includes: a memory 41 , a processor 42 and a communication component 43 .

存储器41,用于存储计算机程序,并可被配置为存储其它各种数据以支持在节点设备上的操作。这些数据的示例包括用于在节点设备上操作的任何应用程序或方法的指令,联系人数据,电话簿数据,消息,图片,视频等。The memory 41 is used to store computer programs and may be configured to store various other data to support operations on the node device. Examples of such data include instructions for any application or method operating on the node device, contact data, phonebook data, messages, pictures, videos, etc.

处理器42,与存储器41耦合,用于执行存储器41中的计算机程序,以用于:A processor 42, coupled to the memory 41, for executing a computer program in the memory 41 for:

通过通信组件43接收工作流管理节点发送的工作流执行单元运行时使用的系统身份标识,工作流执行单元是需要在目标资源域中部署的工作流的执行单元;Receive through the communication component 43 the system identity used when the workflow execution unit is running and sent by the workflow management node, and the workflow execution unit is the execution unit of the workflow that needs to be deployed in the target resource domain;

在工作流执行单元运行时使用的系统身份标识属于目标资源域有权使用的系统身份标识的情况下,将工作流执行单元部署到目标资源域中的工作节点上;In the case that the system identity used when the workflow execution unit is running belongs to the system identity that the target resource domain has the right to use, deploy the workflow execution unit to the worker nodes in the target resource domain;

其中,工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对分布式计算系统的共享存储资源进行访存。Wherein, the workflow execution unit fetches the shared storage resources of the distributed computing system based on the fetching authority corresponding to the system identity used during its running.

在一可选实施例中,处理器42具体用于:通过通信组件43接收工作流管理节点依次发送的至少一个工作流执行单元模型,每个工作流执行单元模型包含至少一个工作流执行单元;针对每个工作流执行单元模型,判断该工作流执行单元模型中的工作流执行单元运行时使用的系统身份标识是否均属于目标资源域有权使用的系统身份标识,若判断结果为是,将该工作流执行单元模型中的工作流执行单元部署到目标资源域中的工作节点上。In an optional embodiment, the processor 42 is specifically configured to: receive at least one workflow execution unit model sequentially sent by the workflow management node through the communication component 43, and each workflow execution unit model includes at least one workflow execution unit; For each workflow execution unit model, determine whether the system identities used by the workflow execution units in the workflow execution unit model when they are running all belong to the system identities that the target resource domain has the right to use. The workflow execution unit in the workflow execution unit model is deployed on the worker nodes in the target resource domain.

在一可选实施例中,处理器42还用于:通过通信组件43接收工作流管理节点发送的目标资源域的标识以及申请部署工作流的用户身份凭证;根据预先维护的资源域的标识与用户身份凭证之间的对应关系,确定目标资源域的标识和用户身份凭证是否对应,并向工作流管理节点返回确定结果。In an optional embodiment, the processor 42 is further configured to: receive, through the communication component 43, the identifier of the target resource domain sent by the workflow management node and the user identity credential for applying for deploying the workflow; The correspondence between the user identity credentials determines whether the identifier of the target resource domain corresponds to the user identity credential, and returns the determination result to the workflow management node.

在一可选实施例中,处理器42还用于:面向目标租户的运维管理人员提供资源域安全配置界面,以供运维管理人员配置目标资源域的安全参数;安全参数包括目标资源域的用户身份凭证、目标资源域的标识以及目标资源域有权使用的系统身份标识;建立目标资源域的用户身份凭证、目标资源域的标识以及目标资源域有权使用的运行用户身份标识范围之间的对应关系;其中,目标租户与目标资源域对应。In an optional embodiment, the processor 42 is further configured to: provide a resource domain security configuration interface for the operation and maintenance management personnel of the target tenant, so that the operation and maintenance management personnel can configure the security parameters of the target resource domain; the security parameters include the target resource domain The user identity credential of the target resource domain, the identity of the target resource domain, and the system identity that the target resource domain has the right to use; establish the user identity credential of the target resource domain, the identity of the target resource domain, and the scope of the running user identity that the target resource domain has the right to use. The corresponding relationship between the target tenants and target resource domains.

进一步,如图4所示,该节点设备还包括:显示器44、电源组件45、音频组件46等其它组件。图4中仅示意性给出部分组件,并不意味着节点设备只包括图4所示组件。另外,根据节点设备实现形态的不同,图4中带虚线框的组件为可选组件,而非必选组件。Further, as shown in FIG. 4 , the node device further includes: a display 44 , a power supply component 45 , an audio component 46 and other components. Only some components are schematically shown in FIG. 4 , which does not mean that the node device only includes the components shown in FIG. 4 . In addition, according to different implementation forms of node devices, components with dotted boxes in FIG. 4 are optional components, not mandatory components.

相应地,本申请实施例还提供一种存储有计算机程序的计算机可读存储介质,计算机程序被执行时能够实现上述方法实施例中可由主控节点执行的各步骤。Correspondingly, the embodiments of the present application further provide a computer-readable storage medium storing a computer program, and when the computer program is executed, the steps in the above method embodiments that can be executed by the master node can be implemented.

上述图3和图4中的存储器可以由任何类型的易失性或非易失性存储设备或者它们的组合实现,如静态随机存取存储器(SRAM),电可擦除可编程只读存储器(EEPROM),可擦除可编程只读存储器(EPROM),可编程只读存储器(PROM),只读存储器(ROM),磁存储器,快闪存储器,磁盘或光盘。The memories in Figures 3 and 4 above can be implemented by any type of volatile or non-volatile storage device or combination thereof, such as static random access memory (SRAM), electrically erasable programmable read only memory ( EEPROM), erasable programmable read only memory (EPROM), programmable read only memory (PROM), read only memory (ROM), magnetic memory, flash memory, magnetic or optical disks.

上述图3和图4中的通信组件被配置为便于通信组件所在设备和其他设备之间有线或无线方式的通信。通信组件所在设备可以接入基于通信标准的无线网络,如WiFi,2G或3G,或它们的组合。在一个示例性实施例中,通信组件经由广播信道接收来自外部广播管理系统的广播信号或广播相关信息。在一个示例性实施例中,所述通信组件还可以包括近场通信(NFC)模块,射频识别(RFID)技术,红外数据协会(IrDA)技术,超宽带(UWB)技术,蓝牙(BT)技术等。The communication components in FIGS. 3 and 4 described above are configured to facilitate wired or wireless communication between the device where the communication component is located and other devices. The device where the communication component is located can access a wireless network based on a communication standard, such as WiFi, 2G or 3G, or a combination thereof. In one exemplary embodiment, the communication component receives broadcast signals or broadcast related information from an external broadcast management system via a broadcast channel. In an exemplary embodiment, the communication component may further include a Near Field Communication (NFC) module, Radio Frequency Identification (RFID) technology, Infrared Data Association (IrDA) technology, Ultra Wide Band (UWB) technology, Bluetooth (BT) technology Wait.

上述图3和图4中的显示器包括屏幕,其屏幕可以包括液晶显示器(LCD)和触摸面板(TP)。如果屏幕包括触摸面板,屏幕可以被实现为触摸屏,以接收来自用户的输入信号。触摸面板包括一个或多个触摸传感器以感测触摸、滑动和触摸面板上的手势。所述触摸传感器可以不仅感测触摸或滑动动作的边界,而且还检测与所述触摸或滑动操作相关的持续时间和压力。The above-mentioned displays in FIGS. 3 and 4 include a screen, which may include a liquid crystal display (LCD) and a touch panel (TP). If the screen includes a touch panel, the screen may be implemented as a touch screen to receive input signals from a user. The touch panel includes one or more touch sensors to sense touch, swipe, and gestures on the touch panel. The touch sensor may not only sense the boundaries of a touch or swipe action, but also detect the duration and pressure associated with the touch or swipe action.

上述图3和图4中的电源组件,为电源组件所在设备的各种组件提供电力。电源组件可以包括电源管理系统,一个或多个电源,及其他与为电源组件所在设备生成、管理和分配电力相关联的组件。The power supply assemblies in the above-mentioned FIGS. 3 and 4 provide power for various components of the equipment in which the power supply assemblies are located. A power supply assembly may include a power management system, one or more power supplies, and other components associated with generating, managing, and distributing power to the equipment in which the power supply assembly is located.

上述图3和图4中的音频组件,可被配置为输出和/或输入音频信号。例如,音频组件包括一个麦克风(MIC),当音频组件所在设备处于操作模式,如呼叫模式、记录模式和语音识别模式时,麦克风被配置为接收外部音频信号。所接收的音频信号可以被进一步存储在存储器或经由通信组件发送。在一些实施例中,音频组件还包括一个扬声器,用于输出音频信号。The audio components described above in FIGS. 3 and 4 may be configured to output and/or input audio signals. For example, the audio component includes a microphone (MIC) that is configured to receive external audio signals when the device in which the audio component is located is in operating modes, such as call mode, recording mode, and voice recognition mode. The received audio signal may be further stored in memory or transmitted via the communication component. In some embodiments, the audio assembly further includes a speaker for outputting audio signals.

本领域内的技术人员应明白,本发明的实施例可提供为方法、系统、或计算机程序产品。因此,本发明可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且,本发明可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。As will be appreciated by one skilled in the art, embodiments of the present invention may be provided as a method, system, or computer program product. Accordingly, the present invention may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment combining software and hardware aspects. Furthermore, the present invention may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, etc.) having computer-usable program code embodied therein.

本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。The present invention is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the invention. It will be understood that each process and/or block in the flowchart illustrations and/or block diagrams, and combinations of processes and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to the processor of a general purpose computer, special purpose computer, embedded processor or other programmable data processing device to produce a machine such that the instructions executed by the processor of the computer or other programmable data processing device produce Means for implementing the functions specified in a flow or flow of a flowchart and/or a block or blocks of a block diagram.

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。These computer program instructions may also be stored in a computer-readable memory capable of directing a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory result in an article of manufacture comprising instruction means, the instructions The apparatus implements the functions specified in the flow or flow of the flowcharts and/or the block or blocks of the block diagrams.

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。These computer program instructions can also be loaded on a computer or other programmable data processing device to cause a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented process such that The instructions provide steps for implementing the functions specified in the flow or blocks of the flowcharts and/or the block or blocks of the block diagrams.

在一个典型的配置中,计算设备包括一个或多个处理器(CPU)、输入/输出接口、网络接口和内存。In a typical configuration, a computing device includes one or more processors (CPUs), input/output interfaces, network interfaces, and memory.

内存可能包括计算机可读介质中的非永久性存储器,随机存取存储器(RAM)和/或非易失性内存等形式,如只读存储器(ROM)或闪存(flash RAM)。内存是计算机可读介质的示例。Memory may include non-persistent memory in computer readable media, random access memory (RAM) and/or non-volatile memory in the form of, for example, read only memory (ROM) or flash memory (flash RAM). Memory is an example of a computer-readable medium.

计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括,但不限于相变内存(PRAM)、静态随机存取存储器(SRAM)、动态随机存取存储器(DRAM)、其他类型的随机存取存储器(RAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、快闪记忆体或其他内存技术、只读光盘只读存储器(CD-ROM)、数字多功能光盘(DVD)或其他光学存储、磁盒式磁带,磁带磁磁盘存储或其他磁性存储设备或任何其他非传输介质,可用于存储可以被计算设备访问的信息。按照本文中的界定,计算机可读介质不包括暂存电脑可读媒体(transitory media),如调制的数据信号和载波。Computer-readable media includes both persistent and non-permanent, removable and non-removable media, and storage of information may be implemented by any method or technology. Information may be computer readable instructions, data structures, modules of programs, or other data. Examples of computer storage media include, but are not limited to, phase-change memory (PRAM), static random access memory (SRAM), dynamic random access memory (DRAM), other types of random access memory (RAM), read only memory (ROM), Electrically Erasable Programmable Read Only Memory (EEPROM), Flash Memory or other memory technology, Compact Disc Read Only Memory (CD-ROM), Digital Versatile Disc (DVD) or other optical storage, Magnetic tape cassettes, magnetic tape magnetic disk storage or other magnetic storage devices or any other non-transmission medium that can be used to store information that can be accessed by a computing device. As defined herein, computer-readable media does not include transitory computer-readable media, such as modulated data signals and carrier waves.

还需要说明的是,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、商品或者设备不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、商品或者设备所固有的要素。在没有更多限制的情况下,由语句“包括一个……”限定的要素,并不排除在包括所述要素的过程、方法、商品或者设备中还存在另外的相同要素。It should also be noted that the terms "comprising", "comprising" or any other variation thereof are intended to encompass a non-exclusive inclusion such that a process, method, article or device comprising a series of elements includes not only those elements, but also Other elements not expressly listed, or which are inherent to such a process, method, article of manufacture, or apparatus are also included. Without further limitation, an element qualified by the phrase "comprising a..." does not preclude the presence of additional identical elements in the process, method, article of manufacture, or device that includes the element.

以上所述仅为本申请的实施例而已,并不用于限制本申请。对于本领域技术人员来说,本申请可以有各种更改和变化。凡在本申请的精神和原理之内所作的任何修改、等同替换、改进等,均应包含在本申请的权利要求范围之内。The above descriptions are merely examples of the present application, and are not intended to limit the present application. Various modifications and variations of this application are possible for those skilled in the art. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present application shall be included within the scope of the claims of the present application.

Claims (24)

1.一种分布式计算系统,其特征在于,包括:主控节点、工作流管理节点以及不同租户对应的资源域;1. A distributed computing system, comprising: a master control node, a workflow management node, and resource domains corresponding to different tenants; 所述工作流管理节点,用于根据目标资源域中的工作流部署信息,获取工作流执行单元运行时使用的系统身份标识;将所述工作流执行单元运行时使用的系统身份标识传输给所述主控节点;The workflow management node is configured to obtain the system identity used when the workflow execution unit is running according to the workflow deployment information in the target resource domain; and transmit the system identity used when the workflow execution unit is running to the the main control node; 所述主控节点,用于在所述工作流执行单元运行时使用的系统身份标识属于所述目标资源域有权使用的系统身份标识的情况下,将所述工作流执行单元部署到所述目标资源域中的工作节点上;The master control node is configured to deploy the workflow execution unit to the on the worker nodes in the target resource domain; 其中,所述工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对所述分布式计算系统的共享存储资源进行访存。Wherein, the workflow execution unit fetches the shared storage resources of the distributed computing system based on the fetching authority corresponding to the system identity used in the runtime. 2.根据权利要求1所述的系统,其特征在于,所述工作流管理节点还用于:2. The system according to claim 1, wherein the workflow management node is further configured to: 根据所述工作流部署信息生成所述主控节点可识别的至少一个工作流执行单元模型,每个工作流执行单元模型包含至少一个工作流执行单元;Generate at least one workflow execution unit model identifiable by the master control node according to the workflow deployment information, and each workflow execution unit model includes at least one workflow execution unit; 按照所述至少一个工作流执行单元模型之间的时序依赖关系,依次将所述至少一个工作流执行单元模型发送给所述主控节点,以供所述主控节点以工作流执行单元模型为单位对工作流执行单元进行部署。According to the time sequence dependency between the at least one workflow execution unit model, the at least one workflow execution unit model is sequentially sent to the master control node, so that the master control node uses the workflow execution unit model as the The unit deploys the workflow execution unit. 3.根据权利要求2所述的系统,其特征在于,所述主控节点具体用于:3. The system according to claim 2, wherein the master control node is specifically used for: 接收所述工作流管理节点依次发送的所述至少一个工作流执行单元模型;receiving the at least one workflow execution unit model sequentially sent by the workflow management node; 针对每个工作流执行单元模型,判断所述工作流执行单元模型中的工作流执行单元运行时使用的系统身份标识是否均属于所述目标资源域有权使用的系统身份标识;若判断结果为是,将所述工作流执行单元模型中的工作流执行单元部署到所述目标资源域中的工作节点上。For each workflow execution unit model, determine whether the system identities used by the workflow execution units in the workflow execution unit model when running all belong to the system identities that the target resource domain has the right to use; if the judgment result is Yes, deploy the workflow execution unit in the workflow execution unit model to the work node in the target resource domain. 4.根据权利要求3所述的系统,其特征在于,所述工作流管理节点还用于:4. The system according to claim 3, wherein the workflow management node is further configured to: 从所述工作流部署信息中获取所述目标资源域的标识以及申请部署工作流的用户身份凭证;将所述目标资源域的标识和所述用户身份凭证发送给所述主控节点;以及Obtain the identifier of the target resource domain and the user identity credential for applying to deploy the workflow from the workflow deployment information; send the identifier of the target resource domain and the user identity credential to the master control node; and 在所述主控节点确定所述目标资源域的标识和所述用户身份凭证对应的情况下,按照所述至少一个工作流执行单元模型之间的时序依赖关系,依次将所述至少一个工作流执行单元模型发送给所述主控节点。In the case where the master control node determines that the identifier of the target resource domain corresponds to the user identity credential, according to the time sequence dependency between the at least one workflow execution unit model, the at least one workflow is sequentially The execution unit model is sent to the master node. 5.根据权利要求4所述的系统,其特征在于,所述主控节点还用于:5. The system according to claim 4, wherein the master control node is further used for: 根据预先维护的资源域的标识与用户身份凭证之间的对应关系,确定所述目标资源域的标识和所述用户身份凭证是否对应,并向所述工作流管理节点返回确定结果。According to the pre-maintained correspondence between the identifier of the resource domain and the user identity credential, it is determined whether the identifier of the target resource domain corresponds to the user identity credential, and a determination result is returned to the workflow management node. 6.根据权利要求1-5任一项所述的系统,其特征在于,所述主控节点还用于:6. The system according to any one of claims 1-5, wherein the master control node is further configured to: 面向目标租户的运维管理人员提供资源域安全配置界面,以供所述运维管理人员配置所述目标资源域的安全参数;所述安全参数包括所述目标资源域的用户身份凭证、所述目标资源域的标识以及所述目标资源域有权使用的系统身份标识;The operation and maintenance management personnel of the target tenant provide a resource domain security configuration interface for the operation and maintenance management personnel to configure the security parameters of the target resource domain; the security parameters include the user identity credentials of the target resource domain, the The identifier of the target resource domain and the system identity that the target resource domain has the right to use; 建立所述目标资源域的用户身份凭证、所述目标资源域的标识以及所述目标资源域有权使用的运行用户身份标识范围之间的对应关系;其中,所述目标租户与所述目标资源域对应。establishing a correspondence between the user identity credential of the target resource domain, the identity of the target resource domain, and the scope of the running user identity that the target resource domain has the right to use; wherein, the target tenant and the target resource domain correspondence. 7.根据权利要求1-5任一项所述的系统,其特征在于,所述工作流管理节点还用于:7. The system according to any one of claims 1-5, wherein the workflow management node is further configured to: 面向目标租户中工作流部署人员提供工作流部署界面,并获取所述工作流部署人员在所述工作流部署界面上配置的工作流部署信息;Provide a workflow deployment interface for the workflow deployment personnel in the target tenant, and obtain the workflow deployment information configured by the workflow deployment personnel on the workflow deployment interface; 其中,所述工作流部署信息包括需要部署工作流的目标资源域的标识、申请部署工作流的用户身份凭证和工作流执行单元运行时使用的系统身份标识;所述目标租户与所述目标资源域对应。The workflow deployment information includes the identifier of the target resource domain where the workflow needs to be deployed, the user identity credential for applying to deploy the workflow, and the system identity used when the workflow execution unit runs; the target tenant and the target resource domain correspondence. 8.根据权利要求1-5任一项所述的系统,其特征在于,所述工作流执行单元运行时使用的系统身份标识为用户标识Uid或用户组标识Gid。8 . The system according to claim 1 , wherein the system identity used when the workflow execution unit runs is a user identity Uid or a user group identity Gid. 9 . 9.一种基于容器编排调度系统实现的分布式计算系统,其特征在于,包括:主控节点、工作流管理节点以及不同租户对应的命名空间;9. A distributed computing system based on a container orchestration and scheduling system, comprising: a master control node, a workflow management node, and namespaces corresponding to different tenants; 所述工作流管理节点,用于根据目标命名空间中的工作流部署信息,获取待部署工作流所需的容器运行时使用的系统身份标识;将所述容器运行时使用的系统身份标识传输给所述主控节点;The workflow management node is configured to acquire, according to the workflow deployment information in the target namespace, the system identity used by the container runtime required by the to-be-deployed workflow; and transmit the system identity used by the container runtime to the the master control node; 所述主控节点,用于在所述容器运行时使用的系统身份标识属于所述目标命名空间有权使用的系统身份标识的情况下,将所述容器部署到所述目标命名空间下的工作节点上;The master control node is used for deploying the container to work under the target namespace when the system identity used when the container is running belongs to the system identity that the target namespace has the right to use on the node; 其中,所述容器基于其运行时使用的系统身份标识对应的访存权限对所述分布式计算系统的共享存储资源进行访存。Wherein, the container fetches the shared storage resources of the distributed computing system based on the fetching authority corresponding to the system identity used by the container when it runs. 10.根据权利要求9所述的系统,其特征在于,所述工作流管理节点还用于:10. The system according to claim 9, wherein the workflow management node is further configured to: 根据所述工作流部署信息生成所述主控节点可识别的至少一个容器组模型,每个容器组模型包含至少一个容器;Generate at least one container group model identifiable by the master control node according to the workflow deployment information, and each container group model includes at least one container; 按照所述至少一个容器组模型之间的时序依赖关系,依次将所述至少一个容器组模型发送给所述主控节点,以供所述主控节点以容器组模型为单位对容器进行部署。The at least one container group model is sequentially sent to the master control node according to the time-series dependency between the at least one container group model, so that the master control node deploys containers in units of the container group model. 11.根据权利要求10所述的系统,其特征在于,所述主控节点具体用于:11. The system according to claim 10, wherein the master control node is specifically used for: 接收所述工作流管理节点依次发送的所述至少一个容器组模型;receiving the at least one container group model sequentially sent by the workflow management node; 针对每个容器组模型,判断所述容器组模型中的容器运行时使用的系统身份标识是否均属于所述目标命名空间有权使用的系统身份标识,若判断结果为是,将所述容器组模型中的容器部署到所述目标命名空间下的工作节点上。For each container group model, it is judged whether the system identities used when the containers in the container group model are running all belong to the system identities that the target namespace has the right to use, and if the judgment result is yes, the container group Containers in the model are deployed on worker nodes under the target namespace. 12.根据权利要求9-11任一项所述的系统,其特征在于,所述工作流管理节点还用于:12. The system according to any one of claims 9-11, wherein the workflow management node is further configured to: 面向目标租户的工作流部署人员提供工作流部署界面,并获取所述工作流部署人员在所述工作流部署界面上配置的工作流部署信息;Provide a workflow deployment interface for the workflow deployment personnel of the target tenant, and obtain the workflow deployment information configured by the workflow deployment personnel on the workflow deployment interface; 其中,所述工作流部署信息包括目标命名空间的标识、申请部署工作流的用户身份凭证和待部署工作流所需的容器运行时使用的系统身份标识;其中,所述目标租户与所述目标命名空间对应。The workflow deployment information includes the identifier of the target namespace, the user identity credentials for applying for deploying the workflow, and the system identifier used when the container is run for the workflow to be deployed; wherein the target tenant and the target Namespace correspondence. 13.一种工作流部署方法,适用于工作流管理节点,其特征在于,所述方法包括:13. A workflow deployment method, applicable to a workflow management node, wherein the method comprises: 根据目标资源域中的工作流部署信息,获取工作流执行单元运行时使用的系统身份标识;According to the workflow deployment information in the target resource domain, obtain the system identity used when the workflow execution unit is running; 将所述工作流执行单元运行时使用的系统身份标识传输给所述工作流管理节点所属分布式计算系统中的主控节点,以供所述主控节点在所述工作流执行单元运行时使用的系统身份标识属于所述目标资源域有权使用的系统身份标识的情况下,将所述工作流执行单元部署到所述目标资源域中的工作节点上;Transmitting the system identity used when the workflow execution unit is running to the master control node in the distributed computing system to which the workflow management node belongs, for the master control node to use when the workflow execution unit is running In the case that the system identifier belongs to the system identifier that the target resource domain has the right to use, deploy the workflow execution unit on the worker node in the target resource domain; 其中,所述工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对所述分布式计算系统的共享存储资源进行访存。Wherein, the workflow execution unit fetches the shared storage resources of the distributed computing system based on the fetching authority corresponding to the system identity used in the runtime. 14.根据权利要求13所述的方法,其特征在于,还包括:14. The method of claim 13, further comprising: 根据所述工作流部署信息生成所述主控节点可识别的至少一个工作流执行单元模型,每个工作流执行单元模型包含至少一个工作流执行单元;Generate at least one workflow execution unit model identifiable by the master control node according to the workflow deployment information, and each workflow execution unit model includes at least one workflow execution unit; 按照所述至少一个工作流执行单元模型之间的时序依赖关系,依次将所述至少一个工作流执行单元模型发送给所述主控节点,以供所述主控节点以工作流执行单元模型为单位对工作流执行单元进行部署。According to the time sequence dependency between the at least one workflow execution unit model, the at least one workflow execution unit model is sequentially sent to the master control node, so that the master control node uses the workflow execution unit model as the The unit deploys the workflow execution unit. 15.根据权利要求14所述的方法,其特征在于,在依次将所述至少一个工作流执行单元模型发送给所述主控节点之前,还包括:15. The method according to claim 14, wherein before sequentially sending the at least one workflow execution unit model to the master control node, the method further comprises: 从所述工作流部署信息中获取所述目标资源域的标识以及申请部署工作流的用户身份凭证;Obtain the identifier of the target resource domain and the user identity credential for applying to deploy the workflow from the workflow deployment information; 将所述目标资源域的标识和所述用户身份凭证发送给所述主控节点,以供所述主控节点确定所述目标资源域的标识和所述用户身份凭证是否对应;以及sending the identifier of the target resource domain and the user identity credential to the master control node, so that the master control node can determine whether the identifier of the target resource domain corresponds to the user identity credential; and 接收所述主控节点返回的所述目标资源域的标识和所述用户身份凭证是否对应的确定结果。A determination result of whether the identifier of the target resource domain and the user identity credential are corresponding or not returned by the master control node is received. 16.根据权利要求13-15任一项所述的方法,其特征在于,还包括:16. The method of any one of claims 13-15, further comprising: 面向目标租户的工作流部署人员提供工作流部署界面,并获取所述工作流部署人员在所述工作流部署界面上配置的工作流部署信息;Provide a workflow deployment interface for the workflow deployment personnel of the target tenant, and obtain the workflow deployment information configured by the workflow deployment personnel on the workflow deployment interface; 其中,所述工作流部署信息包括需要部署工作流的目标资源域的标识、申请部署工作流的用户身份凭证和工作流执行单元运行时使用的系统身份标识;所述目标租户与所述目标资源域对应。The workflow deployment information includes the identifier of the target resource domain where the workflow needs to be deployed, the user identity credential for applying to deploy the workflow, and the system identity used when the workflow execution unit runs; the target tenant and the target resource domain correspondence. 17.一种工作流部署方法,适用于主控节点,其特征在于,所述方法包括:17. A workflow deployment method, applicable to a master control node, wherein the method comprises: 接收工作流管理节点发送的工作流执行单元运行时使用的系统身份标识,所述工作流执行单元是需要在目标资源域中部署的工作流的执行单元;receiving the system identity used when the workflow execution unit is running and sent by the workflow management node, where the workflow execution unit is the execution unit of the workflow that needs to be deployed in the target resource domain; 在所述工作流执行单元运行时使用的系统身份标识属于所述目标资源域有权使用的系统身份标识的情况下,将所述工作流执行单元部署到所述目标资源域中的工作节点上;Deploying the workflow execution unit to a worker node in the target resource domain under the condition that the system identity used when the workflow execution unit is running belongs to the system identity that the target resource domain has the right to use ; 其中,所述工作流执行单元基于其运行时使用的系统身份标识对应的访存权限对所述分布式计算系统的共享存储资源进行访存。Wherein, the workflow execution unit fetches the shared storage resources of the distributed computing system based on the fetching authority corresponding to the system identity used in the runtime. 18.根据权利要求17所述的方法,其特征在于,将所述工作流执行单元部署到所述目标资源域中的工作节点上,包括:18. The method according to claim 17, wherein deploying the workflow execution unit to a worker node in the target resource domain comprises: 接收所述工作流管理节点依次发送的至少一个工作流执行单元模型,每个工作流执行单元模型包含至少一个工作流执行单元;receiving at least one workflow execution unit model sequentially sent by the workflow management node, where each workflow execution unit model includes at least one workflow execution unit; 针对每个工作流执行单元模型,判断所述工作流执行单元模型中的工作流执行单元运行时使用的系统身份标识是否均属于所述目标资源域有权使用的系统身份标识,若判断结果为是,将所述工作流执行单元模型中的工作流执行单元部署到所述目标资源域中的工作节点上。For each workflow execution unit model, it is judged whether the system identities used by the workflow execution units in the workflow execution unit model when running all belong to the system identities that the target resource domain has the right to use, if the judgment result is Yes, deploy the workflow execution unit in the workflow execution unit model to the work node in the target resource domain. 19.根据权利要求18所述的方法,其特征在于,在接收所述工作流管理节点依次发送的至少一个工作流执行单元模型之前,还包括:19. The method according to claim 18, wherein before receiving the at least one workflow execution unit model sequentially sent by the workflow management node, the method further comprises: 接收所述工作流管理节点发送的所述目标资源域的标识以及申请部署工作流的用户身份凭证;receiving the identifier of the target resource domain sent by the workflow management node and the user identity credential for applying to deploy the workflow; 根据预先维护的资源域的标识与用户身份凭证之间的对应关系,确定所述目标资源域的标识和所述用户身份凭证是否对应,并向所述工作流管理节点返回确定结果。According to the pre-maintained correspondence between the identifier of the resource domain and the user identity credential, it is determined whether the identifier of the target resource domain corresponds to the user identity credential, and a determination result is returned to the workflow management node. 20.根据权利要求17-19任一项所述的方法,其特征在于,还包括:20. The method of any one of claims 17-19, further comprising: 面向目标租户的运维管理人员提供资源域安全配置界面,以供所述运维管理人员配置所述目标资源域的安全参数;所述安全参数包括所述目标资源域的用户身份凭证、所述目标资源域的标识以及所述目标资源域有权使用的系统身份标识;The operation and maintenance management personnel of the target tenant provide a resource domain security configuration interface for the operation and maintenance management personnel to configure the security parameters of the target resource domain; the security parameters include the user identity credentials of the target resource domain, the The identifier of the target resource domain and the system identity that the target resource domain has the right to use; 建立所述目标资源域的用户身份凭证、所述目标资源域的标识以及所述目标资源域有权使用的运行用户身份标识范围之间的对应关系;其中,所述目标租户与所述目标资源域对应。establishing a correspondence between the user identity credential of the target resource domain, the identity of the target resource domain, and the scope of the running user identity that the target resource domain has the right to use; wherein, the target tenant and the target resource domain correspondence. 21.一种节点设备,其特征在于,包括:存储器和处理器;所述存储器用于存储计算机程序;当所述计算机程序被所述处理器执行时,致使所述处理器实现权利要求13-16任一项所述方法中的步骤。21. A node device, comprising: a memory and a processor; the memory is used to store a computer program; when the computer program is executed by the processor, the processor is caused to implement claims 13- 16 The steps of any one of the methods. 22.一种存储有计算机程序的计算机可读存储介质,其特征在于,当所述计算机程序被处理器执行时,致使所述处理器执行权利要求13-16任一项所述方法中的步骤。22. A computer-readable storage medium storing a computer program, wherein when the computer program is executed by a processor, the processor is caused to perform the steps in the method of any one of claims 13-16 . 23.一种节点设备,其特征在于,包括:存储器和处理器;所述存储器存储有计算机程序,当所述计算机程序被所述处理器执行时,致使所述处理器实现权利要求17-20任一项所述方法中的步骤。23. A node device, comprising: a memory and a processor; the memory stores a computer program that, when executed by the processor, causes the processor to implement claims 17-20 The steps of any one of the methods. 24.一种存储有计算机程序的计算机可读存储介质,其特征在于,当所述计算机程序被处理器执行时,致使所述处理器执行权利要求17-20任一项所述方法中的步骤。24. A computer-readable storage medium storing a computer program, characterized in that, when the computer program is executed by a processor, the processor is caused to perform the steps in the method of any one of claims 17-20 .
CN201910452307.8A 2019-05-28 2019-05-28 Workflow deployment method, device, system and storage medium Active CN112015524B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201910452307.8A CN112015524B (en) 2019-05-28 2019-05-28 Workflow deployment method, device, system and storage medium

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201910452307.8A CN112015524B (en) 2019-05-28 2019-05-28 Workflow deployment method, device, system and storage medium

Publications (2)

Publication Number Publication Date
CN112015524A true CN112015524A (en) 2020-12-01
CN112015524B CN112015524B (en) 2024-11-29

Family

ID=73500995

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201910452307.8A Active CN112015524B (en) 2019-05-28 2019-05-28 Workflow deployment method, device, system and storage medium

Country Status (1)

Country Link
CN (1) CN112015524B (en)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN112698914A (en) * 2020-12-30 2021-04-23 北京理工大学 Workflow task container generation system and method

Citations (14)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103532981A (en) * 2013-10-31 2014-01-22 中国科学院信息工程研究所 Identity escrow and authentication cloud resource access control system and method for multiple tenants
CN104123616A (en) * 2014-07-25 2014-10-29 南京邮电大学 Cloud computing system towards multiple tenants
CN104769908A (en) * 2012-09-07 2015-07-08 甲骨文国际公司 LDAP-based multi-tenant in-cloud identity management system
CN105323282A (en) * 2014-07-28 2016-02-10 神州数码信息系统有限公司 Enterprise application deployment and management system for multiple tenants
CN106127368A (en) * 2016-06-14 2016-11-16 成都镜杰科技有限责任公司 Date storage method for ERP System
CN107111696A (en) * 2014-12-19 2017-08-29 微软技术许可有限责任公司 Security and authority framework in multi-tenant computing system
US20170331812A1 (en) * 2016-05-11 2017-11-16 Oracle International Corporation Microservices based multi-tenant identity and data security management cloud service
CN107995197A (en) * 2017-12-04 2018-05-04 中国电子科技集团公司第三十研究所 A kind of method for realizing across management domain identity and authority information is shared
CN108337260A (en) * 2016-05-11 2018-07-27 甲骨文国际公司 Multi-tenant identity and data security management cloud service
US20180285146A1 (en) * 2017-03-31 2018-10-04 International Business Machines Corporation Workflow handling in a multi-tenant cloud environment
CN108885554A (en) * 2016-04-07 2018-11-23 国际商业机器公司 specific distributed computer system
CN109218100A (en) * 2018-09-21 2019-01-15 郑州云海信息技术有限公司 Distributed objects storage cluster and its request responding method, system and storage medium
CN109327422A (en) * 2017-08-01 2019-02-12 中国移动通信集团浙江有限公司 A multi-tenant tenant isolation method and device
CN109656879A (en) * 2018-12-13 2019-04-19 深圳前海微众银行股份有限公司 Big data method for managing resource, device, equipment and storage medium

Patent Citations (14)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN104769908A (en) * 2012-09-07 2015-07-08 甲骨文国际公司 LDAP-based multi-tenant in-cloud identity management system
CN103532981A (en) * 2013-10-31 2014-01-22 中国科学院信息工程研究所 Identity escrow and authentication cloud resource access control system and method for multiple tenants
CN104123616A (en) * 2014-07-25 2014-10-29 南京邮电大学 Cloud computing system towards multiple tenants
CN105323282A (en) * 2014-07-28 2016-02-10 神州数码信息系统有限公司 Enterprise application deployment and management system for multiple tenants
CN107111696A (en) * 2014-12-19 2017-08-29 微软技术许可有限责任公司 Security and authority framework in multi-tenant computing system
CN108885554A (en) * 2016-04-07 2018-11-23 国际商业机器公司 specific distributed computer system
US20170331812A1 (en) * 2016-05-11 2017-11-16 Oracle International Corporation Microservices based multi-tenant identity and data security management cloud service
CN108337260A (en) * 2016-05-11 2018-07-27 甲骨文国际公司 Multi-tenant identity and data security management cloud service
CN106127368A (en) * 2016-06-14 2016-11-16 成都镜杰科技有限责任公司 Date storage method for ERP System
US20180285146A1 (en) * 2017-03-31 2018-10-04 International Business Machines Corporation Workflow handling in a multi-tenant cloud environment
CN109327422A (en) * 2017-08-01 2019-02-12 中国移动通信集团浙江有限公司 A multi-tenant tenant isolation method and device
CN107995197A (en) * 2017-12-04 2018-05-04 中国电子科技集团公司第三十研究所 A kind of method for realizing across management domain identity and authority information is shared
CN109218100A (en) * 2018-09-21 2019-01-15 郑州云海信息技术有限公司 Distributed objects storage cluster and its request responding method, system and storage medium
CN109656879A (en) * 2018-12-13 2019-04-19 深圳前海微众银行股份有限公司 Big data method for managing resource, device, equipment and storage medium

Non-Patent Citations (3)

* Cited by examiner, † Cited by third party
Title
ZUO QIONG等: "Autonomous Decentralized Authorization and Authentication Management for Hierarchical Multi-Tenancy", 《APR 2016》, 23 September 2016 (2016-09-23), pages 786 - 793, XP093041889, DOI: 10.1587/transcom.2015ADI0002 *
王锋;张;张彤;马维纲;: "基于Eucalyptus的多租户水利系统应用研究", 计算机系统应用, no. 09, 15 September 2018 (2018-09-15), pages 107 - 111 *
肖健等: "多租户系统的轻量级实现及其在大型仪器设备共享平台中的应用", 《实验技术与管理》, vol. 35, no. 5, 31 May 2018 (2018-05-31), pages 146 - 150 *

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN112698914A (en) * 2020-12-30 2021-04-23 北京理工大学 Workflow task container generation system and method
CN112698914B (en) * 2020-12-30 2022-12-27 北京理工大学 Workflow task container generation system and method

Also Published As

Publication number Publication date
CN112015524B (en) 2024-11-29

Similar Documents

Publication Publication Date Title
WO2020238751A1 (en) Resource access method under serverless architecture, device, system, and storage medium
US10848520B2 (en) Managing access to resources
US9436813B2 (en) Multi-tenancy support for a product that does not support multi-tenancy
US10104053B2 (en) System and method for providing annotated service blueprints in an intelligent workload management system
US20180316676A1 (en) Dynamic computing resource access authorization
US9866547B2 (en) Controlling a discovery component, within a virtual environment, that sends authenticated data to a discovery engine outside the virtual environment
US11102196B2 (en) Authenticating API service invocations
US20150113528A1 (en) Virtual desktop service apparatus and method
US9998474B2 (en) Secure assertion attribute for a federated log in
CN108701175B (en) Associating user accounts with enterprise workspaces
US20120089666A1 (en) Virtual workplace environments
CN108293045A (en) Single sign-on identity management between local and remote systems
US10542048B2 (en) Security compliance framework usage
US20200052882A1 (en) Secure environment device management
CN108551438A (en) X.509, Single Sign-On between different server, which uses, to be verified
CN112015524A (en) Workflow deployment method, device, system and storage medium
KR101495562B1 (en) Method And Apparatus for Providing Data Analysis Service
CN116755842B (en) Identity verification system deployment method, device, equipment and storage medium
US20180349634A1 (en) System and Method to Remotely Provision Out-of-Band Systems
US20240356854A1 (en) Access control for restricted entities
US20250028833A1 (en) Electronic device management using a device management system
CN119271346A (en) Kerberos application deployment method and device

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant