CN116955324A

CN116955324A - Information processing method, service processing method and device and electronic equipment

Info

Publication number: CN116955324A
Application number: CN202311117495.1A
Authority: CN
Inventors: 薛鹏宇
Original assignee: China Construction Bank Corp; CCB Finetech Co Ltd
Current assignee: China Construction Bank Corp; CCB Finetech Co Ltd
Priority date: 2023-08-31
Filing date: 2023-08-31
Publication date: 2023-10-27

Abstract

The disclosure provides an information processing method, a business processing device and electronic equipment, which can be applied to the fields of computer technology and financial science and technology. The information processing method comprises the following steps: in response to receiving an information processing request, determining M sub-information identifiers corresponding to the information identifiers to be processed, processing type information and association relation information corresponding to the M sub-information identifiers respectively according to the information identifiers to be processed indicated by the information processing request, wherein M is a positive integer; acquiring configuration information and information to be processed corresponding to the M sub-information identifiers according to the M sub-information identifiers and the processing type information corresponding to the M sub-information identifiers respectively; processing configuration information and information to be processed, which correspond to the M sub-information identifiers respectively, according to the association relation information to obtain an information processing result; and storing the information identification to be processed and the configuration information corresponding to each of the M sub-information identifications, the information to be processed and the information processing result in a data cluster in an associated mode.

Description

Information processing method, service processing method and device and electronic equipment

Technical Field

The present disclosure relates to the field of computer technology and financial technology, and more particularly, to an information processing method and apparatus, an electronic device, a computer-readable storage medium, and a computer program product.

Background

With the development of computer technology, the volume of service data related to various services is increasing, and how to effectively implement management of service data is a problem to be solved.

In the related art, a flow management system may be used to manage service data, where a database used by the flow management system basically belongs to an unstructured database. Because the unstructured database is convenient for data circulation, modification and display, but is unfavorable for data statistics and generation of a carding report, the unstructured database needs to be independently developed for service data under the condition of data statistics.

In the process of implementing the disclosed concept, the inventor finds that at least the following problems exist in the related art: the existing flow management system is difficult to effectively count data, and cannot process multiple service data in parallel, so that the information processing efficiency cannot be guaranteed.

Disclosure of Invention

In view of this, the present disclosure provides an information processing method and apparatus, an electronic device, a computer-readable storage medium, and a computer program product.

According to an aspect of the present disclosure, there is provided an information processing method including: in response to receiving the information processing request, M sub-information identifiers corresponding to the information identifiers to be processed, processing type information and association relation information corresponding to the M sub-information identifiers are determined according to the information identifiers to be processed indicated by the information processing request, wherein M is a positive integer. And acquiring configuration information and information to be processed corresponding to the M sub-information identifiers according to the M sub-information identifiers and the processing type information corresponding to the M sub-information identifiers. And processing the configuration information and the information to be processed, which correspond to the M sub-information identifiers respectively, according to the association relation information to obtain an information processing result. And storing the information identification to be processed and the configuration information corresponding to each of the M sub-information identifications, the information to be processed and the information processing result in a data cluster in an associated mode.

According to an embodiment of the present disclosure, according to M sub-information identifiers and processing type information corresponding to the M sub-information identifiers, obtaining configuration information and information to be processed corresponding to the M sub-information identifiers includes: and acquiring configuration information corresponding to each M sub-information identifier according to the M sub-information identifiers. And acquiring the information to be processed corresponding to each of the M sub-information identifiers from the target data source corresponding to the processing type information according to the processing type information corresponding to each of the M sub-information identifiers.

According to an embodiment of the present disclosure, the process type information includes a streaming process type or a batch process type. For each of the M sub-information identifiers, when the processing type information includes a streaming processing type, according to the processing type information corresponding to each of the M sub-information identifiers, obtaining information to be processed corresponding to each of the M sub-information identifiers from a target data source corresponding to the processing type information includes: and determining a first data source identifier corresponding to the sub-information identifier according to the sub-information identifier. And responding to the monitoring of the change of the information corresponding to the sub-information identification in the first data source corresponding to the first data source identification, and acquiring the information to be processed corresponding to the sub-information identification by utilizing the acquisition thread corresponding to the sub-information identification.

According to an embodiment of the present disclosure, in case the information type information includes a batch type, the method further comprises: and determining a second data source identifier and an acquisition interface identifier corresponding to the sub-information identifier according to the sub-information identifier. And calling an acquisition interface corresponding to the acquisition interface identifier in response to the timing acquisition task being triggered. And acquiring information to be processed corresponding to the sub-information identification by using an acquisition interface.

According to the embodiment of the disclosure, storing the to-be-processed information identifier, the configuration information corresponding to each of the M sub-information identifiers, the to-be-processed information, and the information processing result in association to the data cluster includes determining a data cluster storage identifier for each of the M sub-information identifiers according to the to-be-processed information identifier and the sub-information identifier. And storing the data cluster storage identifier, the configuration information corresponding to the sub-information identifier, the information to be processed and the information processing result in a data cluster in a correlated way by using the storage thread corresponding to the sub-information identifier.

According to an embodiment of the present disclosure, processing configuration information and information to be processed, which correspond to each of M sub-information identifiers, according to association relationship information, to obtain an information processing result includes: and determining an mth target sub-information identifier in the M sub-information identifiers, wherein M is a positive integer and is smaller than or equal to M. And determining a sub-information processing result corresponding to the mth target sub-information identifier according to the mth target sub-information identifier. And processing sub-information processing results corresponding to the m target sub-information identifiers respectively according to the association relation information to obtain information processing results.

According to an embodiment of the present disclosure, the configuration information includes a first number of sub-configuration information including a configuration field name and a configuration rule corresponding to the configuration field name. The information to be processed comprises a second number of key value relations to be processed, and the key value relations to be processed comprise field names to be processed and field values to be processed corresponding to the field names to be processed.

According to an embodiment of the present disclosure, determining, according to the mth target sub-information identifier, a sub-information processing result corresponding to the mth target sub-information identifier includes: and according to the mth target sub-information identification, determining a first number of target configuration field names and a second number of target pending field names corresponding to the mth target sub-information identification. And matching the first number of target configuration field names and the second number of target to-be-processed field names to obtain a matching result. And responding to the matching result to represent that the target configuration field name is matched with the target to-be-processed field name, and processing the target to-be-processed field value corresponding to the target to-be-processed field name by utilizing a target configuration rule corresponding to the target configuration field name to obtain a processed field value. And determining a sub-information processing result corresponding to the mth target sub-information identifier according to the processing field values corresponding to the names of the second number of target to-be-processed fields.

According to an embodiment of the present disclosure, according to M sub-information identifiers, obtaining information configuration information corresponding to each of the M sub-information identifiers includes: and respectively matching N candidate sub-information identifiers in the configuration management database according to each sub-information identifier in the M sub-information identifiers to obtain a target sub-information identifier, wherein the configuration management database also comprises candidate information configuration information corresponding to the N candidate sub-information identifiers. Candidate information configuration information corresponding to the target sub-information identification is acquired.

According to an embodiment of the present disclosure, the candidate information configuration information includes P candidate sub-configuration information including a candidate configuration field name and a candidate configuration rule corresponding to the candidate configuration field name. The candidate sub-configuration information is obtained by: and in response to detecting the configuration operation corresponding to the candidate sub-information identification, acquiring a field to be configured corresponding to the configuration operation and a configuration rule corresponding to the field to be configured. And determining the field to be configured as a candidate configuration field name. The configuration rule is determined as a candidate configuration rule. And determining candidate sub-configuration information according to the candidate configuration field name and the candidate configuration rule.

According to another aspect of the present disclosure, there is provided a service processing method, including: and responding to the received service processing request from the user, and determining S data cluster storage identifiers to be matched according to S information identifiers corresponding to the service identifiers to be processed in the service processing request. And obtaining information processing results corresponding to the S data cluster storage identifiers to be matched from the data clusters. And processing the information processing results corresponding to the S data cluster storage identifiers to be matched respectively to obtain service processing results. Wherein the data clusters are obtained by the method.

