[go: up one dir, main page]

WO2021013056A1 - Microservice-based data processing method and apparatus, and device and readable storage medium - Google Patents

Microservice-based data processing method and apparatus, and device and readable storage medium Download PDF

Info

Publication number
WO2021013056A1
WO2021013056A1 PCT/CN2020/102537 CN2020102537W WO2021013056A1 WO 2021013056 A1 WO2021013056 A1 WO 2021013056A1 CN 2020102537 W CN2020102537 W CN 2020102537W WO 2021013056 A1 WO2021013056 A1 WO 2021013056A1
Authority
WO
WIPO (PCT)
Prior art keywords
code execution
request instruction
available engine
execution request
data processing
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.)
Ceased
Application number
PCT/CN2020/102537
Other languages
French (fr)
Chinese (zh)
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.)
WeBank Co Ltd
Original Assignee
WeBank Co 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 WeBank Co Ltd filed Critical WeBank Co Ltd
Publication of WO2021013056A1 publication Critical patent/WO2021013056A1/en
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; 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/44Arrangements for executing specific programs
    • G06F9/448Execution paradigms, e.g. implementations of programming paradigms
    • G06F9/4482Procedural
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; 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/52Program synchronisation; Mutual exclusion, e.g. by means of semaphores

Definitions

  • This application relates to the technical field of financial technology (Fintech), and in particular to a data processing method, device, device and readable storage medium based on microservices.
  • the main purpose of this application is to provide a data processing method, device, device, and readable storage medium based on microservices, which are intended to solve the lack of the ability to simultaneously connect multiple sources in the prior art because open source products can only target certain execution services
  • the unified execution service of these products reduces the technical problem of data processing efficiency.
  • an embodiment of the present application provides a microservice-based data processing method, and the microservice-based data processing method includes:
  • the target function component to which the code execution request instruction is directed is determined based on a preset middleware, wherein the preset middleware connects each function based on the microservice
  • the component steps include:
  • the preset middleware connects various functional components based on microservices, and each functional component includes various microservice interfaces, and each microservice interface is distributed on various platforms and matches the code execution request type One-way functional interface.
  • the step of obtaining code execution result data pointed to by the code execution request instruction based on the target functional component includes:
  • the code execution request instruction is sent to the available engine to obtain code execution result data fed back by the available engine.
  • the method further includes:
  • the code execution request instruction is sent to the new available engine to obtain code execution result data fed back by the new available engine.
  • the step of generating a new available engine includes:
  • the target engine manager is determined through the preset resource manager, so as to apply for the corresponding new available engine in the target engine manager for the code execution request instruction.
  • the step of sending the code execution request instruction to the available engine to obtain the code execution result data fed back by the available engine further includes:
  • the step includes:
  • the present application also provides a data processing device based on microservices, the data processing device based on microservices includes:
  • the detection module is configured to determine the target functional component to which the code execution request instruction points based on a preset middleware when the code execution request instruction is detected, wherein the preset middleware connects each functional component based on the microservice;
  • the obtaining module is configured to obtain the code execution result data pointed to by the code execution request instruction based on the target functional component.
  • the detection module includes:
  • the first obtaining unit is configured to obtain the type of the code execution request instruction when the code execution request instruction is detected;
  • the first determining unit is configured to determine the target functional component to which the code execution request instruction points based on the preset middleware and the type of the code execution request instruction;
  • the preset middleware connects various functional components based on microservices, and each functional component includes various microservice interfaces, and each microservice interface is distributed on various platforms and matches the code execution request type One-way functional interface.
  • the acquisition module includes:
  • the second determining unit is configured to determine whether there is an available engine based on the target function component
  • the second obtaining unit is configured to send the code execution request instruction to the available engine if it is determined that there is an available engine, so as to obtain code execution result data fed back by the available engine.
  • the acquisition module includes:
  • the generating unit is used to generate a new available engine if it is determined that there is no available engine;
  • the third obtaining unit is configured to send the code execution request instruction to the new available engine to obtain code execution result data fed back by the new available engine.
  • the generating unit includes:
  • the application subunit is used to determine the target engine manager through the preset resource manager if it is determined that there is no available engine, so as to apply for the corresponding new available engine in the target engine manager for the code execution request instruction.
  • the second acquiring unit includes:
  • the acquiring subunit is configured to send the code execution request instruction to the available engine if it is determined that there is an available engine, and perform lock processing on the available engine to obtain code execution result data fed back by the available engine ;
  • the unlocking subunit is configured to perform unlock processing on the available engine in the lock processing after acquiring the code execution result data fed back by the available engine.
  • the microservice-based data processing device includes:
  • the generating module is used to release the available engine and generate a prompt message indicating that the code execution result data has been obtained.
  • the present application also provides a readable storage medium having a microservice-based data processing program stored on the readable storage medium, and the microservice-based data processing program, when executed by a processor, realizes the microservice-based The steps of the data processing method.
  • the target function component to which the code execution request instruction points is determined based on a preset middleware, wherein the preset middleware connects each function component based on the microservice; based on the target
  • the functional component obtains the code execution result data pointed to by the code execution request instruction.
  • the preset middleware due to the existence of preset middleware, and the preset middleware connects various functional components based on microservices, the preset middleware based on various functional components of microservices can realize simultaneous docking of multiple types
  • the unified execution service of the product is not just for a certain execution service, so it can directly avoid the problems of multiple external entrances, inconsistencies, unclear call relationships and hierarchical structures in open source products, and achieve the technical effect of improving data processing efficiency.
  • FIG. 1 is a schematic flowchart of a first embodiment of a microservice-based data processing method according to this application;
  • Figure 2 is the second embodiment of the microservice-based data processing method of this application, when a code execution request instruction is detected, the target functional component to which the code execution request instruction points is determined based on a preset middleware, wherein the preset The middleware connection is based on the detailed flow diagram of each functional component step of the microservice;
  • FIG. 3 is a schematic diagram of the device structure of the hardware operating environment involved in the method of the embodiment of the present application.
  • the data processing method based on microservices includes:
  • Step S10 when the code execution request instruction is detected, determine the target functional component pointed to by the code execution request instruction based on a preset middleware, wherein the preset middleware connects each functional component based on the microservice;
  • Step S20 based on the target functional component, obtain the code execution result data pointed to by the code execution request instruction.
  • Step S10 when the code execution request instruction is detected, determine the target functional component pointed to by the code execution request instruction based on a preset middleware, wherein the preset middleware connects each functional component based on the microservice;
  • the data processing method based on microservices is applied to a data processing system based on microservices.
  • Microservices are based on a single function of microservices that implement data processing functions. Due to the existence of preset middleware, the data processing system can be connected to multiple external business systems. The multiple external business systems may involve loan business systems and insurance business systems, etc.
  • the microservice-based data processing system can be connected to multiple external business systems. In addition to a business system, it is also based on the existence of preset middleware to interface with upper-level data processing tools such as an integrated development environment IDE platform.
  • the integrated development environment IDE platform contains business codes written in various languages.
  • the data processing system based on microservices can responsible for the background analysis and execution of the business code of the integrated development environment IDE platform, that is, the data processing system based on microservices can realize the functions of execution.
  • the data processing system based on microservices can also solve the calculation, storage, resource management, and authority control. , Data integration, metadata management, visualization of workflow development results and other functions, and can provide massive data offline processing, data modeling, ad hoc query analysis, data mining and other functions.
  • the target functional component to which the code execution request instruction is pointed is determined based on the preset middleware.
  • the code execution request instruction may be sent by the API interface of multiple external business systems, and the code execution request instruction may be sent by the API interface of multiple external business systems. After the code execution request instruction sent by the API interface of multiple business systems, the microservice-based data processing system processes the code execution request instruction.
  • the code execution request instruction can be an execution request instruction type or a data acquisition request instruction type, etc.
  • the execution request instruction type refers to the business code type in the IDE platform of the integrated development environment
  • the data acquisition request instruction type refers to data query requests from multiple external business systems
  • the code execution request instruction is determined based on the preset middleware
  • the target function component that is pointed to wherein the preset middleware connects each function component based on microservices, that is, the middleware of the data processing system based on microservices can decouple and call specific functions for each specific business or
  • the code execution environment is correspondingly developed with a microservice interface, and furthermore, various functions are realized.
  • the target function component to which the code execution request instruction is pointed is determined based on a preset middleware, wherein the preset middleware connects each function component based on the microservice.
  • Step S11 when the code execution request instruction is detected, obtain the type of the code execution request instruction
  • the type of the code execution request instruction is acquired, specifically, whether the code execution request instruction is an execution request instruction type or a data acquisition request instruction type, or more specifically To obtain the specific environment execution request command type or the specific data acquisition request command type of the code execution request instruction.
  • Step S12 Determine the target functional component to which the code execution request instruction points based on the preset middleware and the type of the code execution request instruction;
  • the target functional component pointed to by the code execution request instruction based on the preset middleware and the type of the code execution request instruction. For example, if the type of the code execution request instruction is the data acquisition request instruction type, based on the preset middleware And the type of the code execution request instruction determines that the target functional component pointed to by the code execution request instruction is the first category of target functional component, and if the type of the code execution request instruction is the execution request instruction type, it is based on a preset middleware And the type of the code execution request instruction determines that the target functional component pointed to by the code execution request instruction is the second major type of target functional component, if the type of the code execution request instruction is the data query subtype in the data acquisition request instruction type At this time, based on the preset middleware and the data query subtype, it is determined that the target functional component pointed to by the code execution request instruction is the query sub-category functional component in the first major category of target functional components.
  • the preset middleware connects various functional components based on microservices, and each functional component includes various microservice interfaces, and each microservice interface is distributed on various platforms and matches the code execution request type One-way functional interface.
  • microservice interfaces are correspondingly set in the microservice-based data processing system, and the multiple microservice interfaces correspond to specific business functions or
  • the specific code execution environment has a one-to-one mapping relationship, that is, the specific business function is different, the microservice interface is different, the specific code execution environment is different, the microservice interface is different, and the microservice interface is essentially a set of preset standards
  • a single function can perform business data query or To execute a certain type of code, etc.
  • the same business or the same code execution environment is synchronized on multiple platforms, for the same business or execution environment, there are different platforms corresponding to or docking with different platforms The same function of the microservice interface.
  • microservice interfaces corresponding to different platforms or the same function on different platforms to manage the same business or on different platforms.
  • the microservice interfaces of the same function of the same code execution environment are described in specific embodiments.
  • various microservice interfaces with different functions are set up for the development of Q loan business.
  • the function of the interface is to query the application status of the B loan business based on the insurance policy number, and the Q loan business is available on platforms such as q1 and q2.
  • the Platforms such as q1 and q2 have different micro-service interfaces for querying the status of Q loan business applications based on policy numbers
  • functional components are the functional components that manage different micro-service interfaces for querying the status of Q loan business applications based on insurance policy numbers on different platforms.
  • Step S20 based on the target functional component, obtain the code execution result data pointed to by the code execution request instruction.
  • the service interface can obtain the code execution result data pointed to by the code execution request instruction, where the code execution result data includes code execution progress, code execution status, code execution log, or business acquisition data.
  • the target function component to which the code execution request instruction points is determined based on a preset middleware, wherein the preset middleware connects each function component based on the microservice; based on the target
  • the functional component obtains the code execution result data pointed to by the code execution request instruction.
  • the preset middleware due to the existence of preset middleware, and the preset middleware connects various functional components based on microservices, the preset middleware based on various functional components of microservices can realize simultaneous docking of multiple types
  • the unified execution service of the product is not just for a certain execution service, so it can directly avoid the problems of multiple external entrances in open source products, inconsistency, unclear calling relationships and unclear hierarchical structure, and achieve the technical effect of improving data processing efficiency. That is, it solves the technical problem in the prior art that the open source product can only be targeted for a certain execution service but lacks a unified execution service that can connect multiple products at the same time, which reduces the data processing efficiency.
  • the present application provides another embodiment of a data processing method based on microservices.
  • the step of obtaining the code execution result data pointed to by the code execution request instruction based on the target functional component includes:
  • Step S21 Determine whether there is an available engine based on the target function component
  • the target function component communicates with each platform through the microservice interface.
  • Step S22 If it is determined that there is an available engine, the code execution request instruction is sent to the available engine to obtain code execution result data fed back by the available engine.
  • the code execution request instruction is sent to the available engine through each microservice interface in each functional component connected with the preset middleware to Obtain code execution result data fed back by the available engine.
  • the method further includes:
  • Step S23 if it is determined that there is no available engine, a new available engine is generated
  • the step of generating a new available engine includes:
  • step S231 if it is determined that there is no available engine, the target engine manager is determined through the preset resource manager, so as to apply for the corresponding new available engine in the target engine manager for the code execution request instruction.
  • the preset resource manager uniformly sets authority information for each user or tenant. It is no longer necessary for users to repeatedly configure defined environment variables in each system and upload dependent material files. , Custom functions, application for resources, etc. It should be noted that the preset resource manager also sets a unified resource management service for each user, that is, each tenant.
  • the target engine manager is determined through the preset resource manager associated with each platform, so as to apply for the corresponding new available engine manager in the target engine manager for the code execution request instruction. engine. Specifically, by requesting new resources corresponding to the code execution request instruction from the preset resource manager associated with each platform, first obtain the user information carried in the request code execution request instruction corresponding to the current tenant isolation in the preset resource manager State, determine the engine manager corresponding to the user information from the preset resource manager, and after the engine manager corresponding to the user information is determined, the target data type carried in the request code execution request instruction is also obtained, and from the target data type according to the target data type The target engine manager is selected from the engine manager corresponding to the user information, that is, the target engine manager applies for a corresponding new available engine in the target engine manager according to the code execution request instruction.
  • Step S24 Send the code execution request instruction to the new available engine to obtain code execution result data fed back by the new available engine.
  • this application provides another embodiment of a data processing method based on microservices.
  • the code execution request instruction is sent to the available engine to obtain all available engines.
  • the code execution result data step that can be fed back by the engine also includes:
  • Step S25 if it is determined that there is an available engine, send the code execution request instruction to the available engine, and perform lock processing on the available engine to obtain code execution result data fed back by the available engine;
  • the code execution request instruction is sent to the available engine, and the available engine is locked to make the available engine available.
  • the engine processes the code execution request instructions on a full-time basis to avoid processing confusion caused by one usable engine processing multiple code execution request instructions at the same time, so as to obtain code execution result data fed back by the usable engine.
  • Step S26 After obtaining the code execution result data fed back by the available engine, perform unlock processing on the available engine of the lock processing.
  • the code execution request instruction is sent to the available engine, and the available engine is locked, so as to obtain the code execution result fed back by the available engine Data; after obtaining the code execution result data fed back by the available engine, unlock the available engine for the lock processing.
  • the fault tolerance of the code execution request instruction is improved.
  • this application provides another embodiment of a data processing method based on microservices.
  • the step of obtaining the code execution result data pointed to by the code execution request instruction based on the target function component includes:
  • Step S40 Perform release processing on the available engine, and generate a prompt message indicating that the code execution result data has been acquired.
  • the available engine is released, and a prompt message that the code execution result data has been obtained is generated for the user to promptly The code execution result data is obtained to improve user experience.
  • FIG. 3 is a schematic diagram of the device structure of the hardware operating environment involved in the solution of the embodiment of the present application.
  • the data processing device based on microservices in the embodiment of the present application may be a PC, or a terminal device such as a smart phone, a tablet computer, or a portable computer.
  • the microservice-based data processing device may include: a processor 1001, such as a CPU, a memory 1005, and a communication bus 1002.
  • the communication bus 1002 is used to implement connection and communication between the processor 1001 and the memory 1005.
  • the memory 1005 can be a high-speed RAM memory or a stable memory (non-volatile memory), such as disk storage.
  • the memory 1005 may also be a storage device independent of the foregoing processor 1001.
  • the microservice-based data processing device may also include a target user interface, a network interface, a camera, and RF (Radio Frequency (radio frequency) circuits, sensors, audio circuits, WiFi modules, etc.
  • the target user interface may include a display screen (Display) and an input unit such as a keyboard (Keyboard), and the optional target user interface may also include a standard wired interface and a wireless interface.
  • the optional network interface can include standard wired interface and wireless interface (such as WI-FI interface).
  • FIG. 3 does not constitute a limitation on the data processing device based on microservices, and may include more or less components than shown in the figure, or a combination Certain components, or different component arrangements.
  • the memory 1005 as a computer storage medium may include an operating system, a network communication module, and a data processing program based on microservices.
  • the operating system is a program that manages and controls the hardware and software resources of microservice-based data processing equipment, and supports the operation of microservice-based data processing programs and other software and/or programs.
  • the network communication module is used to implement communication between various components in the memory 1005, as well as communication with other hardware and software in the microservice-based data processing device.
  • the processor 1001 is configured to execute the microservice-based data processing program stored in the memory 1005 to implement the microservice-based data processing method described in any one of the above step.
  • microservice-based data processing device of this application is basically the same as the foregoing embodiments of the microservice-based data processing method, and will not be repeated here.
  • an embodiment of the present application also proposes a data processing device based on microservices, and the data processing device based on microservices includes:
  • the detection module is configured to determine the target functional component to which the code execution request instruction points based on a preset middleware when the code execution request instruction is detected, wherein the preset middleware connects each functional component based on the microservice;
  • the obtaining module is configured to obtain the code execution result data pointed to by the code execution request instruction based on the target functional component.
  • the detection module includes:
  • the first acquiring unit is configured to acquire the type of the code execution request instruction when the code execution request instruction is detected;
  • the first determining unit is configured to determine the target functional component to which the code execution request instruction points based on the preset middleware and the type of the code execution request instruction;
  • the preset middleware connects various functional components based on microservices, and each functional component includes various microservice interfaces, and each microservice interface is distributed on various platforms and matches the code execution request type One-way functional interface.
  • the acquisition module includes:
  • the second determining unit is configured to determine whether there is an available engine based on the target function component
  • the second obtaining unit is configured to send the code execution request instruction to the available engine if it is determined that there is an available engine, so as to obtain the code execution result data fed back by the available engine.
  • the acquisition module includes:
  • the generating unit is used to generate a new available engine if it is determined that there is no available engine;
  • the third obtaining unit is configured to send the code execution request instruction to the new available engine to obtain code execution result data fed back by the new available engine.
  • the generating unit includes:
  • the application subunit is used to determine the target engine manager through the preset resource manager if it is determined that there is no available engine, so as to apply for the corresponding new available engine in the target engine manager for the code execution request instruction.
  • the second acquiring unit includes:
  • the acquiring subunit is configured to send the code execution request instruction to the available engine if it is determined that there is an available engine, and perform lock processing on the available engine to obtain code execution result data fed back by the available engine ;
  • the unlocking subunit is configured to perform unlock processing on the available engine in the lock processing after acquiring the code execution result data fed back by the available engine.
  • the microservice-based data processing device includes:
  • the generating module is used to release the available engine and generate a prompt message indicating that the code execution result data has been obtained.
  • microservice-based data processing apparatus of the present application is basically the same as the foregoing embodiments of the microservice-based data processing method, and will not be repeated here.
  • an embodiment of the present application also proposes a data processing device based on microservices.
  • the device includes: a memory 109, a processor 110, and a microservice-based data processing program stored in the memory 109 and running on the processor 110, When the microservice-based data processing program is executed by the processor 110, the steps of the foregoing microservice-based data processing method embodiments are implemented.
  • this application also provides a computer-readable storage medium that stores one or more programs, and the one or more programs can also be executed by one or more processors for use To implement the steps of each embodiment of the above-mentioned microservice-based data processing method.
  • the expanded content of the specific implementation of the device and the readable storage medium of the application is basically the same as the above embodiments of the microservice-based data processing method, and will not be repeated here.
  • the method of the above embodiments can be implemented by means of software plus the necessary general hardware platform. Of course, it can also be implemented by hardware, but in many cases the former is better. ⁇
  • the technical solution of this application essentially or the part that contributes to the existing technology can be embodied in the form of a software product, and the computer software product is stored in a storage medium (such as ROM/RAM, magnetic disk, The optical disc) includes several instructions to make a terminal (which may be a mobile phone, a computer, a server, an air conditioner, or a network device, etc.) execute the methods described in the various embodiments of the present application.

Landscapes

  • Engineering & Computer Science (AREA)
  • Software Systems (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Stored Programmes (AREA)

Abstract

The present application relates to the technical field of Fintech. Disclosed are a microservice-based data processing method and apparatus, and a device and a readable storage medium. The method comprises: upon detecting a code execution request instruction, on the basis of preset middleware, determining a target functional component to which the code execution request instruction points, wherein the preset middleware connects microservice-based functional components; and on the basis of the target functional component, obtaining code execution result data to which the code execution request instruction points.

Description

基于微服务的数据处理方法、装置、设备及可读存储介质Microservice-based data processing method, device, equipment and readable storage medium

本申请要求于2019年7月19日申请的、申请号为201910656797.3、名称为“基于微服务的数据处理方法、装置、设备及可读存储介质”的中国专利申请的优先权,其全部内容通过引用结合在本申请中。This application claims the priority of the Chinese patent application filed on July 19, 2019, the application number is 201910656797.3, and the name is "microservice-based data processing methods, devices, equipment, and readable storage media", all of which are passed The reference is incorporated in this application.

技术领域Technical field

本申请涉及金融科技(Fintech)技术领域,尤其涉及一种基于微服务的数据处理方法、装置、设备及可读存储介质。This application relates to the technical field of financial technology (Fintech), and in particular to a data processing method, device, device and readable storage medium based on microservices.

背景技术Background technique

随着金融科技(Fintech),尤其是互联网科技金融的不断发展,越来越多的技术应用在金融领域。其中,金融领域中的数据处理过程涉及众多技术应用,然而目前,由于目前开源产品中对外入口多,不统一,调用关系和层次结构不清晰等,大都只能针对某种执行服务而缺乏能够同时对接多种产品的统一执行服务,直接影响业务产品的数据处理效率,这降低了数据处理效率。With the continuous development of Fintech, especially Internet technology finance, more and more technologies are applied in the financial field. Among them, the data processing process in the financial field involves many technical applications. However, at present, due to the large number of external entrances in the current open source products, inconsistencies, unclear calling relationships and hierarchical structures, etc., most of them can only be targeted for a certain execution service and lack the ability to simultaneously The unified execution service of docking multiple products directly affects the data processing efficiency of business products, which reduces the data processing efficiency.

技术解决方案Technical solutions

本申请的主要目的在于提供一种基于微服务的数据处理方法、装置、设备及可读存储介质,旨在解决现有技术中由于开源产品中只能针对某种执行服务而缺乏能够同时对接多种产品的统一执行服务,降低了数据处理效率的技术问题。The main purpose of this application is to provide a data processing method, device, device, and readable storage medium based on microservices, which are intended to solve the lack of the ability to simultaneously connect multiple sources in the prior art because open source products can only target certain execution services The unified execution service of these products reduces the technical problem of data processing efficiency.

为实现上述目的,本申请实施例提供一种基于微服务的数据处理方法,所述基于微服务的数据处理方法包括:To achieve the foregoing objective, an embodiment of the present application provides a microservice-based data processing method, and the microservice-based data processing method includes:

在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件;When the code execution request instruction is detected, determine the target functional component to which the code execution request instruction points based on a preset middleware, where the preset middleware connects each functional component based on the microservice;

基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据。Based on the target functional component, obtain the code execution result data pointed to by the code execution request instruction.

在一实施例中,所述在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件步骤包括:In an embodiment, when the code execution request instruction is detected, the target function component to which the code execution request instruction is directed is determined based on a preset middleware, wherein the preset middleware connects each function based on the microservice The component steps include:

在检测到代码执行请求指令时,获取所述代码执行请求指令的类型;When the code execution request instruction is detected, acquiring the type of the code execution request instruction;

基于预设中间件以及所述代码执行请求指令的类型确定所述代码执行请求指令指向的目标功能组件;Determining the target functional component to which the code execution request instruction points based on the preset middleware and the type of the code execution request instruction;

其中,所述预设中间件连接基于微服务的各个功能组件,所述各个功能组件包括各个微服务接口,所述各个微服务接口是分布在各个平台上的与所述代码执行请求类型匹配的单向功能接口。Wherein, the preset middleware connects various functional components based on microservices, and each functional component includes various microservice interfaces, and each microservice interface is distributed on various platforms and matches the code execution request type One-way functional interface.

在一实施例中,所述基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据步骤包括:In an embodiment, the step of obtaining code execution result data pointed to by the code execution request instruction based on the target functional component includes:

基于所述目标功能组件,确定是否存在可用引擎;Based on the target functional component, determine whether there is an available engine;

若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据。If it is determined that there is an available engine, the code execution request instruction is sent to the available engine to obtain code execution result data fed back by the available engine.

在一实施例中,所述基于所述目标功能组件,确定是否存在可用引擎步骤之后还包括:In an embodiment, after the step of determining whether there is an available engine based on the target functional component, the method further includes:

若确定未存在可用引擎时,生成新的可用引擎;If it is determined that there is no available engine, a new available engine is generated;

将所述代码执行请求指令发送给所述新的可用引擎,以获取所述新的可用引擎反馈的代码执行结果数据。The code execution request instruction is sent to the new available engine to obtain code execution result data fed back by the new available engine.

在一实施例中,所述若确定未存在可用引擎时,生成新的可用引擎步骤包括:In an embodiment, if it is determined that there is no available engine, the step of generating a new available engine includes:

若确定未存在可用引擎时,通过预设资源管理器确定目标引擎管理器,以为所述代码执行请求指令在目标引擎管理器中申请对应的新的可用引擎。If it is determined that there is no available engine, the target engine manager is determined through the preset resource manager, so as to apply for the corresponding new available engine in the target engine manager for the code execution request instruction.

在一实施例中,所述若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据步骤还包括:In an embodiment, if it is determined that there is an available engine, the step of sending the code execution request instruction to the available engine to obtain the code execution result data fed back by the available engine further includes:

若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,并对所述可用引擎进行加锁处理,以获取所述可用引擎反馈的代码执行结果数据;If it is determined that there is an available engine, send the code execution request instruction to the available engine, and lock the available engine to obtain the code execution result data fed back by the available engine;

在获取所述可用引擎反馈的代码执行结果数据后,对所述加锁处理的所述可用引擎进行解锁处理。After obtaining the code execution result data fed back by the available engine, unlock the available engine for the lock processing.

在一实施例中,所述基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据步骤之后包括:In an embodiment, after the step of obtaining the code execution result data pointed to by the code execution request instruction based on the target functional component, the step includes:

对所述可用引擎进行释放处理,并生成已获取到所述代码执行结果数据的提示信息。Perform release processing on the available engine, and generate a prompt message that the code execution result data has been obtained.

根据所述待多发主题信息的多发标识对所述待多发主题信息进行去重处理。Perform de-duplication processing on the subject information to be multiplexed according to the multiple identity of the subject information to be multiplexed.

本申请还提供一种基于微服务的数据处理装置,所述基于微服务的数据处理装置包括:The present application also provides a data processing device based on microservices, the data processing device based on microservices includes:

检测模块,用于在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件;The detection module is configured to determine the target functional component to which the code execution request instruction points based on a preset middleware when the code execution request instruction is detected, wherein the preset middleware connects each functional component based on the microservice;

获取模块,用于基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据。The obtaining module is configured to obtain the code execution result data pointed to by the code execution request instruction based on the target functional component.

在一实施例中,所述检测模块包括:In an embodiment, the detection module includes:

第一获取单元,用于在检测到代码执行请求指令时,获取所述代码执行请求指令的类型;The first obtaining unit is configured to obtain the type of the code execution request instruction when the code execution request instruction is detected;

第一确定单元,用于基于预设中间件以及所述代码执行请求指令的类型确定所述代码执行请求指令指向的目标功能组件;The first determining unit is configured to determine the target functional component to which the code execution request instruction points based on the preset middleware and the type of the code execution request instruction;

其中,所述预设中间件连接基于微服务的各个功能组件,所述各个功能组件包括各个微服务接口,所述各个微服务接口是分布在各个平台上的与所述代码执行请求类型匹配的单向功能接口。Wherein, the preset middleware connects various functional components based on microservices, and each functional component includes various microservice interfaces, and each microservice interface is distributed on various platforms and matches the code execution request type One-way functional interface.

在一实施例中,所述获取模块包括:In an embodiment, the acquisition module includes:

第二确定单元,用于基于所述目标功能组件,确定是否存在可用引擎;The second determining unit is configured to determine whether there is an available engine based on the target function component;

第二获取单元,用于若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据。The second obtaining unit is configured to send the code execution request instruction to the available engine if it is determined that there is an available engine, so as to obtain code execution result data fed back by the available engine.

在一实施例中,所述获取模块包括:In an embodiment, the acquisition module includes:

生成单元,用于若确定未存在可用引擎时,生成新的可用引擎;The generating unit is used to generate a new available engine if it is determined that there is no available engine;

第三获取单元,用于将所述代码执行请求指令发送给所述新的可用引擎,以获取所述新的可用引擎反馈的代码执行结果数据。The third obtaining unit is configured to send the code execution request instruction to the new available engine to obtain code execution result data fed back by the new available engine.

在一实施例中,所述生成单元包括:In an embodiment, the generating unit includes:

申请子单元,用于若确定未存在可用引擎时,通过预设资源管理器确定目标引擎管理器,以为所述代码执行请求指令在目标引擎管理器中申请对应的新的可用引擎。The application subunit is used to determine the target engine manager through the preset resource manager if it is determined that there is no available engine, so as to apply for the corresponding new available engine in the target engine manager for the code execution request instruction.

在一实施例中,所述第二获取单元包括:In an embodiment, the second acquiring unit includes:

获取子单元,用于若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,并对所述可用引擎进行加锁处理,以获取所述可用引擎反馈的代码执行结果数据;The acquiring subunit is configured to send the code execution request instruction to the available engine if it is determined that there is an available engine, and perform lock processing on the available engine to obtain code execution result data fed back by the available engine ;

解锁子单元,用于在获取所述可用引擎反馈的代码执行结果数据后,对所述加锁处理的所述可用引擎进行解锁处理。The unlocking subunit is configured to perform unlock processing on the available engine in the lock processing after acquiring the code execution result data fed back by the available engine.

在一实施例中,所述基于微服务的数据处理装置包括:In an embodiment, the microservice-based data processing device includes:

生成模块,用于对所述可用引擎进行释放处理,并生成已获取到所述代码执行结果数据的提示信息。The generating module is used to release the available engine and generate a prompt message indicating that the code execution result data has been obtained.

本申请还提供一种可读存储介质,所述可读存储介质上存储有基于微服务的数据处理程序,所述基于微服务的数据处理程序被处理器执行时实现如上述的基于微服务的数据处理方法的步骤。The present application also provides a readable storage medium having a microservice-based data processing program stored on the readable storage medium, and the microservice-based data processing program, when executed by a processor, realizes the microservice-based The steps of the data processing method.

本申请在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件;基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据。在本申请中,由于预设有中间件的存在,且该预设中间件连接基于微服务的各个功能组件,因而,该基于微服务的各个功能组件的预设中间件能够实现同时对接多种产品的统一执行服务,而不只是针对某种执行服务,因而能够直接避免开源产品中对外入口多,不统一,调用关系和层次结构不清晰等的问题,取得提升数据处理效率的技术效果。When a code execution request instruction is detected in this application, the target function component to which the code execution request instruction points is determined based on a preset middleware, wherein the preset middleware connects each function component based on the microservice; based on the target The functional component obtains the code execution result data pointed to by the code execution request instruction. In this application, due to the existence of preset middleware, and the preset middleware connects various functional components based on microservices, the preset middleware based on various functional components of microservices can realize simultaneous docking of multiple types The unified execution service of the product is not just for a certain execution service, so it can directly avoid the problems of multiple external entrances, inconsistencies, unclear call relationships and hierarchical structures in open source products, and achieve the technical effect of improving data processing efficiency.

附图说明Description of the drawings

图1为本申请基于微服务的数据处理方法第一实施例的流程示意图;FIG. 1 is a schematic flowchart of a first embodiment of a microservice-based data processing method according to this application;

图2为本申请基于微服务的数据处理方法第二实施例中在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件步骤的细化流程示意图;Figure 2 is the second embodiment of the microservice-based data processing method of this application, when a code execution request instruction is detected, the target functional component to which the code execution request instruction points is determined based on a preset middleware, wherein the preset The middleware connection is based on the detailed flow diagram of each functional component step of the microservice;

图3是本申请实施例方法涉及的硬件运行环境的设备结构示意图。FIG. 3 is a schematic diagram of the device structure of the hardware operating environment involved in the method of the embodiment of the present application.

本申请目的的实现、功能特点及优点将结合实施例,参照附图做进一步说明。The realization, functional characteristics, and advantages of the purpose of this application will be further described in conjunction with the embodiments and with reference to the accompanying drawings.

本发明的实施方式Embodiments of the invention

应当理解,此处所描述的具体实施例仅仅用以解释本申请,并不用于限定本申请。It should be understood that the specific embodiments described here are only used to explain the application, and are not used to limit the application.

本申请提供一种基于微服务的数据处理方法,在基于微服务的数据处理方法一实施例中,参照图1,所述基于微服务的数据处理方法包括:This application provides a data processing method based on microservices. In an embodiment of the data processing method based on microservices, referring to FIG. 1, the data processing method based on microservices includes:

步骤S10,在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件;Step S10, when the code execution request instruction is detected, determine the target functional component pointed to by the code execution request instruction based on a preset middleware, wherein the preset middleware connects each functional component based on the microservice;

步骤S20,基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据。Step S20, based on the target functional component, obtain the code execution result data pointed to by the code execution request instruction.

具体步骤如下:Specific steps are as follows:

步骤S10,在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件;Step S10, when the code execution request instruction is detected, determine the target functional component pointed to by the code execution request instruction based on a preset middleware, wherein the preset middleware connects each functional component based on the microservice;

需要说明的是,在本实施例中,基于微服务的数据处理方法应用于基于微服务的数据处理系统,基于微服务即是基于单一功能的微小服务实现数据处理的功能,该基于微服务的数据处理系统由于预设中间件的存在,因而可以对接外部多个业务系统,该外部多个业务系统可以涉及贷款业务系统以及保险业务系统等等,该基于微服务的数据处理系统除了对接外部多个业务系统外,还基于预设中间件的存在对接上层数据处理工具如集成开发环境IDE平台,该集成开发环境IDE平台中存在使用各种语言撰写的业务代码,基于微服务的数据处理系统能够负责后台解析执行集成开发环境IDE平台的业务代码,也即,基于微服务的数据处理系统能够实现执行的功能,另外,基于微服务的数据处理系统还能够解决计算、存储、资源管理、权限控制、数据集成、元数据管理、工作流开发结果可视化等功能,且可以提供海量数据的离线加工、数据建模、即席查询分析、数据挖掘等功能。It should be noted that, in this embodiment, the data processing method based on microservices is applied to a data processing system based on microservices. Microservices are based on a single function of microservices that implement data processing functions. Due to the existence of preset middleware, the data processing system can be connected to multiple external business systems. The multiple external business systems may involve loan business systems and insurance business systems, etc. The microservice-based data processing system can be connected to multiple external business systems. In addition to a business system, it is also based on the existence of preset middleware to interface with upper-level data processing tools such as an integrated development environment IDE platform. The integrated development environment IDE platform contains business codes written in various languages. The data processing system based on microservices can Responsible for the background analysis and execution of the business code of the integrated development environment IDE platform, that is, the data processing system based on microservices can realize the functions of execution. In addition, the data processing system based on microservices can also solve the calculation, storage, resource management, and authority control. , Data integration, metadata management, visualization of workflow development results and other functions, and can provide massive data offline processing, data modeling, ad hoc query analysis, data mining and other functions.

其中,在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,该代码执行请求指令可以是外部多个业务系统的API接口发送的,在接收外部多个业务系统的API接口发送的代码执行请求指令后,基于微服务的数据处理系统处理该代码执行请求指令,该代码执行请求指令可以是执行请求指令类型或者是数据获取请求指令类型等,另外,该执行请求指令类型指的是集成开发环境IDE平台中的业务代码类型,该数据获取请求指令类型指的外部多个业务系统的数据查询请求,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件,也即,基于微服务的数据处理系统的中间件能够解耦调用针对每个具体业务的具体功能或者针对代码执行环境对应开发有微服务接口,进而,实现各项功能。Wherein, when the code execution request instruction is detected, the target functional component to which the code execution request instruction is pointed is determined based on the preset middleware. The code execution request instruction may be sent by the API interface of multiple external business systems, and the code execution request instruction may be sent by the API interface of multiple external business systems. After the code execution request instruction sent by the API interface of multiple business systems, the microservice-based data processing system processes the code execution request instruction. The code execution request instruction can be an execution request instruction type or a data acquisition request instruction type, etc. The execution request instruction type refers to the business code type in the IDE platform of the integrated development environment, and the data acquisition request instruction type refers to data query requests from multiple external business systems, and the code execution request instruction is determined based on the preset middleware The target function component that is pointed to, wherein the preset middleware connects each function component based on microservices, that is, the middleware of the data processing system based on microservices can decouple and call specific functions for each specific business or The code execution environment is correspondingly developed with a microservice interface, and furthermore, various functions are realized.

参照图2,所述在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件步骤包括:2, when the code execution request instruction is detected, the target function component to which the code execution request instruction is pointed is determined based on a preset middleware, wherein the preset middleware connects each function component based on the microservice. include:

步骤S11,在检测到代码执行请求指令时,获取所述代码执行请求指令的类型;Step S11, when the code execution request instruction is detected, obtain the type of the code execution request instruction;

在本实施例中,在检测到代码执行请求指令时,获取所述代码执行请求指令的类型,具体地,获取该代码执行请求指令是执行请求指令类型还是数据获取请求指令类型,或者更为具体地,获取该代码执行请求指令是何种具体环境的执行请求指令类型或者是何种具体的数据获取请求指令类型。In this embodiment, when a code execution request instruction is detected, the type of the code execution request instruction is acquired, specifically, whether the code execution request instruction is an execution request instruction type or a data acquisition request instruction type, or more specifically To obtain the specific environment execution request command type or the specific data acquisition request command type of the code execution request instruction.

步骤S12,基于预设中间件以及所述代码执行请求指令的类型确定所述代码执行请求指令指向的目标功能组件;Step S12: Determine the target functional component to which the code execution request instruction points based on the preset middleware and the type of the code execution request instruction;

基于预设中间件以及所述代码执行请求指令的类型确定所述代码执行请求指令指向的目标功能组件,例如,若所述代码执行请求指令的类型为数据获取请求指令类型,基于预设中间件以及所述代码执行请求指令的类型确定所述代码执行请求指令指向的目标功能组件为第一大类目标功能组件,若所述代码执行请求指令的类型为执行请求指令类型,基于预设中间件以及所述代码执行请求指令的类型确定所述代码执行请求指令指向的目标功能组件为第二大类目标功能组件,若所述代码执行请求指令的类型为数据获取请求指令类型中数据查询子类型时,基于预设中间件以及所述数据查询子类型确定所述代码执行请求指令指向的目标功能组件为第一大类目标功能组件中的查询子类功能组件。Determine the target functional component pointed to by the code execution request instruction based on the preset middleware and the type of the code execution request instruction. For example, if the type of the code execution request instruction is the data acquisition request instruction type, based on the preset middleware And the type of the code execution request instruction determines that the target functional component pointed to by the code execution request instruction is the first category of target functional component, and if the type of the code execution request instruction is the execution request instruction type, it is based on a preset middleware And the type of the code execution request instruction determines that the target functional component pointed to by the code execution request instruction is the second major type of target functional component, if the type of the code execution request instruction is the data query subtype in the data acquisition request instruction type At this time, based on the preset middleware and the data query subtype, it is determined that the target functional component pointed to by the code execution request instruction is the query sub-category functional component in the first major category of target functional components.

其中,所述预设中间件连接基于微服务的各个功能组件,所述各个功能组件包括各个微服务接口,所述各个微服务接口是分布在各个平台上的与所述代码执行请求类型匹配的单向功能接口。Wherein, the preset middleware connects various functional components based on microservices, and each functional component includes various microservice interfaces, and each microservice interface is distributed on various platforms and matches the code execution request type One-way functional interface.

即对于每个具体业务或者具体代码执行环境而言,在基于微服务的数据处理系统中都对应设置有多个微服务接口,该多个微服务接口与该具体的业务对应具体的业务功能或者具体的代码执行环境存在一一映射关系,即具体业务功能不同,该微服务接口不同,具体的代码执行环境不同,该微服务接口不同,其中,微服务接口本质上是一套预设标准的基于企业具体业务设计或者具体的代码执行环境设计的API接口,即该不同微服务接口中具有不同的预设规则或者函数、以实现相应单一的功能,如单一的功能可是进行业务数据的查询或者执行某类型代码等,需要说明的是,由于在在多个平台上同步开展同一业务或者同一代码执行环境,因而,对于该同一业务或者执行环境而言,存在对应于不同平台或者对接于不同平台的同一功能的微服务接口。That is, for each specific business or specific code execution environment, multiple microservice interfaces are correspondingly set in the microservice-based data processing system, and the multiple microservice interfaces correspond to specific business functions or The specific code execution environment has a one-to-one mapping relationship, that is, the specific business function is different, the microservice interface is different, the specific code execution environment is different, the microservice interface is different, and the microservice interface is essentially a set of preset standards An API interface designed based on the company’s specific business design or specific code execution environment, that is, the different microservice interfaces have different preset rules or functions to achieve a corresponding single function. For example, a single function can perform business data query or To execute a certain type of code, etc., it should be noted that because the same business or the same code execution environment is synchronized on multiple platforms, for the same business or execution environment, there are different platforms corresponding to or docking with different platforms The same function of the microservice interface.

在基于微服务的数据处理系统中,还进行功能组件的设置,即是在对应于不同平台或者对接于不同平台的同一功能的微服务接口上,封装功能组件,以管理不同平台的同一业务或者同一代码执行环境的同一功能的各微服务接口,用以具体实施例进行说明,在基于微服务的数据处理系统中,针对Q贷款业务开发设置有不同功能的各个微服务接口,其中一个微服务接口的功能是基于保单号进行B贷款业务申请状态的查询,而该Q贷款业务在q1、q2等平台上都有营业,因而,在基于微服务的数据处理系统中,是设置有接通该q1、q2等平台的基于保单号进行Q贷款业务申请状态查询不同的微服务接口,而管理不同平台上的基于保单号进行Q贷款业务申请状态查询的不同的微服务接口的即是功能组件。In the data processing system based on microservices, functional components are also set, that is, the functional components are encapsulated on the microservice interfaces corresponding to different platforms or the same function on different platforms to manage the same business or on different platforms. The microservice interfaces of the same function of the same code execution environment are described in specific embodiments. In the data processing system based on microservices, various microservice interfaces with different functions are set up for the development of Q loan business. One of the microservices The function of the interface is to query the application status of the B loan business based on the insurance policy number, and the Q loan business is available on platforms such as q1 and q2. Therefore, in the data processing system based on microservices, the Platforms such as q1 and q2 have different micro-service interfaces for querying the status of Q loan business applications based on policy numbers, and functional components are the functional components that manage different micro-service interfaces for querying the status of Q loan business applications based on insurance policy numbers on different platforms.

步骤S20,基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据。Step S20, based on the target functional component, obtain the code execution result data pointed to by the code execution request instruction.

在确定目标功能组件后,由于功能组件实现管理不同平台的同一业务或者同一代码执行环境的同一功能的各微服务接口,因而,基于不同平台的同一业务或者同一代码执行环境的同一功能的各微服务接口,即可获取所述代码执行请求指令指向的代码执行结果数据,其中,代码执行结果数据包括代码执行进度,代码执行状态,代码执行日志,或者业务获取数据等。After determining the target functional component, because the functional component realizes the microservice interface that manages the same business on different platforms or the same function of the same code execution environment, the microservices based on the same business on different platforms or the same function of the same code execution environment The service interface can obtain the code execution result data pointed to by the code execution request instruction, where the code execution result data includes code execution progress, code execution status, code execution log, or business acquisition data.

本申请在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件;基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据。在本申请中,由于预设有中间件的存在,且该预设中间件连接基于微服务的各个功能组件,因而,该基于微服务的各个功能组件的预设中间件能够实现同时对接多种产品的统一执行服务,而不只是针对某种执行服务,因而能够直接避免开源产品中对外入口多,不统一,调用关系和层次结构不清晰等的问题,取得提升数据处理效率的技术效果,也即解决了现有技术中由于开源产品中只能针对某种执行服务而缺乏能够同时对接多种产品的统一执行服务,降低了数据处理效率的技术问题。When a code execution request instruction is detected in this application, the target function component to which the code execution request instruction points is determined based on a preset middleware, wherein the preset middleware connects each function component based on the microservice; based on the target The functional component obtains the code execution result data pointed to by the code execution request instruction. In this application, due to the existence of preset middleware, and the preset middleware connects various functional components based on microservices, the preset middleware based on various functional components of microservices can realize simultaneous docking of multiple types The unified execution service of the product is not just for a certain execution service, so it can directly avoid the problems of multiple external entrances in open source products, inconsistency, unclear calling relationships and unclear hierarchical structure, and achieve the technical effect of improving data processing efficiency. That is, it solves the technical problem in the prior art that the open source product can only be targeted for a certain execution service but lacks a unified execution service that can connect multiple products at the same time, which reduces the data processing efficiency.

进一步地,本申请提供基于微服务的数据处理方法另一实施例,在该实施例中,所述基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据步骤包括:Further, the present application provides another embodiment of a data processing method based on microservices. In this embodiment, the step of obtaining the code execution result data pointed to by the code execution request instruction based on the target functional component includes:

步骤S21,基于所述目标功能组件,确定是否存在可用引擎;Step S21: Determine whether there is an available engine based on the target function component;

在本实施例中,目标功能组件通过微服务接口是与各个平台中进行通信的,在与各个平台中进行通信过程中,需要确定各个平台中是否存在可用引擎服务,即,确定是否存在可用引擎(由具有反馈数据功能的模块构成),其中,通过向预设资源管理器(与各个平台关联)发送查询请求,确定各个平台中是否存在可用引擎服务也即是否存在可用引擎,以确定是否能从各个平台获取代码执行请求指令对应的相关数据。In this embodiment, the target function component communicates with each platform through the microservice interface. In the process of communicating with each platform, it is necessary to determine whether there is an available engine service in each platform, that is, whether there is an available engine (Consisting of a module with the function of feedback data), in which, by sending a query request to the preset resource manager (associated with each platform), it is determined whether there is an available engine service in each platform, that is, whether there is an available engine to determine whether it can Obtain the relevant data corresponding to the code execution request instruction from each platform.

步骤S22,若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据。Step S22: If it is determined that there is an available engine, the code execution request instruction is sent to the available engine to obtain code execution result data fed back by the available engine.

在本实施例中,若确定存在可用引擎或者空闲引擎时,通过与预设中间件进行连接的各个功能组件中的各个微服务接口,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据。In this embodiment, if it is determined that there is an available engine or an idle engine, the code execution request instruction is sent to the available engine through each microservice interface in each functional component connected with the preset middleware to Obtain code execution result data fed back by the available engine.

所述基于所述目标功能组件,确定是否存在可用引擎步骤之后还包括:After the step of determining whether there is an available engine based on the target function component, the method further includes:

步骤S23,若确定未存在可用引擎时,生成新的可用引擎;Step S23, if it is determined that there is no available engine, a new available engine is generated;

在本实施例中,通过向预设资源管理器发送查询请求,确定各个平台中是否存在可用引擎服务也即是否存在可用引擎,若确定未存在可用引擎时,生成新的可用引擎。以避免无法获取代码执行请求指令对应的相关数据。In this embodiment, by sending a query request to the preset resource manager, it is determined whether there is an available engine service in each platform, that is, whether there is an available engine, and if it is determined that there is no available engine, a new available engine is generated. In order to avoid being unable to obtain the relevant data corresponding to the code execution request instruction.

所述若确定未存在可用引擎时,生成新的可用引擎步骤包括:If it is determined that there is no available engine, the step of generating a new available engine includes:

步骤S231,若确定未存在可用引擎时,通过预设资源管理器确定目标引擎管理器,以为所述代码执行请求指令在目标引擎管理器中申请对应的新的可用引擎。In step S231, if it is determined that there is no available engine, the target engine manager is determined through the preset resource manager, so as to apply for the corresponding new available engine in the target engine manager for the code execution request instruction.

在本实施例中,存在预设资源管理器,该预设资源管理器针对每个用户或者租户统一设置有权限信息,不再需要用户在各个系统反复配置定义的环境变量,上传依赖的物料文件,自定义函数,申请资源等,需要说明的是,预设资源管理器针对每个用户也即每个租户还设置有统一的资源管理服务。In this embodiment, there is a preset resource manager, and the preset resource manager uniformly sets authority information for each user or tenant. It is no longer necessary for users to repeatedly configure defined environment variables in each system and upload dependent material files. , Custom functions, application for resources, etc. It should be noted that the preset resource manager also sets a unified resource management service for each user, that is, each tenant.

在本实施例中,若确定未存在可用引擎时,通过与各个平台关联的预设资源管理器确定目标引擎管理器,以为所述代码执行请求指令在目标引擎管理器中申请对应的新的可用引擎。具体地,通过向各个平台关联的预设资源管理器请求代码执行请求指令对应的新的资源,首先获取请求代码执行请求指令对应中携带的用户信息,根据预设资源管理器中当前租户隔离的状态,从预设资源管理器中确定用户信息对应的引擎管理器,在确定用户信息对应的引擎管理器后,还获取请求代码执行请求指令中携带的目标数据类型,根据所述目标数据类型从用户信息对应的引擎管理器中选取目标引擎管理器,也即,也即根据目标引擎管理器为所述代码执行请求指令在目标引擎管理器中申请对应的新的可用引擎。In this embodiment, if it is determined that there is no available engine, the target engine manager is determined through the preset resource manager associated with each platform, so as to apply for the corresponding new available engine manager in the target engine manager for the code execution request instruction. engine. Specifically, by requesting new resources corresponding to the code execution request instruction from the preset resource manager associated with each platform, first obtain the user information carried in the request code execution request instruction corresponding to the current tenant isolation in the preset resource manager State, determine the engine manager corresponding to the user information from the preset resource manager, and after the engine manager corresponding to the user information is determined, the target data type carried in the request code execution request instruction is also obtained, and from the target data type according to the target data type The target engine manager is selected from the engine manager corresponding to the user information, that is, the target engine manager applies for a corresponding new available engine in the target engine manager according to the code execution request instruction.

步骤S24,将所述代码执行请求指令发送给所述新的可用引擎,以获取所述新的可用引擎反馈的代码执行结果数据。Step S24: Send the code execution request instruction to the new available engine to obtain code execution result data fed back by the new available engine.

在本实施例中,通过基于所述目标功能组件,确定是否存在可用引擎;若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据。在本实施例中,实现准确获取代码执行结果数据。In this embodiment, based on the target functional component, it is determined whether there is an available engine; if it is determined that there is an available engine, the code execution request instruction is sent to the available engine to obtain the code fed back by the available engine Execution result data. In this embodiment, accurate acquisition of code execution result data is achieved.

进一步地,本申请提供基于微服务的数据处理方法另一实施例,在该实施例中,所述若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据步骤还包括:Further, this application provides another embodiment of a data processing method based on microservices. In this embodiment, if it is determined that there is an available engine, the code execution request instruction is sent to the available engine to obtain all available engines. The code execution result data step that can be fed back by the engine also includes:

步骤S25,若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,并对所述可用引擎进行加锁处理,以获取所述可用引擎反馈的代码执行结果数据;Step S25, if it is determined that there is an available engine, send the code execution request instruction to the available engine, and perform lock processing on the available engine to obtain code execution result data fed back by the available engine;

在本实施例中,在获取代码执行结果数据过程中,若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,并对所述可用引擎进行加锁处理,以使得可用引擎专职处理所述代码执行请求指令,以避免一个可用引擎同时处理多个代码执行请求指令而造成的处理错乱的情况,以获取所述可用引擎反馈的代码执行结果数据。In this embodiment, in the process of obtaining code execution result data, if it is determined that there is an available engine, the code execution request instruction is sent to the available engine, and the available engine is locked to make the available engine available. The engine processes the code execution request instructions on a full-time basis to avoid processing confusion caused by one usable engine processing multiple code execution request instructions at the same time, so as to obtain code execution result data fed back by the usable engine.

步骤S26,在获取所述可用引擎反馈的代码执行结果数据后,对所述加锁处理的所述可用引擎进行解锁处理。Step S26: After obtaining the code execution result data fed back by the available engine, perform unlock processing on the available engine of the lock processing.

在获取所述可用引擎反馈的代码执行结果数据后,对所述加锁处理的所述可用引擎进行解锁处理或者释放处理,以使得解锁处理后的可用引擎处理其他指令,以避免资源的浪费。After obtaining the code execution result data fed back by the available engine, unlock or release the available engine for the lock processing, so that the unlocked available engine can process other instructions to avoid waste of resources.

在本实施例中,通过若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,并对所述可用引擎进行加锁处理,以获取所述可用引擎反馈的代码执行结果数据;在获取所述可用引擎反馈的代码执行结果数据后,对所述加锁处理的所述可用引擎进行解锁处理。在本实施例中,通过对可用引擎的加锁解锁处理,提升代码执行请求指令的处理容错性。In this embodiment, if it is determined that there is an available engine, the code execution request instruction is sent to the available engine, and the available engine is locked, so as to obtain the code execution result fed back by the available engine Data; after obtaining the code execution result data fed back by the available engine, unlock the available engine for the lock processing. In this embodiment, by locking and unlocking the available engines, the fault tolerance of the code execution request instruction is improved.

进一步地,本申请提供基于微服务的数据处理方法另一实施例,在该实施例中,所述基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据步骤之后包括:Further, this application provides another embodiment of a data processing method based on microservices. In this embodiment, the step of obtaining the code execution result data pointed to by the code execution request instruction based on the target function component includes:

步骤S40,对所述可用引擎进行释放处理,并生成已获取到所述代码执行结果数据的提示信息。Step S40: Perform release processing on the available engine, and generate a prompt message indicating that the code execution result data has been acquired.

在本实施例中,在获取所述代码执行请求指令指向的代码执行结果数据后,对所述可用引擎进行释放处理,并生成已获取到所述代码执行结果数据的提示信息,以供用户及时获取到所述代码执行结果数据,以提升用户体验。In this embodiment, after obtaining the code execution result data pointed to by the code execution request instruction, the available engine is released, and a prompt message that the code execution result data has been obtained is generated for the user to promptly The code execution result data is obtained to improve user experience.

参照图3,图3是本申请实施例方案涉及的硬件运行环境的设备结构示意图。Referring to FIG. 3, FIG. 3 is a schematic diagram of the device structure of the hardware operating environment involved in the solution of the embodiment of the present application.

本申请实施例基于微服务的数据处理设备可以是PC,也可以是智能手机、平板电脑、便携计算机等终端设备。The data processing device based on microservices in the embodiment of the present application may be a PC, or a terminal device such as a smart phone, a tablet computer, or a portable computer.

如图3所示,该基于微服务的数据处理设备可以包括:处理器1001,例如CPU,存储器1005,通信总线1002。其中,通信总线1002用于实现处理器1001和存储器1005之间的连接通信。存储器1005可以是高速RAM存储器,也可以是稳定的存储器(non-volatile memory),例如磁盘存储器。存储器1005可选的还可以是独立于前述处理器1001的存储设备。As shown in FIG. 3, the microservice-based data processing device may include: a processor 1001, such as a CPU, a memory 1005, and a communication bus 1002. Among them, the communication bus 1002 is used to implement connection and communication between the processor 1001 and the memory 1005. The memory 1005 can be a high-speed RAM memory or a stable memory (non-volatile memory), such as disk storage. Optionally, the memory 1005 may also be a storage device independent of the foregoing processor 1001.

在一实施例中,该基于微服务的数据处理设备还可以包括目标用户接口、网络接口、摄像头、RF(Radio Frequency,射频)电路,传感器、音频电路、WiFi模块等等。目标用户接口可以包括显示屏(Display)、输入单元比如键盘(Keyboard),可选目标用户接口还可以包括标准的有线接口、无线接口。网络接口可选的可以包括标准的有线接口、无线接口(如WI-FI接口)。In an embodiment, the microservice-based data processing device may also include a target user interface, a network interface, a camera, and RF (Radio Frequency (radio frequency) circuits, sensors, audio circuits, WiFi modules, etc. The target user interface may include a display screen (Display) and an input unit such as a keyboard (Keyboard), and the optional target user interface may also include a standard wired interface and a wireless interface. The optional network interface can include standard wired interface and wireless interface (such as WI-FI interface).

本领域技术人员可以理解,图3中示出的基于微服务的数据处理设备结构并不构成对基于微服务的数据处理设备的限定,可以包括比图示更多或更少的部件,或者组合某些部件,或者不同的部件布置。Those skilled in the art can understand that the structure of the data processing device based on microservices shown in FIG. 3 does not constitute a limitation on the data processing device based on microservices, and may include more or less components than shown in the figure, or a combination Certain components, or different component arrangements.

如图3所示,作为一种计算机存储介质的存储器1005中可以包括操作系统、网络通信模块以及基于微服务的数据处理程序。操作系统是管理和控制基于微服务的数据处理设备硬件和软件资源的程序,支持基于微服务的数据处理程序以及其它软件和/或程序的运行。网络通信模块用于实现存储器1005内部各组件之间的通信,以及与基于微服务的数据处理设备中其它硬件和软件之间通信。As shown in FIG. 3, the memory 1005 as a computer storage medium may include an operating system, a network communication module, and a data processing program based on microservices. The operating system is a program that manages and controls the hardware and software resources of microservice-based data processing equipment, and supports the operation of microservice-based data processing programs and other software and/or programs. The network communication module is used to implement communication between various components in the memory 1005, as well as communication with other hardware and software in the microservice-based data processing device.

在图3所示的基于微服务的数据处理设备中,处理器1001用于执行存储器1005中存储的基于微服务的数据处理程序,实现上述任一项所述的基于微服务的数据处理方法的步骤。In the microservice-based data processing device shown in FIG. 3, the processor 1001 is configured to execute the microservice-based data processing program stored in the memory 1005 to implement the microservice-based data processing method described in any one of the above step.

本申请基于微服务的数据处理设备具体实施方式与上述基于微服务的数据处理方法各实施例基本相同,在此不再赘述。The specific implementation of the microservice-based data processing device of this application is basically the same as the foregoing embodiments of the microservice-based data processing method, and will not be repeated here.

此外,本申请实施例还提出一种基于微服务的数据处理装置,所述基于微服务的数据处理装置包括:In addition, an embodiment of the present application also proposes a data processing device based on microservices, and the data processing device based on microservices includes:

检测模块,用于在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件;The detection module is configured to determine the target functional component to which the code execution request instruction points based on a preset middleware when the code execution request instruction is detected, wherein the preset middleware connects each functional component based on the microservice;

获取模块,用于基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据。The obtaining module is configured to obtain the code execution result data pointed to by the code execution request instruction based on the target functional component.

在一实施例中,所述检测模块包括:In an embodiment, the detection module includes:

第一获取单元,用于在检测到代码执行请求指令时,获取所述代码执行请求指令的类型;The first acquiring unit is configured to acquire the type of the code execution request instruction when the code execution request instruction is detected;

第一确定单元,用于基于预设中间件以及所述代码执行请求指令的类型确定所述代码执行请求指令指向的目标功能组件;The first determining unit is configured to determine the target functional component to which the code execution request instruction points based on the preset middleware and the type of the code execution request instruction;

其中,所述预设中间件连接基于微服务的各个功能组件,所述各个功能组件包括各个微服务接口,所述各个微服务接口是分布在各个平台上的与所述代码执行请求类型匹配的单向功能接口。Wherein, the preset middleware connects various functional components based on microservices, and each functional component includes various microservice interfaces, and each microservice interface is distributed on various platforms and matches the code execution request type One-way functional interface.

在一实施例中,所述获取模块包括:In an embodiment, the acquisition module includes:

第二确定单元,用于基于所述目标功能组件,确定是否存在可用引擎;The second determining unit is configured to determine whether there is an available engine based on the target function component;

第二获取单元,用于若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据。The second obtaining unit is configured to send the code execution request instruction to the available engine if it is determined that there is an available engine, so as to obtain the code execution result data fed back by the available engine.

在一实施例中,所述获取模块包括:In an embodiment, the acquisition module includes:

生成单元,用于若确定未存在可用引擎时,生成新的可用引擎;The generating unit is used to generate a new available engine if it is determined that there is no available engine;

第三获取单元,用于将所述代码执行请求指令发送给所述新的可用引擎,以获取所述新的可用引擎反馈的代码执行结果数据。The third obtaining unit is configured to send the code execution request instruction to the new available engine to obtain code execution result data fed back by the new available engine.

在一实施例中,所述生成单元包括:In an embodiment, the generating unit includes:

申请子单元,用于若确定未存在可用引擎时,通过预设资源管理器确定目标引擎管理器,以为所述代码执行请求指令在目标引擎管理器中申请对应的新的可用引擎。The application subunit is used to determine the target engine manager through the preset resource manager if it is determined that there is no available engine, so as to apply for the corresponding new available engine in the target engine manager for the code execution request instruction.

在一实施例中,所述第二获取单元包括:In an embodiment, the second acquiring unit includes:

获取子单元,用于若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,并对所述可用引擎进行加锁处理,以获取所述可用引擎反馈的代码执行结果数据;The acquiring subunit is configured to send the code execution request instruction to the available engine if it is determined that there is an available engine, and perform lock processing on the available engine to obtain code execution result data fed back by the available engine ;

解锁子单元,用于在获取所述可用引擎反馈的代码执行结果数据后,对所述加锁处理的所述可用引擎进行解锁处理。The unlocking subunit is configured to perform unlock processing on the available engine in the lock processing after acquiring the code execution result data fed back by the available engine.

在一实施例中,所述基于微服务的数据处理装置包括:In an embodiment, the microservice-based data processing device includes:

生成模块,用于对所述可用引擎进行释放处理,并生成已获取到所述代码执行结果数据的提示信息。The generating module is used to release the available engine and generate a prompt message indicating that the code execution result data has been obtained.

本申请基于微服务的数据处理装置具体实施方式与上述基于微服务的数据处理方法各实施例基本相同,在此不再赘述。The specific implementation of the microservice-based data processing apparatus of the present application is basically the same as the foregoing embodiments of the microservice-based data processing method, and will not be repeated here.

此外,本申请实施例还提出一种基于微服务的数据处理设备,设备包括:存储器109、处理器110及存储在存储器109上并可在处理器110上运行的基于微服务的数据处理程序,基于微服务的数据处理程序被处理器110执行时实现上述的基于微服务的数据处理方法各实施例的步骤。In addition, an embodiment of the present application also proposes a data processing device based on microservices. The device includes: a memory 109, a processor 110, and a microservice-based data processing program stored in the memory 109 and running on the processor 110, When the microservice-based data processing program is executed by the processor 110, the steps of the foregoing microservice-based data processing method embodiments are implemented.

此外,本申请还提供了一种计算机可读存储介质,所述计算机可读存储介质存储有一个或者一个以上程序,所述一个或者一个以上程序还可被一个或者一个以上的处理器执行以用于实现上述基于微服务的数据处理方法各实施例的步骤。In addition, this application also provides a computer-readable storage medium that stores one or more programs, and the one or more programs can also be executed by one or more processors for use To implement the steps of each embodiment of the above-mentioned microservice-based data processing method.

本申请设备及可读存储介质(即计算机可读存储介质)的具体实施方式的拓展内容与上述基于微服务的数据处理方法各实施例基本相同,在此不做赘述。The expanded content of the specific implementation of the device and the readable storage medium of the application (ie, the computer readable storage medium) is basically the same as the above embodiments of the microservice-based data processing method, and will not be repeated here.

需要说明的是,在本文中,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者装置不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者装置所固有的要素。在没有更多限制的情况下,由语句“包括一个……”限定的要素,并不排除在包括该要素的过程、方法、物品或者装置中还存在另外的相同要素。It should be noted that in this article, the terms "include", "include" or any other variants thereof are intended to cover non-exclusive inclusion, so that a process, method, article or device including a series of elements not only includes those elements, It also includes other elements not explicitly listed, or elements inherent to the process, method, article, or device. If there are no more restrictions, the element defined by the sentence "including a..." does not exclude the existence of other identical elements in the process, method, article or device that includes the element.

上述本申请实施例序号仅仅为了描述,不代表实施例的优劣。The serial numbers of the foregoing embodiments of the present application are for description only, and do not represent the superiority of the embodiments.

通过以上的实施方式的描述,本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现,当然也可以通过硬件,但很多情况下前者是更佳的实施方式。基于这样的理解,本申请的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质(如ROM/RAM、磁碟、光盘)中,包括若干指令用以使得一台终端(可以是手机,计算机,服务器,空调器,或者网络设备等)执行本申请各个实施例所述的方法。Through the description of the above embodiments, those skilled in the art can clearly understand that the method of the above embodiments can be implemented by means of software plus the necessary general hardware platform. Of course, it can also be implemented by hardware, but in many cases the former is better.的实施方式。 Based on this understanding, the technical solution of this application essentially or the part that contributes to the existing technology can be embodied in the form of a software product, and the computer software product is stored in a storage medium (such as ROM/RAM, magnetic disk, The optical disc) includes several instructions to make a terminal (which may be a mobile phone, a computer, a server, an air conditioner, or a network device, etc.) execute the methods described in the various embodiments of the present application.

上面结合附图对本申请的实施例进行了描述,但是本申请并不局限于上述的具体实施方式,上述的具体实施方式仅仅是示意性的,而不是限制性的,本领域的普通技术人员在本申请的启示下,在不脱离本申请宗旨和权利要求所保护的范围情况下,还可做出很多形式,这些均属于本申请的保护之内。The embodiments of the present application are described above with reference to the accompanying drawings, but the present application is not limited to the above-mentioned specific embodiments. The above-mentioned specific embodiments are only illustrative and not restrictive. Those of ordinary skill in the art are Under the enlightenment of this application, many forms can be made without departing from the purpose of this application and the scope of protection of the claims, and these are all within the protection of this application.

Claims (10)

一种基于微服务的数据处理方法,其中,所述基于微服务的数据处理方法包括:A data processing method based on microservices, wherein the data processing method based on microservices includes: 在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件;When the code execution request instruction is detected, determine the target functional component to which the code execution request instruction points based on a preset middleware, where the preset middleware connects each functional component based on the microservice; 基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据。Based on the target functional component, obtain the code execution result data pointed to by the code execution request instruction. 如权利要求1所述的基于微服务的数据处理方法,其中,所述在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件步骤包括:The microservice-based data processing method according to claim 1, wherein when the code execution request instruction is detected, the target functional component to which the code execution request instruction is directed is determined based on a preset middleware, wherein the The steps of the preset middleware to connect the functional components based on microservices include: 在检测到代码执行请求指令时,获取所述代码执行请求指令的类型;When the code execution request instruction is detected, acquiring the type of the code execution request instruction; 基于预设中间件以及所述代码执行请求指令的类型确定所述代码执行请求指令指向的目标功能组件;Determining the target functional component to which the code execution request instruction points based on the preset middleware and the type of the code execution request instruction; 其中,所述预设中间件连接基于微服务的各个功能组件,所述各个功能组件包括各个微服务接口,所述各个微服务接口是分布在各个平台上的与所述代码执行请求类型匹配的单向功能接口。Wherein, the preset middleware connects various functional components based on microservices, and each functional component includes various microservice interfaces, and each microservice interface is distributed on various platforms and matches the code execution request type One-way functional interface. 如权利要求1所述的基于微服务的数据处理方法,其中,所述基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据步骤包括:The microservice-based data processing method according to claim 1, wherein the step of obtaining the code execution result data pointed to by the code execution request instruction based on the target functional component comprises: 基于所述目标功能组件,确定是否存在可用引擎;Based on the target functional component, determine whether there is an available engine; 若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据。If it is determined that there is an available engine, the code execution request instruction is sent to the available engine to obtain code execution result data fed back by the available engine. 如权利要求3所述的基于微服务的数据处理方法,其中,所述基于所述目标功能组件,确定是否存在可用引擎步骤之后还包括:The microservice-based data processing method of claim 3, wherein after the step of determining whether there is an available engine based on the target functional component, the method further comprises: 若确定未存在可用引擎时,生成新的可用引擎;If it is determined that there is no available engine, a new available engine is generated; 将所述代码执行请求指令发送给所述新的可用引擎,以获取所述新的可用引擎反馈的代码执行结果数据。The code execution request instruction is sent to the new available engine to obtain code execution result data fed back by the new available engine. 如权利要求4所述的基于微服务的数据处理方法,其中,所述若确定未存在可用引擎时,生成新的可用引擎步骤包括:The microservice-based data processing method according to claim 4, wherein if it is determined that there is no available engine, the step of generating a new available engine comprises: 若确定未存在可用引擎时,通过预设资源管理器确定目标引擎管理器,以为所述代码执行请求指令在目标引擎管理器中申请对应的新的可用引擎。If it is determined that there is no available engine, the target engine manager is determined through the preset resource manager, so as to apply for the corresponding new available engine in the target engine manager for the code execution request instruction. 如权利要求3所述的基于微服务的数据处理方法,其中,所述若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,以获取所述可用引擎反馈的代码执行结果数据步骤还包括:The microservice-based data processing method according to claim 3, wherein, if it is determined that there is an available engine, the code execution request instruction is sent to the available engine to obtain the code execution feedback from the available engine The result data step also includes: 若确定存在可用引擎时,将所述代码执行请求指令发送给所述可用引擎,并对所述可用引擎进行加锁处理,以获取所述可用引擎反馈的代码执行结果数据;If it is determined that there is an available engine, send the code execution request instruction to the available engine, and lock the available engine to obtain the code execution result data fed back by the available engine; 在获取所述可用引擎反馈的代码执行结果数据后,对所述加锁处理的所述可用引擎进行解锁处理。After obtaining the code execution result data fed back by the available engine, unlock the available engine for the lock processing. 如权利要求1-6任一项所述的基于微服务的数据处理方法,其中,所述基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据步骤之后包括:The microservice-based data processing method according to any one of claims 1 to 6, wherein after the step of obtaining the code execution result data pointed to by the code execution request instruction based on the target functional component, comprises: 对所述可用引擎进行释放处理,并生成已获取到所述代码执行结果数据的提示信息。Perform release processing on the available engine, and generate a prompt message that the code execution result data has been obtained. 一种基于微服务的数据处理装置,其中,所述基于微服务的数据处理装置包括:A data processing device based on microservices, wherein the data processing device based on microservices includes: 检测模块,用于在检测到代码执行请求指令时,基于预设中间件确定所述代码执行请求指令指向的目标功能组件,其中,所述预设中间件连接基于微服务的各个功能组件;The detection module is configured to determine the target functional component to which the code execution request instruction points based on a preset middleware when the code execution request instruction is detected, wherein the preset middleware connects each functional component based on the microservice; 获取模块,用于基于所述目标功能组件,获取所述代码执行请求指令指向的代码执行结果数据。The obtaining module is configured to obtain the code execution result data pointed to by the code execution request instruction based on the target functional component. 一种基于微服务的数据处理设备,其中,所述设备包括:存储器、处理器及存储在所述存储器上并可在所述处理器上运行的基于微服务的数据处理程序,所述基于微服务的数据处理程序被所述处理器执行时实现如权利要求1至7中任一项所述的基于微服务的数据处理方法的步骤。A data processing device based on microservices, wherein the device includes: a memory, a processor, and a microservice-based data processing program stored on the memory and running on the processor; When the data processing program of the service is executed by the processor, the steps of the microservice-based data processing method according to any one of claims 1 to 7 are implemented. 一种可读存储介质,其中,所述可读存储介质上存储有基于微服务的数据处理程序,所述基于微服务的数据处理程序被处理器执行时实现如权利要求1至7中任一项所述的基于微服务的数据处理方法的步骤。A readable storage medium, wherein a data processing program based on microservices is stored on the readable storage medium, and when the data processing program based on microservices is executed by a processor, the implementation is as in any one of claims 1 to 7. The steps of the microservice-based data processing method described in the item.
PCT/CN2020/102537 2019-07-19 2020-07-17 Microservice-based data processing method and apparatus, and device and readable storage medium Ceased WO2021013056A1 (en)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN201910656797.3A CN110333917A (en) 2019-07-19 2019-07-19 Microservice-based data processing method, device, device, and readable storage medium
CN201910656797.3 2019-07-19

Publications (1)

Publication Number Publication Date
WO2021013056A1 true WO2021013056A1 (en) 2021-01-28

Family

ID=68145835

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2020/102537 Ceased WO2021013056A1 (en) 2019-07-19 2020-07-17 Microservice-based data processing method and apparatus, and device and readable storage medium

Country Status (2)

Country Link
CN (1) CN110333917A (en)
WO (1) WO2021013056A1 (en)

Families Citing this family (9)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN110333917A (en) * 2019-07-19 2019-10-15 深圳前海微众银行股份有限公司 Microservice-based data processing method, device, device, and readable storage medium
CN113051303A (en) * 2019-12-27 2021-06-29 北京国双科技有限公司 Business data processing method and device, electronic equipment and storage medium
CN111444500A (en) * 2020-03-02 2020-07-24 深圳壹账通智能科技有限公司 Authentication method, apparatus, device and readable storage medium
CN111552580B (en) * 2020-05-07 2025-10-21 深圳前海微众银行股份有限公司 Distributed microservice decision-making method, device, equipment and computer storage medium
CN111581635B (en) * 2020-05-13 2023-09-05 中国民航信息网络股份有限公司 Data processing method and system
CN111767200B (en) * 2020-06-23 2022-12-02 平安普惠企业管理有限公司 Method, device and computer equipment for processing service based on service log
CN112860450B (en) * 2020-12-04 2024-04-19 武汉悦学帮网络技术有限公司 Request processing method and device
CN114615521B (en) * 2022-03-10 2024-02-23 网易(杭州)网络有限公司 Video processing method and device, computer readable storage medium and electronic equipment
CN115756450A (en) * 2022-12-05 2023-03-07 广州玖晔网络科技有限公司 A microservice development method and system

Citations (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20100299437A1 (en) * 2009-05-22 2010-11-25 Comcast Interactive Media, Llc Web Service System and Method
US20150350153A1 (en) * 2014-05-30 2015-12-03 Vonage Business Solutions, Inc. System and method for account-based dns routing
CN106612188A (en) * 2015-10-21 2017-05-03 中兴通讯股份有限公司 Method and device for extending software function based on micro service architecture
CN108418862A (en) * 2018-01-31 2018-08-17 金蝶软件(中国)有限公司 Micro services management method and system based on artificial intelligence service cloud platform
CN110278284A (en) * 2019-07-10 2019-09-24 中国民航信息网络股份有限公司 A kind of service calling method and device
CN110333917A (en) * 2019-07-19 2019-10-15 深圳前海微众银行股份有限公司 Microservice-based data processing method, device, device, and readable storage medium
CN110381143A (en) * 2019-07-19 2019-10-25 深圳前海微众银行股份有限公司 Operation, which is submitted, executes method, apparatus, equipment and computer storage medium

Patent Citations (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20100299437A1 (en) * 2009-05-22 2010-11-25 Comcast Interactive Media, Llc Web Service System and Method
US20150350153A1 (en) * 2014-05-30 2015-12-03 Vonage Business Solutions, Inc. System and method for account-based dns routing
CN106612188A (en) * 2015-10-21 2017-05-03 中兴通讯股份有限公司 Method and device for extending software function based on micro service architecture
CN108418862A (en) * 2018-01-31 2018-08-17 金蝶软件(中国)有限公司 Micro services management method and system based on artificial intelligence service cloud platform
CN110278284A (en) * 2019-07-10 2019-09-24 中国民航信息网络股份有限公司 A kind of service calling method and device
CN110333917A (en) * 2019-07-19 2019-10-15 深圳前海微众银行股份有限公司 Microservice-based data processing method, device, device, and readable storage medium
CN110381143A (en) * 2019-07-19 2019-10-25 深圳前海微众银行股份有限公司 Operation, which is submitted, executes method, apparatus, equipment and computer storage medium

Also Published As

Publication number Publication date
CN110333917A (en) 2019-10-15

Similar Documents

Publication Publication Date Title
WO2021013056A1 (en) Microservice-based data processing method and apparatus, and device and readable storage medium
US10623406B2 (en) Access authentication for cloud-based shared content
CN103049684A (en) Data authority control method and data authority control system based on RBAC (role-based access control) model extension
WO2013128331A1 (en) On-demand file synchronization
CN102857537B (en) A kind of remote invocation method, device and system
US11620445B2 (en) System and method for implementing an automatic data collection and presentation generator module
US10911299B2 (en) Multiuser device staging
WO2021031905A1 (en) Data management method, apparatus, device and system and computer-readable storage medium
WO2018119589A1 (en) Account management method and apparatus, and account management system
WO2020001162A1 (en) Container management method, apparatus, and device
CN112105026B (en) Authorization control method, device and storage medium
US11461288B2 (en) Systems and methods for database management system (DBMS) discovery
CN114531486B (en) A method, device, equipment, and storage medium for industrial Internet data processing
WO2025081795A1 (en) Cloud platform access method and apparatus, electronic device, and storage medium
WO2015188568A1 (en) Public cloud-based authentication method, security authentication middleware and cloud computing resource pool
CN104410511A (en) Server management method and system
CN115495197A (en) Configuration information modification method and device, storage medium and electronic equipment
CN114090785A (en) Service processing method, device, computer equipment and storage medium
US10862747B2 (en) Single user device staging
US20240086247A1 (en) Hardware Accelerator Service Discovery
CN112583890A (en) Message pushing method and device based on enterprise office system and computer equipment
CN109992298A (en) Approval platform extension method, device, approval platform and readable storage medium
CN118786421A (en) Service map conversion with preserved history information
CN112685135A (en) Platform cluster deployment method, device and system and computer readable storage medium
CN106156339B (en) Access method, device and system of policy management system

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 20843429

Country of ref document: EP

Kind code of ref document: A1

NENP Non-entry into the national phase

Ref country code: DE

122 Ep: pct application non-entry in european phase

Ref document number: 20843429

Country of ref document: EP

Kind code of ref document: A1