CN110880146A - Block chain chaining method, device, electronic equipment and storage medium - Google Patents
Block chain chaining method, device, electronic equipment and storage mediumDownload PDFInfo
- Publication number
- CN110880146A CN110880146ACN201911153200.XACN201911153200ACN110880146ACN 110880146 ACN110880146 ACN 110880146ACN 201911153200 ACN201911153200 ACN 201911153200ACN 110880146 ACN110880146 ACN 110880146A
- Authority
- CN
- China
- Prior art keywords
- data
- uplink
- data source
- configuration information
- processing model
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Classifications
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/04—Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F21/00—Security arrangements for protecting computers, components thereof, programs or data against unauthorised activity
- G06F21/60—Protecting data
- G06F21/62—Protecting access to data via a platform, e.g. using keys or access control rules
- G06F21/6218—Protecting access to data via a platform, e.g. using keys or access control rules to a system of files or objects, e.g. local or distributed file system or database
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F21/00—Security arrangements for protecting computers, components thereof, programs or data against unauthorised activity
- G06F21/60—Protecting data
- G06F21/64—Protecting data integrity, e.g. using checksums, certificates or signatures
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q20/00—Payment architectures, schemes or protocols
- G06Q20/38—Payment protocols; Details thereof
- G06Q20/382—Payment protocols; Details thereof insuring higher security of transaction
- G06Q20/3829—Payment protocols; Details thereof insuring higher security of transaction involving key management
Landscapes
- Engineering & Computer Science (AREA)
- Business, Economics & Management (AREA)
- Theoretical Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Computer Security & Cryptography (AREA)
- Accounting & Taxation (AREA)
- Physics & Mathematics (AREA)
- Finance (AREA)
- Computer Hardware Design (AREA)
- General Business, Economics & Management (AREA)
- Software Systems (AREA)
- General Health & Medical Sciences (AREA)
- Bioethics (AREA)
- Health & Medical Sciences (AREA)
- Strategic Management (AREA)
- General Engineering & Computer Science (AREA)
- Development Economics (AREA)
- Economics (AREA)
- Marketing (AREA)
- Technology Law (AREA)
- Databases & Information Systems (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
Description
Technical Field
The present application relates to the field of computer network technologies, and in particular, to a method and an apparatus for chaining a block chain, an electronic device, and a storage medium.
Background
A blockchain network is a technical infrastructure that provides ledger and intelligent contract (chain code) services for applications. The application program is connected with the block chain network, block chain basic service needs to be installed, information such as node access information, node access authority, a data channel where the node is located and the like is configured, and the node is added into the block chain network. The business data uplink refers to that an application program calls an intelligent contract to access a blockchain account book through a blockchain node, when an endorsement policy is met, business data is recognized as 'transaction', and transaction data is packaged in a block to become a new block through a consensus mechanism and is linked to a previous block to become data which cannot be tampered on the chain.
The existing technical scheme realizes the uplink of enterprise business data by actively receiving and passively capturing data. The method reduces the obstacle of the enterprise adaptation block chain to a certain extent. However, the existing solutions focus on the data uplink process, and do not solve the problem of interfacing between the enterprise internal business system (such as ERP) and the blockchain network. Due to the difference of business systems of different enterprises, business data sources have certain difference, and business data of the enterprises cannot be linked up directly.
In view of the above problems, no effective technical solution exists at present.
Disclosure of Invention
An object of the embodiments of the present application is to provide a block chain uplink method, an apparatus, an electronic device, and a storage medium, which solve the problem that an enterprise cannot directly join a block chain due to differences in service data sources, and reduce uplink difficulty of the block chain.
In a first aspect, an embodiment of the present application provides a block chain uplink method, including the following steps:
acquiring a data source to be uplinked and configuration information of the data source;
generating a data processing model according to the configuration information, wherein the data processing model is used for connecting the data source and converting the data of the data source into target uplink data;
performing uplink parameter configuration according to the configuration information, wherein the uplink parameters are necessary parameters required for uplink of the target uplink data to a block chain;
extracting and analyzing the data of the data source based on the data processing model to obtain target uplink data;
and uplink is carried out on the target uplink data based on the uplink parameters.
In the method for uplink of block chain according to the embodiment of the present application, the step of generating a data processing model according to the configuration information includes:
judging whether the data source is a universal data source or a non-universal data source;
if the data structure type of the data source is a universal data source, generating a universal analysis engine according to the configuration information, and generating a data processing model according to the universal analysis engine, wherein the universal analysis engine is used for analyzing data of the universal data source to obtain target uplink data through conversion;
and if the data source is a non-universal data source, generating a plug-in engine according to the configuration information, wherein the plug-in engine is used for analyzing the data of the non-universal data source to obtain target uplink data through conversion, and generating a data processing model according to the plug-in engine.
In the blockchain uplink method according to the embodiment of the present application, the universal data source is a database data source, a directory data source, a Webservice data source, or a middleware data source.
In the method for uplink of block chain according to the embodiment of the present application, the step of generating a data processing model according to the configuration information further includes:
and generating an interface plug-in for connecting a data source, wherein the interface plug-in carries out parameter configuration according to the configuration information of the data source.
In the block chain uplink method according to the embodiment of the present application, in the step of generating an interface plug-in for connecting to a data source:
when the data source is a database data source, the data processing model generated according to the configuration information needs to be configured with the following parameters: data source name, content label, data table name, service type field and increment time field;
when the data source is a Webservice data source, configuring the following parameters according to a data processing model generated by the configuration information: accessing a parameter table and monitoring a URL;
when the data source is a middleware data source, the data processing model generated according to the configuration information needs to configure the following parameters: a data source name and a content tag;
when the data source is a directory data source, the data processing model generated according to the configuration information needs to configure the following parameters: data source name, monitoring directory, directory name, and data source address information.
In the block chain uplink method according to the embodiment of the present application, the step of performing uplink parameter configuration according to the configuration information includes:
completing uplink parameter configuration according to configuration information, wherein the uplink parameters comprise: data source name, data source type, channel name, intelligent contract name, and intelligent contract method.
In the block chain uplink method according to the embodiment of the present application, the method further includes the following steps:
and monitoring the uplink process of the target uplink data so as to acquire state data in the uplink process.
In a second aspect, an embodiment of the present application further provides a block chain chaining apparatus, including:
an obtaining module, configured to obtain a data source to be uplinked and configuration information of the data source;
a generating module, configured to generate a data processing model according to the configuration information, where the data processing model is used to connect to the data source and convert data of the data source into target uplink data;
a configuration module, configured to perform uplink parameter configuration according to the configuration information, where the uplink parameter is a necessary parameter required for uplink of the target uplink data to a block chain;
the analysis module is used for extracting and analyzing the data of the data source based on the data processing model so as to obtain target uplink data;
a uplink module for uplink transmission of the target uplink data based on the uplink parameters.
In a third aspect, an embodiment of the present application provides an electronic device, including a processor and a memory, where the memory stores computer-readable instructions, and when the computer-readable instructions are executed by the processor, the steps in the method as provided in the first aspect are executed.
In a fourth aspect, embodiments of the present application provide a storage medium, on which a computer program is stored, where the computer program, when executed by a processor, performs the steps in the method as provided in the first aspect.
In view of the above, the block chain uplink method, apparatus, electronic device and storage medium provided in the present application obtain a data source to be uplink and configuration information of the data source; generating a data processing model according to the configuration information; performing uplink parameter configuration according to the configuration information; extracting and analyzing the data of the data source based on the data processing model to obtain target uplink data; performing uplink on the target uplink data based on the uplink parameters; therefore, the uplink of the data is realized, the data processing model can be established through the configuration information of the data source, the data of the data sources of different types are analyzed through the data processing model to obtain the target uplink data capable of being directly uplink, the problem that an enterprise cannot directly join the block chain due to difference of the service data sources is solved, and the uplink difficulty of the block chain is reduced.
Additional features and advantages of the present application will be set forth in the description which follows, and in part will be obvious from the description, or may be learned by the practice of the embodiments of the present application. The objectives and other advantages of the application may be realized and attained by the structure particularly pointed out in the written description and claims hereof as well as the appended drawings.
Drawings
In order to more clearly illustrate the technical solutions of the embodiments of the present application, the drawings that are required to be used in the embodiments of the present application will be briefly described below, it should be understood that the following drawings only illustrate some embodiments of the present application and therefore should not be considered as limiting the scope, and that those skilled in the art can also obtain other related drawings based on the drawings without inventive efforts.
Fig. 1 is a diagram of a scenario of a block chain uplink method and apparatus according to an embodiment of the present disclosure.
Fig. 2 is a flowchart of a block chain uplink method according to an embodiment of the present application.
Fig. 3 is another flowchart of a method for uplink on a block chain according to an embodiment of the present invention.
Fig. 4 is a schematic structural diagram of a block chain uplink apparatus according to an embodiment of the present disclosure.
Fig. 5 is a schematic structural diagram of an uplink apparatus for a block chain according to an embodiment of the present disclosure.
Fig. 6 is a schematic structural diagram of an electronic device according to an embodiment of the present application.
Detailed Description
In the embodiments provided in the present application, it should be understood that the disclosed apparatus and method may be implemented in other ways. The above-described embodiments of the apparatus are merely illustrative, and for example, the division of the units is only one logical division, and there may be other divisions when actually implemented, and for example, a plurality of units or components may be combined or integrated into another system, or some features may be omitted, or not executed. In addition, the shown or discussed mutual coupling or direct coupling or communication connection may be an indirect coupling or communication connection of devices or units through some communication interfaces, and may be in an electrical, mechanical or other form.
In addition, units described as separate parts may or may not be physically separate, and parts displayed as units may or may not be physical units, may be located in one place, or may be distributed on a plurality of network units. Some or all of the units can be selected according to actual needs to achieve the purpose of the solution of the embodiment.
Furthermore, the functional modules in the embodiments of the present application may be integrated together to form an independent part, or each module may exist separately, or two or more modules may be integrated to form an independent part.
In this document, relational terms such as first and second, and the like may be used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions.
Referring to fig. 1, the present application provides a block chain chaining method and apparatus, which is integrated in an electronic device in the form of a computer program. The block chain chaining method and the device acquire a data source and configuration information thereof from an internal data source of an enterprise through an acquisition module, and then generate a data processing model according to the configuration information through a generation module; the uplink parameters are configured according to the configuration information through a configuration module, and the uplink parameters comprise but are not limited to parameters such as data source names, channel names, intelligent contract methods and the like; then, obtaining internal data of an enterprise through an interface plug-in of the data processing model, analyzing and converting the data of an enterprise data source into a data type capable of uplink, namely target uplink data, through a general engine or a plug-in engine of the data processing model, and finally uplink the target uplink data through the uplink module; certainly, a firewall is disposed between the blockchain network and the blockchain uplink device, so as to protect the blockchain network. The data processing model analyzes the data of different types of data sources to obtain the target uplink data capable of being directly uplink, so that the problem that an enterprise cannot directly join the block chain due to difference of the business data sources is solved, and the uplink difficulty of the block chain is reduced.
The block chain uplink method and apparatus will be described in detail below with reference to the accompanying drawings.
Referring to fig. 2, fig. 2 is a flowchart of a block chain uplink method according to some embodiments of the present application. The block chain chaining method is used in electronic equipment such as a mobile phone, a tablet or a computer. The block chain uplink method comprises the following steps:
s101, obtaining a data source to be uplink and configuration information of the data source.
And S102, generating a data processing model according to the configuration information, wherein the data processing model is used for connecting the data source and converting the data of the data source into target uplink data.
S103, uplink parameter configuration is performed according to the configuration information, wherein the uplink parameters are necessary parameters required for uplink of the target uplink data to a block chain.
And S104, extracting and analyzing the data of the data source based on the data processing model to obtain the target uplink data.
S105, performing uplink on the target uplink data based on the uplink parameters.
The above steps will be described in detail below.
In step S101, the data source to be linked may be a universal data source, where the universal data source refers to a data source with a simpler data structure, and for example, the universal data source referred to in this application may be a database data source, a directory data source, a Webservice data source, or a middleware data source. The configuration information of the database data source comprises a plurality of pieces of information: data source name, database type, database name, server address, port number, user name, and password. The configuration information of the directory data source includes: directory name and address information. The configuration information of the Webservice data source comprises: username parameter name, password parameter name, and authentication type. The configuration information of the middleware data source includes a plurality of pieces of information: data source name, server address, port number, username, and password.
It will be appreciated that in some embodiments, before performing this step S101, certain preparation work needs to be performed, for example: environment preparation, unit management, user management and network management.
Wherein the environmental preparation means: preparing software and hardware environment according to configuration requirements, and operating an environment requirement operating system: windows7 and above, linux operating system.
The unit management is used for managing enterprise basic information such as enterprise names, enterprise codes and the like which are added into the block chain network, uploading enterprise certificate files and private keys, and a safety unit which accords with financial level safety is arranged in the device to ensure the safety of key storage.
The user management is used for maintaining basic information of enterprise users and authenticating and authorizing the enterprise internal users through enterprise certificates. The users are divided into administrator users and ordinary users, the administrator users have all the rights of equipment management, and the ordinary users have gateway monitoring and transaction inquiry rights.
The network management is used for configuring system parameters of the gateway, including setting of block chain nodes, certificate files, keys and the like.
In step S102, two parts are provided in the data processing model, one is an interface plug-in for connecting to a data source of an enterprise and a general engine for parsing and converting the data source of the enterprise into the target uplink data.
The generic engine can parse data in json and csv formats. The generic engine is used to convert data from a generic data source, such as json and csv format data, into target uplink data capable of uplink. The configuration information contains the type information of the data source, so that the corresponding general engine can be generated according to the type information of the data source. When the general engine is generated, the configuration of the accounting parameter table is needed. The purpose of the configuration of the accounting parameter table is to analyze data in the data source, and the accounting parameter table has five fields: account parameter name, parameter title, parameter type, parameter value, and formatting expression. The accounting parameters and parameter titles are configured accounting parameter names and titles, are only identification, have no practical significance and can not be configured. The parameter types are divided into single field, multi-field, variable, record and constant. A single field requires a field name (which is a json data type) or an index value (which is a csv data type) to be configured in the parameter value, which is needed to resolve the data value. Multiple fields require configuring multiple field names (which are json data types) or index values (which are csv data types) required for analyzing data values in parameter values, and the field names are separated by an '@' character; the constant type can configure some constants in the parameter values, and the constants are used as the method parameters of an intelligent contract to uplink; the variable type can acquire the variables or time variables in the configuration as the method parameters of an intelligent contract for uplink. The universal engine can convert data of data sources of most enterprises into target uplink data meeting uplink standards, so that uplink difficulty is greatly reduced.
When the interface plug-in is configured, the parameter configuration of the interface plug-in is required according to the configuration information of the data source. For example, when the data source is a database data source, the interface plug-in configures parameters, which need to be configured: data source name, content tag, data table name, service type field, and delta time field. The content tag is configured when the acquired data needs to be acquired through the field. The name of the data table is a parameter required to be configured by a database data source, and the name of the data table is as follows: the database data source needs configuration parameters, names of tables in the monitored database, and names of tables in the monitored database. The service type field is a configuration parameter required by a database data source and is used for extracting field names of all data of a certain field of the data in the database. The increment time field is a parameter required to be configured by a database data source and is used for extracting the increment time field of the data in the database. By automatically configuring the interface plug-in, an enterprise data source can be seamlessly connected with the block chain, so that data chaining is facilitated.
For example, when the data source is a directory data source, the interface plug-in configures parameters that need to be configured: data source name, monitoring directory, directory name, and data source address information.
For example, when the data source is a Webservice data source, the interface plug-in configures parameters, which need to be configured: data source name, monitoring URL, access parameter table. And when the data source is of the webservice type, an access parameter table needs to be configured. The purpose of the access parameter table configuration is to obtain access parameters which need to be transferred when data is acquired from the webservice interface. The access parameter table has five fields: accessing parameter name, parameter title, parameter type, parameter value, and formatting expression. And the access parameter name and the parameter value are transmitted to the webservice interface as a key value pair. The parameter types are field types and variable types, the field type parameter value fills in the value of the key value pair to be transmitted, the variable type fills in the name of the variable in the parameter value, the value of the variable or the time variable in the gateway configuration is obtained as the value of the key value pair, and the configurable variable is the same as the accounting parameter table. The parameter header is merely a logo and has no practical meaning. The format expression is a format expression of which the parameter value needs to be converted. And monitoring the URL as a parameter required to be configured by the webservice data source so as to obtain the URL address of the data.
For example, when the data source is a middleware data source, the interface plug-in configures parameters, which need to be configured: data source name, content tag, monitoring subject name, monitoring tag. The monitoring subject name is the configuration parameter required by the middleware data source, and is the subject name of the monitoring middleware. The monitoring label is a configuration parameter required by the middleware data source, and the monitoring label is a label name of the monitoring middleware.
It will be appreciated that in some embodiments, the pre-configuration may be with generic engines for various data source types, and that when building the data processing model, the generic engines of the corresponding types may be invoked directly.
In step S103, uplink parameters are necessary parameters for uplink of the target uplink data to the block chain, and configuration is required: data source name, channel name, intelligent contract method and other parameters. The configuration of the channel name, the intelligent contract name and the intelligent contract method is carried out based on the configuration information of the data source. The channel name is a block chain channel name, and is used for identifying the channel of the uplink selected by the target uplink data. The intelligent contract name is the name of the intelligent contract that the target uplink data link needs to call. The intelligent contract method is the name of the intelligent contract which needs to be called by the target uplink data link.
In step S104, the data processing model is connected to a data source of an enterprise through an interface plug-in the data processing model to extract data in the data source, and then the extracted data is analyzed and processed through a general engine in the data processing model, so as to obtain target uplink data that can be directly uplink.
In step S105, after completing the uplink parameter configuration and the parsing and converting of the data source, the target uplink data can be uplinked. And when the user carries out uplink operation, selecting a corresponding uplink channel based on the channel name, calling a corresponding intelligent contract based on a pre-configured intelligent contract name, and calling a corresponding intelligent contract method based on a pre-configured intelligent contract method.
It will be appreciated that in some embodiments, the method further comprises the steps of: and monitoring the uplink process of the target uplink data so as to acquire state data in the uplink process. In the data uplink process, the timing task or the middleware runs in the background to acquire the running state. The user may view the status data through a visualized interface, including: channel name, intelligent contract name, start uplink time, end time, operation result, number of successful entries, number of failed entries, etc.
It will be appreciated that in some embodiments, the method may also monitor transaction status data. Wherein the transaction status data that may be monitored includes: service ID, transaction ID, service information, uplink time, transaction status and failure times, and uplink details. Wherein, the service information is a data record of the uplink. The transaction status includes four types: the system can automatically re-chain the records of the submission failure and the accounting failure, and users can check the records through a visual interface.
As can be seen from the above, the block chain uplink method provided by the present application obtains a data source to be uplink and configuration information of the data source; generating a data processing model according to the configuration information, wherein the data processing model is used for connecting the data source and converting the data of the data source into target uplink data; performing uplink parameter configuration according to the configuration information, wherein the uplink parameters are necessary parameters required for uplink of the target uplink data to a block chain; extracting and analyzing the data of the data source based on the data processing model to obtain target uplink data; performing uplink on the target uplink data based on the uplink parameters; therefore, the uplink of the data is realized, the data processing model can be established through the configuration information of the data source, the data of the data sources of different types are analyzed through the data processing model to obtain the target uplink data capable of being directly uplink, the problem that an enterprise cannot directly join the block chain due to difference of the service data sources is solved, and the uplink difficulty of the block chain is reduced.
Referring to fig. 3, fig. 3 is a flowchart of a block chain uplink method according to some embodiments of the present application. The block chain chaining method is used in electronic equipment such as a mobile phone, a tablet or a computer. The block chain uplink method comprises the following steps:
s201, obtaining a data source to be uplink and configuration information of the data source.
S2021, judging that the data source is a universal data source or a non-universal data source.
S2022, if the data source is a non-universal data source, generating a plug-in engine according to the configuration information, wherein the plug-in engine is used for analyzing data of the non-universal data source to obtain target uplink data through conversion, and generating a data processing model according to the plug-in engine.
And S2023, if the data structure type of the data source is a universal data source, generating a universal analysis engine according to the configuration information, and generating a data processing model according to the universal analysis engine, wherein the universal analysis engine is used for analyzing the data of the universal data source to obtain the target uplink data through conversion.
S203, performing uplink parameter configuration according to the configuration information, where the uplink parameter is a necessary parameter for uplink of the target uplink data to a block chain.
S204, extracting and analyzing the data of the data source based on the data processing model to obtain the target uplink data.
S205, uplink is performed on the target uplink data based on the uplink parameters.
The above steps will be described in detail below.
In step S201, the data source may be a general data source or a non-general data source. The universal data source is a data source with a relatively simple data structure. The universal data source may be a database data source, a directory data source, a Webservice data source, or a middleware data source. The non-universal data source is a data source with a relatively complex data structure, the data of the non-universal data source is a multi-level tree structure, and the universal configuration cannot analyze the multi-level tree structure and convert the multi-level tree structure into a subdata uploading block chain, so that a plug-in needs to be separately developed and uploaded.
In step S2021, the type of the data source can be determined by the data source type information in the configuration information of the data source, and the data source is determined to be a generic data source or a non-generic data source.
In step S2022, the structure of the non-universal data source is complex, the universal engine cannot analyze and convert the data that the user wants to uplink, a plug-in needs to be separately developed for uploading, the service needs to be restarted after the uploading is successful, the plug-in engine in the plug-in list can be selected when the data processing module is established after the uploading is successful, and the configuration of the accounting parameter is not needed. The plug-in engine can realize data source monitoring, data packaging and signature aiming at non-universal data sources. The defect that data source data with a complex data structure cannot be subjected to direct chain loading is overcome by arranging the plug-in engine, and the chain loading difficulty is reduced.
In step S2023, the general purpose engine may parse json and csv format data. The generic engine is used to convert data from a generic data source, such as json and csv format data, into target uplink data capable of uplink. The configuration information contains the type information of the data source, so that the corresponding general engine can be generated according to the type information of the data source. When the general engine is generated, the configuration of the accounting parameter table is needed. The purpose of the configuration of the accounting parameter table is to analyze data in the data source, and the accounting parameter table has five fields: account parameter name, parameter title, parameter type, parameter value, and formatting expression. The accounting parameters and parameter titles are configured accounting parameter names and titles, are only identification, have no practical significance and can not be configured. The parameter types are divided into single field, multi-field, variable, record and constant. A single field needs to configure a field name (json data type) or an index value (csv data type) needed for analyzing a data value in a parameter value; multiple fields require configuring multiple field names (json data types) or index values (csv data types) required for analyzing data values in parameter values, and the field names are separated by @ characters; the constant type can configure some constants in the parameter values, and the constants are used as the method parameters of an intelligent contract to uplink; the variable type can acquire the variables or time variables in the configuration as the method parameters of an intelligent contract for uplink.
When the interface plug-in is configured, parameter configuration is required according to configuration information of a data source. For example, when the data source is a database data source, the interface plug-in configures parameters, which need to be configured: data source name, content tag, data table name, service type field, and delta time field. The content tag is configured when the acquired data needs to be acquired through the field. The name of the data table is a parameter required to be configured by a database data source, and the name of the data table is as follows: the database data source needs configuration parameters, names of tables in the monitored database, and names of tables in the monitored database. The service type field is a configuration parameter required by a database data source and is used for extracting field names of all data of a certain field of the data in the database. The increment time field is a parameter required to be configured by a database data source and is used for extracting the increment time field of the data in the database.
Of course, it can be understood that the interface plug-in of the non-universal data source is configured according to the data structure of the non-universal data source and the basic configuration information thereof, and the configuration method is similar to the above.
In step S203, uplink parameters are necessary parameters for uplink of the target uplink data to the block chain, and configuration is required to configure: data source name, channel name, intelligent contract method and other parameters. The configuration of the channel name, the intelligent contract name and the intelligent contract method is carried out based on the configuration information of the data source. The channel name is a block chain channel name, and is used for identifying the channel of the uplink selected by the target uplink data. The intelligent contract name is the name of the intelligent contract that the target uplink data link needs to call. The intelligent contract method is the name of the intelligent contract which needs to be called by the target uplink data link.
In step S204, the data processing model is connected to a data source of an enterprise through an interface plug-in the data processing model to extract data in the data source, and then the extracted data is analyzed and processed through a general engine in the data processing model, so as to obtain target uplink data that can be directly uplink.
In step S205, after completing the uplink parameter configuration and the parsing and converting of the data source, the target uplink data can be uplinked. And when the user carries out uplink operation, selecting a corresponding uplink channel based on the channel name, calling a corresponding intelligent contract based on a pre-configured intelligent contract name, and calling a corresponding intelligent contract method based on a pre-configured intelligent contract method.
It will be appreciated that in some embodiments, the method further comprises the steps of: and monitoring the uplink process of the target uplink data so as to acquire state data in the uplink process. In the data uplink process, the timing task or the middleware runs in the background to acquire the running state. The user may view the status data through a visualized interface, including: channel name, intelligent contract name, start uplink time, end time, operation result, number of successful entries, number of failed entries, etc.
It will be appreciated that in some embodiments, the method may also monitor transaction status data. Wherein the transaction status data that may be monitored includes: service ID, transaction ID, service information, uplink time, transaction status and failure times, and uplink details. Wherein, the service information is a data record of the uplink. The transaction status includes four types: the system can automatically re-chain the records of the submission failure and the accounting failure, and users can check the records through a visual interface.
Referring to fig. 4, fig. 4 is a block diagram of a device for uplink block chain according to some embodiments of the present application. The block chain chaining device comprises: anacquisition module 301, ageneration module 302, aconfiguration module 303, aparsing module 304, and anuplink module 305.
The obtainingmodule 301 is configured to obtain a data source to be uplinked and configuration information of the data source. The data source to be linked may be a universal data source, which refers to a data source with a simpler data structure, for example, the universal data source referred to in this application may be a database data source, a directory data source, a web service data source, or a middleware data source. The configuration information of the database data source comprises a plurality of pieces of information: data source name, database type, database name, server address, port number, user name, and password. The configuration information of the directory data source includes: directory name and address information. The configuration information of the Webservice data source comprises: username parameter name, password parameter name, and authentication type. The configuration information of the middleware data source includes a plurality of pieces of information: data source name, server address, port number, username, and password.
Thegenerating module 302 is configured to generate a data processing model according to the configuration information, where the data processing model is configured to connect to the data source and convert data of the data source into target uplink data.
Referring to fig. 5, in some embodiments, thegenerating module 302 includes a determiningunit 3021, afirst generating unit 3022, and asecond generating unit 3023. The judging unit is used for judging whether the data source is a universal data source or a non-universal data source. The first generating unit is configured to generate a plug-in engine according to the configuration information if the data source is a non-universal data source, where the plug-in engine is configured to analyze data of the non-universal data source to obtain target uplink data through conversion, and generate a data processing model according to the plug-in engine. The second generating unit is configured to generate a general analysis engine according to the configuration information if the data structure type of the data source is a general data source, and generate a data processing model according to the general analysis engine, where the general analysis engine is configured to analyze data of the general data source to obtain target uplink data through conversion.
Theconfiguration module 303 is configured to perform uplink parameter configuration according to the configuration information, where the uplink parameter is a necessary parameter for uplink of the target uplink data to a block chain. The uplink parameters are necessary parameters for uplink of the target uplink data to the block chain, and the configuration needs to be performed: data source name, channel name, intelligent contract method and other parameters. The configuration of the channel name, the intelligent contract name and the intelligent contract method is carried out based on the configuration information of the data source. The channel name is a block chain channel name, and is used for identifying the channel of the uplink selected by the target uplink data. The intelligent contract name is the name of the intelligent contract that the target uplink data link needs to call. The intelligent contract method is the name of the intelligent contract which needs to be called by the target uplink data link.
Theparsing module 304 is configured to extract and parse the data of the data source based on the data processing model to obtain the target uplink data. And connecting the data source of an enterprise through an interface plug-in the data processing model to extract data in the data source, and analyzing and processing the extracted data through a general engine in the data processing model so as to convert the extracted data into target uplink data capable of being directly uplink.
Theuplink module 305 is configured to uplink the target uplink data based on the uplink parameters. After completing the uplink parameter configuration and the analysis and conversion of the data source, the target uplink data can be uplink-transmitted. And when the user carries out uplink operation, selecting a corresponding uplink channel based on the channel name, calling a corresponding intelligent contract based on a pre-configured intelligent contract name, and calling a corresponding intelligent contract method based on a pre-configured intelligent contract method.
As can be seen from the above, the block chain uplink apparatus provided in the present application obtains a data source to be uplink and configuration information of the data source; generating a data processing model according to the configuration information, wherein the data processing model is used for connecting the data source and converting the data of the data source into target uplink data; performing uplink parameter configuration according to the configuration information, wherein the uplink parameters are necessary parameters required for uplink of the target uplink data to a block chain; extracting and analyzing the data of the data source based on the data processing model to obtain target uplink data; performing uplink on the target uplink data based on the uplink parameters; therefore, the uplink of the data is realized, the data processing model can be established through the configuration information of the data source, the data of the data sources of different types are analyzed through the data processing model to obtain the target uplink data capable of being directly uplink, the problem that an enterprise cannot directly join the block chain due to difference of the service data sources is solved, and the uplink difficulty of the block chain is reduced.
Referring to fig. 6, fig. 6 is a schematic structural diagram of an electronic device according to an embodiment of the present application, in which an electronic device 4 includes: theprocessor 401 and thememory 402, theprocessor 401 and thememory 402 being interconnected and communicating with each other via acommunication bus 403 and/or other form of connection mechanism (not shown), thememory 402 storing a computer program executable by theprocessor 401, the computer program being executable by theprocessor 401 when the computing device is running to perform the block chain chaining method in any of the alternative implementations of the above embodiments.
An embodiment of the present invention further provides a storage medium, and when executed by a processor, the computer program performs the block chain uplink method in any of the above optional implementations. The storage medium may be implemented by any type of volatile or nonvolatile storage device or combination thereof, such as a Static Random Access Memory (SRAM), an Electrically Erasable Programmable Read-Only Memory (EEPROM), an Erasable Programmable Read-Only Memory (EPROM), a Programmable Read-Only Memory (PROM), a Read-Only Memory (ROM), a magnetic Memory, a flash Memory, a magnetic disk, or an optical disk.
The above description is only an example of the present application and is not intended to limit the scope of the present application, and various modifications and changes may be made by those skilled in the art. Any modification, equivalent replacement, improvement and the like made within the spirit and principle of the present application shall be included in the protection scope of the present application.
Claims (10)
1. A method for uplink on a block chain, comprising the steps of:
acquiring a data source to be uplinked and configuration information of the data source;
generating a data processing model according to the configuration information, wherein the data processing model is used for connecting the data source and converting the data of the data source into target uplink data;
performing uplink parameter configuration according to the configuration information, wherein the uplink parameters are parameters required for uplink of the target uplink data to a block chain;
extracting and analyzing the data of the data source based on the data processing model to obtain target uplink data;
and uplink is carried out on the target uplink data based on the uplink parameters.
2. The blockchain uplink method of claim 1, wherein the step of generating a data processing model according to the configuration information includes:
judging whether the data source is a universal data source or a non-universal data source;
if the data structure type of the data source is a universal data source, generating a universal analysis engine according to the configuration information, and generating a data processing model according to the universal analysis engine, wherein the universal analysis engine is used for analyzing data of the universal data source to obtain target uplink data through conversion;
and if the data source is a non-universal data source, generating a plug-in engine according to the configuration information, wherein the plug-in engine is used for analyzing the data of the non-universal data source to obtain target uplink data through conversion, and generating a data processing model according to the plug-in engine.
3. The blockchain uplink method of claim 2, wherein the common data source is a database data source, a directory data source, a Webservice data source, or a middleware data source.
4. The blockchain uplink method of claim 2, wherein the step of generating a data processing model according to the configuration information further comprises:
and generating an interface plug-in for connecting a data source, wherein the interface plug-in carries out parameter configuration according to the configuration information of the data source.
5. The blockchain uplink method of claim 4, wherein in the step of generating an interface plug-in for connecting to a data source:
when the data source is a database data source, the data processing model generated according to the configuration information needs to be configured with the following parameters: data source name, content label, data table name, service type field and increment time field;
when the data source is a Webservice data source, configuring the following parameters according to a data processing model generated by the configuration information: accessing a parameter table and monitoring a URL;
when the data source is a middleware data source, the data processing model generated according to the configuration information needs to configure the following parameters: a data source name and a content tag;
when the data source is a directory data source, the data processing model generated according to the configuration information needs to configure the following parameters: data source name, monitoring directory, directory name, and data source address information.
6. The method of claim 1, wherein the step of configuring uplink parameters according to the configuration information comprises:
completing uplink parameter configuration according to configuration information, wherein the uplink parameters comprise: a data source name, a data source type, a blockchain channel name, an intelligent contract name, and an intelligent contract method.
7. The method for uplink on a blockchain of claim 1, further comprising the steps of:
and monitoring the uplink process of the target uplink data so as to acquire state data in the uplink process.
8. An apparatus for uplink block chain, comprising:
an obtaining module, configured to obtain a data source to be uplinked and configuration information of the data source;
a generating module, configured to generate a data processing model according to the configuration information, where the data processing model is used to connect to the data source and convert data of the data source into target uplink data;
a configuration module, configured to perform uplink parameter configuration according to the configuration information, where the uplink parameter is a parameter required for uplink of the target uplink data to a block chain;
the analysis module is used for extracting and analyzing the data of the data source based on the data processing model so as to obtain target uplink data;
a uplink module for uplink transmission of the target uplink data based on the uplink parameters.
9. An electronic device comprising a processor and a memory, said memory storing computer readable instructions which, when executed by said processor, perform the steps of the method of any of claims 1-7.
10. A storage medium having a computer program stored thereon, wherein the computer program, when executed by a processor, performs the steps of the method according to any one of claims 1-7.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911153200.XACN110880146A (en) | 2019-11-21 | 2019-11-21 | Block chain chaining method, device, electronic equipment and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911153200.XACN110880146A (en) | 2019-11-21 | 2019-11-21 | Block chain chaining method, device, electronic equipment and storage medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN110880146Atrue CN110880146A (en) | 2020-03-13 |
Family
ID=69729447
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201911153200.XAPendingCN110880146A (en) | 2019-11-21 | 2019-11-21 | Block chain chaining method, device, electronic equipment and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN110880146A (en) |
Cited By (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111585764A (en)* | 2020-04-28 | 2020-08-25 | 浙江大学宁波理工学院 | System for block chain on terminal equipment data |
| CN112732833A (en)* | 2021-01-08 | 2021-04-30 | 西安交通大学 | Universal data bridge architecture for acquiring block chain information and design method |
| CN113609196A (en)* | 2021-06-23 | 2021-11-05 | 云南昆钢电子信息科技有限公司 | Block chain chaining automation system and method |
| CN113778502A (en)* | 2020-06-29 | 2021-12-10 | 北京沃东天骏信息技术有限公司 | A data processing method, device, system and storage medium |
| CN114168218A (en)* | 2021-11-30 | 2022-03-11 | 深圳市名竹科技有限公司 | Data processing method, data processing device, computer equipment and storage medium |
| CN114201503A (en)* | 2021-12-09 | 2022-03-18 | 东软集团股份有限公司 | Blockchain data processing method, device, storage medium and electronic device |
| WO2022199567A1 (en)* | 2021-03-26 | 2022-09-29 | 中兴通讯股份有限公司 | Data processing method, device, and storage medium |
| WO2022206123A1 (en)* | 2021-03-29 | 2022-10-06 | 中兴通讯股份有限公司 | Blockchain chaining method and apparatus, and electronic device and storage medium |
| CN115601177A (en)* | 2022-11-15 | 2023-01-13 | 南京知麦信息科技有限公司（Cn） | Intelligent contract generation method based on animal product breeding and processing overall process management model |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107368503A (en)* | 2016-05-13 | 2017-11-21 | 北京京东尚科信息技术有限公司 | Method of data synchronization and system based on Kettle |
| CN108595480A (en)* | 2018-03-13 | 2018-09-28 | 广州市优普科技有限公司 | A kind of big data ETL tool systems and application process based on cloud computing |
| CN108846076A (en)* | 2018-06-08 | 2018-11-20 | 山大地纬软件股份有限公司 | The massive multi-source ETL process method and system of supporting interface adaptation |
| CN110134671A (en)* | 2019-05-21 | 2019-08-16 | 北京物资学院 | A blockchain database data management system and method for traceability applications |
- 2019
- 2019-11-21CNCN201911153200.XApatent/CN110880146A/enactivePending
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107368503A (en)* | 2016-05-13 | 2017-11-21 | 北京京东尚科信息技术有限公司 | Method of data synchronization and system based on Kettle |
| CN108595480A (en)* | 2018-03-13 | 2018-09-28 | 广州市优普科技有限公司 | A kind of big data ETL tool systems and application process based on cloud computing |
| CN108846076A (en)* | 2018-06-08 | 2018-11-20 | 山大地纬软件股份有限公司 | The massive multi-source ETL process method and system of supporting interface adaptation |
| CN110134671A (en)* | 2019-05-21 | 2019-08-16 | 北京物资学院 | A blockchain database data management system and method for traceability applications |
Cited By (12)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111585764A (en)* | 2020-04-28 | 2020-08-25 | 浙江大学宁波理工学院 | System for block chain on terminal equipment data |
| CN113778502A (en)* | 2020-06-29 | 2021-12-10 | 北京沃东天骏信息技术有限公司 | A data processing method, device, system and storage medium |
| CN112732833A (en)* | 2021-01-08 | 2021-04-30 | 西安交通大学 | Universal data bridge architecture for acquiring block chain information and design method |
| CN112732833B (en)* | 2021-01-08 | 2024-07-02 | 西安交通大学 | Universal data bridge architecture for acquiring blockchain information and design method |
| WO2022199567A1 (en)* | 2021-03-26 | 2022-09-29 | 中兴通讯股份有限公司 | Data processing method, device, and storage medium |
| US12261739B2 (en) | 2021-03-26 | 2025-03-25 | Zte Corporation | Data processing method, device, and storage medium |
| WO2022206123A1 (en)* | 2021-03-29 | 2022-10-06 | 中兴通讯股份有限公司 | Blockchain chaining method and apparatus, and electronic device and storage medium |
| CN113609196A (en)* | 2021-06-23 | 2021-11-05 | 云南昆钢电子信息科技有限公司 | Block chain chaining automation system and method |
| CN114168218A (en)* | 2021-11-30 | 2022-03-11 | 深圳市名竹科技有限公司 | Data processing method, data processing device, computer equipment and storage medium |
| CN114168218B (en)* | 2021-11-30 | 2024-03-29 | 深圳市名竹科技有限公司 | Data processing method, device, computer equipment and storage medium |
| CN114201503A (en)* | 2021-12-09 | 2022-03-18 | 东软集团股份有限公司 | Blockchain data processing method, device, storage medium and electronic device |
| CN115601177A (en)* | 2022-11-15 | 2023-01-13 | 南京知麦信息科技有限公司（Cn） | Intelligent contract generation method based on animal product breeding and processing overall process management model |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110880146A (en) | Block chain chaining method, device, electronic equipment and storage medium | |
| CN110598446B (en) | Block chain-based test method, device, storage medium and computer equipment | |
| CN108665372B (en) | Information processing, inquiring and storing method and device based on block chain | |
| CN110266872B (en) | Address book data management and control method and device, cloud address book system, computer equipment and computer readable storage medium | |
| CN114500690B (en) | Interface data processing method and device, electronic equipment and storage medium | |
| CN111427613B (en) | Application program interface API management method and device | |
| CN112363997B (en) | Data version management method, device and storage medium | |
| CN114567643B (en) | Cross-blockchain data transfer method, device and related equipment | |
| CN106844489A (en) | A kind of file operation method, device and system | |
| CN110597541A (en) | Interface updating processing method, device, equipment and storage medium based on block chain | |
| US11997216B2 (en) | Systems and methods for maintaining secure, encrypted communications across distributed computer networks by linking cryptography-based digital repositories in order to perform blockchain operations in decentralized applications | |
| EP4407954A1 (en) | Data exchange method, system and apparatus, and device | |
| CN114666113A (en) | Dynamic response data desensitization method based on API gateway | |
| EP4407930A1 (en) | Data security protection system | |
| US12219068B2 (en) | Systems and methods for using secure, encrypted communications across distributed computer networks to efficiently index blockchain states for performing blockchain operations in decentralized applications using cryptography-based digital repositories | |
| CN119835045A (en) | Heterogeneous system data sharing method, equipment and medium based on self-built gateway | |
| CN113014556B (en) | Bank-enterprise communication system, communication method and electronic terminal | |
| CN118487795B (en) | A unified service bus USB system based on authorization relationship | |
| CN113129008A (en) | Data processing method and device, computer readable medium and electronic equipment | |
| CN117171812A (en) | Multi-source trusted data production method based on blockchain, blockchain node and system | |
| US12079183B2 (en) | Systems and methods for a stateless blockchain overlay layer | |
| US12244722B2 (en) | Systems and methods for selecting secure, encrypted communications across distributed computer networks for cryptography-based digital repositories in order to perform blockchain operations in decentralized | |
| US12206788B2 (en) | Systems and methods for using secure, encrypted communications across distributed computer networks to efficiently update cryptography-based digital repositories for performing blockchain operations in decentralized applications | |
| CN113778709B (en) | Interface calling method, device, server and storage medium | |
| CN116980412A (en) | Block chain-based data processing method, equipment and readable storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| CB02 | Change of applicant information | Address after:200040, room 710, 302 Changping Road, Shanghai, Jingan District Applicant after:Shanghai Xinlian Information Development Co.,Ltd. Address before:200040, room 710, 302 Changping Road, Shanghai, Jingan District Applicant before:SHANGHAI ZHONGXIN INFORMATION DEVELOPMENT Co.,Ltd. | |
| CB02 | Change of applicant information | ||
| RJ01 | Rejection of invention patent application after publication | Application publication date:20200313 | |
| RJ01 | Rejection of invention patent application after publication |