According to an embodiment of the present disclosure, the service processing request further includes a presentation type identifier. The method further comprises the steps of processing information processing results corresponding to the S data cluster storage identifiers to be matched respectively to obtain service processing results: and processing the service processing result according to the display type identifier to obtain the view interface to be displayed. And displaying the view interface to be displayed to the user.

According to another aspect of the present disclosure, there is provided an information processing apparatus including a first determination module, a first acquisition module, a first processing module, and an association module. The first determining module is used for determining M sub-information identifiers corresponding to the information identifiers to be processed, processing type information and association relation information corresponding to the M sub-information identifiers respectively according to the information identifiers to be processed indicated by the information processing request, wherein M is a positive integer. The first acquisition module is used for acquiring configuration information and information to be processed corresponding to the M sub-information identifiers according to the M sub-information identifiers and the processing type information corresponding to the M sub-information identifiers. The first processing module is used for processing the configuration information and the information to be processed, which correspond to the M sub-information identifiers respectively, according to the association relation information to obtain an information processing result. And the association module is used for associating and storing the information identification to be processed and the configuration information corresponding to each of the M sub-information identifications with the information to be processed and the information processing result to the data cluster.

According to another aspect of the present disclosure, there is provided a service processing apparatus, including a second determining module, a third obtaining module, and a second processing module. And the second determining module is used for responding to the received service processing request and determining S data cluster storage identifiers to be matched corresponding to the service identifiers to be processed according to the service identifiers to be processed in the service processing request. And the third acquisition module is used for acquiring information processing results corresponding to the S data cluster storage identifiers to be matched from the data clusters. And the second processing module is used for processing the information processing results corresponding to the S data cluster storage identifiers to be matched respectively to obtain service processing results.

According to another aspect of the present disclosure, there is provided an electronic device including: one or more processors; and a memory for storing one or more instructions that, when executed by the one or more processors, cause the one or more processors to implement a method as described in the present disclosure.

According to another aspect of the present disclosure, there is provided a computer-readable storage medium having stored thereon executable instructions that, when executed by a processor, cause the processor to implement a method as described in the present disclosure.

According to another aspect of the present disclosure, there is provided a computer program product comprising computer executable instructions which, when executed, are adapted to carry out the method as described in the present disclosure.

According to the embodiment of the disclosure, since the information processing result is obtained by processing the configuration information and the information to be processed, which are respectively corresponding to the M sub-information identifiers, according to the association relation information, the configuration information and the information to be processed are obtained by determining the M sub-information identifiers determined by the information to be processed identifier indicated by the information processing request and the processing type information respectively corresponding to the M sub-information identifiers, the information processing result can be automatically determined according to the information to be processed identifier, and the information processing efficiency is improved. On the basis, the to-be-processed information identifiers, the configuration information corresponding to the M sub-information identifiers, the to-be-processed information and the information processing result are stored in the data cluster in an associated mode, so that the follow-up business processing based on the data cluster is facilitated, the technical problem that the existing flow management system in the related technology is difficult to effectively perform data statistics is at least partially solved, and the information processing efficiency and accuracy are improved.

Drawings

The above and other objects, features and advantages of the present disclosure will become more apparent from the following description of embodiments thereof with reference to the accompanying drawings in which:

fig. 1 schematically illustrates a system architecture to which an information processing method and a service processing method may be applied according to an embodiment of the present disclosure;

FIG. 2 schematically illustrates a flow chart of an information processing method according to an embodiment of the present disclosure;

FIG. 3a schematically illustrates a schematic diagram of streaming processing types in an information processing method according to an embodiment of the present disclosure;

FIG. 3b schematically illustrates a schematic diagram of batch processing types in an information processing method according to an embodiment of the present disclosure;

fig. 4a schematically illustrates a schematic diagram of processing sub-information processing results corresponding to m target sub-information identifiers according to association relationship information in an information processing method according to an embodiment of the present disclosure, to obtain information processing results;

fig. 4b schematically illustrates a schematic diagram of matching a first number of target configuration field names and a second number of target pending field names with each other in an information processing method according to an embodiment of the present disclosure, resulting in a matching result;

fig. 4c schematically illustrates a schematic diagram of processing a target to-be-processed field value corresponding to a target to-be-processed field name by using a target configuration rule corresponding to the target configuration field name in an information processing method according to an embodiment of the present disclosure, to obtain a processed field value;

Fig. 5a schematically illustrates a schematic diagram of matching N candidate sub-information identifiers in a configuration management database according to sub-information identifiers for each of M sub-information identifiers in an information processing method according to an embodiment of the present disclosure, to obtain a target sub-information identifier;

FIG. 5b schematically illustrates a schematic diagram of determining candidate sub-configuration information according to candidate configuration field names and candidate configuration rules in an information processing method according to an embodiment of the present disclosure;

FIG. 6 schematically illustrates a flow chart of a business processing method according to an embodiment of the disclosure;

fig. 7 schematically illustrates a schematic diagram of a view interface to be presented in a service processing method according to an embodiment of the present disclosure;

fig. 8 schematically shows a block diagram of an information processing apparatus according to an embodiment of the present disclosure;

fig. 9 schematically illustrates a block diagram of a traffic processing apparatus according to an embodiment of the present disclosure; and

fig. 10 schematically illustrates a block diagram of an electronic device adapted to implement an information processing method and a business processing method according to an embodiment of the present disclosure.

Detailed Description

Hereinafter, embodiments of the present disclosure will be described with reference to the accompanying drawings. It should be understood that the description is only exemplary and is not intended to limit the scope of the present disclosure. In the following detailed description, for purposes of explanation, numerous specific details are set forth in order to provide a thorough understanding of the embodiments of the present disclosure. It may be evident, however, that one or more embodiments may be practiced without these specific details. In addition, in the following description, descriptions of well-known structures and techniques are omitted so as not to unnecessarily obscure the concepts of the present disclosure.

The terminology used herein is for the purpose of describing particular embodiments only and is not intended to be limiting of the disclosure. The terms "comprises," "comprising," and/or the like, as used herein, specify the presence of stated features, steps, operations, and/or components, but do not preclude the presence or addition of one or more other features, steps, operations, or components.

All terms (including technical and scientific terms) used herein have the same meaning as commonly understood by one of ordinary skill in the art unless otherwise defined. It should be noted that the terms used herein should be construed to have meanings consistent with the context of the present specification and should not be construed in an idealized or overly formal manner.

Where expressions like at least one of "A, B and C, etc. are used, the expressions should generally be interpreted in accordance with the meaning as commonly understood by those skilled in the art (e.g.," a system having at least one of A, B and C "shall include, but not be limited to, a system having a alone, B alone, C alone, a and B together, a and C together, B and C together, and/or A, B, C together, etc.).

In the technical scheme of the invention, the related user information (including but not limited to user personal information, user image information, user equipment information, such as position information and the like) and data (including but not limited to data for analysis, stored data, displayed data and the like) are information and data authorized by a user or fully authorized by all parties, and the processing of the related data such as collection, storage, use, processing, transmission, provision, disclosure, application and the like are all conducted according to the related laws and regulations and standards of related countries and regions, necessary security measures are adopted, no prejudice to the public welfare is provided, and corresponding operation inlets are provided for the user to select authorization or rejection.

In order to at least partially solve the technical problems in the related art, the present disclosure provides an information processing method, a service processing device, and an electronic device, which can be applied to the fields of computer technology and financial science and technology. The information processing method comprises the following steps: in response to receiving an information processing request, determining M sub-information identifiers corresponding to the information identifiers to be processed, processing type information and association relation information corresponding to the M sub-information identifiers respectively according to the information identifiers to be processed indicated by the information processing request, wherein M is a positive integer; acquiring configuration information and information to be processed corresponding to the M sub-information identifiers according to the M sub-information identifiers and the processing type information corresponding to the M sub-information identifiers respectively; processing configuration information and information to be processed, which correspond to the M sub-information identifiers respectively, according to the association relation information to obtain an information processing result; and storing the information identification to be processed and the configuration information corresponding to each of the M sub-information identifications, the information to be processed and the information processing result in a data cluster in an associated mode.

It should be noted that the information processing method, the service processing method and the device provided by the embodiments of the present disclosure may be used in the fields of computer technology and financial technology, for example, in the field of internet technology. The information processing method, the business processing method and the business processing device provided by the embodiment of the disclosure can also be applied to any field except the fields of computer technology and financial science and technology, for example, the information security technical field. The application fields of the information processing method, the service processing method and the device provided by the embodiment of the disclosure are not limited.

