CN114443294B - Big data service component deployment method, system, terminal and storage medium - Google Patents
Big data service component deployment method, system, terminal and storage medium Download PDFInfo
- Publication number
- CN114443294B CN114443294B CN202210068720.6A CN202210068720A CN114443294B CN 114443294 B CN114443294 B CN 114443294B CN 202210068720 A CN202210068720 A CN 202210068720A CN 114443294 B CN114443294 B CN 114443294B
- Authority
- CN
- China
- Prior art keywords
- service
- deployment
- dependency
- deployed
- service components
- 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.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 43
- 238000003860 storage Methods 0.000 title claims abstract description 16
- 238000010586 diagram Methods 0.000 claims abstract description 54
- 238000009434 installation Methods 0.000 claims abstract description 39
- 238000012544 monitoring process Methods 0.000 claims abstract description 22
- 238000012986 modification Methods 0.000 claims description 16
- 230000004048 modification Effects 0.000 claims description 16
- 238000012795 verification Methods 0.000 claims description 13
- 238000012217 deletion Methods 0.000 claims description 8
- 230000037430 deletion Effects 0.000 claims description 8
- 238000004590 computer program Methods 0.000 claims description 3
- 238000002360 preparation method Methods 0.000 claims description 3
- 238000010276 construction Methods 0.000 claims 3
- 230000000007 visual effect Effects 0.000 abstract description 4
- 230000006870 function Effects 0.000 description 6
- 238000004891 communication Methods 0.000 description 5
- 238000007792 addition Methods 0.000 description 4
- 230000008878 coupling Effects 0.000 description 3
- 238000010168 coupling process Methods 0.000 description 3
- 238000005859 coupling reaction Methods 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 3
- 230000003287 optical effect Effects 0.000 description 3
- 238000012545 processing Methods 0.000 description 3
- 238000006467 substitution reaction Methods 0.000 description 3
- 125000002015 acyclic group Chemical group 0.000 description 2
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000000739 chaotic effect Effects 0.000 description 1
- 230000006837 decompression Effects 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 238000012423 maintenance Methods 0.000 description 1
- 238000004519 manufacturing process Methods 0.000 description 1
- 230000003068 static effect Effects 0.000 description 1
- 230000001360 synchronised effect Effects 0.000 description 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements 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/46—Multiprogramming arrangements
- G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5061—Partitioning or combining of resources
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Transfer Between Computers (AREA)
- Stored Programmes (AREA)
Abstract
Description
技术领域Technical field
本发明涉及大数据技术领域,具体涉及一种大数据服务组件部署方法、系统、终端及存储介质。The present invention relates to the field of big data technology, and specifically to a big data service component deployment method, system, terminal and storage medium.
背景技术Background technique
大数据服务组件之间存在着相互依赖的关系,例如:HBase的底层存储依赖HDFS,而HDFS的高可用部署需要依赖Zookeeper。而对于企业级的数据中心,在复杂的应用场景下,往往需要同一个服务组件实施多套部署,例如在同一个物理集群内,部署多套HBase或HDFS集群,这些同组件不同的集群支撑的业务以及数据相互独立,并共同承载起一个庞大且复杂的大数据集群。然而在实施过程中,多个服务之间的依赖关系容易产生交叉、冲突等问题,系统混乱,缺少统一的管理方案,随着业务的扩大,对于后期维护管理带来了巨大的困难。There are interdependencies between big data service components. For example, the underlying storage of HBase relies on HDFS, and the high-availability deployment of HDFS relies on Zookeeper. For enterprise-level data centers, in complex application scenarios, it is often necessary to implement multiple deployments of the same service component. For example, deploy multiple HBase or HDFS clusters in the same physical cluster. These clusters with the same component support different services. Business and data are independent of each other and jointly carry a huge and complex big data cluster. However, during the implementation process, the dependencies between multiple services are prone to overlap, conflict and other problems. The system is chaotic and lacks a unified management plan. As the business expands, it brings huge difficulties to later maintenance and management.
发明内容Contents of the invention
针对现有大数据服务组件部署方法存在的多个服务之间依赖关系容易产生交叉、冲突等问题,本发明提供一种大数据服务组件部署方法、系统、终端及存储介质,以避免庞大业务下多服务部署的结构混乱问题,为集群管理提供极大的便利。Aiming at problems such as dependencies between multiple services in existing big data service component deployment methods that are prone to overlap, conflict, etc., the present invention provides a big data service component deployment method, system, terminal and storage medium to avoid huge business downtime. The structural chaos of multi-service deployment provides great convenience for cluster management.
第一方面,本发明提供一种大数据服务组件部署方法,包括:In a first aspect, the present invention provides a big data service component deployment method, including:
通过浏览器界面编辑依赖树图,所述依赖树图指示待部署服务组件之间的依赖关系和待部署服务组件的身份信息及部署地址;Edit a dependency tree diagram through the browser interface, which indicates the dependency relationship between the service components to be deployed and the identity information and deployment address of the service components to be deployed;
将所述依赖关系转换为各服务组件的部署顺序,根据所述部署顺序依次调取服务组件安装文件,并根据待部署服务组件的身份信息和部署地址执行相应安装文件;Convert the dependency relationship into the deployment sequence of each service component, sequentially retrieve the service component installation files according to the deployment sequence, and execute the corresponding installation file according to the identity information and deployment address of the service component to be deployed;
创建分布式监控进程,所述分布式监控进程监控已部署的服务组件的运行信息。Create a distributed monitoring process that monitors running information of deployed service components.
进一步的,通过浏览器界面编辑依赖树图,所述依赖树图指示待部署服务组件之间的依赖关系和待部署服务组件的身份信息及部署地址,包括:Further, edit the dependency tree diagram through the browser interface. The dependency tree diagram indicates the dependency relationship between the service components to be deployed and the identity information and deployment address of the service components to be deployed, including:
预先设置多种服务组件标签及连接指示标记;Pre-set various service component labels and connection indicators;
接收用户拖动指令,所述用户拖动指令包括拖动对象和目标点坐标,根据用户拖动指令将拖动对象复制至目标点坐标所在区域,所述拖动对象为服务组件标签或连接指示标记;Receive user drag instructions, which include drag objects and target point coordinates, and copy the drag objects to the area where the target point coordinates are located according to the user drag instructions. The drag objects are service component labels or connection instructions. mark;
为拖动至目标点坐标的服务组件标签调用默认配置模板,所述默认配置模板包括待配置参数项,向所述待配置参数项输入参数值后将所述默认配置模板保存为所述服务组件标签的配置文件,所述待配置参数项包括身份信息和部署地址;Call the default configuration template for the service component label dragged to the target point coordinates. The default configuration template includes parameter items to be configured. After inputting parameter values to the parameter items to be configured, the default configuration template is saved as the service component. The configuration file of the label, the parameter items to be configured include identity information and deployment address;
根据相邻服务组件之间的连接指示标记生成依赖树图中服务组件之间的依赖关系;Generate dependencies between service components in a dependency tree diagram based on connection indication marks between adjacent service components;
根据设定的校验规则校验依赖树图的合理性,所述校验规则包括无环图、一个服务组件依赖的服务组件数量不超过1个、不同依赖树图的同一个服务组件部署地址不交叉。Verify the rationality of the dependency tree diagram according to the set verification rules. The verification rules include an acyclic graph, the number of service components that a service component depends on does not exceed 1, and the deployment address of the same service component in different dependency tree diagrams. No crossing.
进一步的,将所述依赖关系转换为各服务组件的部署顺序,根据所述部署顺序依次调取服务组件安装文件,并根据待部署服务组件的身份信息和部署地址执行相应安装文件,包括:Further, the dependency relationship is converted into the deployment sequence of each service component, the service component installation files are sequentially retrieved according to the deployment sequence, and the corresponding installation file is executed according to the identity information and deployment address of the service component to be deployed, including:
解析依赖树图得到服务组件之间的依赖关系和待部署服务组件的身份信息及部署地址,并根据所述依赖关系依次将各服务组件的安装文件分发至各服务组件的部署地址;Parse the dependency tree graph to obtain the dependencies between service components and the identity information and deployment address of the service components to be deployed, and distribute the installation files of each service component to the deployment addresses of each service component in sequence based on the dependency relationships;
根据所述依赖关系依次解压安装各服务组件的安装文件,并根据所述依赖关系依次启动各服务组件。The installation files for installing each service component are sequentially decompressed according to the dependency relationship, and each service component is started sequentially according to the dependency relationship.
进一步的,创建分布式监控进程,所述分布式监控进程监控已部署的服务组件的运行信息,包括:Further, create a distributed monitoring process that monitors the running information of deployed service components, including:
利用分布式监控进程收集各服务组件的运行信息,所述运行信息包括进程、所在物理节点和运行状态信息;Use the distributed monitoring process to collect the running information of each service component. The running information includes the process, the physical node where it is located, and the running status information;
将所述依赖树图和收集的运行状态信息保存至元数据库,根据浏览器界面接收的查询指令从元数据调取相应数据并将相应数据返回至浏览器界面的显示页面。The dependency tree diagram and the collected running status information are saved in the metadata database, corresponding data is retrieved from the metadata according to the query instructions received by the browser interface, and the corresponding data is returned to the display page of the browser interface.
进一步的,所述方法还包括:Further, the method also includes:
通过浏览器界面更新所述依赖树图,并将更新后的依赖树图同步更新至源数据库,更新操作包括服务组件配置修改、增删服务组件、服务下线及依赖树删除;Update the dependency tree diagram through the browser interface, and synchronize the updated dependency tree diagram to the source database. The update operations include service component configuration modification, addition and deletion of service components, service offline and dependency tree deletion;
对比修改前的依赖树,解析修改的节点和修改内容,根据依赖关系对已部署的服务组件进行相关操作,操作包括配置修改,节点增删,服务下架;若删除依赖树,则解析出当前依赖树的依赖关系,并根据逆向依赖关系依次对当前依赖树的所有服务组件进行卸载。Compare the dependency tree before modification, parse the modified nodes and modification content, and perform related operations on the deployed service components based on the dependency relationships. The operations include configuration modification, node addition and deletion, and service removal; if the dependency tree is deleted, the current dependencies are parsed The dependency relationship of the tree, and all service components of the current dependency tree are uninstalled in sequence based on the reverse dependency relationship.
第二方面,本发明提供一种大数据服务组件部署系统,包括:In a second aspect, the present invention provides a big data service component deployment system, including:
树图构建单元,用于通过浏览器界面编辑依赖树图,所述依赖树图指示待部署服务组件之间的依赖关系和待部署服务组件的身份信息及部署地址;A tree diagram building unit for editing a dependency tree diagram through a browser interface, where the dependency tree diagram indicates the dependency relationship between the service components to be deployed and the identity information and deployment address of the service components to be deployed;
组件部署单元,用于将所述依赖关系转换为各服务组件的部署顺序,根据所述部署顺序依次调取服务组件安装文件,并根据待部署服务组件的身份信息和部署地址执行相应安装文件;A component deployment unit, used to convert the dependency relationship into a deployment sequence of each service component, sequentially retrieve the service component installation files according to the deployment sequence, and execute the corresponding installation file according to the identity information and deployment address of the service component to be deployed;
组件监控单元,用于创建分布式监控进程,所述分布式监控进程监控已部署的服务组件的运行信息。A component monitoring unit is used to create a distributed monitoring process, and the distributed monitoring process monitors the running information of deployed service components.
进一步的,所述树图构建单元包括:Further, the tree diagram building unit includes:
标签准备模块,用于预先设置多种服务组件标签及连接指示标记;Label preparation module, used to pre-set various service component labels and connection indication marks;
对象拖动模块,用于接收用户拖动指令,所述用户拖动指令包括拖动对象和目标点坐标,根据用户拖动指令将拖动对象复制至目标点坐标所在区域,所述拖动对象为服务组件标签或连接指示标记;The object drag module is used to receive user drag instructions, the user drag instructions include the drag object and the target point coordinates, and copy the drag object to the area where the target point coordinates are located according to the user drag instructions, the drag object Labels or connection indicators for service components;
组件配置模块,用于为拖动至目标点坐标的服务组件标签调用默认配置模板,所述默认配置模板包括待配置参数项,向所述待配置参数项输入参数值后将所述默认配置模板保存为所述服务组件标签的配置文件,所述待配置参数项包括身份信息和部署地址;The component configuration module is used to call a default configuration template for the service component label dragged to the target point coordinates. The default configuration template includes a parameter item to be configured. After inputting a parameter value to the parameter item to be configured, the default configuration template is Save the configuration file as the service component label, and the parameter items to be configured include identity information and deployment address;
关系构建模块,用于根据相邻服务组件之间的连接指示标记生成依赖树图中服务组件之间的依赖关系;The relationship building module is used to generate dependency relationships between service components in the dependency tree diagram based on the connection indicator marks between adjacent service components;
合理校验模块,用于根据设定的校验规则校验依赖树图的合理性,所述校验规则包括无环图、一个服务组件依赖的服务组件数量不超过1个、不同依赖树图的同一个服务组件部署地址不交叉。Reasonable verification module, used to verify the rationality of the dependency tree diagram according to the set verification rules. The verification rules include acyclic graphs, the number of service components that a service component depends on does not exceed 1, and different dependency tree diagrams. The deployment addresses of the same service component do not overlap.
进一步的,所述组件部署单元包括:Further, the component deployment unit includes:
树图解析模块,用于解析依赖树图得到服务组件之间的依赖关系和待部署服务组件的身份信息及部署地址,并根据所述依赖关系依次将各服务组件的安装文件分发至各服务组件的部署地址;The tree diagram parsing module is used to parse the dependency tree diagram to obtain the dependency relationships between service components and the identity information and deployment addresses of the service components to be deployed, and distribute the installation files of each service component to each service component in sequence based on the dependency relationships. deployment address;
组件安装模块,用于根据所述依赖关系依次解压安装各服务组件的安装文件,并根据所述依赖关系依次启动各服务组件。The component installation module is used to decompress and install the installation files of each service component in sequence according to the dependency relationship, and to start each service component in sequence according to the dependency relationship.
第三方面,提供一种终端,包括:In the third aspect, a terminal is provided, including:
处理器、存储器,其中,processor, memory, where,
该存储器用于存储计算机程序,This memory is used to store computer programs,
该处理器用于从存储器中调用并运行该计算机程序,使得终端执行上述的终端的方法。The processor is used to call and run the computer program from the memory, so that the terminal executes the above terminal method.
第四方面,提供了一种计算机存储介质,所述计算机可读存储介质中存储有指令,当其在计算机上运行时,使得计算机执行上述各方面所述的方法。In a fourth aspect, a computer storage medium is provided. The computer-readable storage medium stores instructions, which when run on a computer, cause the computer to perform the methods described in the above aspects.
本发明的有益效果在于,本发明提供的大数据服务组件部署方法、系统、终端及存储介质,使大数据集群具备多服务部署的管理能力,提供了清晰且直观的服务依赖关系,有效避免了实施过程中,同一个大数据组件多个部署之间的节点冲突;同时修改某个服务的配置、扩展和退服等不再需要逐个节点进行操作,可在界面统一进行,支持一键部署、修改或卸载,大大减少了管理成本。The beneficial effect of the present invention is that the big data service component deployment method, system, terminal and storage medium provided by the present invention enable the big data cluster to have the management capability of multi-service deployment, provide clear and intuitive service dependencies, and effectively avoid During the implementation process, node conflicts between multiple deployments of the same big data component; simultaneous modification of the configuration, expansion, and decommissioning of a service no longer require node-by-node operations, but can be performed uniformly on the interface, supporting one-click deployment, Modification or uninstallation greatly reduces management costs.
此外,本发明设计原理可靠,结构简单,具有非常广泛的应用前景。In addition, the design principle of the invention is reliable, the structure is simple, and it has very broad application prospects.
附图说明Description of the drawings
为了更清楚地说明本发明实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,对于本领域普通技术人员而言,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings needed to be used in the description of the embodiments or the prior art will be briefly introduced below. Obviously, for those of ordinary skill in the art, It is said that other drawings can also be obtained based on these drawings without exerting creative work.
图1是本发明一个实施例的方法的示意性流程图。Figure 1 is a schematic flow chart of a method according to an embodiment of the present invention.
图2是本发明一个实施例的系统的示意性框图。Figure 2 is a schematic block diagram of a system according to an embodiment of the present invention.
图3为本发明实施例提供的一种终端的结构示意图。Figure 3 is a schematic structural diagram of a terminal provided by an embodiment of the present invention.
具体实施方式Detailed ways
为了使本技术领域的人员更好地理解本发明中的技术方案,下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都应当属于本发明保护的范围。In order to enable those skilled in the art to better understand the technical solutions in the present invention, the technical solutions in the embodiments of the present invention will be clearly and completely described below in conjunction with the accompanying drawings in the embodiments of the present invention. Obviously, the described The embodiments are only some of the embodiments of the present invention, not all of them. Based on the embodiments of the present invention, all other embodiments obtained by those of ordinary skill in the art without creative efforts should fall within the scope of protection of the present invention.
图1是本发明一个实施例的方法的示意性流程图。其中,图1执行主体可以为一种大数据服务组件部署系统。Figure 1 is a schematic flow chart of a method according to an embodiment of the present invention. Among them, the execution subject in Figure 1 can be a big data service component deployment system.
如图1所示,该方法包括:As shown in Figure 1, the method includes:
步骤110,通过浏览器界面编辑依赖树图,所述依赖树图指示待部署服务组件之间的依赖关系和待部署服务组件的身份信息及部署地址;Step 110: Edit the dependency tree diagram through the browser interface. The dependency tree diagram indicates the dependency relationship between the service components to be deployed and the identity information and deployment address of the service components to be deployed;
步骤120,将所述依赖关系转换为各服务组件的部署顺序,根据所述部署顺序依次调取服务组件安装文件,并根据待部署服务组件的身份信息和部署地址执行相应安装文件;Step 120: Convert the dependency relationship into the deployment sequence of each service component, sequentially retrieve the service component installation files according to the deployment sequence, and execute the corresponding installation file according to the identity information and deployment address of the service component to be deployed;
步骤130,创建分布式监控进程,所述分布式监控进程监控已部署的服务组件的运行信息。Step 130: Create a distributed monitoring process that monitors the running information of deployed service components.
为了便于对本发明的理解,下面以本发明大数据服务组件部署方法的原理,结合实施例中对大数据服务组件进行部署的过程,对本发明提供的大数据服务组件部署方法做进一步的描述。In order to facilitate understanding of the present invention, the big data service component deployment method provided by the present invention will be further described below based on the principle of the big data service component deployment method of the present invention and the process of deploying the big data service components in the embodiment.
具体的,所述大数据服务组件部署方法包括:Specifically, the big data service component deployment method includes:
S1、通过浏览器界面编辑依赖树图,所述依赖树图指示待部署服务组件之间的依赖关系和待部署服务组件的身份信息及部署地址。S1. Edit a dependency tree diagram through a browser interface. The dependency tree diagram indicates the dependency relationship between the service components to be deployed and the identity information and deployment address of the service components to be deployed.
Web界面提供可视化查询、监控与操作功能,使用者在部署服务之前,在web界面编辑依赖树,并在编辑完成后提交任务。依赖树图的功能需要实现以下模块:The web interface provides visual query, monitoring and operation functions. Before deploying services, users can edit the dependency tree in the web interface and submit the task after the editing is completed. The function of dependency tree diagram requires the implementation of the following modules:
可视化界面提供了全量的大数据服务标签以及连接指针,例如Zookeeper,HDFS等,使用者通过在面板中拖动、连接等方式创建出树状图,树状图为有向无环图,不允许出现首尾相接的情况;The visual interface provides a full range of big data service tags and connection pointers, such as Zookeeper, HDFS, etc. Users can create a tree diagram by dragging and connecting in the panel. The tree diagram is a directed acyclic graph and is not allowed. End-to-end connection occurs;
依赖树状图的各个节点对应各个大数据组件,各个组件都有独立的id和名称,用于区分不同的服务部署,例如两个树状图均引入了HBase服务,则它们的id和名称不同;Each node of the dependency tree corresponds to each big data component. Each component has an independent ID and name, which is used to distinguish different service deployments. For example, if the HBase service is introduced in both tree diagrams, their IDs and names are different. ;
每个节点的服务都有配置文件的默认模板,任务提交后会根据该模板生成服务所需的配置文件,使用者需要根据实际生产需要进行配置的编写与修改。同时,使用者需要填入各个服务的安装节点IP以及客户端的部署节点;Each node's service has a default template for the configuration file. After the task is submitted, the configuration file required for the service will be generated based on the template. Users need to write and modify the configuration according to actual production needs. At the same time, users need to fill in the installation node IP of each service and the client's deployment node;
Web界面会自动校验使用者编辑的树状图的合理性,例如同一个HDFS不允许同时依赖两个Zookeeper,不同树状图的同一个服务部署的IP不允许交叉等,当使用者完成编辑并提交时,依赖树状图会作为任务提交给服务管理器,相关信息会写入元数据库;The web interface will automatically verify the rationality of the tree diagram edited by the user. For example, the same HDFS is not allowed to rely on two Zookeepers at the same time, and the IPs deployed by the same service in different tree diagrams are not allowed to cross, etc., when the user completes the edit When submitted, the dependency tree diagram will be submitted to the service manager as a task, and the relevant information will be written to the metadata database;
对于现有的已部署并运行中的依赖,可以进行编辑操作,例如配置修改,节点的增删,服务下线甚至整个依赖树删除等,完成编辑后同样作为任务提交给服务管理器。For existing deployed and running dependencies, you can perform editing operations, such as configuration modifications, node additions and deletions, service offline or even deletion of the entire dependency tree, etc. After editing is completed, it is also submitted to the service manager as a task.
S2、将所述依赖关系转换为各服务组件的部署顺序,根据所述部署顺序依次调取服务组件安装文件,并根据待部署服务组件的身份信息和部署地址执行相应安装文件。S2. Convert the dependency relationship into the deployment sequence of each service component, sequentially retrieve the service component installation files according to the deployment sequence, and execute the corresponding installation file according to the identity information and deployment address of the service component to be deployed.
服务管理器维护着所有待部署的大数据组件的安装压缩包,并接收web界面提交的任务请求,将相关的参数进行解析并实施安装部署与启动。过程如下:The service manager maintains the installation compressed packages of all big data components to be deployed, receives task requests submitted by the web interface, parses the relevant parameters, and implements installation, deployment, and startup. The process is as follows:
服务管理器解析提交的依赖树状图,获取服务之间的依赖关系以及各个服务将要部署的IP节点,进而自动生成脚本语言,并将对应的服务安装包解压到对应的物理机的指定目录下;The service manager parses the submitted dependency tree, obtains the dependencies between services and the IP nodes to be deployed for each service, then automatically generates a script language, and decompresses the corresponding service installation package to the specified directory of the corresponding physical machine. ;
当完成各个服务的解压安装之后,根据使用者提供的编辑后的配置模板,生成配置文件并覆盖在对应的安装目录之中;After the decompression and installation of each service is completed, the configuration file is generated according to the edited configuration template provided by the user and overwritten in the corresponding installation directory;
根据依赖树中的依赖关系,管理器通过远程命令按照正确的顺序依次启动各个大数据服务;According to the dependency relationships in the dependency tree, the manager starts each big data service in the correct order through remote commands;
如果提交的任务是对现有依赖树进行修改编辑,服务管理器会对比修改前的依赖树,解析修改的节点和修改内容,生成脚本语言发送远程主机,以正确的依赖顺序对现已部署的服务进行相关操作,例如配置修改,节点增删,服务下架等;若删除整个依赖树,服务管理器同样解析出当前依赖树的线性顺序,并对当前树内所有服务进行一键卸载。If the submitted task is to modify and edit the existing dependency tree, the service manager will compare the dependency tree before the modification, parse the modified nodes and modification content, generate a script language and send it to the remote host, and compare the currently deployed dependencies in the correct dependency order. The service performs related operations, such as configuration modification, node addition and deletion, service removal, etc.; if the entire dependency tree is deleted, the service manager also parses the linear order of the current dependency tree and uninstalls all services in the current tree with one click.
S3、创建分布式监控进程,所述分布式监控进程监控已部署的服务组件的运行信息。S3. Create a distributed monitoring process that monitors the running information of deployed service components.
监控控件是一个轻量的分布式服务,当依赖树状图对应的各个服务节点启动完成后,监控控件会收集这些组件的进程、所在物理节点以及运行状态等信息,并同步到元数据库,当任何一个服务节点发生变化,监控控件均会实时采集信息并进行同步数据。The monitoring control is a lightweight distributed service. When each service node corresponding to the dependency tree diagram is started, the monitoring control will collect information such as the processes, physical nodes where these components are located, and running status, and synchronize them to the metadata database. When any service node changes, the monitoring control will collect information in real time and synchronize the data.
元数据库存储了使用者编辑的树状图信息,任务信息以及各个服务节点的运行状态,web模块通过查询这些信息进行可视化展示,如果使用者对依赖树状图进行改动,会及时同步到元数据库,并产生新的任务提交到服务管理器。The metadatabase stores the user-edited treemap information, task information, and the running status of each service node. The web module queries this information for visual display. If the user makes changes to the dependency treemap, it will be synchronized to the metadatabase in a timely manner. , and generate new tasks to submit to the service manager.
如图2所示,该系统200包括:As shown in Figure 2, the system 200 includes:
树图构建单元210,用于通过浏览器界面编辑依赖树图,所述依赖树图指示待部署服务组件之间的依赖关系和待部署服务组件的身份信息及部署地址;The tree diagram building unit 210 is configured to edit a dependency tree diagram through a browser interface, where the dependency tree diagram indicates the dependency relationship between the service components to be deployed and the identity information and deployment address of the service components to be deployed;
组件部署单元220,用于将所述依赖关系转换为各服务组件的部署顺序,根据所述部署顺序依次调取服务组件安装文件,并根据待部署服务组件的身份信息和部署地址执行相应安装文件;The component deployment unit 220 is used to convert the dependency relationship into the deployment sequence of each service component, sequentially retrieve the service component installation files according to the deployment sequence, and execute the corresponding installation file according to the identity information and deployment address of the service component to be deployed. ;
组件监控单元230,用于创建分布式监控进程,所述分布式监控进程监控已部署的服务组件的运行信息。The component monitoring unit 230 is used to create a distributed monitoring process that monitors the running information of deployed service components.
可选地,作为本发明一个实施例,所述树图构建单元包括:Optionally, as an embodiment of the present invention, the tree diagram building unit includes:
标签准备模块,用于预先设置多种服务组件标签及连接指示标记;Label preparation module, used to pre-set various service component labels and connection indication marks;
对象拖动模块,用于接收用户拖动指令,所述用户拖动指令包括拖动对象和目标点坐标,根据用户拖动指令将拖动对象复制至目标点坐标所在区域,所述拖动对象为服务组件标签或连接指示标记;The object drag module is used to receive user drag instructions, the user drag instructions include the drag object and the target point coordinates, and copy the drag object to the area where the target point coordinates are located according to the user drag instructions, the drag object Labels or connection indicators for service components;
组件配置模块,用于为拖动至目标点坐标的服务组件标签调用默认配置模板,所述默认配置模板包括待配置参数项,向所述待配置参数项输入参数值后将所述默认配置模板保存为所述服务组件标签的配置文件,所述待配置参数项包括身份信息和部署地址;The component configuration module is used to call a default configuration template for the service component label dragged to the target point coordinates. The default configuration template includes a parameter item to be configured. After inputting a parameter value to the parameter item to be configured, the default configuration template is Save the configuration file as the service component label, and the parameter items to be configured include identity information and deployment address;
关系构建模块,用于根据相邻服务组件之间的连接指示标记生成依赖树图中服务组件之间的依赖关系;The relationship building module is used to generate dependency relationships between service components in the dependency tree diagram based on the connection indicator marks between adjacent service components;
合理校验模块,用于根据设定的校验规则校验依赖树图的合理性,所述校验规则包括无环图、一个服务组件依赖的服务组件数量不超过1个、不同依赖树图的同一个服务组件部署地址不交叉。Reasonable verification module, used to verify the rationality of the dependency tree diagram according to the set verification rules. The verification rules include acyclic graphs, the number of service components that a service component depends on does not exceed 1, and different dependency tree diagrams. The deployment addresses of the same service component do not overlap.
可选地,作为本发明一个实施例,所述组件部署单元包括:Optionally, as an embodiment of the present invention, the component deployment unit includes:
树图解析模块,用于解析依赖树图得到服务组件之间的依赖关系和待部署服务组件的身份信息及部署地址,并根据所述依赖关系依次将各服务组件的安装文件分发至各服务组件的部署地址;The tree diagram parsing module is used to parse the dependency tree diagram to obtain the dependency relationships between service components and the identity information and deployment addresses of the service components to be deployed, and distribute the installation files of each service component to each service component in sequence based on the dependency relationships. deployment address;
组件安装模块,用于根据所述依赖关系依次解压安装各服务组件的安装文件,并根据所述依赖关系依次启动各服务组件。The component installation module is used to decompress and install the installation files of each service component in sequence according to the dependency relationship, and to start each service component in sequence according to the dependency relationship.
图3为本发明实施例提供的一种终端300的结构示意图,该终端300可以用于执行本发明实施例提供的大数据服务组件部署方法。FIG. 3 is a schematic structural diagram of a terminal 300 provided by an embodiment of the present invention. The terminal 300 can be used to execute the big data service component deployment method provided by an embodiment of the present invention.
其中,该终端300可以包括:处理器310、存储器320及通信单元330。这些组件通过一条或多条总线进行通信,本领域技术人员可以理解,图中示出的服务器的结构并不构成对本发明的限定,它既可以是总线形结构,也可以是星型结构,还可以包括比图示更多或更少的部件,或者组合某些部件,或者不同的部件布置。The terminal 300 may include: a processor 310, a memory 320, and a communication unit 330. These components communicate through one or more buses. Those skilled in the art can understand that the structure of the server shown in the figure does not limit the invention. It can be a bus structure, a star structure, or More or fewer components may be included than shown, or certain components may be combined, or may be arranged differently.
其中,该存储器320可以用于存储处理器310的执行指令,存储器320可以由任何类型的易失性或非易失性存储终端或者它们的组合实现,如静态随机存取存储器(SRAM),电可擦除可编程只读存储器(EEPROM),可擦除可编程只读存储器(EPROM),可编程只读存储器(PROM),只读存储器(ROM),磁存储器,快闪存储器,磁盘或光盘。当存储器320中的执行指令由处理器310执行时,使得终端300能够执行以下上述方法实施例中的部分或全部步骤。Among them, the memory 320 can be used to store execution instructions of the processor 310. The memory 320 can be implemented by any type of volatile or non-volatile storage terminals or their combination, such as static random access memory (SRAM), electronic 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 disk . When the execution instructions in the memory 320 are executed by the processor 310, the terminal 300 is enabled to perform some or all of the steps in the following method embodiments.
处理器310为存储终端的控制中心,利用各种接口和线路连接整个电子终端的各个部分,通过运行或执行存储在存储器320内的软件程序和/或模块,以及调用存储在存储器内的数据,以执行电子终端的各种功能和/或处理数据。所述处理器可以由集成电路(Integrated Circuit,简称IC)组成,例如可以由单颗封装的IC所组成,也可以由连接多颗相同功能或不同功能的封装IC而组成。举例来说,处理器310可以仅包括中央处理器(Central Processing Unit,简称CPU)。在本发明实施方式中,CPU可以是单运算核心,也可以包括多运算核心。The processor 310 is the control center of the storage terminal, using various interfaces and lines to connect various parts of the entire electronic terminal, by running or executing software programs and/or modules stored in the memory 320, and calling data stored in the memory, To perform various functions of the electronic terminal and/or process data. The processor may be composed of an integrated circuit (IC for short), for example, it may be composed of a single packaged IC, or it may be composed of multiple packaged ICs connected with the same function or different functions. For example, the processor 310 may only include a central processing unit (Central Processing Unit, CPU for short). In the embodiment of the present invention, the CPU may be a single computing core or may include multiple computing cores.
通信单元330,用于建立通信信道,从而使所述存储终端可以与其它终端进行通信。接收其他终端发送的用户数据或者向其他终端发送用户数据。The communication unit 330 is used to establish a communication channel so that the storage terminal can communicate with other terminals. Receive user data sent by other terminals or send user data to other terminals.
本发明还提供一种计算机存储介质,其中,该计算机存储介质可存储有程序,该程序执行时可包括本发明提供的各实施例中的部分或全部步骤。所述的存储介质可为磁碟、光盘、只读存储记忆体(英文:read-only memory,简称:ROM)或随机存储记忆体(英文:random access memory,简称:RAM)等。The present invention also provides a computer storage medium, wherein the computer storage medium can store a program, and when executed, the program can include some or all of the steps in the embodiments provided by the present invention. The storage medium may be a magnetic disk, an optical disk, a read-only memory (ROM) or a random access memory (RAM), etc.
因此,本发明使大数据集群具备多服务部署的管理能力,提供了清晰且直观的服务依赖关系,有效避免了实施过程中,同一个大数据组件多个部署之间的节点冲突;同时修改某个服务的配置、扩展和退服等不再需要逐个节点进行操作,可在界面统一进行,支持一键部署、修改或卸载,大大减少了管理成本,本实施例所能达到的技术效果可以参见上文中的描述,此处不再赘述。Therefore, the present invention enables the big data cluster to have the management capability of multi-service deployment, provides clear and intuitive service dependencies, and effectively avoids node conflicts between multiple deployments of the same big data component during the implementation process; simultaneously modifying certain The configuration, expansion and decommissioning of individual services no longer need to be performed node by node. They can be performed uniformly on the interface, supporting one-click deployment, modification or uninstallation, which greatly reduces management costs. The technical effects achieved by this embodiment can be found in The above description will not be repeated here.
本领域的技术人员可以清楚地了解到本发明实施例中的技术可借助软件加必需的通用硬件平台的方式来实现。基于这样的理解,本发明实施例中的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质中如U盘、移动硬盘、只读存储器(ROM,Read-Only Memory)、随机存取存储器(RAM,Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质,包括若干指令用以使得一台计算机终端(可以是个人计算机,服务器,或者第二终端、网络终端等)执行本发明各个实施例所述方法的全部或部分步骤。Those skilled in the art can clearly understand that the technology in the embodiments of the present invention can be implemented by means of software plus the necessary general hardware platform. Based on this understanding, the technical solutions in the embodiments of the present invention can be embodied in the form of software products in essence or in part that contribute to the existing technology. The computer software products are stored in a storage medium such as a USB flash drive, mobile phone, etc. Hard disk, read-only memory (ROM, Read-Only Memory), random access memory (RAM, Random Access Memory), magnetic disk or optical disk and other media that can store program code, including a number of instructions to make a computer terminal (It can be a personal computer, a server, a second terminal, a network terminal, etc.) to perform all or part of the steps of the methods described in various embodiments of the present invention.
本说明书中各个实施例之间相同相似的部分互相参见即可。尤其,对于终端实施例而言,由于其基本相似于方法实施例,所以描述的比较简单,相关之处参见方法实施例中的说明即可。The same and similar parts among the various embodiments in this specification can be referred to each other. In particular, for the terminal embodiment, since it is basically similar to the method embodiment, the description is relatively simple. For relevant details, please refer to the description in the method embodiment.
在本发明所提供的几个实施例中,应该理解到,所揭露的系统和方法,可以通过其它的方式实现。例如,以上所描述的系统实施例仅仅是示意性的,例如,所述单元的划分,仅仅为一种逻辑功能划分,实际实现时可以有另外的划分方式,例如多个单元或组件可以结合或者可以集成到另一个系统,或一些特征可以忽略,或不执行。另一点,所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口,系统或单元的间接耦合或通信连接,可以是电性,机械或其它的形式。In the several embodiments provided by the present invention, it should be understood that the disclosed systems and methods can be implemented in other ways. For example, the system embodiments described above are only illustrative. For example, the division of the units is only a logical function division. In actual implementation, there may be other division methods. For example, multiple units or components may be combined or can be integrated into another system, or some features can be ignored, or not implemented. On the other hand, the coupling or direct coupling or communication connection between each other shown or discussed may be through some interfaces, indirect coupling or communication connection of the system or unit, which may be in electrical, mechanical or other forms.
所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。The units described as separate components may or may not be physically separated, and the components shown as units may or may not be physical units, that is, they may be located in one place, or they may be distributed to multiple network units. Some or all of the units can be selected according to actual needs to achieve the purpose of the solution of this embodiment.
另外,在本发明各个实施例中的各功能单元可以集成在一个处理单元中,也可以是各个单元单独物理存在,也可以两个或两个以上单元集成在一个单元中。In addition, each functional unit in various embodiments of the present invention can be integrated into one processing unit, or each unit can exist physically alone, or two or more units can be integrated into one unit.
尽管通过参考附图并结合优选实施例的方式对本发明进行了详细描述,但本发明并不限于此。在不脱离本发明的精神和实质的前提下,本领域普通技术人员可以对本发明的实施例进行各种等效的修改或替换,而这些修改或替换都应在本发明的涵盖范围内/任何熟悉本技术领域的技术人员在本发明揭露的技术范围内,可轻易想到变化或替换,都应涵盖在本发明的保护范围之内。因此,本发明的保护范围应所述以权利要求的保护范围为准。Although the present invention has been described in detail with reference to the accompanying drawings in conjunction with preferred embodiments, the present invention is not limited thereto. Without departing from the spirit and essence of the present invention, those of ordinary skill in the art can make various equivalent modifications or substitutions to the embodiments of the present invention, and these modifications or substitutions should be within the scope/any scope of the present invention. Those skilled in the art can easily think of changes or substitutions within the technical scope disclosed in the present invention, and they should all be covered by the protection scope of the present invention. Therefore, the protection scope of the present invention should be determined by the protection scope of the claims.
Claims (6)
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202210068720.6A CN114443294B (en) | 2022-01-20 | 2022-01-20 | Big data service component deployment method, system, terminal and storage medium |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202210068720.6A CN114443294B (en) | 2022-01-20 | 2022-01-20 | Big data service component deployment method, system, terminal and storage medium |
Publications (2)
Publication Number | Publication Date |
---|---|
CN114443294A CN114443294A (en) | 2022-05-06 |
CN114443294B true CN114443294B (en) | 2023-11-07 |
Family
ID=81368019
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202210068720.6A Active CN114443294B (en) | 2022-01-20 | 2022-01-20 | Big data service component deployment method, system, terminal and storage medium |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN114443294B (en) |
Families Citing this family (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
WO2024011627A1 (en) * | 2022-07-15 | 2024-01-18 | 京东方科技集团股份有限公司 | Method for deploying big data cluster and data processing method based on big data cluster |
CN115914341B (en) * | 2022-09-28 | 2024-11-29 | 中银金融科技有限公司 | Cluster deployment method and device for monitoring system |
CN119441001A (en) * | 2023-08-02 | 2025-02-14 | 中兴通讯股份有限公司 | Abnormal dependency detection method, device and storage medium |
Citations (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN1601510A (en) * | 2003-03-06 | 2005-03-30 | 微软公司 | Architecture for distributed computing system and automated design, deployment, and management of distributed applications |
CN101739254A (en) * | 2009-12-31 | 2010-06-16 | 山东中创软件商用中间件股份有限公司 | Method and device for realizing multiplexing of multi-platform communication assemblies |
-
2022
- 2022-01-20 CN CN202210068720.6A patent/CN114443294B/en active Active
Patent Citations (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN1601510A (en) * | 2003-03-06 | 2005-03-30 | 微软公司 | Architecture for distributed computing system and automated design, deployment, and management of distributed applications |
CN101739254A (en) * | 2009-12-31 | 2010-06-16 | 山东中创软件商用中间件股份有限公司 | Method and device for realizing multiplexing of multi-platform communication assemblies |
Also Published As
Publication number | Publication date |
---|---|
CN114443294A (en) | 2022-05-06 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN114443294B (en) | Big data service component deployment method, system, terminal and storage medium | |
CN115292026B (en) | Management method, device and equipment of container cluster and computer readable storage medium | |
EP3387528B1 (en) | Updating dependent services | |
US11144292B2 (en) | Packaging support system and packaging support method | |
CN111857777B (en) | System updating method and device based on double-core intelligent ammeter and computer equipment | |
CN111752581A (en) | Distributed system upgrading method and device and computer system | |
CN110784347A (en) | Node management method, system, equipment and storage medium for container cluster | |
CN114546588A (en) | Task deployment method, device, storage medium, and electronic device | |
CN113326052B (en) | Business component upgrade method, device, computer equipment and storage medium | |
CN113806309A (en) | Metadata deleting method, system, terminal and storage medium based on distributed lock | |
US7240348B2 (en) | Suspending scenario generation method, server device, and program therefor | |
CN111767126A (en) | System and method for distributed batch processing | |
CN110019059B (en) | Timing synchronization method and device | |
CN116578497A (en) | Automatic interface testing method, system, computer equipment and storage medium | |
CN115277398A (en) | Cluster network configuration method and device | |
CN114640687A (en) | A software upgrade method, device, storage medium and electronic device | |
CN113449035A (en) | Data synchronization method and device, computer equipment and readable storage medium | |
JP2010224812A (en) | Job management system and method | |
US20150046414A1 (en) | Computer product, managing apparatus, and managing method | |
CN116893834B (en) | Load update method, device, system, electronic equipment and readable storage medium | |
CN113055500B (en) | Address request method, device and computer readable storage medium | |
CN117170916B (en) | Fault analysis method, device, equipment and storage medium | |
CN114327654B (en) | USB device management method and system based on cloud platform | |
CN117407049B (en) | Application release arrangement method, device, equipment and storage medium | |
CN117873602A (en) | Management method, device, equipment and storage medium of distributed computing framework |
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 |