CN108984603A - Isomeric data acquisition method, equipment, storage medium and system - Google Patents
Isomeric data acquisition method, equipment, storage medium and system Download PDFInfo
- Publication number
- CN108984603A CN108984603A CN201810572837.1A CN201810572837A CN108984603A CN 108984603 A CN108984603 A CN 108984603A CN 201810572837 A CN201810572837 A CN 201810572837A CN 108984603 A CN108984603 A CN 108984603A
- Authority
- CN
- China
- Prior art keywords
- data
- interface
- data field
- heterogeneous
- server
- 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
- 238000000034 method Methods 0.000 title claims abstract description 58
- 238000013480 data collection Methods 0.000 claims abstract description 51
- 238000011161 development Methods 0.000 abstract description 9
- 241001269238 Data Species 0.000 abstract 1
- 230000008569 process Effects 0.000 description 10
- 238000012545 processing Methods 0.000 description 5
- 238000004891 communication Methods 0.000 description 4
- 230000003252 repetitive effect Effects 0.000 description 4
- 238000010586 diagram Methods 0.000 description 2
- 230000004807 localization Effects 0.000 description 2
- 238000003032 molecular docking Methods 0.000 description 2
- 230000003993 interaction Effects 0.000 description 1
- 230000002452 interceptive effect Effects 0.000 description 1
- 238000013507 mapping Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 230000004044 response Effects 0.000 description 1
- 230000009466 transformation Effects 0.000 description 1
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
Description
技术领域technical field
本发明涉及电信领域,尤其涉及异构数据采集方法、设备、存储介质及系统。The present invention relates to the field of telecommunications, and in particular to heterogeneous data collection methods, equipment, storage media and systems.
背景技术Background technique
目前数据市场上的各个数据提供方的数据服务接口多为自己定义,在接口交互方式、调用参数、数据格式等方面并不统一。因此各数据需求方在采集外部数据时,需要分别不同提供方的接口,还需要对异构数据进行本地化处理,存在大量的重复工作。随着提供方或需求方数量增加,重复工作量也将倍增。At present, the data service interfaces of various data providers in the data market are mostly defined by themselves, and they are not uniform in terms of interface interaction methods, call parameters, and data formats. Therefore, when each data demander collects external data, it needs to separate the interfaces of different providers, and also needs to localize the heterogeneous data, resulting in a lot of repetitive work. As the number of suppliers or demanders increases, the amount of duplication of work will also multiply.
上述内容仅用于辅助理解本发明的技术方案,并不代表承认上述内容是现有技术。The above content is only used to assist in understanding the technical solution of the present invention, and does not mean that the above content is admitted as prior art.
发明内容Contents of the invention
本发明的主要目的在于提供异构数据采集方法、用户设备、存储介质及系统,旨在解决现有技术中对异构数据进行采集时存在大量的重复工作的问题。The main purpose of the present invention is to provide a heterogeneous data collection method, user equipment, storage medium and system, aiming to solve the problem of a lot of repetitive work in the prior art when collecting heterogeneous data.
为上述目的,本发明提供异构数据采集方法,所述异构数据采集方法包括以下步骤:For the above purpose, the present invention provides a method for collecting heterogeneous data, and the method for collecting heterogeneous data includes the following steps:
数据采集设备响应于用户输入的数据栏位查询指令,判断预设数据目录是否包含与所述数据栏位查询指令对应的数据栏位;The data acquisition device responds to the data field query instruction input by the user, and determines whether the preset data directory contains the data field corresponding to the data field query instruction;
在所述预设数据目录包含与所述数据栏位查询指令对应的数据栏位时,所述数据采集设备从服务端获取接口实现程序;When the preset data directory includes a data field corresponding to the data field query instruction, the data acquisition device acquires an interface implementation program from the server;
通过所述接口实现程序从数据提供方获取待采集的异构数据,将采集得到的所述异构数据写入与所述数据栏位查询指令对应的数据栏位。The interface implementation program acquires the heterogeneous data to be collected from the data provider, and writes the collected heterogeneous data into the data field corresponding to the data field query instruction.
优选地,在所述判断预设数据目录是否包含与所述数据栏位查询指令对应的数据栏位之后,所述异构数据采集方法还包括:Preferably, after the judging whether the preset data directory contains the data field corresponding to the data field query instruction, the heterogeneous data collection method further includes:
在所述预设数据目录中没有所述数据栏位时,将与所述数据栏位查询指令对应的数据栏位添加至所述预设数据目录中;When the data field does not exist in the default data directory, adding the data field corresponding to the data field query instruction to the default data directory;
所述数据采集设备从服务端获取接口实现程序;The data acquisition device acquires an interface implementation program from the server;
通过所述接口实现程序从数据提供方获取待采集的异构数据,将采集得到的所述异构数据写入添加的数据栏位。The heterogeneous data to be collected is obtained from the data provider through the interface implementation program, and the collected heterogeneous data is written into the added data column.
优选地,所述将与所述数据栏位查询指令对应的数据栏位添加至所述预设数据目录中,具体包括:Preferably, adding the data field corresponding to the data field query instruction to the preset data directory specifically includes:
从所述服务端获取待采集数据的接口文档,根据所述接口文档判断对应的目标数据接口是否能直接配置;Obtain an interface document of the data to be collected from the server, and judge whether the corresponding target data interface can be directly configured according to the interface document;
当所述目标数据接口不能直接配置时,向所述服务端发送特殊数据接口指令,获取所述服务端返回的特殊数据栏位;When the target data interface cannot be directly configured, send a special data interface command to the server to obtain the special data field returned by the server;
将所述特征数据栏位作为与所述数据栏位查询指令对应的数据栏位,并将与所述数据栏位查询指令对应的数据栏位更新至所述预设数据目录。The feature data field is used as a data field corresponding to the data field query instruction, and the data field corresponding to the data field query instruction is updated to the default data directory.
优选地,所述根据所述接口文档判断对应的目标数据接口是否能直接配置之后,所述异构数据采集方法还包括:Preferably, after determining whether the corresponding target data interface can be directly configured according to the interface document, the heterogeneous data collection method further includes:
当所述目标数据接口能直接配置时,配置所述通用数据接口,向所述服务端发送更新指令,获取服务端返回与所述通用接口对应的通用数据栏位;When the target data interface can be directly configured, configure the general data interface, send an update command to the server, and obtain the general data field corresponding to the general interface returned by the server;
将所述通用数据栏位作为与所述数据栏位查询指令对应的数据栏位,将与所述数据栏位查询指令对应的数据栏位更新至所述预设数据目录。The general data field is used as the data field corresponding to the data field query instruction, and the data field corresponding to the data field query instruction is updated to the default data directory.
优选地,所述数据采集设备从服务端获取接口实现程序,具体包括:Preferably, the data acquisition device acquires an interface implementation program from the server, specifically including:
接收所述服务端返回的目标接口实现程序,判断所述目标接口实现程序中的目标数据接口配置和所述数据栏位是否合法,当判断结果为合法时,所述数据采集设备从服务端获取接口实现程序。Receiving the target interface implementation program returned by the server, judging whether the target data interface configuration in the target interface implementation program and the data field are legal, and when the judgment result is legal, the data acquisition device obtains the Interface implementer.
优选地,所述判断所述目标数据接口中的目标数据接口配置和所述数据栏位是否合法之后,所述方法还包括:Preferably, after determining whether the configuration of the target data interface in the target data interface and the data fields are legal, the method further includes:
当判断结果为不合法时,修改所述目标数据接口配置和所述数据栏位。When the judging result is invalid, modify the target data interface configuration and the data field.
优选地,所述将所述待采集异构数据写入与所述数据栏位查询指令对应的数据栏位之后,所述方法还包括:Preferably, after writing the heterogeneous data to be collected into the data field corresponding to the data field query instruction, the method further includes:
输出并显示所述数据栏位,以使用户调用所述待采集异构数据。The data field is output and displayed, so that the user can call the heterogeneous data to be collected.
优选地,所述数据采集系统包括:Preferably, the data collection system includes:
判断模块:用于数据采集设备响应于用户输入的数据栏位查询指令,判断预设数据目录是否包含与所述数据栏位查询指令对应的数据栏位;Judgment module: used for the data acquisition device to respond to the data field query instruction input by the user, and judge whether the preset data directory contains the data field corresponding to the data field query instruction;
控制模块:用于在所述预设数据目录包含与所述数据栏位查询指令对应的数据栏位时,所述数据采集设备从服务端获取接口实现程序;A control module: used for, when the preset data directory includes a data field corresponding to the data field query instruction, the data acquisition device acquires an interface implementation program from the server;
采集模块:用于通过所述接口实现程序从数据提供方获取待采集的异构数据,将采集得到的所述异构数据写入与所述数据栏位查询指令对应的数据栏位。Acquisition module: used to obtain the heterogeneous data to be collected from the data provider through the interface implementation program, and write the collected heterogeneous data into the data field corresponding to the data field query instruction.
此外,本发明还提出一种数据采集设备,所述数据采集设备包括:存储器、处理器及存储在所述存储器上并可在所述处理器上运行的数据采集程序,所述数据采集程序配置为如上所述的数据采集方法的步骤。In addition, the present invention also proposes a data collection device, the data collection device includes: a memory, a processor, and a data collection program stored in the memory and operable on the processor, the data collection program is configured are the steps of the data collection method described above.
此外,本发明还提出一种存储介质,所述存储介质上存储有数据采集程序,所述数据采集程序被处理器执行时如上所述的异构数据采集方法的步骤。In addition, the present invention also proposes a storage medium, on which a data collection program is stored, and when the data collection program is executed by a processor, the steps of the above-mentioned heterogeneous data collection method are described.
本发明技术方案通过对数据栏位进行查询,从而判断出预设数据目录是否包含与相应的数据栏位;在所述预设数据目录包含相应的数据栏位时,所述数据采集设备从服务端获取接口实现程序,通过所述接口实现程序从数据提供方获取待采集的异构数据;将所述待采集异构数据写入相应的数据栏位,从而在数据采集设备在采集外部数据(例如服务器)时,无需自定义开发接口,只需从服务端获取相应的数据接口,通过接口实现程序读取待采集异构数据,实现异构数据本地化处理,解决了对异构数据进行采集时存在大量的重复工作的问题。The technical solution of the present invention checks the data field to determine whether the preset data directory contains the corresponding data field; when the preset data directory contains the corresponding data field, the data collection device will The terminal obtains the interface implementation program, and obtains the heterogeneous data to be collected from the data provider through the interface implementation program; writes the heterogeneous data to be collected into the corresponding data column, so that the data collection device is collecting external data ( For example, when using a server), there is no need to customize the development interface, just obtain the corresponding data interface from the server, implement the program to read the heterogeneous data to be collected through the interface, realize the localization processing of heterogeneous data, and solve the problem of collecting heterogeneous data There is a lot of duplication of work.
附图说明Description of drawings
图1是本发明实施例方案涉及的硬件运行环境的用户设备结构示意图;FIG. 1 is a schematic structural diagram of a user equipment in a hardware operating environment involved in an embodiment of the present invention;
图2为本发明异构数据采集方法第一实施例的流程示意图;Fig. 2 is a schematic flow chart of the first embodiment of the heterogeneous data collection method of the present invention;
图3为本发明异构数据采集方法第二实施例的流程示意图;Fig. 3 is a schematic flow chart of the second embodiment of the heterogeneous data collection method of the present invention;
图4为本发明异构数据采集方法第三实施例的流程示意图;Fig. 4 is a schematic flow chart of the third embodiment of the heterogeneous data collection method of the present invention;
图5为本发明数据采集设备一实施例的模块图。Fig. 5 is a block diagram of an embodiment of the data acquisition device of the present invention.
本发明目的的、功能特点及优点将结合实施例,参照附图做进一步说明。The purpose, functional features and advantages of the present invention will be further described in conjunction with the embodiments and with reference to the accompanying drawings.
具体实施方式Detailed ways
应当理解,此处所描述的具体实施例仅仅用以解释本发明,并不用于限定本发明。It should be understood that the specific embodiments described here are only used to explain the present invention, not to limit the present invention.
本发明异构数据采集方法基于一种数据采集设备,所述数据采集设备可为个人电脑或智能手机等电子设备。The heterogeneous data collection method of the present invention is based on a data collection device, and the data collection device can be an electronic device such as a personal computer or a smart phone.
如图1所示,数据采集设备100可以包括:处理器1001,例如CPU,网络接口1004,用户接口1003,存储器1005,通信总线1002。其中,通信总线1002用于实现这些组件之间的连接通信。用户接口1003可以包括显示单元(Display)、输入单元比如交互界面,在本发明中数据采集设备100在软件运行的过程中可与用户端进行交互,在数据采集设备100进行参数设置或调试时,测试人员或设置人员可利用用户接口1003进行数据信息的输入,可选用户接口1003还可以包括标准的有线接口、无线接口。网络接口1004可选的可以包括标准的有线接口、无线接口(如WI-FI接口)。存储器1005可以是高速RAM存储器,也可以是稳定的存储器(non-volatile memory),例如磁盘存储器。存储器1005可选的还可以是独立于前述处理器1001的存储装置。As shown in FIG. 1 , the data collection device 100 may include: a processor 1001 , such as a CPU, a network interface 1004 , a user interface 1003 , a memory 1005 , and a communication bus 1002 . Wherein, the communication bus 1002 is used to realize connection and communication between these components. The user interface 1003 can include a display unit (Display), an input unit such as an interactive interface. In the present invention, the data acquisition device 100 can interact with the user terminal during the software running process. When the data acquisition device 100 performs parameter setting or debugging, Testers or setup personnel can use the user interface 1003 to input data information, and the optional user interface 1003 can also include standard wired interfaces and wireless interfaces. Optionally, the network interface 1004 may include a standard wired interface and a wireless interface (such as a WI-FI interface). The memory 1005 can be a high-speed RAM memory, or a stable memory (non-volatile memory), such as a disk memory. Optionally, the memory 1005 may also be a storage device independent of the aforementioned processor 1001 .
基于上述硬件结构,提出本发明异构数据采集方法的实施例。Based on the above hardware structure, an embodiment of the heterogeneous data collection method of the present invention is proposed.
参照图2,图2为本发明异构数据采集方法第一实施例的流程示意图。Referring to FIG. 2 , FIG. 2 is a schematic flowchart of a first embodiment of a method for collecting heterogeneous data according to the present invention.
在第一实施例中,所述异构数据采集方法包括以下步骤:In the first embodiment, the heterogeneous data collection method includes the following steps:
步骤S10:数据采集设备响应于用户输入的数据栏位查询指令,判断预设数据目录是否包含与所述数据栏位查询指令对应的数据栏位。Step S10: In response to the data field query command input by the user, the data collection device determines whether the preset data directory contains the data field corresponding to the data field query command.
可以理解的是,本实施例的执行主体为数据采集设备。考虑到用户在通过数据采集设备来采集各类外部异构数据时,数据对接场景下,数据需求方需要根据数据提供方的技术规范(接口规范、数据规范)来进行系统对接。通常的做法是需求方自行开发接口,并部署在自身的系统环境中,无论此环境是在自建机房或者在云计算环境上,数据需求方根据数据提供方的技术规范来开发接口是一个必不可少的环节。当需求方或提供方有更换时,这一开发环节始终存在。本实施例可通过数据需求方统一负责接口实现,客户端从服务端获取接口实现,负责对应数据接入和处理。从而减少客户端对接口的重复开发工作,快速灵活的接入各类数据。It can be understood that the execution subject of this embodiment is the data acquisition device. Considering that when users collect various external heterogeneous data through data collection equipment, in the data docking scenario, the data demander needs to carry out system docking according to the technical specifications (interface specifications, data specifications) of the data provider. The usual practice is that the demand side develops the interface by itself and deploys it in its own system environment. Whether the environment is in a self-built computer room or in a cloud computing environment, it is a must for the data demand side to develop the interface according to the technical specifications of the data provider. indispensable link. This development link always exists when the demand side or the provider is changed. In this embodiment, the data requester is responsible for the implementation of the interface, and the client obtains the interface implementation from the server and is responsible for corresponding data access and processing. In this way, the repeated development work of the client on the interface is reduced, and various types of data can be accessed quickly and flexibly.
应当理解的是。当数据需求打开一个预设输入页面时,该预设输入页面中存在多个数据目录,不同的数据目录对应不同的数据栏位。例如数据目录的类型可以包括司法类、身份信息类、互联网类、车辆类、位置类、运营商类、银行卡类、旅游类等,数据目录还可以包括子目录,例如运营商类进一步的划分为联通、移动、电信、全网。It should be understood. When the data requirement opens a default input page, there are multiple data directories in the default input page, and different data directories correspond to different data fields. For example, the type of data directory can include judicial, identity information, Internet, vehicle, location, operator, bank card, travel, etc., and the data directory can also include subdirectories, such as further division of operator For China Unicom, China Mobile, China Telecom, and the entire network.
选中所需查询的数据目录的类型后,进入栏位查询页面。在栏位查询的输入框内,输入所要查询的数据栏位名称。通过将输入的数据栏位名称与预设数据目录中的数据栏位进行匹配,通过匹配结果,可判断预设数据目录是否包含与所述数据栏位查询指令对应的数据栏位。After selecting the type of data catalog to be queried, enter the field query page. In the field query input box, enter the name of the data field to be queried. By matching the input data field name with the data field in the default data directory, it can be determined whether the default data directory contains the data field corresponding to the data field query instruction based on the matching result.
数据栏位可以是身份信息、手机号码、姓名等。The data field can be identity information, mobile phone number, name, etc.
步骤S20:在所述预设数据目录包含与所述数据栏位查询指令对应的数据栏位时,所述数据采集设备从服务端获取接口实现程序;Step S20: when the preset data directory includes a data field corresponding to the data field query instruction, the data acquisition device acquires an interface implementation program from the server;
可以理解的是,输入的数据栏位名称与预设数据目录中的数据栏位匹配成功时,说明所述预设数据目录包含与所述数据栏位查询指令对应的数据栏位。此时,在预设页面上可直接看到所需的数据栏位,数据采集设备从服务端下载对应的接口实现程序。It can be understood that when the name of the input data field matches the data field in the default data directory successfully, it means that the default data directory includes the data field corresponding to the data field query instruction. At this point, the required data fields can be directly seen on the preset page, and the data acquisition device downloads the corresponding interface implementation program from the server.
步骤S30:通过所述接口实现程序从数据提供方获取待采集的异构数据,将采集得到的所述异构数据写入与所述数据栏位查询指令对应的数据栏位。Step S30: Obtain the heterogeneous data to be collected from the data provider through the interface implementation program, and write the collected heterogeneous data into the data field corresponding to the data field query instruction.
易于理解的是,数据采集设备通过接口实现程序从所述数据提供方读取待采集异构数据,异构数据从服务端下载完成后,存储于数据采集设备的存储器中,数据采集设备从存储器中读取异构数据,将读取的异构数据写入数据栏位进行展示,方便数据需求方进行查阅。It is easy to understand that the data collection device reads the heterogeneous data to be collected from the data provider through the interface implementation program. After the heterogeneous data is downloaded from the server, it is stored in the memory of the data collection device. Read heterogeneous data in the database, and write the read heterogeneous data into the data column for display, which is convenient for data demanders to view.
本发明技术方案通过对数据栏位进行查询,从而判断出预设数据目录是否包含与相应的数据栏位;在所述预设数据目录包含相应的数据栏位时,所述数据采集设备从服务端获取接口实现程序,通过所述接口实现程序从数据提供方获取待采集的异构数据;将所述待采集异构数据写入相应的数据栏位,从而在数据采集设备在采集外部数据(例如服务器)时,无需自定义开发接口,只需从服务端获取相应的数据接口,通过接口实现程序读取待采集异构数据,实现异构数据本地化处理,解决了对异构数据进行采集时存在大量的重复工作的问题。The technical solution of the present invention checks the data field to determine whether the preset data directory contains the corresponding data field; when the preset data directory contains the corresponding data field, the data collection device will The terminal obtains the interface implementation program, and obtains the heterogeneous data to be collected from the data provider through the interface implementation program; writes the heterogeneous data to be collected into the corresponding data column, so that the data collection device is collecting external data ( For example, when using a server), there is no need to customize the development interface, just obtain the corresponding data interface from the server, implement the program to read the heterogeneous data to be collected through the interface, realize the localization processing of heterogeneous data, and solve the problem of collecting heterogeneous data There is a lot of duplication of work.
参照图3,在第二实施例中,在所述判断预设数据目录是否包含与所述数据栏位查询指令对应的数据栏位之后,所述异构数据采集方法还包括:Referring to FIG. 3 , in the second embodiment, after the determination of whether the preset data directory contains the data field corresponding to the data field query instruction, the heterogeneous data collection method further includes:
步骤S40:在所述预设数据目录中没有所述数据栏位时,将与所述数据栏位查询指令对应的数据栏位添加至所述预设数据目录中。Step S40: When the data field does not exist in the default data directory, add the data field corresponding to the data field query instruction to the default data directory.
值得说明的是,数据栏位可由业务人员进行手动配置或者由服务器进行自动配置。在进行手动配置时,由业务人员在预设页面上进行配置,经过模板化的配置流程对数据接口进行定义,并将对应数据栏位添加到数据目录中。在一实施例中,模板化的配置流程包括如下步骤:新增进程、新增接口、新增头部参数、新增参数、新增栏位、新增栏位映射、新增加解密信息及新增解析信息。通过这些配置后,数据栏位也相应的添加到数据目录中。It is worth noting that the data fields can be manually configured by business personnel or automatically configured by the server. During manual configuration, business personnel configure on the preset page, define the data interface through a templated configuration process, and add the corresponding data fields to the data directory. In one embodiment, the templated configuration process includes the following steps: adding a process, adding an interface, adding a header parameter, adding a parameter, adding a field, adding a field mapping, adding decryption information, and adding a new Add analysis information. After passing these configurations, the data fields are added to the data directory accordingly.
服务器进行自动配置时,数据采集设备从服务器下载接口实现程序,在数据采集设备进行配置安装。When the server performs automatic configuration, the data acquisition device downloads the interface implementation program from the server, and configures and installs it on the data acquisition device.
S50、所述数据采集设备从服务端获取接口实现程序。S50. The data collection device acquires an interface implementation program from the server.
易于理解的是,数据采集设备从服务端下载对应的接口实现程序,在数据采集设备进行配置安装,数据采集设备通过接口实现程序从所述服务端读取待采集异构数据。It is easy to understand that the data acquisition device downloads the corresponding interface implementation program from the server, configures and installs it on the data acquisition device, and the data acquisition device reads the heterogeneous data to be collected from the server through the interface implementation program.
S60、通过所述接口实现程序从数据提供方获取待采集的异构数据,将采集得到的所述异构数据写入添加的数据栏位。易于理解的是,这里步骤S60与第一实施例中步骤S30相同。S60. Obtain the heterogeneous data to be collected from the data provider through the interface implementation program, and write the collected heterogeneous data into the added data column. It is easy to understand that step S60 here is the same as step S30 in the first embodiment.
参照图4,在第三实施例中,所述将与所述数据栏位查询指令对应的数据栏位添加至所述预设数据目录中,所述异构数据采集方法具体包括:Referring to Fig. 4, in the third embodiment, the data field corresponding to the data field query instruction is added to the preset data directory, and the heterogeneous data collection method specifically includes:
步骤S401:从所述服务端获取待采集数据的接口文档,根据所述接口文档判断对应的目标数据接口是否能直接配置。Step S401: Obtain an interface document of the data to be collected from the server, and judge whether the corresponding target data interface can be directly configured according to the interface document.
可以理解的是,在项目开发中,web项目的前后端分离开发,APP开发,需要由前后端工程师共同定义接口,编写接口文档,之后都根据这个接口文档进行开发。It is understandable that in project development, the front-end and back-end of web projects are developed separately, and APP development requires front-end and back-end engineers to jointly define interfaces, write interface documents, and then develop based on this interface document.
因而接口文档中记录了目标数据接口的方法、uri、请求参数和返回参数等。通过接口文档可获知目标数据接口的类型。Therefore, the method, uri, request parameters and return parameters of the target data interface are recorded in the interface document. The type of the target data interface can be known through the interface document.
在一实施例中,通过查看待采集数据的api接口文档(数据提供方给出),根据该api接口文档的客户端接入说明判断是否该目标数据接口属于通用的单次调用型http或者https类型接口,如是则可以直接配置实现。In one embodiment, by checking the api interface document of the data to be collected (given by the data provider), it is judged according to the client access description of the api interface document whether the target data interface belongs to the general single-call type http or https Type interface, if so, it can be directly configured and implemented.
步骤S402:当所述目标数据接口不能直接配置时,向所述服务端发送特殊数据接口指令,获取所述服务端返回的特殊数据栏位。Step S402: When the target data interface cannot be configured directly, send a special data interface command to the server to obtain the special data field returned by the server.
值得说明的是,当目标数据接口类型不是单次调用型http或者https时,数据采集设备向服务端发送特殊数据接口指令,同时附带该特殊数据接口的api接口文档,服务端接收到特殊数据接口请求时,实现该特殊数据接口及特殊数据栏位,并通知数据采集设备。数据采集设备收到通知后,下载特殊数据栏位。It is worth noting that when the target data interface type is not a single-call type http or https, the data acquisition device sends a special data interface instruction to the server, and at the same time attaches the api interface document of the special data interface, and the server receives the special data interface When requested, implement the special data interface and special data field, and notify the data collection device. After receiving the notification, the data collection device downloads the special data fields.
步骤S403:将所述特征数据栏位作为与所述数据栏位查询指令对应的数据栏位,并将与所述数据栏位查询指令对应的数据栏位更新至所述预设数据目录。Step S403: Use the feature data field as a data field corresponding to the data field query command, and update the data field corresponding to the data field query command to the default data directory.
如此,在目标数据接口不能直接配置时,从服务端接收特殊数据栏位,实现对异构数据的采集,无需在数据采集设备上开发数据接口,从而减少客户端对接口的重复开发工作,快速灵活的接入各类数据。In this way, when the target data interface cannot be directly configured, the special data field is received from the server to realize the collection of heterogeneous data, without the need to develop the data interface on the data collection device, thereby reducing the repetitive development work of the client on the interface, and quickly Flexible access to various types of data.
进一步地,所述根据所述接口文档判断对应的目标数据接口是否能直接配置之后,所述异构数据采集方法还包括:Further, after determining whether the corresponding target data interface can be directly configured according to the interface document, the heterogeneous data collection method further includes:
步骤S405:当所述目标数据接口能直接配置时,配置所述通用数据接口,向所述服务端发送更新指令,获取服务端返回与所述通用接口对应的通用数据栏位。Step S405: When the target data interface can be directly configured, configure the general data interface, send an update command to the server, and obtain the general data field corresponding to the general interface returned by the server.
在一实施例中,当所述目标数据接口为单次调用型http或者https时,说明能够直接配置。通过业务人员手动配置通用接口,数据采集设备向服务端发送更新指令,该更新指令包括该通用接口的api接口文档中所包含的信息,服务端根据更新指令实现与所述通用接口对应的通用数据栏位,服务端通知数据采集设备进行下载。In an embodiment, when the target data interface is a single-call type http or https, it indicates that it can be directly configured. Through the manual configuration of the general interface by business personnel, the data acquisition device sends an update instruction to the server, the update instruction includes the information contained in the API interface document of the general interface, and the server implements the general data corresponding to the general interface according to the update instruction Field, the server notifies the data collection device to download.
步骤S406:将所述通用数据栏位作为与所述数据栏位查询指令对应的数据栏位,将与所述数据栏位查询指令对应的数据栏位更新至所述预设数据目录。Step S406: Using the common data field as the data field corresponding to the data field query instruction, updating the data field corresponding to the data field query instruction to the default data directory.
如此,在目标数据接口能直接配置时,从服务端接收通用数据栏位,实现对异构数据的采集,无需在数据采集设备上开发数据接口,从而减少客户端对接口的重复开发工作,快速灵活的接入各类数据。In this way, when the target data interface can be directly configured, the general data field is received from the server to realize the collection of heterogeneous data, and there is no need to develop the data interface on the data collection device, thereby reducing the repetitive development work of the client on the interface, and quickly Flexible access to various types of data.
进一步地,所述数据采集设备从服务端获取接口实现程序,具体包括:Further, the data acquisition device acquires an interface implementation program from the server, specifically including:
接收所述服务端返回的目标接口实现程序,判断所述目标接口实现程序中的目标数据接口配置和所述数据栏位是否合法,当判断结果为合法时,所述数据采集设备从服务端获取接口实现程序。Receiving the target interface implementation program returned by the server, judging whether the target data interface configuration in the target interface implementation program and the data field are legal, and when the judgment result is legal, the data acquisition device obtains the Interface implementer.
具体地,可通过人工打开至预设页面,判断目标数据接口配置和所述数据栏位是否正确,从而确定是否合法。Specifically, by manually opening to a preset page, it is judged whether the target data interface configuration and the data field are correct, thereby determining whether it is legal.
可以理解的是,在本实施例中通过判断数据接口配置和所述数据栏位是否合法,再进行数据读取,可以提高了数据采集的可靠性和安全性。It can be understood that, in this embodiment, by judging whether the data interface configuration and the data fields are legal, and then reading the data, the reliability and security of data collection can be improved.
进一步地,所述判断所述目标数据接口中的目标数据接口配置和所述数据栏位是否合法之后,所述方法还包括,所述异构数据采集方法还可以包括:Further, after judging whether the configuration of the target data interface in the target data interface and the data fields are legal, the method further includes that the heterogeneous data collection method may also include:
当判断结果为不合法时,修改所述目标数据接口配置和所述数据栏位。值得说明的是,在修改完成后,再次判断所述目标数据接口配置和所述数据栏位是否合法,直至判断为合法。When the judging result is invalid, modify the target data interface configuration and the data field. It is worth noting that after the modification is completed, it is judged again whether the configuration of the target data interface and the data field are legal until it is judged to be legal.
如此,能够提高异构数据采集的可靠性。In this way, the reliability of heterogeneous data collection can be improved.
综上,本发明技术方案包括两个软件系统,一个是部署在互联网的服务端系统,另一个是部署在各个数据需求方自有环境下的客户端系统,两者可以通过互联网进行通讯,也可以通过运营商专线或VPN进行通讯。To sum up, the technical solution of the present invention includes two software systems, one is a server system deployed on the Internet, and the other is a client system deployed in the environment of each data demander, both of which can communicate through the Internet, and also Communication can be carried out through the operator's dedicated line or VPN.
服务端系统统一负责提供方数据接口实现程序,客户端通过互联网从服务端获取这些数据接口实现程序,各个数据接口实现程序运行在客户端系统中,从而将客户端和各个数据提供方直接对接起来。The server system is responsible for the data interface implementation program of the provider. The client obtains these data interface implementation programs from the server through the Internet, and each data interface implementation program runs in the client system, thereby directly connecting the client and each data provider. .
在实际的使用过程中,数据需求方业务人员通过浏览和检索数据目录内容,可以对存在的数据直接获取对应的接口实现。如果需要的数据在目录中不存在,对于通用的提供方api数据接口,数据需求方业务人员可以自行在客户端系统配置新的数据提供方接口,添加新的数据栏位;对于特殊的无法由配置实现的api数据接口,业务人员可以通过客户端向服务端提交接口实现请求,并在服务端实现完毕后获取接口实现,添加新的数据栏位。In the actual use process, the business personnel on the data demand side can directly obtain the corresponding interface implementation for the existing data by browsing and retrieving the contents of the data directory. If the required data does not exist in the directory, for the general provider api data interface, the business personnel of the data demand side can configure a new data provider interface in the client system and add new data fields; Configure the implemented api data interface, and business personnel can submit an interface implementation request to the server through the client, and obtain the interface implementation after the server is implemented, and add a new data field.
数据需求方仅需要客户端系统的统一数据接口,即可用统一的格式接入各类数据栏位,用自定义的数据栏位加工逻辑处理数据值,快速灵活的把外部数据采集到自己的应用系统中。The data demand side only needs the unified data interface of the client system, that is, it can access various data fields in a unified format, process data values with custom data field processing logic, and quickly and flexibly collect external data into its own application system.
参照图5,基于上述异构数据采集方法,本发明还提出一种异构数据采集系统,所述数据采集系统包括:Referring to Fig. 5, based on the above heterogeneous data collection method, the present invention also proposes a heterogeneous data collection system, the data collection system includes:
判断模块10:用于数据采集设备响应于用户输入的数据栏位查询指令,判断预设数据目录是否包含与所述数据栏位查询指令对应的数据栏位。Judgment module 10: used for the data acquisition device to respond to the data field query instruction input by the user, and judge whether the preset data directory contains the data field corresponding to the data field query instruction.
需要说明的是,当数据需求打开一个预设输入页面时,该预设输入页面中存在多个数据目录,不同的数据目录对应不同的数据栏位。例如数据目录的类型可以包括司法类、身份信息类、互联网类、车辆类、位置类、运营商类、银行卡类、旅游类等,数据目录还可以包括子目录,例如运营商类进一步的划分为联通、移动、电信、全网。It should be noted that when a data requirement opens a preset input page, there are multiple data directories in the preset input page, and different data directories correspond to different data fields. For example, the type of data directory can include judicial, identity information, Internet, vehicle, location, operator, bank card, travel, etc., and the data directory can also include subdirectories, such as further division of operator For China Unicom, China Mobile, China Telecom, and the entire network.
选中所需查询的数据目录的类型后,进入栏位查询页面。在栏位查询的输入框内,输入所要查询的数据栏位名称。通过将输入的数据栏位名称与预设数据目录中的数据栏位进行匹配,通过匹配结果,可判断预设数据目录是否包含与所述数据栏位查询指令对应的数据栏位。After selecting the type of data catalog to be queried, enter the field query page. In the field query input box, enter the name of the data field to be queried. By matching the input data field name with the data field in the default data directory, it can be determined whether the default data directory contains the data field corresponding to the data field query instruction based on the matching result.
控制模块20:用于在所述预设数据目录包含与所述数据栏位查询指令对应的数据栏位时,所述数据采集设备从服务端获取接口实现程序。The control module 20 is configured to, when the preset data directory includes the data field corresponding to the data field query instruction, the data collection device acquires an interface implementation program from the server.
可以理解的是,输入的数据栏位名称与预设数据目录中的数据栏位匹配成功时,说明所述预设数据目录包含与所述数据栏位查询指令对应的数据栏位。此时,在预设页面上可直接看到所需的数据栏位,数据采集设备从服务端下载对应的接口实现程序,在数据采集设备进行配置安装,数据采集设备通过接口实现程序以及服务端中的数据读取接口从所述服务端读取待采集异构数据。It can be understood that when the name of the input data field matches the data field in the default data directory successfully, it means that the default data directory includes the data field corresponding to the data field query instruction. At this point, you can directly see the required data fields on the preset page. The data acquisition device downloads the corresponding interface implementation program from the server, configures and installs it on the data acquisition device, and the data acquisition device realizes the program through the interface and the server. The data reading interface in reads the heterogeneous data to be collected from the server.
采集模块30:用于通过所述接口实现程序从数据提供方获取待采集的异构数据,将采集得到的所述异构数据写入与所述数据栏位查询指令对应的数据栏位。The collection module 30: used to obtain the heterogeneous data to be collected from the data provider through the interface implementation program, and write the collected heterogeneous data into the data field corresponding to the data field query instruction.
易于理解的是,异构数据从数据提供方下载完成后,存储与数据采集设备的存储器中,数据采集设备从存储器中读取异构数据,将读取的异构数据写入数据栏位进行展示,方便数据需求方进行查阅。It is easy to understand that after the heterogeneous data is downloaded from the data provider, it is stored in the memory of the data acquisition device, and the data acquisition device reads the heterogeneous data from the memory and writes the read heterogeneous data into the data field for further processing. Display, to facilitate the data demand side to check.
为实现本发明目的,本发明还提出一种存储介质,所述存储介质上存储有数据采集程序,所述数据采集程序被处理器执行时如上所述的异构数据采集方法的步骤。To achieve the object of the present invention, the present invention also proposes a storage medium, on which a data collection program is stored, and when the data collection program is executed by a processor, the above-mentioned steps of the heterogeneous data collection method are described.
需要说明的是,在本文中,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者系统不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者系统所固有的要素。在没有更多限制的情况下,由语句“包括一个……”限定的要素,并不排除在包括该要素的过程、方法、物品或者系统中还存在另外的相同要素。It should be noted that, as used herein, the term "comprises", "comprises" or any other variation thereof is intended to cover a non-exclusive inclusion such that a process, method, article or system comprising a set of elements includes not only those elements, It also includes other elements not expressly listed, or elements inherent in the process, method, article, or system. Without further limitations, an element defined by the phrase "comprising a..." does not preclude the presence of additional identical elements in the process, method, article or system comprising that element.
上述本发明实施例序号仅仅为了描述,不代表实施例的优劣。词语第一、第二、以及第三等的使用不表示任何顺序,可将这些词解释为名称。The serial numbers of the above embodiments of the present invention are for description only, and do not represent the advantages and disadvantages of the embodiments. The use of the words first, second, and third etc. does not indicate any order and these words may be interpreted as designations.
通过以上的实施方式的描述,本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来,当然也可以通过硬件,但很多情况下前者是更佳的实施方式。基于这样的理解,本发明的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质(如ROM/RAM、磁碟、光盘)中,包括若干指令用以使得一台终端设备(可以是手机,计算机,服务器,空调器,或者网络设备等)执行本发明各个实施例所述的方法。Through the description of the above embodiments, those skilled in the art can clearly understand that the method of the above embodiments can be implemented by means of software plus the necessary general-purpose hardware platform, of course, it can also be implemented by hardware, but in many cases the former is better implementation. Based on this understanding, the technical solution of the present invention can be embodied in the form of a software product in essence or the part that contributes to the prior art, and the computer software product is stored in a storage medium (such as ROM/RAM, disk, CD) contains several instructions to make a terminal device (which may be a mobile phone, a computer, a server, an air conditioner, or a network device, etc.) execute the methods described in various embodiments of the present invention.
以上仅为本发明的优选实施例,并非因此限制本发明的专利范围,凡是利用本发明说明书及附图内容所作的等效结构或等效流程变换,或直接或间接运用在其他相关的技术领域,均同理包括在本发明的专利保护范围内。The above are only preferred embodiments of the present invention, and are not intended to limit the patent scope of the present invention. Any equivalent structure or equivalent process transformation made by using the description of the present invention and the contents of the accompanying drawings, or directly or indirectly used in other related technical fields , are all included in the scope of patent protection of the present invention in the same way.
Claims (10)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810572837.1A CN108984603A (en) | 2018-06-05 | 2018-06-05 | Isomeric data acquisition method, equipment, storage medium and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810572837.1A CN108984603A (en) | 2018-06-05 | 2018-06-05 | Isomeric data acquisition method, equipment, storage medium and system |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN108984603A true CN108984603A (en) | 2018-12-11 |
Family
ID=64540781
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201810572837.1A Pending CN108984603A (en) | 2018-06-05 | 2018-06-05 | Isomeric data acquisition method, equipment, storage medium and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN108984603A (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112367348A (en) * | 2020-09-23 | 2021-02-12 | 北京迈格威科技有限公司 | Data acquisition method, device, equipment and medium |
Citations (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104615630A (en) * | 2014-10-27 | 2015-05-13 | 武汉钢铁(集团)公司 | Data format conversion method between isomerous database systems |
| US9454767B2 (en) * | 2013-03-13 | 2016-09-27 | Salesforce.Com, Inc. | Systems, methods, and apparatuses for implementing a related command with a predictive query interface |
| US20160321369A1 (en) * | 2012-09-07 | 2016-11-03 | Splunk Inc. | Graphically Selectable Filter Parameters for Field Data in a Set of Machine Data |
| CN106372176A (en) * | 2016-08-30 | 2017-02-01 | 东华大学 | Method for supporting uniform SQL (Structured Query Language) query of embedded document |
| US20170046431A1 (en) * | 2015-08-11 | 2017-02-16 | Microsoft Technology Licensing, Llc | Task-level search engine evaluation |
| CN106547800A (en) * | 2015-09-23 | 2017-03-29 | 北京国双科技有限公司 | The method and device of striding equipment synchronization user behavior |
| CN106599197A (en) * | 2016-12-14 | 2017-04-26 | 深圳天源迪科信息技术股份有限公司 | Data acquisition and exchange engine |
| CN107391003A (en) * | 2017-07-25 | 2017-11-24 | 环球智达科技(北京)有限公司 | Navigation data processing method |
| CN107679064A (en) * | 2017-07-31 | 2018-02-09 | 平安科技(深圳)有限公司 | Data query method, apparatus and computer-readable recording medium |
| CN107730164A (en) * | 2017-09-15 | 2018-02-23 | 嘉兴友汇现代物流科技有限公司 | A kind of WCS intelligent storages dispatching management information system and its control method |
-
2018
- 2018-06-05 CN CN201810572837.1A patent/CN108984603A/en active Pending
Patent Citations (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20160321369A1 (en) * | 2012-09-07 | 2016-11-03 | Splunk Inc. | Graphically Selectable Filter Parameters for Field Data in a Set of Machine Data |
| US9454767B2 (en) * | 2013-03-13 | 2016-09-27 | Salesforce.Com, Inc. | Systems, methods, and apparatuses for implementing a related command with a predictive query interface |
| CN104615630A (en) * | 2014-10-27 | 2015-05-13 | 武汉钢铁(集团)公司 | Data format conversion method between isomerous database systems |
| US20170046431A1 (en) * | 2015-08-11 | 2017-02-16 | Microsoft Technology Licensing, Llc | Task-level search engine evaluation |
| CN106547800A (en) * | 2015-09-23 | 2017-03-29 | 北京国双科技有限公司 | The method and device of striding equipment synchronization user behavior |
| CN106372176A (en) * | 2016-08-30 | 2017-02-01 | 东华大学 | Method for supporting uniform SQL (Structured Query Language) query of embedded document |
| CN106599197A (en) * | 2016-12-14 | 2017-04-26 | 深圳天源迪科信息技术股份有限公司 | Data acquisition and exchange engine |
| CN107391003A (en) * | 2017-07-25 | 2017-11-24 | 环球智达科技(北京)有限公司 | Navigation data processing method |
| CN107679064A (en) * | 2017-07-31 | 2018-02-09 | 平安科技(深圳)有限公司 | Data query method, apparatus and computer-readable recording medium |
| CN107730164A (en) * | 2017-09-15 | 2018-02-23 | 嘉兴友汇现代物流科技有限公司 | A kind of WCS intelligent storages dispatching management information system and its control method |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112367348A (en) * | 2020-09-23 | 2021-02-12 | 北京迈格威科技有限公司 | Data acquisition method, device, equipment and medium |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111367976B (en) | Method and device for exporting EXCEL file data based on JAVA reflection mechanism | |
| KR102317535B1 (en) | Methods and systems for implementing data tracking with software development kits | |
| KR101389977B1 (en) | Client terminal and method for supporting multiple Operating System | |
| CN106990950B (en) | Interface layout method and device | |
| CN109614157A (en) | A kind of configuration method of system, device and storage medium | |
| US20030195951A1 (en) | Method and system to dynamically detect, download and install drivers from an online service | |
| CN113204558B (en) | Automatic data table structure updating method and device | |
| CN110245116A (en) | Reconciliation data processing method, device, equipment and computer-readable storage medium | |
| CN110286922A (en) | Application download update method, device, computer equipment and storage medium | |
| CN110263222B (en) | Data acquisition method, device, equipment and medium | |
| CN111859076A (en) | Data crawling method and device, computer equipment and computer readable storage medium | |
| WO2022127196A1 (en) | Application identification method and apparatus, and device and storage medium | |
| CN110598107A (en) | Management method of query system and computer storage medium | |
| US8510423B2 (en) | Install system and install method | |
| CN110688201A (en) | Log management method and related equipment | |
| CN108984603A (en) | Isomeric data acquisition method, equipment, storage medium and system | |
| CN105094787B (en) | Method and device for processing enterprise internet application | |
| CN101350020A (en) | Method, apparatus and system for verifying embedded type file system | |
| CN103150343A (en) | Method and system for managing downloaded files | |
| TW201905669A (en) | APP application display interface method, device and electronic device | |
| CN114168618A (en) | Intelligent data accounting method, system, device and medium | |
| CN111770004B (en) | HTTP (hyper text transport protocol) (S) flow content automatic verification method and storage medium | |
| CN108363614B (en) | Application service module management method and device and server | |
| JP6546832B2 (en) | Operating environment reconfiguration program, operating environment reconfiguration system, operating environment reconfiguration method | |
| CN113645289B (en) | Quota data request method, quota data transmission method, client, server and quota data transmission system |
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 | ||
| TA01 | Transfer of patent application right | ||
| TA01 | Transfer of patent application right |
Effective date of registration: 20220829 Address after: Room 1006, Building 16, Yingcai North 3rd Street, Future Science City, Changping District, Beijing 102200 Applicant after: China Mobile Information Technology Co.,Ltd. Address before: 518000 Room 201, building A, No. 1, Qian Wan Road, Qianhai Shenzhen Hong Kong cooperation zone, Shenzhen, Guangdong (Shenzhen Qianhai business secretary Co., Ltd.) Applicant before: SHIJINSHI CREDIT SERVICE Co.,Ltd. |
|
| RJ01 | Rejection of invention patent application after publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20181211 |