Fig. 1 schematically illustrates a system architecture to which an information processing method and a service processing method may be applied according to an embodiment of the present disclosure. It should be noted that fig. 1 is only an example of a system architecture to which embodiments of the present disclosure may be applied to assist those skilled in the art in understanding the technical content of the present disclosure, but does not mean that embodiments of the present disclosure may not be used in other devices, systems, environments, or scenarios.

As shown in fig. 1, a system architecture 100 according to this embodiment may include a first terminal device 101, a second terminal device 102, a third terminal device 103, a network 104, and a server 105. The network 104 is a medium used to provide a communication link between the first terminal device 101, the second terminal device 102, the third terminal device 103, and the server 105. The network 104 may include various connection types, such as wired, wireless communication links, or fiber optic cables, among others.

The user may interact with the server 105 through the network 104 using at least one of the first terminal device 101, the second terminal device 102, the third terminal device 103, to receive or send messages, etc. Various communication client applications, such as a shopping class application, a web browser application, a search class application, an instant messaging tool, a mailbox client, social platform software, etc. (by way of example only) may be installed on the first terminal device 101, the second terminal device 102, and the third terminal device 103.

The first terminal device 101, the second terminal device 102, the third terminal device 103 may be various electronic devices having a display screen and supporting web browsing, including but not limited to smartphones, tablets, laptop and desktop computers, and the like.

The server 105 may be a server providing various services, such as a background management server (by way of example only) providing support for websites browsed by the user using the first terminal device 101, the second terminal device 102, and the third terminal device 103. The background management server may analyze and process the received data such as the user request, and feed back the processing result (e.g., the web page, information, or data obtained or generated according to the user request) to the terminal device.

It should be noted that the information processing method and the service processing method provided by the embodiments of the present disclosure may be generally executed by the server 105. Accordingly, the information processing apparatus and the service processing apparatus provided by the embodiments of the present disclosure may be generally provided in the server 105. The information processing method provided by the embodiment of the present disclosure may also be performed by a server or a server cluster that is different from the server 105 and is capable of communicating with the first terminal device 101, the second terminal device 102, the third terminal device 103, and/or the server 105. Accordingly, the information processing apparatus and the service processing apparatus provided by the embodiments of the present disclosure may also be provided in a server or a server cluster that is different from the server 105 and is capable of communicating with the first terminal apparatus 101, the second terminal apparatus 102, the third terminal apparatus 103, and/or the server 105.

Alternatively, the information processing method and the service processing method provided by the embodiments of the present disclosure may also be performed by the first terminal device 101, the second terminal device 102, or the third terminal device 103, or may also be performed by other terminal devices different from the first terminal device 101, the second terminal device 102, or the third terminal device 103. Accordingly, the information processing apparatus and the service processing apparatus provided by the embodiments of the present disclosure may also be provided in the first terminal apparatus 101, the second terminal apparatus 102, or the third terminal apparatus 103, or in other terminal apparatuses different from the first terminal apparatus 101, the second terminal apparatus 102, or the third terminal apparatus 103.

It should be understood that the number of terminal devices, networks and servers in fig. 1 is merely illustrative. There may be any number of terminal devices, networks, and servers, as desired for implementation.

It should be noted that the sequence numbers of the respective operations in the following methods are merely representative of the operations for the purpose of description, and should not be construed as representing the order of execution of the respective operations. The method need not be performed in the exact order shown unless explicitly stated.

Fig. 2 schematically shows a flowchart of an information processing method according to an embodiment of the present disclosure.

As shown in fig. 2, the information processing method includes operations S210 to S240.

In operation S210, in response to receiving the information processing request, M sub-information identifiers corresponding to the information identifiers to be processed, processing type information and association relationship information corresponding to the M sub-information identifiers, respectively, are determined according to the information identifiers to be processed indicated by the information processing request, where M is a positive integer.

In operation S220, according to the M sub-information identifiers and the processing type information corresponding to each of the M sub-information identifiers, configuration information and information to be processed corresponding to each of the M sub-information identifiers are obtained.

In operation S230, the configuration information and the information to be processed corresponding to each of the M sub-information identifiers are processed according to the association relationship information, so as to obtain an information processing result.

In operation S240, the to-be-processed information identifier, the configuration information corresponding to each of the M sub-information identifiers, and the to-be-processed information, and the information processing result are stored in association with the data cluster.

According to an embodiment of the present disclosure, the information to be processed characterizes acquisition information to be processed or/and service information to be processed. The information to be processed can be real-time acquisition service information or/and service information stored in a database. The information to be processed identifier characterizes a unique identifier of the information to be processed. The information identification to be processed may include at least one of: service type number and service name. It should be noted that the identification of the information to be processed is not limited to the service type number and the service name, and other forms of the unique identification capable of characterizing the information to be processed are also possible.

According to an embodiment of the present disclosure, the sub-information identification characterizes a unique identification of the sub-information in the information to be processed. The sub-information identification may be a name of the sub-information. For example, M is equal to 2, the information to be processed is account opening information, and the account opening information includes an account opening name and an account opening address. The information identification to be processed may be a service name "account opening information". The sub-information identification may be the name of the sub-information, such as "account opening name", "account opening address".

According to embodiments of the present disclosure, process type information may be used to characterize the manner of processing. The processing type information may be unified processing or may be separate processing. The association relationship information characterizes the association relationship between the sub-information. For example, the association relationship information may be the order of processing between the respective pieces of sub information.

According to an embodiment of the present disclosure, the configuration information characterizes the processing rules of the sub-information. The configuration information may include at least one of: the field rule information of the sub information and the template rule information of the sub information. For example, the processing rule information of the sub information "account name" is field rule information.

According to the embodiment of the disclosure, the data cluster characterization can be used for storing the to-be-processed information identification, the configuration information corresponding to each of the M sub-information identifications, the to-be-processed information and the storage space of the information processing result in an associated mode. For example, the data clusters may be distributed storage clusters, kafka, and the like.

For example, the identification to be information processed may be "business change". M is equal to 3. The 3 sub-information identifications corresponding to the information identification to be processed 'service change' are respectively 'account name', 'original service' and 'new service'. The process type information corresponding to the sub information identification "account name" and "original service" and "new service" is batch processing. The association relation information can be to process the sub-information 'account name', process the sub-information 'new service', and process the sub-information 'original service'. On this basis, the processing type information corresponding to the new service is unified processing to acquire configuration information corresponding to the 3 sub-information identifications as field rule information. And obtaining the information to be processed corresponding to the 3 sub-information identifiers. And processing the configuration information and the information to be processed corresponding to the 3 sub-information identifiers respectively according to the association relation of the sub-information account name processed firstly and the sub-information new service processed secondly and the sub-information original service processed finally, so as to obtain an information processing result. And storing the information identification to be processed and the configuration information corresponding to the 3 sub-information identifications respectively, and the information to be processed and the information processing result in a data cluster in an associated mode.

According to the embodiment of the disclosure, since the information processing result is obtained by processing the configuration information and the information to be processed, which are respectively corresponding to the M sub-information identifiers, according to the association relation information, the configuration information and the information to be processed are obtained by determining the M sub-information identifiers determined by the information to be processed identifier indicated by the information processing request and the processing type information respectively corresponding to the M sub-information identifiers, the information processing result can be automatically determined according to the information to be processed identifier, and the information processing efficiency is improved. On the basis, the to-be-processed information identifiers, the configuration information corresponding to the M sub-information identifiers, the to-be-processed information and the information processing result are stored in the data cluster in an associated mode, so that the follow-up business processing based on the data cluster is facilitated, the technical problem that the existing flow management system in the related technology is difficult to effectively perform data statistics is at least partially solved, and the information processing efficiency and accuracy are improved. .

According to the embodiment of the disclosure, the target data source characterizes the original storage space of M pieces of sub-information identification respectively corresponding to the information to be processed. The target Data source may be a business database, mongo db (Mongo Data Base ).

For example, M is equal to 2. And acquiring configuration information corresponding to the sub-information identifiers 'A' and 'B' according to the 2 sub-information identifiers 'A' and 'B', respectively. The configuration information corresponding to the sub information identification "a" may be field rule information. The configuration information corresponding to the sub-information identification "B" may be template rule information.

The sub-information identifiers "a" and "B" respectively correspond to the processing type information being unified processing and processing respectively. The target data source corresponding to the processing type information "unified processing" may be MongoDB. The target data source corresponding to the processing type information "unified processing" may be a local service database.

And acquiring the information to be processed corresponding to the sub-information identifier 'A' according to the target data source MongoDB of the sub-information identifier 'A'. And acquiring the information to be processed corresponding to the sub-information identifier 'B' according to the target data source local service database of the sub-information identifier 'B'.

According to the embodiment of the disclosure, the configuration information and the information to be processed corresponding to the M sub-information identifiers are acquired according to the M sub-information identifiers, so that the integrity of the acquired information can be ensured, and on the basis, the information processing can be performed according to the configuration information corresponding to the M sub-information identifiers, so that the efficiency of the information processing can be improved.

According to an embodiment of the present disclosure, the streaming class characterizes the process of information processing by streaming collection of sub-information. The batch processing type characterization sub-information is subjected to batch acquisition to carry out information processing. The acquisition thread characterizes the execution flow of the acquisition. For example. The acquisition thread may be "acquire sub information from MongoDB, put sub information into kafka".

For example, the processing type information corresponding to the sub-information identifier is a streaming processing type, and it may be determined that the first data source identifier corresponding to the sub-information identifier is Mysql (My Structured Query Language, structured query language) according to the sub-information identifier. The first data source is for storing sub-information. Through Binlog monitoring processing of Mysql, whether information corresponding to the sub information identifier in Mysql is changed or not can be monitored. When the information corresponding to the sub-information identification in the first data source corresponding to the first data source identification is monitored to be changed, the sub-information is acquired from Mysql by utilizing the acquisition thread corresponding to the sub-information identification, and the sub-information is put into kafka, so that the information to be processed corresponding to the sub-information identification is acquired. The information corresponding to the sub-information identification may be changed including at least one of: add (i.e., add), delete (i.e., delete), update (i.e., update), and Reload (i.e., reload).

For example, the first data source identifier corresponding to the sub-information identifier is mongadb, and the debezum plug-in may be used to determine whether the information corresponding to the sub-information identifier in the mongadb database is changed. When the information corresponding to the sub information identification in the first data source corresponding to the first data source identification is monitored to be changed, the sub information is acquired from the MongoDB by utilizing the acquisition thread corresponding to the sub information identification, and the sub information is put into the kafka, so that the information to be processed corresponding to the sub information identification is acquired, and the real-time data acquisition is realized.

According to the embodiment of the disclosure, by monitoring that the information corresponding to the sub-information identifier in the first data source corresponding to the first data source identifier is changed and using the acquisition thread corresponding to the sub-information identifier, the information to be processed corresponding to the sub-information identifier is acquired, real-time data acquisition of the changed sub-information can be realized, and the efficiency of subsequent information processing is improved.

According to an embodiment of the present disclosure, the acquisition interface identification characterizes an interface identification of the acquisition sub-information. For example, the acquisition interface identifier may be a business API (Application Programming Interface ) interface.

According to an embodiment of the disclosure, batch processing may be information processing by introducing a batch running module through a xxl-job (distributed task scheduling platform). The run module can provide timed, single, sliced, etc. paged configurations.

For example, according to the sub-information identification "a", a second data source identification "service database" and an acquisition interface identification "service API interface" corresponding to the sub-information identification "a" are determined. And triggering a timing acquisition task in the running module, and calling an acquisition interface corresponding to an acquisition interface identifier of 'service API interface'. And acquiring information to be processed corresponding to the sub-information identification by using an acquisition interface.

According to the embodiment of the disclosure, the acquisition interface corresponding to the acquisition interface identifier is called in response to the triggering of the timing acquisition task, so that the information to be processed corresponding to the sub-information identifier is acquired, the timing acquisition of the sub-information under the condition of batch processing type can be realized, and the efficiency of subsequent information processing is improved.

Fig. 3a schematically shows a schematic diagram of streaming processing types in an information processing method according to an embodiment of the present disclosure.

As shown in fig. 3a, a schematic diagram 300a of a streaming processing type in the information processing method includes a first data source 301, a streaming acquisition module 302, kafka 303, streaming processing information 304, an external interface 305, a configuration management database 306, a storage database 307, and a data arrangement result 30S.

For example, a first data source identifier corresponding to the sub-information identifier is determined according to the sub-information identifier. The stream collecting module 302 may monitor that the information corresponding to the sub-information identifier in the first data source 301 corresponding to the first data source identifier is changed, obtain the information to be processed corresponding to the sub-information identifier by using the collecting thread corresponding to the sub-information identifier, and store the information to be processed in the kafka 303. On this basis, the information to be processed can be processed through the external interface 305, the configuration management database 306 and the storage database 307 to obtain the streaming processing information 304. The stream processing information 304 is stored in the kafka 303. The stream processing information in kafka 303 is subjected to data arrangement to obtain a data arrangement result 308.

Fig. 3b schematically shows a schematic diagram of batch processing types in an information processing method according to an embodiment of the present disclosure.

As shown in fig. 3b, the schematic diagram 300b of batch processing type in the information processing method includes a second data source 309, an acquisition interface 310, a batch acquisition module 311, kafka 303, batch processing information 312, configuration management rules 313, data planning rules 314, and data sort results 308.

And determining a second data source identifier and an acquisition interface identifier corresponding to the sub-information identifier according to the sub-information identifier. Batch acquisition may be when a timed acquisition task is triggered, invoking an acquisition interface 310 corresponding to an acquisition interface identification. The collection interface 310 is used to obtain the information to be processed corresponding to the sub-information identifier from the second data source 309 corresponding to the second data source identifier.

The information to be processed is stored in kafka 303. The information to be processed is processed through the external interface 305, the configuration management database 306 and the storage database 307 in fig. 3a to obtain batch processing information 312. Batch information 312 is then stored in kafka 303. The batch processing information in kafka 303 is subjected to data arrangement to obtain a data arrangement result 308.

Alternatively, the information to be processed is also called by the scheduler, and is processed using the configuration management rule 313, the data planning rule 314, and the like, to obtain the batch processing information 312. Based on the batch processing information 312, a data sort result 308 is determined.

According to the embodiment of the disclosure, storing the to-be-processed information identifier, the configuration information corresponding to each of the M sub-information identifiers, the to-be-processed information, and the information processing result in association to the data cluster includes determining a data cluster storage identifier for each of the M sub-information identifiers according to the to-be-processed information identifier and the sub-information identifier. And storing the data cluster storage identifier, the configuration information corresponding to the sub-information identifier, the information to be processed and the information processing result in a data cluster in a correlated manner by using the storage thread corresponding to the sub-information identifier.

According to an embodiment of the present disclosure, a data cluster stores a hash value identifying a unique key in service information characterizing information to be processed. The storage thread characterizes the storage execution flow of the sub-information. For example, the storage thread may be "store kafka first, perform information processing, store the information obtained after the processing in kafka".

According to the embodiment of the disclosure, the data cluster characterizes a storage space for storing the data cluster storage identifier, configuration information corresponding to the sub-information identifier, information to be processed and information processing results in an associated manner. For example, the data cluster may be kafka.

According to the embodiment of the disclosure, the storage thread corresponding to the sub-information identifier is utilized to store the data cluster storage identifier, the configuration information corresponding to the sub-information identifier, the information to be processed and the information processing result in a correlated manner to the data cluster, so that the subsequent data call is facilitated. In addition, the coupling between the memory modules is lower, so that the technical means of information processing are more diversified.

According to an embodiment of the present disclosure, processing configuration information and information to be processed, which correspond to each of M sub-information identifiers, according to association relationship information, to obtain an information processing result includes: and determining an mth target sub-information identifier in the M sub-information identifiers, wherein M is a positive integer and is smaller than or equal to M. And determining a sub-information processing result corresponding to the mth target sub-information identifier according to the mth target sub-information identifier. And processing the sub-information processing results corresponding to the m target sub-information identifiers respectively according to the association relation information to obtain information processing results.

According to an embodiment of the present disclosure, the configuration information characterizes the processing rules of the sub-information. The configuration information may be field rules. In this case, the sub information may be configuration mapped using field rules in order to enable automatic information processing.

Fig. 4a schematically illustrates a schematic diagram of processing sub-information processing results corresponding to m target sub-information identifiers according to association relationship information in an information processing method according to an embodiment of the present disclosure, to obtain information processing results.

As shown in fig. 4a, this embodiment includes m target sub-information identifications respectively corresponding to sub-information processing results 401, association relationship information 402, and information processing results 403.

For example, M is equal to 3 and M is equal to 1. In this case, the 1 st target sub-information identification may be determined among the 3 sub-information identifications. And determining a sub-information processing result corresponding to the 1 st target sub-information identifier according to the 1 st target sub-information identifier. Sub-information processing results 401 corresponding to the 1 target sub-information identifications are processed according to the association relation information 402, and information processing results 403 are obtained.

According to the embodiment of the disclosure, sub-information processing results corresponding to the m target sub-information identifications are processed according to the association relation information to obtain the information processing results, so that the efficiency of the information processing process is improved, and meanwhile, the accuracy of the information processing results is improved.

For example, the configuration field name in the sub-configuration information may be "source filed code", and the processed sub-information may be "processed field: the model field ", the configuration rule corresponding to the configuration field name may be a field rule". The second number of key-value relationships to be processed may also be the corresponding conversions between key-values, or may be a module rule type.

According to the embodiment of the disclosure, according to the mth target sub-information identification, a first number of target configuration field names and a second number of target pending field names corresponding to the mth target sub-information identification are determined.

Fig. 4b schematically illustrates a schematic diagram of matching a first number of target configuration field names and a second number of target pending field names with each other in an information processing method according to an embodiment of the present disclosure, to obtain a matching result.

As shown in fig. 4b, this embodiment includes a first number of target configuration field names 404, a second number of target pending field names 405, and a match result 406.

The first number of target configuration field names 404 and the second number of target pending field names 405 are matched with each other to obtain a matching result 406.

For example, the first number of target configuration field names 404 may be "a files", the second number of target pending field names 405 may be "B files", and matching the "a files" with the "B files" results in a match that the first number of target configuration field names 404 do not match the second number of target pending field names 405.

For example, the first number of target configuration field names 404 may be "a files", the second number of target pending field names 405 may be "a files", and matching the "a files" with the "a files" results in a match between the first number of target configuration field names 404 and the second number of target pending field names 405.

Fig. 4c schematically illustrates a schematic diagram of processing a target pending field value corresponding to a target pending field name with a target configuration rule corresponding to the target configuration field name in an information processing method according to an embodiment of the present disclosure, to obtain a processed field value.

As shown in fig. 4c, this embodiment includes a target configuration rule 407 corresponding to a target configuration field name, a target pending field value 408 corresponding to a target pending field name, and a processing field value 409.

In the case where the matching result 406 characterizes that the target configuration field name and the target to-be-processed field name match, the target to-be-processed field value 408 corresponding to the target to-be-processed field name is processed by using the target configuration rule 407 corresponding to the target configuration field name, to obtain the processed field value 409.

According to the embodiment of the disclosure, the sub-information processing result corresponding to the mth target sub-information identification is determined according to the processing field values corresponding to the second number of target to-be-processed field names. For example, the field names to be processed may include at least one of: personnel, departments, groups of users, dropdown, radio, cascading, and the like.

According to the embodiment of the disclosure, the first number of target configuration field names and the second number of target to-be-processed field names are matched with each other, so that the target to-be-processed field values corresponding to the target to-be-processed field names are processed by utilizing the target configuration rule corresponding to the target configuration field names, sub-information processing results are obtained, and the information processing efficiency and the accuracy of the information processing results can be improved.

Fig. 5a schematically illustrates a schematic diagram of matching N candidate sub-information identifiers in a configuration management database according to sub-information identifiers for each of M sub-information identifiers in an information processing method according to an embodiment of the present disclosure, to obtain a target sub-information identifier.

As shown in fig. 5a, this embodiment includes a sub-information identification 501, and N candidate sub-information identifications 502 and a target sub-information identification 503 in the configuration management database.

For each sub-information identifier 501 in the M sub-information identifiers, according to the sub-information identifier 501, N candidate sub-information identifiers 502 in the configuration management database are respectively matched to obtain a target sub-information identifier 503. Candidate information configuration information corresponding to the target sub-information identification 503 is acquired.

According to an embodiment of the present disclosure, candidate information configuration information corresponding to each of the N candidate sub-information identifications may also be included in the configuration management database.

According to the embodiment of the disclosure, the N candidate sub-information identifiers in the configuration management database are respectively matched according to the sub-information identifiers to obtain the target sub-information identifiers, so that candidate information configuration information corresponding to the target sub-information identifiers is obtained, the configuration information is accurately queried, and the efficiency of subsequent information processing is improved.

According to an embodiment of the present disclosure, the candidate information configuration information includes P candidate sub-configuration information including a candidate configuration field name and a candidate configuration rule corresponding to the candidate configuration field name.

According to an embodiment of the present disclosure, in response to detecting a configuration operation corresponding to a candidate sub-information identification, a field to be configured corresponding to the configuration operation and a configuration rule corresponding to the field to be configured are acquired. And determining the field to be configured as a candidate configuration field name. The configuration rule is determined as a candidate configuration rule.

Fig. 5b schematically illustrates a schematic diagram of determining candidate sub-configuration information according to candidate configuration field names and candidate configuration rules in an information processing method according to an embodiment of the present disclosure.

As shown in fig. 5b, this embodiment includes candidate configuration field names 504, candidate configuration rules 505, and candidate sub-configuration information 506. Candidate sub-configuration information 506 may be determined based on candidate configuration field names 504 and candidate configuration rules 505.

According to the embodiment of the disclosure, the candidate sub-configuration information is determined according to the candidate configuration field name and the candidate configuration rule, so that the accurate query of the sub-configuration information can be realized, and the efficiency of subsequent information processing is improved.

Fig. 6 schematically shows a flow chart of a traffic handling method according to an embodiment of the present disclosure.

As shown in fig. 6, the service processing method of this embodiment includes operations S610 to S630.

In operation S610, in response to receiving a service processing request from a user, S data cluster storage identifiers to be matched are determined according to S information identifiers corresponding to service identifiers to be processed in the service processing request.

In operation S620, information processing results corresponding to the storage identifiers of the S data clusters to be matched are obtained from the data clusters.

In operation S630, the information processing results corresponding to the S data cluster storage identifiers to be matched are processed, so as to obtain service processing results.

According to an embodiment of the present disclosure, a data cluster is obtained by the above-described information processing method.

For example, S equals 2. And receiving a service processing request from a user, and determining 2 data cluster storage identifiers to be matched according to 2 information identifiers corresponding to the service identifiers to be processed in the service processing request. The data cluster storage identities to be matched may be kafka and Mysql, respectively.

On this basis, the information processing result corresponding to kafka may be acquired from the data cluster, and the information processing result corresponding to Mysql may be acquired from the data cluster. And processing the two information processing results to obtain a service processing result.

According to the embodiment of the disclosure, the information processing results corresponding to the S data cluster storage identifiers to be matched are obtained from the data clusters, so that the information processing results corresponding to the S data cluster storage identifiers to be matched are processed, service processing results are obtained, the technical problem that various service data cannot be processed in parallel in the related art is at least partially solved, and the adaptability and the efficiency of service processing are improved.

According to embodiments of the present disclosure, the presentation type identification may include at least one of: report type identification, large screen type identification or data aggregation identification.

For example, a view tool may be accessed to expose a view interface to be presented. For example, the view tool may be a da vinci view tool. The view tool may provide a presentation of report types, large screen types, data aggregation types.

Fig. 7 schematically illustrates a schematic diagram of a view interface to be presented in a service processing method according to an embodiment of the disclosure.

As shown in fig. 7, the view interface 700 to be presented in this embodiment may have a list type 701, a column type 702, a pie type 703, and the like.

According to the embodiment of the disclosure, the service processing result is processed according to the display type identifier to obtain the view interface to be displayed, and the view interface to be displayed is displayed to the user, so that the real-time display of the service processing result is realized, and the user experience can be improved.

Fig. 8 schematically shows a block diagram of an information processing apparatus according to an embodiment of the present disclosure.

As shown in fig. 8, the information processing apparatus 800 may include a first determination module 810, a first acquisition module 820, a second acquisition module 830, and a first processing module 840.

The first determining module 810 is configured to determine, in response to receiving the information processing request, M sub-information identifiers corresponding to the information identifiers to be processed, information type information and association relationship information corresponding to the M sub-information identifiers, where M is a positive integer, according to the information identifiers to be processed indicated by the information processing request. In an embodiment, the first determining module 810 may be used to perform the operation S210 described above, which is not described herein.

The first obtaining module 820 is configured to obtain, according to the M sub-information identifiers, configuration information corresponding to each of the M sub-information identifiers. In an embodiment, the first obtaining module 820 may be used to perform the operation S220 described above, which is not described herein.

The second obtaining module 830 is configured to obtain, from a data source corresponding to the information type information, information to be processed corresponding to each of the M sub-information identifiers according to the information type information corresponding to each of the M sub-information identifiers. In an embodiment, the second obtaining module 830 may be configured to perform the operation S230 described above, which is not described herein.

The first processing module 840 is configured to process the information configuration information and the information to be processed corresponding to each of the M sub-information identifiers according to the association relationship information, to obtain an information processing result. In an embodiment, the first processing module 840 may be configured to perform the operation S240 described above, which is not described herein.

According to an embodiment of the present disclosure, the first acquisition module 810 includes a first acquisition sub-module and a second acquisition sub-module. The first acquisition sub-module is used for acquiring configuration information corresponding to the M sub-information identifiers respectively according to the M sub-information identifiers. And the second acquisition sub-module is used for acquiring the information to be processed corresponding to each of the M sub-information identifiers from the target data source corresponding to the processing type information according to the processing type information corresponding to each of the M sub-information identifiers.

According to an embodiment of the present disclosure, the process type information includes a streaming process type or a batch process type. The second acquisition submodule includes a first determination unit and a first acquisition unit. A first determining unit, configured to determine, for each of the M sub-information identifiers, a first data source identifier corresponding to the sub-information identifier according to the sub-information identifier in a case where the processing type information includes a streaming processing type. The first obtaining unit is configured to obtain, for each sub-information identifier in the M sub-information identifiers, to-be-processed information corresponding to the sub-information identifier by using an acquisition thread corresponding to the sub-information identifier in response to monitoring that information corresponding to the sub-information identifier in the first data source corresponding to the first data source identifier is changed when the processing type information includes a streaming processing type.

According to an embodiment of the disclosure, the second acquisition sub-module further comprises a second determination unit, a calling unit and a second acquisition unit. And the second determining unit is used for determining a second data source identifier and an acquisition interface identifier corresponding to the sub-information identifier according to the sub-information identifier when the information type information comprises the batch processing type. And the calling unit is used for calling the acquisition interface corresponding to the acquisition interface identifier in response to the triggering of the timing acquisition task. The second acquisition unit is used for acquiring the information to be processed corresponding to the sub-information identification by utilizing the acquisition interface.

According to an embodiment of the present disclosure, the association module includes a first determination sub-module and an association sub-module. The first determining sub-module is used for determining a data cluster storage identifier according to the information identifier to be processed and the sub-information identifier aiming at each sub-information identifier in the M sub-information identifiers. And the association sub-module is used for associating and storing the data cluster storage identification, the configuration information corresponding to the sub-information identification, the information to be processed and the information processing result into the data cluster by using the storage thread corresponding to the sub-information identification.

According to an embodiment of the present disclosure, the first processing module includes a second determination sub-module, a third determination sub-module, and a first processing sub-module. And the second determining sub-module is used for determining an mth target sub-information identifier in M sub-information identifiers, wherein M is a positive integer and is smaller than or equal to M. And the third determining sub-module is used for determining a sub-information processing result corresponding to the mth target sub-information identifier according to the mth target sub-information identifier. And the first processing sub-module is used for processing sub-information processing results corresponding to the m target sub-information identifiers respectively according to the association relation information to obtain information processing results.

According to an embodiment of the present disclosure, the third determination submodule includes a third determination unit, a first matching unit, a processing unit, and a fourth determination unit. And the third determining unit is used for determining the first number of target configuration field names and the second number of target pending field names corresponding to the mth target sub-information identification according to the mth target sub-information identification. The first matching unit is used for matching the first number of the target configuration field names and the second number of the target pending field names to obtain a matching result. And the processing unit is used for responding to the matching result to represent that the target configuration field name is matched with the target field name to be processed, and processing the target field value corresponding to the target field name to be processed by utilizing the target configuration rule corresponding to the target configuration field name to obtain a processed field value. And a fourth determining unit, configured to determine a sub-information processing result corresponding to the mth target sub-information identifier according to the processing field values corresponding to the second number of target to-be-processed field names.

According to an embodiment of the disclosure, the first acquisition sub-module comprises a second matching unit and a third acquisition unit. The second matching unit is used for respectively matching N candidate sub-information identifiers in the configuration management database according to the sub-information identifiers aiming at each sub-information identifier in the M sub-information identifiers to obtain a target sub-information identifier, wherein the configuration management database also comprises candidate information configuration information corresponding to the N candidate sub-information identifiers. And a third acquisition unit, configured to acquire candidate information configuration information corresponding to the target sub-information identifier.

Any number of modules, sub-modules, units, sub-units, or at least some of the functionality of any number of the sub-units according to embodiments of the present disclosure may be implemented in one module. Any one or more of the modules, sub-modules, units, sub-units according to embodiments of the present disclosure may be implemented as split into multiple modules. Any one or more of the modules, sub-modules, units, sub-units according to embodiments of the present disclosure may be implemented at least in part as a hardware circuit, such as a Field Programmable Gate Array (FPGA), a Programmable Logic Array (PLA), a system-on-chip, a system-on-substrate, a system-on-package, an Application Specific Integrated Circuit (ASIC), or in any other reasonable manner of hardware or firmware that integrates or encapsulates the circuit, or in any one of or a suitable combination of three of software, hardware, and firmware. Alternatively, one or more of the modules, sub-modules, units, sub-units according to embodiments of the present disclosure may be at least partially implemented as computer program modules, which when executed, may perform the corresponding functions.

For example, any of the first determining module 810, the first acquiring module 820, the second acquiring module 830, and the first processing module 840 may be combined in one module/unit/sub-unit, or any one of the modules/units/sub-units may be split into a plurality of modules/units/sub-units. Alternatively, at least some of the functionality of one or more of these modules/units/sub-units may be combined with at least some of the functionality of other modules/units/sub-units and implemented in one module/unit/sub-unit. According to embodiments of the present disclosure, at least one of the first determination module 810, the first acquisition module 820, the second acquisition module 830, and the first processing module 840 may be implemented at least in part as hardware circuitry, such as a Field Programmable Gate Array (FPGA), a Programmable Logic Array (PLA), a system on a chip, a system on a substrate, a system on a package, an Application Specific Integrated Circuit (ASIC), or may be implemented in hardware or firmware in any other reasonable manner of integrating or packaging the circuitry, or in any one of or a suitable combination of three of software, hardware, and firmware. Alternatively, at least one of the first determination module 810, the first acquisition module 820, the second acquisition module 830, and the first processing module 840 may be at least partially implemented as computer program modules, which when executed, may perform the respective functions.

It should be noted that, in the embodiment of the present disclosure, the information processing apparatus portion corresponds to the information processing method portion in the embodiment of the present disclosure, and the description of the information processing apparatus portion specifically refers to the information processing method portion, which is not described herein.

Fig. 9 schematically illustrates a block diagram of a traffic processing apparatus according to an embodiment of the present disclosure.

As shown in fig. 9, the service processing apparatus 900 may include a second determining module 910, a second acquiring module 920, and a second processing module 930.

The second determining module 910 is configured to determine, in response to receiving the service processing request, S to-be-matched data cluster storage identifiers corresponding to the to-be-processed service identifiers according to the to-be-processed service identifiers in the service processing request. In an embodiment, the second determining module 910 may be configured to perform the operation S610 described above, which is not described herein.

The second obtaining module 920 is configured to obtain information processing results corresponding to the S data cluster storage identifiers to be matched from the data clusters. In an embodiment, the second obtaining module 920 may be configured to perform the operation S620 described above, which is not described herein.

And the second processing module 930 is configured to process the information processing results corresponding to the S data cluster storage identifiers to be matched, so as to obtain a service processing result. In an embodiment, the second processing module 930 may be configured to perform the operation S630 described above, which is not described herein.

According to an embodiment of the present disclosure, the service processing request further includes a presentation type identifier. The service processing device also comprises a third processing module and a display module. The third processing module is configured to process information processing results corresponding to the S data cluster storage identifiers to be matched, and obtain service processing results: and processing the service processing result according to the display type identifier to obtain the view interface to be displayed. The display module is used for processing the information processing results corresponding to the S data cluster storage identifiers to be matched respectively to obtain service processing results: and displaying the view interface to be displayed to the user.

For example, any of the second determining module 910, the second obtaining module 920, and the second processing module 930 may be combined in one module/unit/sub-unit, or any of the modules/units/sub-units may be split into a plurality of modules/units/sub-units. Alternatively, at least some of the functionality of one or more of these modules/units/sub-units may be combined with at least some of the functionality of other modules/units/sub-units and implemented in one module/unit/sub-unit. According to embodiments of the present disclosure, at least one of the second determination module 910, the second acquisition module 920, and the second processing module 930 may be implemented at least in part as hardware circuitry, such as a Field Programmable Gate Array (FPGA), a Programmable Logic Array (PLA), a system on a chip, a system on a substrate, a system on a package, an Application Specific Integrated Circuit (ASIC), or may be implemented in hardware or firmware in any other reasonable way of integrating or packaging circuitry, or in any one of or a suitable combination of three of software, hardware, and firmware. Alternatively, at least one of the second determination module 910, the second acquisition module 920, and the second processing module 930 may be at least partially implemented as computer program modules, which when executed, may perform the respective functions.

It should be noted that, in the embodiment of the present disclosure, the service processing apparatus portion corresponds to the service processing method portion in the embodiment of the present disclosure, and the description of the service processing apparatus portion specifically refers to the service processing method portion and is not described herein again.

Fig. 10 schematically illustrates a block diagram of an electronic device adapted to implement an information processing method and a business processing method according to an embodiment of the present disclosure. The electronic device shown in fig. 10 is merely an example and should not be construed to limit the functionality and scope of use of the disclosed embodiments.

As shown in fig. 10, a computer electronic device 1000 according to an embodiment of the present disclosure includes a processor 1001 that can perform various appropriate actions and processes according to a program stored in a Read Only Memory (ROM) 1002 or a program loaded from a storage section 10010 into a Random Access Memory (RAM) 1003. The processor 1001 may include, for example, a general purpose microprocessor (e.g., a CPU), an instruction set processor and/or an associated chipset and/or a special purpose microprocessor (e.g., an Application Specific Integrated Circuit (ASIC)), or the like. The processor 1001 may also include on-board memory for caching purposes. The processor 1001 may include a single processing unit or multiple processing units for performing different actions of the method flows according to embodiments of the present disclosure.

In the RAM 1003, various programs and data necessary for the operation of the electronic apparatus 1000 are stored. The processor 1001, the ROM 1002, and the RAM 1003 are connected to each other by a bus 1004. The processor 1001 performs various operations of the method flow according to the embodiment of the present disclosure by executing programs in the ROM 1002 and/or the RAM 1003. Note that the program may be stored in one or more memories other than the ROM 1002 and the RAM 1003. The processor 1001 may also perform various operations of the method flow according to the embodiments of the present disclosure by executing programs stored in the one or more memories.

According to an embodiment of the disclosure, the electronic device 1000 may also include an input/output (I/O) interface 1005, the input/output (I/O) interface 1005 also being connected to the bus 1004. The electronic device 1000 may also include one or more of the following components connected to an input/output (I/O) interface 1005: an input section 1006 including a keyboard, a mouse, and the like; an output portion 1007 including a Cathode Ray Tube (CRT), a Liquid Crystal Display (LCD), etc., and a speaker, etc.; a storage portion 1008 including a hard disk or the like; and a communication section 1009 including a network interface card such as a LAN card, a modem, or the like. The communication section 1009 performs communication processing via a network such as the internet. The drive 1010 is also connected to an input/output (I/O) interface 1005 as needed. A removable medium 1011, such as a magnetic disk, an optical disk, a magneto-optical disk, a semiconductor memory, or the like, is installed as needed in the drive 1010, so that a computer program read out therefrom is installed as needed in the storage section 1008.

According to embodiments of the present disclosure, the method flow according to embodiments of the present disclosure may be implemented as a computer software program. For example, embodiments of the present disclosure include a computer program product comprising a computer program embodied on a computer readable storage medium, the computer program comprising program code for performing the method shown in the flowcharts. In such an embodiment, the computer program may be downloaded and installed from a network via the communication portion 1009, and/or installed from the removable medium 1011. The above-described functions defined in the system of the embodiments of the present disclosure are performed when the computer program is executed by the processor 1001. The systems, devices, apparatus, modules, units, etc. described above may be implemented by computer program modules according to embodiments of the disclosure.

The present disclosure also provides a computer-readable storage medium that may be embodied in the apparatus/device/system described in the above embodiments; or may exist alone without being assembled into the apparatus/device/system. The computer-readable storage medium carries one or more programs which, when executed, implement methods in accordance with embodiments of the present disclosure.

According to embodiments of the present disclosure, the computer-readable storage medium may be a non-volatile computer-readable storage medium. Examples may include, but are not limited to: a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this disclosure, a computer-readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device.

For example, according to embodiments of the present disclosure, the computer-readable storage medium may include ROM 1002 and/or RAM 1003 and/or one or more memories other than ROM 1002 and RAM 1003 described above.

Embodiments of the present disclosure also include a computer program product comprising a computer program comprising program code for performing the methods provided by the embodiments of the present disclosure, the program code for causing an electronic device to implement the information processing methods and the business processing methods provided by the embodiments of the present disclosure when the computer program product is run on the electronic device.

The above-described functions defined in the system/apparatus of the embodiments of the present disclosure are performed when the computer program is executed by the processor 1001. The systems, apparatus, modules, units, etc. described above may be implemented by computer program modules according to embodiments of the disclosure.

In one embodiment, the computer program may be based on a tangible storage medium such as an optical storage device, a magnetic storage device, or the like. In another embodiment, the computer program may also be transmitted in the form of signals on a network medium, distributed, and downloaded and installed via the communication section 1009, and/or installed from the removable medium 1011. The computer program may include program code that may be transmitted using any appropriate network medium, including but not limited to: wireless, wired, etc., or any suitable combination of the foregoing.

According to embodiments of the present disclosure, program code for performing computer programs provided by embodiments of the present disclosure may be written in any combination of one or more programming languages, and in particular, such computer programs may be implemented in high-level procedural and/or object-oriented programming languages, and/or assembly/machine languages. Programming languages include, but are not limited to, such as Java, c++, python, "C" or similar programming languages. The program code may execute entirely on the user's computing device, partly on the user's device, partly on a remote computing device, or entirely on the remote computing device or server. In the case of remote computing devices, the remote computing device may be connected to the user computing device through any kind of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or may be connected to an external computing device (e.g., connected via the Internet using an Internet service provider).

The flowcharts and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present disclosure. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams or flowchart illustration, and combinations of blocks in the block diagrams or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions. Those skilled in the art will appreciate that the features recited in the various embodiments of the disclosure and/or in the claims may be combined in various combinations and/or combinations, even if such combinations or combinations are not explicitly recited in the disclosure. In particular, the features recited in the various embodiments of the present disclosure and/or the claims may be variously combined and/or combined without departing from the spirit and teachings of the present disclosure. All such combinations and/or combinations fall within the scope of the present disclosure.

The embodiments of the present disclosure are described above. However, these examples are for illustrative purposes only and are not intended to limit the scope of the present disclosure. Although the embodiments are described above separately, this does not mean that the measures in the embodiments cannot be used advantageously in combination. The scope of the disclosure is defined by the appended claims and equivalents thereof. Various alternatives and modifications can be made by those skilled in the art without departing from the scope of the disclosure, and such alternatives and modifications are intended to fall within the scope of the disclosure.

Claims

1. An information processing method, comprising:

in response to receiving an information processing request, determining M sub-information identifiers corresponding to the information identifiers to be processed, processing type information and association relation information corresponding to the M sub-information identifiers respectively according to the information identifiers to be processed indicated by the information processing request, wherein M is a positive integer;

acquiring configuration information and information to be processed corresponding to the M sub-information identifiers according to the M sub-information identifiers and the processing type information corresponding to the M sub-information identifiers respectively;

processing configuration information and the information to be processed, which correspond to the M sub-information identifiers respectively, according to the association relation information to obtain an information processing result; and

And storing the information identification to be processed, the configuration information and the information to be processed which are respectively corresponding to the M sub-information identifications, and the information processing result in a data cluster in an associated mode.

2. The method of claim 1, wherein the obtaining, according to the M sub-information identifiers and the processing type information corresponding to the M sub-information identifiers, the configuration information and the information to be processed corresponding to the M sub-information identifiers respectively includes:

acquiring the configuration information corresponding to each M sub-information identifier according to the M sub-information identifiers; and

and acquiring the information to be processed corresponding to each of the M sub-information identifiers from a target data source corresponding to the processing type information according to the processing type information corresponding to each of the M sub-information identifiers.

3. The method of claim 2, wherein the process type information comprises a streaming process type or a batch process type;

for each of the M sub-information identities, in case the process type information comprises the streaming process type,

the step of obtaining the information to be processed corresponding to each of the M sub-information identifiers from a target data source corresponding to the processing type information according to the processing type information corresponding to each of the M sub-information identifiers comprises the following steps:

Determining a first data source identifier corresponding to the sub-information identifier according to the sub-information identifier; and

and responding to the monitoring of the change of the information corresponding to the sub-information identification in the first data source corresponding to the first data source identification, and acquiring the information to be processed corresponding to the sub-information identification by utilizing an acquisition thread corresponding to the sub-information identification.

4. A method according to claim 3, wherein in case the information type information comprises the batch type, the method further comprises:

determining a second data source identifier and an acquisition interface identifier corresponding to the sub-information identifier according to the sub-information identifier;

responding to the triggering of a timing acquisition task, and calling an acquisition interface corresponding to the acquisition interface identifier; and

and acquiring the information to be processed corresponding to the sub-information identification by using the acquisition interface.

5. The method of claim 1, wherein the storing the to-be-processed information identification, the configuration information and to-be-processed information respectively corresponding to the M sub-information identifications, and the information processing result in association to a data cluster comprises

For each of the M sub-information identities,

Determining a data cluster storage identifier according to the information identifier to be processed and the sub-information identifier; and

and storing the data cluster storage identifier, the configuration information corresponding to the sub-information identifier, the information to be processed and the information processing result in a correlated manner by using the storage thread corresponding to the sub-information identifier.

6. The method according to any one of claims 1 to 5, wherein the processing, according to the association relationship information, the configuration information and the information to be processed, which correspond to the M sub-information identifiers respectively, to obtain an information processing result includes:

determining an mth target sub-information identifier in the M sub-information identifiers, wherein M is a positive integer and is smaller than or equal to M;

determining a sub-information processing result corresponding to the mth target sub-information identifier according to the mth target sub-information identifier; and

and processing sub-information processing results corresponding to the m target sub-information identifiers respectively according to the association relation information to obtain the information processing results.

7. The method of claim 6, wherein the configuration information comprises a first number of sub-configuration information comprising a configuration field name and a configuration rule corresponding to the configuration field name;

The information to be processed comprises a second number of key value relations to be processed, and the key value relations to be processed comprise field names to be processed and field values to be processed corresponding to the field names to be processed.

8. The method of claim 7, wherein the determining, according to the mth target sub-information identifier, a sub-information processing result corresponding to the mth target sub-information identifier comprises:

according to the mth target sub-information identification, determining a first number of target configuration field names and a second number of target to-be-processed field names corresponding to the mth target sub-information identification;

matching the first number of target configuration field names and the second number of target to-be-processed field names to obtain a matching result;

responding to the matching result to represent that the target configuration field name is matched with the target field name to be processed, and processing a target field value corresponding to the target field name to be processed by utilizing a target configuration rule corresponding to the target configuration field name to obtain a processed field value; and

and determining a sub-information processing result corresponding to the mth target sub-information identifier according to the processing field values corresponding to the second number of target to-be-processed field names.

9. The method according to any one of claims 1 to 5, wherein the obtaining, according to the M sub-information identities, information configuration information corresponding to each of the M sub-information identities includes:

for each of the M sub-information identities,

according to the sub-information identifications, respectively matching N candidate sub-information identifications in a configuration management database to obtain target sub-information identifications, wherein the configuration management database also comprises candidate information configuration information corresponding to the N candidate sub-information identifications; and

and acquiring the candidate information configuration information corresponding to the target sub-information identification.

10. The method of claim 9, wherein the candidate information configuration information comprises P candidate sub-configuration information including a candidate configuration field name and a candidate configuration rule corresponding to the candidate configuration field name;

the candidate configuration information is obtained by the following steps:

in response to detecting a configuration operation corresponding to a candidate sub-information identifier, acquiring a field to be configured corresponding to the configuration operation and a configuration rule corresponding to the field to be configured;

Determining the field to be configured as the candidate configuration field name;

determining the configuration rule as the candidate configuration rule; and

and determining the candidate sub-configuration information according to the candidate configuration field name and the candidate configuration rule.

11. A business processing method, comprising:

responding to a service processing request from a user, and determining S data cluster storage identifiers to be matched according to S information identifiers corresponding to service identifiers to be processed in the service processing request, wherein S is a positive integer;

information processing results corresponding to the S data cluster storage identifiers to be matched are obtained from the data clusters; and

processing information processing results corresponding to the S data cluster storage identifiers to be matched respectively to obtain service processing results;

wherein the data cluster is obtained by the method of any one of claims 1 to 10.

12. The method of claim 11, wherein the business process request further comprises a presentation type identification;

the method further comprises the steps of processing information processing results corresponding to the S data cluster storage identifiers to be matched respectively to obtain service processing results:

Processing the service processing result according to the display type identifier to obtain a view interface to be displayed; and

and displaying the view interface to be displayed to the user.

13. An information processing apparatus comprising:

the first determining module is used for responding to the received information processing request, and determining M sub-information identifiers corresponding to the information identifiers to be processed, processing type information and association relation information corresponding to the M sub-information identifiers respectively according to the information identifiers to be processed indicated by the information processing request, wherein M is a positive integer;

the first acquisition module is used for acquiring configuration information and information to be processed corresponding to the M sub-information identifiers according to the M sub-information identifiers and the processing type information corresponding to the M sub-information identifiers respectively;

the first processing module is used for processing the configuration information and the information to be processed, which correspond to the M sub-information identifiers respectively, according to the association relation information to obtain an information processing result; and

and the association module is used for associating and storing the information to be processed, the configuration information corresponding to each of the M sub-information identifiers, the information to be processed and the information processing result into a data cluster.

14. A traffic processing apparatus comprising:

the second determining module is used for responding to the received service processing request, and determining S data cluster storage identifiers to be matched corresponding to the service identifiers to be processed according to the service identifiers to be processed in the service processing request, wherein S is a positive integer;

the second acquisition module is used for acquiring information processing results corresponding to the S data cluster storage identifiers to be matched from the data clusters; and

the second processing module is used for processing the information processing results corresponding to the S data cluster storage identifiers to be matched respectively to obtain service processing results;

wherein the data cluster is obtained using the apparatus of claim 13.

15. An electronic device, comprising:

one or more processors;

a memory for storing one or more instructions,

wherein the one or more instructions, when executed by the one or more processors, cause the one or more processors to implement the method of any of claims 1 to 10 or any of claims 11 to 12.

16. A computer readable storage medium having stored thereon executable instructions which when executed by a processor cause the processor to implement the method of any of claims 1 to 10 or any of claims 11 to 12.

17. A computer program product comprising computer executable instructions for implementing the method of any one of claims 1 to 10 or any one of claims 11 to 12 when executed.