Movatterモバイル変換


[0]ホーム

URL:


CN114124695A - A data collection method, device and electronic device - Google Patents

A data collection method, device and electronic device
Download PDF

Info

Publication number
CN114124695A
CN114124695ACN202111392362.6ACN202111392362ACN114124695ACN 114124695 ACN114124695 ACN 114124695ACN 202111392362 ACN202111392362 ACN 202111392362ACN 114124695 ACN114124695 ACN 114124695A
Authority
CN
China
Prior art keywords
data acquisition
data
service module
attribute information
middleware
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
Application number
CN202111392362.6A
Other languages
Chinese (zh)
Inventor
王海涛
王化鹏
孙鹏飞
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Shanghai Finshine Technology Co ltd
Original Assignee
Shanghai Finshine Technology Co ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Shanghai Finshine Technology Co ltdfiledCriticalShanghai Finshine Technology Co ltd
Priority to CN202111392362.6ApriorityCriticalpatent/CN114124695A/en
Publication of CN114124695ApublicationCriticalpatent/CN114124695A/en
Pendinglegal-statusCriticalCurrent

Links

Images

Classifications

Landscapes

Abstract

The embodiment of the specification provides a data acquisition method, which comprises the steps of building a configuration platform, a registration center, a middleware, a message queue module and data acquisition service modules corresponding to different data acquisition protocols, sending configuration information to the registration center for registration when the data acquisition service modules are started for the first time, the attribute information of the acquisition equipment is configured for the acquisition equipment by the configuration center, the middleware establishes communication with the message queue module and the registration center, newly added registration information in the registration center is monitored, and establishes communication with the corresponding data acquisition service module, the middleware reads the configured equipment attribute information, and the middleware acquires data acquired by the acquisition equipment under each data acquisition service module through each data acquisition service module and sends the data to the message queue module. The operation and maintenance difficulty is reduced and the resource utilization efficiency is improved in an automatic monitoring and matching mode through the middleware.

Description

Data acquisition method and device and electronic equipment
Technical Field
The present application relates to the field of internet, and in particular, to a data acquisition method and apparatus, and an electronic device.
Background
The internet of things is a mechanism for sharing information and generating useful information between things by connecting the internet and operating without human management. As long as the internet can be connected with the internet, the internet of things is called an object. The data acquisition technology of the internet of things is used for receiving data from equipment and uploading the data to other services for further processing and storage. In the past, most of researches on the internet of things are focused on equipment communication challenges, but with the development of technologies, the application of the internet of things starts to consider the design of openness and expandability of a method and a system for integrating existing network equipment, so the most basic data acquisition of the application of the internet of things should also consider the design of more openness and high expandability.
Traditional monolithic architectures of the internet of things couple almost all functions together, and the internet of things becomes more and more complex in a distributed environment due to the increase in system functions. Therefore, the overload phenomenon often occurs, and at this time, the system can be expanded only by repeatedly deploying a plurality of systems with the same volume, which easily causes resource waste and has high operation and maintenance management difficulty.
Therefore, it is necessary to provide a new data acquisition method to reduce the operation and maintenance difficulty and improve the resource utilization efficiency.
Disclosure of Invention
The embodiment of the specification provides a data acquisition method, a data acquisition device and electronic equipment, which are used for reducing operation and maintenance difficulty and improving resource utilization efficiency.
An embodiment of the present specification provides a data acquisition method, including:
building a configuration platform, a registration center, middleware, a message queue module and data acquisition service modules corresponding to different data acquisition protocols;
the data acquisition service module sends configuration information to a registration center for registration when being started for the first time;
configuring attribute information of acquisition equipment for the acquisition equipment through a configuration center, establishing communication between the middleware and the message queue module as well as a registration center, monitoring newly added registration information in the registration center, and establishing communication with a corresponding data acquisition service module;
the middleware reads the configured equipment attribute information, determines an acquisition service module corresponding to acquisition equipment according to the configured equipment attribute information, and sends the equipment attribute information to the acquisition service module;
the middleware acquires data acquired by acquisition equipment under each data acquisition service module through each data acquisition service module and sends the data to the message queue module.
Optionally, the determining, according to the configured device attribute information, a data collection service module corresponding to a collection device includes:
and matching the corresponding data acquisition service module according to the protocol type in the equipment attribute information.
Optionally, configuring, by the configuration center, attribute information of the acquisition device for the acquisition device includes:
and updating the attribute information of the acquisition equipment for the acquisition equipment through the configuration center.
Optionally, the acquiring the device attribute information includes: device address information and device protocol information.
Optionally, the method further comprises:
building a remote calling system adaptive to a plurality of development languages;
the middleware acquires the data acquired by the acquisition equipment under each data acquisition service module through each data acquisition service module, and the method comprises the following steps:
the middleware establishes communication with each data acquisition service module through the remote calling system and acquires data acquired by acquisition equipment under each data acquisition service module.
Optionally, configuring, by the configuration center, attribute information of the acquisition device for the acquisition device includes:
and pulling the equipment attribute information from the platform of the Internet of things, and automatically configuring.
Optionally, the sending the data to a message queue module includes:
and the middleware collects the data and sends the data to a message queue module.
An embodiment of the present specification further provides a data acquisition apparatus, including:
the system comprises a system building module, a configuration platform, a registration center, a middleware, a message queue module and data acquisition service modules corresponding to different data acquisition protocols;
the data acquisition service module is used for sending configuration information to the registration center for registration when the data acquisition service module is started for the first time;
the configuration platform configures the attribute information of the acquisition equipment for the acquisition equipment;
the middleware establishes communication with the message queue module and the registration center, monitors newly added registration information in the registration center and establishes communication with the corresponding data acquisition service module;
the middleware reads the configured equipment attribute information, determines an acquisition service module corresponding to acquisition equipment according to the configured equipment attribute information, and sends the equipment attribute information to the acquisition service module;
the middleware acquires data acquired by acquisition equipment under each data acquisition service module through each data acquisition service module and sends the data to the message queue module.
Optionally, the determining, according to the configured device attribute information, a data collection service module corresponding to a collection device includes:
and matching the corresponding data acquisition service module according to the protocol type in the equipment attribute information.
Optionally, configuring, by the configuration center, attribute information of the acquisition device for the acquisition device includes:
and updating the attribute information of the acquisition equipment for the acquisition equipment through the configuration center.
Optionally, the acquiring the device attribute information includes: device address information and device protocol information.
Optionally, the method further comprises:
building a remote calling system adaptive to a plurality of development languages;
the middleware acquires the data acquired by the acquisition equipment under each data acquisition service module through each data acquisition service module, and the method comprises the following steps:
the middleware establishes communication with each data acquisition service module through the remote calling system and acquires data acquired by acquisition equipment under each data acquisition service module.
Optionally, configuring, by the configuration center, attribute information of the acquisition device for the acquisition device includes:
and pulling the equipment attribute information from the platform of the Internet of things, and automatically configuring.
Optionally, the sending the data to a message queue module includes:
and the middleware collects the data and sends the data to a message queue module.
An embodiment of the present specification further provides an electronic device, where the electronic device includes:
a processor; and the number of the first and second groups,
a memory storing a computer executable program which, when executed, causes the processor to perform any of the methods described above.
The present specification also provides a computer readable storage medium, wherein the computer readable storage medium stores one or more programs which, when executed by a processor, implement any of the above methods.
The technical proposal provided by the embodiment of the specification sends configuration information to the registration center for registration when the data acquisition service module is started for the first time by building a configuration platform, the registration center, a middleware, a message queue module and data acquisition service modules corresponding to different data acquisition protocols, the attribute information of the acquisition equipment is configured for the acquisition equipment by the configuration center, the middleware establishes communication with the message queue module and the registration center, newly added registration information in the registration center is monitored, and establishes communication with the corresponding data acquisition service module, the middleware reads the configured equipment attribute information, and the middleware acquires data acquired by the acquisition equipment under each data acquisition service module through each data acquisition service module and sends the data to the message queue module. The operation and maintenance difficulty is reduced and the resource utilization efficiency is improved in an automatic monitoring and matching mode through the middleware.
Drawings
The accompanying drawings, which are included to provide a further understanding of the application and are incorporated in and constitute a part of this application, illustrate embodiment(s) of the application and together with the description serve to explain the application and not to limit the application. In the drawings:
FIG. 1 is a schematic diagram illustrating a data collection method according to an embodiment of the present disclosure;
fig. 2 is a schematic structural diagram of a data acquisition device provided in an embodiment of the present disclosure;
fig. 3 is a schematic structural diagram of a data acquisition device provided in an embodiment of the present disclosure;
fig. 4 is a schematic structural diagram of an electronic device provided in an embodiment of the present disclosure;
fig. 5 is a schematic diagram of a computer-readable medium provided in an embodiment of the present specification.
Detailed Description
Exemplary embodiments of the present invention will now be described more fully with reference to the accompanying drawings. The exemplary embodiments, however, may be embodied in many different forms and should not be construed as limited to the embodiments set forth herein. Rather, these exemplary embodiments are provided so that this disclosure will be thorough and complete, and will fully convey the concept of the invention to those skilled in the art. The same reference numerals denote the same or similar elements, components, or parts in the drawings, and thus their repetitive description will be omitted.
Features, structures, characteristics or other details described in a particular embodiment do not preclude the fact that the features, structures, characteristics or other details may be combined in a suitable manner in one or more other embodiments in accordance with the technical idea of the invention.
In describing particular embodiments, the present invention has been described with reference to features, structures, characteristics or other details that are within the purview of one skilled in the art to provide a thorough understanding of the embodiments. One skilled in the relevant art will recognize, however, that the invention may be practiced without one or more of the specific features, structures, characteristics, or other details.
The flow charts shown in the drawings are merely illustrative and do not necessarily include all of the contents and operations/steps, nor do they necessarily have to be performed in the order described. For example, some operations/steps may be decomposed, and some operations/steps may be combined or partially combined, so that the actual execution sequence may be changed according to the actual situation.
The block diagrams shown in the figures are functional entities only and do not necessarily correspond to physically separate entities. I.e. these functional entities may be implemented in the form of software, or in one or more hardware modules or integrated circuits, or in different networks and/or processor means and/or microcontroller means.
The term "and/or" and/or "includes all combinations of any one or more of the associated listed items.
Fig. 1 is a schematic diagram of a data acquisition method provided in an embodiment of the present disclosure, where the method may include:
s101: and (3) building a configuration platform, a registration center, middleware, a message queue module and data acquisition service modules corresponding to different data acquisition protocols.
By combining the concepts of high cohesion, low coupling, openness and high reusability of the existing internet information system, the data acquisition service of the industrial internet of things system and various data processing services can be decoupled into independent services, the data acquisition services of various different protocols are decoupled into a plurality of independent data acquisition services, the adaptation of various protocols of industrial equipment is realized by matching with a gPC (remote process calling system) and a dynamic configuration design, the expandability of a large amount of industrial equipment is supported, and meanwhile, the occupation of resources is reduced as much as possible.
The data acquisition service module is deployed for a plurality of devices using the same communication protocol, the middleware is deployed for a plurality of data acquisition service modules, core service is provided, the middleware is responsible for scheduling and managing the data acquisition service modules, collected data corresponding to the data acquisition service modules are collected in a unified mode, and the collected data are transmitted to an upstream message queue module for data processing service.
S102: and the data acquisition service module sends configuration information to a registration center for registration when being started for the first time.
All the independently deployed data acquisition service modules are started according to default initialization configuration, and the default initialization configuration may not contain acquired equipment information and acquisition point location information, and may only contain information required by a registration center (etcd) and service configuration information. After being started, the data acquisition service registers to the registration center.
S103: and configuring attribute information of the acquisition equipment for the acquisition equipment through a configuration center, establishing communication between the middleware and the message queue module as well as the registration center, monitoring newly added registration information in the registration center, and establishing communication with the corresponding data acquisition service module.
In an embodiment of this specification, the configuring, by the configuration center, attribute information of the acquisition device for the acquisition device includes:
and updating the attribute information of the acquisition equipment for the acquisition equipment through the configuration center.
In an embodiment of this specification, the acquiring of the device attribute information includes: device address information and device protocol information.
And the user enters a configuration page, and if the equipment needing configuration is configured before, the user acquires the previous configuration information to modify. If the equipment needing to be configured is new equipment, the equipment attribute information can be pulled from the platform of the Internet of things, and the configured configuration file is stored in the registration center.
Therefore, in this embodiment of the present specification, the configuring, by the configuration center, attribute information of the acquisition device for the acquisition device may include:
and pulling the equipment attribute information from the platform of the Internet of things, and automatically configuring.
S104: the middleware reads the configured equipment attribute information, determines an data acquisition service module corresponding to acquisition equipment according to the configured equipment attribute information, and sends the equipment attribute information to the data acquisition service module.
In an embodiment of this specification, the determining, according to the configured device attribute information, a data acquisition service module corresponding to an acquisition device includes:
and matching the corresponding data acquisition service module according to the protocol type in the equipment attribute information.
After the middleware is started, the middleware is connected to an upstream message queue and a registry, and the change or update of equipment configuration in the registry is monitored.
And after monitoring the change or update, the middleware finds the address of the data acquisition service module of the corresponding protocol from the data acquisition service registered in the registration center, and triggers the data acquisition service module to acquire data by using the new data acquisition configuration information.
And the data acquisition service module acquires the data according to the configuration information in the middleware request and the equipment point location data in the configuration information by matching with the corresponding protocol, converts the data according to the data format configured by the configuration platform and returns the data to the middleware.
S105: the middleware acquires data acquired by acquisition equipment under each data acquisition service module through each data acquisition service module and sends the data to the message queue module.
The method comprises the steps of building a configuration platform, a registration center, a middleware, a message queue module and data acquisition service modules corresponding to different data acquisition protocols, sending configuration information to the registration center for registration when the data acquisition service modules are started for the first time, configuring acquisition equipment attribute information for acquisition equipment through the configuration center, establishing communication between the middleware and the message queue module as well as the registration center, monitoring newly added registration information in the registration center, establishing communication with the corresponding data acquisition service modules, reading the configured equipment attribute information by the middleware, determining the data acquisition service modules corresponding to the acquisition equipment according to the configured equipment attribute information, sending the equipment attribute information to the data acquisition service modules, and acquiring data acquired by the acquisition equipment under each data acquisition service module through each data acquisition service module by the middleware and sending the data acquired by the acquisition equipment to the message queue module. The operation and maintenance difficulty is reduced and the resource utilization efficiency is improved in an automatic monitoring and matching mode through the middleware.
In the embodiment of this specification, still include:
building a remote calling system adaptive to a plurality of development languages;
the middleware acquires the data acquired by the acquisition equipment under each data acquisition service module through each data acquisition service module, and the method comprises the following steps:
the middleware establishes communication with each data acquisition service module through the remote calling system and acquires data acquired by acquisition equipment under each data acquisition service module.
In an embodiment of this specification, the sending the data to a message queue module includes:
and the middleware collects the data and sends the data to a message queue module.
In specific implementation, a redundant standby data acquisition service module can be set up, and the middleware is switched into the standby data acquisition service module when the state of the middleware meets the preset condition by monitoring the state of the data acquisition service module.
In the embodiment of the specification, a multi-stage data acquisition service module with gradually increasing load capacity can be set up, the middleware switches to the previous-stage data acquisition service module by monitoring the state of the current data acquisition service module when a preset condition is met, and the previous-stage data acquisition service module replaces the current data acquisition service module to acquire data acquired by the acquisition equipment deployed below the previous-stage data acquisition service module.
Fig. 2 is a schematic structural diagram of a data acquisition device provided in an embodiment of the present disclosure, where the data acquisition device may include:
the system comprises asystem building module 201, a configuration platform, a registration center, a middleware, a message queue module and data acquisition service modules corresponding to different data acquisition protocols;
the dataacquisition service module 202 is used for sending configuration information to a registration center for registration when the data acquisition service module is started for the first time;
the configuration platform configures the attribute information of the acquisition equipment for the acquisition equipment;
themiddleware 203 establishes communication with the message queue module and the registration center, monitors newly added registration information in the registration center, and establishes communication with the corresponding data acquisition service module;
the middleware reads the configured equipment attribute information, determines an acquisition service module corresponding to acquisition equipment according to the configured equipment attribute information, and sends the equipment attribute information to the acquisition service module;
the middleware acquires data acquired by acquisition equipment under each data acquisition service module through each data acquisition service module and sends the data to the message queue module.
The device builds a configuration platform, a registration center, a middleware, a message queue module and data acquisition service modules corresponding to different data acquisition protocols, the data acquisition service modules send configuration information to the registration center for registration when being started for the first time, the configuration center configures acquisition equipment attribute information for acquisition equipment, the middleware establishes communication with the message queue module and the registration center, monitors newly added registration information in the registration center and establishes communication with the corresponding data acquisition service modules, the middleware reads the configured equipment attribute information, determines the data acquisition service modules corresponding to the acquisition equipment according to the configured equipment attribute information and sends the equipment attribute information to the data acquisition service modules, and the middleware acquires data acquired by the acquisition equipment under each data acquisition service module through each data acquisition service module and sends the data acquired to the message queue module. The operation and maintenance difficulty is reduced and the resource utilization efficiency is improved in an automatic monitoring and matching mode through the middleware.
Optionally, the determining, according to the configured device attribute information, a data collection service module corresponding to a collection device includes:
and matching the corresponding data acquisition service module according to the protocol type in the equipment attribute information.
Optionally, configuring, by the configuration center, attribute information of the acquisition device for the acquisition device includes:
and updating the attribute information of the acquisition equipment for the acquisition equipment through the configuration center.
Optionally, the acquiring the device attribute information includes: device address information and device protocol information.
Optionally, the method further comprises:
building a remote calling system adaptive to a plurality of development languages;
the middleware acquires the data acquired by the acquisition equipment under each data acquisition service module through each data acquisition service module, and the method comprises the following steps:
the middleware establishes communication with each data acquisition service module through the remote calling system and acquires data acquired by acquisition equipment under each data acquisition service module.
Optionally, configuring, by the configuration center, attribute information of the acquisition device for the acquisition device includes:
and pulling the equipment attribute information from the platform of the Internet of things, and automatically configuring.
Optionally, the sending the data to a message queue module includes:
and the middleware collects the data and sends the data to a message queue module.
Fig. 3 is a schematic structural diagram of a data acquisition apparatus provided in an embodiment of the present disclosure, where the apparatus includes aconfiguration platform 301,middleware 302, aregistry 303, amessage queue module 304, and a dataacquisition service module 305.
b1 is that a user performs configuration operation, including updating data attribute information of configured data acquisition equipment, b2 is that the equipment attribute information is directly acquired from an internet of things platform for automatic configuration, b3 stores the configuration information to a registration center, a middleware monitors the change of the registration center, b4 issues the equipment attribute information of the acquisition equipment to a data acquisition service module, the data acquisition service module can send the data acquired by the acquisition equipment to the middleware, the data acquisition service module can convert the data into json format data and then send the json format data to the middleware, the middleware sends the json format data to a message queue module, and the message queue module can send messages to a real-time database or an I internet of things platform.
Based on the same inventive concept, the embodiment of the specification further provides the electronic equipment.
In the following, embodiments of the electronic device of the present invention are described, which may be regarded as specific physical implementations for the above-described embodiments of the method and apparatus of the present invention. Details described in the embodiments of the electronic device of the invention should be considered supplementary to the embodiments of the method or apparatus described above; for details which are not disclosed in embodiments of the electronic device of the invention, reference may be made to the above-described embodiments of the method or the apparatus.
Fig. 4 is a schematic structural diagram of an electronic device provided in an embodiment of the present specification. Anelectronic device 400 according to this embodiment of the invention is described below with reference to fig. 4. Theelectronic device 400 shown in fig. 4 is only an example and should not bring any limitation to the function and the scope of use of the embodiments of the present invention.
As shown in fig. 4,electronic device 400 is embodied in the form of a general purpose computing device. The components ofelectronic device 400 may include, but are not limited to: at least oneprocessing unit 410, at least onememory unit 420, abus 430 that connects the various system components (including thememory unit 420 and the processing unit 410), adisplay unit 440, and the like.
Wherein the storage unit stores program code executable by theprocessing unit 410 to cause theprocessing unit 410 to perform steps according to various exemplary embodiments of the present invention described in the above-mentioned processing method section of the present specification. For example, theprocessing unit 410 may perform the steps as shown in fig. 1.
Thestorage unit 420 may include readable media in the form of volatile storage units, such as a random access memory unit (RAM)4201 and/or acache memory unit 4202, and may further include a read only memory unit (ROM) 4203.
Thestorage unit 420 may also include a program/utility 4204 having a set (at least one) of program modules 4205, such program modules 4205 including, but not limited to: an operating system, one or more application programs, other program modules, and program data, each of which, or some combination thereof, may comprise an implementation of a network environment.
Bus 430 may be any bus representing one or more of several types of bus structures, including a memory unit bus or memory unit controller, a peripheral bus, an accelerated graphics port, a processing unit, or a local bus using any of a variety of bus architectures.
Theelectronic device 400 may also communicate with one or more external devices 500 (e.g., keyboard, pointing device, bluetooth device, etc.), with one or more devices that enable a user to interact with theelectronic device 400, and/or with any devices (e.g., router, modem, etc.) that enable theelectronic device 400 to communicate with one or more other computing devices. Such communication may occur via input/output (I/O) interfaces 450. Also, theelectronic device 400 may communicate with one or more networks (e.g., a Local Area Network (LAN), a Wide Area Network (WAN), and/or a public network, such as the internet) via thenetwork adapter 460. Thenetwork adapter 460 may communicate with other modules of theelectronic device 400 via thebus 430. It should be appreciated that although not shown in FIG. 4, other hardware and/or software modules may be used in conjunction withelectronic device 400, including but not limited to: microcode, device drivers, redundant processing units, external disk drive arrays, RAI D systems, tape drives, and data backup storage systems, etc.
Through the above description of the embodiments, those skilled in the art will readily understand that the exemplary embodiments of the present invention described herein may be implemented by software, or by software in combination with necessary hardware. Therefore, the technical solution according to the embodiment of the present invention can be embodied in the form of a software product, which can be stored in a computer-readable storage medium (which can be a CD-ROM, a usb disk, a removable hard disk, etc.) or on a network, and includes several instructions to make a computing device (which can be a personal computer, a server, or a network device, etc.) execute the above-mentioned method according to the present invention. The computer program, when executed by a data processing apparatus, enables the computer readable medium to implement the above-described method of the invention, namely: such as the method shown in fig. 1.
Fig. 5 is a schematic diagram of a computer-readable medium provided in an embodiment of the present specification.
A computer program implementing the method shown in fig. 1 may be stored on one or more computer readable media. The computer readable medium may be a readable signal medium or a readable storage medium. A readable storage medium may be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any combination of the foregoing. More specific examples (a non-exhaustive list) of the readable storage medium include: an electrical connection having one or more wires, a portable disk, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing.
The computer readable storage medium may include a propagated data signal with readable program code embodied therein, for example, in baseband or as part of a carrier wave. Such a propagated data signal may take many forms, including, but not limited to, electro-magnetic, optical, or any suitable combination thereof. A readable storage medium may also be any readable medium that is not a readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device. Program code embodied on a readable storage medium may be transmitted using any appropriate medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.
Program code for carrying out operations for aspects of the present invention may be written in any combination of one or more programming languages, including an object oriented programming language such as Java, C + + or the like and conventional procedural programming languages, such as the "C" programming language or similar programming languages. The program code may execute entirely on the user's computing device, partly on the user's device, as a stand-alone software package, partly on the user's computing device and partly on a remote computing device, or entirely on the remote computing device or server. In the case of a remote computing device, the remote computing device may be connected to the user computing device through any kind of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or may be connected to an external computing device (e.g., through the internet using an internet service provider).
In summary, the invention may be implemented in hardware, or in software modules running on one or more processors, or in a combination thereof. Those skilled in the art will appreciate that some or all of the functionality of some or all of the components in embodiments in accordance with the invention may be implemented in practice using a general purpose data processing device such as a microprocessor or a Digital Signal Processor (DSP). The present invention may also be embodied as apparatus or device programs (e.g., computer programs and computer program products) for performing a portion or all of the methods described herein. Such programs implementing the present invention may be stored on computer-readable media or may be in the form of one or more signals. Such a signal may be downloaded from an internet website or provided on a carrier signal or in any other form.
While the foregoing embodiments have described the objects, aspects and advantages of the present invention in further detail, it should be understood that the present invention is not inherently related to any particular computer, virtual machine or electronic device, and various general-purpose machines may be used to implement the present invention. The invention is not to be considered as limited to the specific embodiments thereof, but is to be understood as being modified in all respects, all changes and equivalents that come within the spirit and scope of the invention.
The embodiments in the present specification are described in a progressive manner, and the same and similar parts among the embodiments are referred to each other, and each embodiment focuses on the differences from the other embodiments.
The above description is only an example of the present application and is not intended to limit the present application. Various modifications and changes may occur to those skilled in the art. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present application should be included in the scope of the claims of the present application.

Claims (16)

Translated fromChinese
1.一种数据采集方法,其特征在于,包括:1. a data collection method, is characterized in that, comprises:搭建配置平台,注册中心,中间件,消息队列模块和对应不同数据采集协议的数采服务模块;Build configuration platform, registration center, middleware, message queue module and data acquisition service module corresponding to different data acquisition protocols;所述数采服务模块初次启动时向注册中心发送配置信息进行注册;The data acquisition service module sends configuration information to the registration center for registration when it is first started;通过配置中心为采集设备配置采集设备属性信息,所述中间件与所述消息队列模块及注册中心建立通信,监测注册中心中的新增的注册信息,并与对应的数采服务模块建立通信;The configuration center configures the acquisition device attribute information for the acquisition device, the middleware establishes communication with the message queue module and the registration center, monitors the newly added registration information in the registration center, and establishes communication with the corresponding data acquisition service module;所述中间件读取配置的所述设备属性信息,根据配置的所述设备属性信息匹配采集设备对应的数采服务模块,并将所述设备属性信息下发至所述数采服务模块;The middleware reads the configured device attribute information, matches the data acquisition service module corresponding to the acquisition device according to the configured device attribute information, and delivers the device attribute information to the data acquisition service module;所述中间件通过各数采服务模块获取各数采服务模块下采集设备所采集的数据,并将所述数据发送至消息队列模块。The middleware obtains the data collected by the collection device under each data collection service module through each data collection service module, and sends the data to the message queue module.2.根据权利要求1所述的方法,其特征在于,所述根据配置的所述设备属性信息匹配采集设备对应的数采服务模块,包括:2. The method according to claim 1, wherein the matching data acquisition service module corresponding to the acquisition device according to the configured device attribute information comprises:根据所述设备属性信息中的协议类型匹配对应的数采服务模块。The corresponding data acquisition service module is matched according to the protocol type in the device attribute information.3.根据权利要求1所述的方法,其特征在于,所述通过配置中心为采集设备配置采集设备属性信息,包括:3. The method according to claim 1, wherein, configuring the collection device attribute information for the collection device through the configuration center, comprising:通过配置中心为采集设备更新采集设备属性信息。Update the property information of the collection device for the collection device through the configuration center.4.根据权利要求1所述的方法,其特征在于,所述采集设备属性信息包括:设备地址信息和设备协议信息。4 . The method according to claim 1 , wherein the collecting device attribute information comprises: device address information and device protocol information. 5 .5.根据权利要求1所述的方法,其特征在于,还包括:5. The method of claim 1, further comprising:搭建适配多种开发语言的远程调用系统;Build a remote calling system that adapts to multiple development languages;所述中间件通过各数采服务模块获取各数采服务模块下采集设备所采集的数据,包括:The middleware obtains the data collected by the acquisition equipment under each data acquisition service module through each data acquisition service module, including:所述中间件通过所述远程调用系统与各数采服务模块建立通信,并获取各数采服务模块下采集设备所采集的数据。The middleware establishes communication with each data acquisition service module through the remote calling system, and acquires the data collected by the acquisition equipment under each data acquisition service module.6.根据权利要求1所述的方法,其特征在于,所述通过配置中心为采集设备配置采集设备属性信息,包括:6. The method according to claim 1, wherein, configuring the collection device attribute information for the collection device through the configuration center, comprising:从物联网平台拉取设备属性信息,自动配置。Pull device attribute information from the IoT platform and configure it automatically.7.根据权利要求1所述的方法,其特征在于,所述将所述数据发送至消息队列模块,包括:7. The method according to claim 1, wherein the sending the data to a message queue module comprises:中间件将所述数据汇总后,发送至消息队列模块。The middleware aggregates the data and sends it to the message queue module.8.一种数据采集装置,其特征在于,包括:8. A data acquisition device, characterized in that, comprising:系统搭建模块,搭建配置平台,注册中心,中间件,消息队列模块和对应不同数据采集协议的数采服务模块;System building module, building configuration platform, registration center, middleware, message queue module and data collection service module corresponding to different data collection protocols;数采服务模块,用于初次启动时向注册中心发送配置信息进行注册;The data acquisition service module is used to send configuration information to the registration center for registration when it is first started;所述配置平台,为采集设备配置采集设备属性信息;The configuration platform configures the collection device attribute information for the collection device;所述中间件,与所述消息队列模块及注册中心建立通信,监测注册中心中的新增的注册信息,并与对应的数采服务模块建立通信;The middleware establishes communication with the message queue module and the registration center, monitors the newly added registration information in the registration center, and establishes communication with the corresponding data acquisition service module;所述中间件读取配置的所述设备属性信息,根据配置的所述设备属性信息匹配采集设备对应的数采服务模块,并将所述设备属性信息下发至所述数采服务模块;The middleware reads the configured device attribute information, matches the data acquisition service module corresponding to the acquisition device according to the configured device attribute information, and delivers the device attribute information to the data acquisition service module;所述中间件通过各数采服务模块获取各数采服务模块下采集设备所采集的数据,并将所述数据发送至消息队列模块。The middleware obtains the data collected by the collection device under each data collection service module through each data collection service module, and sends the data to the message queue module.9.根据权利要求8所述的装置,其特征在于,所述根据配置的所述设备属性信息匹配采集设备对应的数采服务模块,包括:9. The device according to claim 8, wherein the matching data acquisition service module corresponding to the acquisition equipment according to the configured equipment attribute information comprises:根据所述设备属性信息中的协议类型匹配对应的数采服务模块。The corresponding data acquisition service module is matched according to the protocol type in the device attribute information.10.根据权利要求8所述的装置,其特征在于,所述通过配置中心为采集设备配置采集设备属性信息,包括:10. The apparatus according to claim 8, wherein the configuring the collection device attribute information for the collection device through the configuration center comprises:通过配置中心为采集设备更新采集设备属性信息。Update the property information of the collection device for the collection device through the configuration center.11.根据权利要求8所述的装置,其特征在于,所述采集设备属性信息包括:设备地址信息和设备协议信息。11 . The apparatus according to claim 8 , wherein the collecting device attribute information comprises: device address information and device protocol information. 12 .12.根据权利要求8所述的装置,其特征在于,还包括:12. The apparatus of claim 8, further comprising:搭建适配多种开发语言的远程调用系统;Build a remote calling system that adapts to multiple development languages;所述中间件通过各数采服务模块获取各数采服务模块下采集设备所采集的数据,包括:The middleware obtains the data collected by the acquisition equipment under each data acquisition service module through each data acquisition service module, including:所述中间件通过所述远程调用系统与各数采服务模块建立通信,并获取各数采服务模块下采集设备所采集的数据。The middleware establishes communication with each data acquisition service module through the remote calling system, and acquires the data collected by the acquisition equipment under each data acquisition service module.13.根据权利要求8所述的装置,其特征在于,所述通过配置中心为采集设备配置采集设备属性信息,包括:13. The apparatus according to claim 8, wherein the configuring the collection device attribute information for the collection device through the configuration center comprises:从物联网平台拉取设备属性信息,自动配置。Pull device attribute information from the IoT platform and configure it automatically.14.根据权利要求8所述的装置,其特征在于,所述将所述数据发送至消息队列模块,包括:14. The apparatus according to claim 8, wherein the sending the data to a message queue module comprises:中间件将所述数据汇总后,发送至消息队列模块。The middleware aggregates the data and sends it to the message queue module.15.一种电子设备,其中,该电子设备包括:15. An electronic device, wherein the electronic device comprises:处理器;以及,processor; and,存储计算机可执行程序的存储器,所述可执行程序在被执行时使所述处理器执行根据权利要求1-7中任一项所述的方法。A memory storing a computer executable program which, when executed, causes the processor to perform the method of any of claims 1-7.16.一种计算机可读存储介质,其中,所述计算机可读存储介质存储一个或多个程序,所述一个或多个程序当被处理器执行时,实现权利要求1-7中任一项所述的方法。16. A computer-readable storage medium, wherein the computer-readable storage medium stores one or more programs that, when executed by a processor, implement any of claims 1-7 the method described.
CN202111392362.6A2021-11-232021-11-23 A data collection method, device and electronic devicePendingCN114124695A (en)

Priority Applications (1)

Application NumberPriority DateFiling DateTitle
CN202111392362.6ACN114124695A (en)2021-11-232021-11-23 A data collection method, device and electronic device

Applications Claiming Priority (1)

Application NumberPriority DateFiling DateTitle
CN202111392362.6ACN114124695A (en)2021-11-232021-11-23 A data collection method, device and electronic device

Publications (1)

Publication NumberPublication Date
CN114124695Atrue CN114124695A (en)2022-03-01

Family

ID=80439993

Family Applications (1)

Application NumberTitlePriority DateFiling Date
CN202111392362.6APendingCN114124695A (en)2021-11-232021-11-23 A data collection method, device and electronic device

Country Status (1)

CountryLink
CN (1)CN114124695A (en)

Cited By (2)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN115314509A (en)*2022-07-272022-11-08上海浦东发展银行股份有限公司 A method, device, device and storage medium for synchronizing application registration information
WO2024087022A1 (en)*2022-10-252024-05-02西门子股份公司Information collection method and system, and storage medium

Citations (9)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN103942063A (en)*2013-11-082014-07-23国家电网公司Centralized configuration and remote deployment method for Java Web application
US20170008162A1 (en)*2015-05-262017-01-12Kabushiki Kaisha ToshibaElectronic appliance control method and electronic appliance control device
CN109327335A (en)*2018-10-072019-02-12杭州安恒信息技术股份有限公司A kind of cloud monitoring solution system and method
CN110071823A (en)*2019-03-152019-07-30中科恒运股份有限公司Middleware system for Internet of things
CN111224817A (en)*2020-04-212020-06-02重庆鲲量科技有限公司Distributed micro-acquisition system and method thereof
CN111416821A (en)*2020-03-202020-07-14杭州物源科技有限公司Internet of things equipment information acquisition method, system and device
CN112737855A (en)*2020-12-302021-04-30百视通网络电视技术发展有限责任公司Multi-dimensional terminal configuration system in OTT service
CN113179316A (en)*2021-04-262021-07-27山东新一代信息产业技术研究院有限公司Cloud edge-side cooperative computing system and method based on containerization design
WO2021203968A1 (en)*2020-10-282021-10-14平安科技(深圳)有限公司Method for unified management of micro-services of multiple registration centers, and apparatus, device and medium

Patent Citations (9)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN103942063A (en)*2013-11-082014-07-23国家电网公司Centralized configuration and remote deployment method for Java Web application
US20170008162A1 (en)*2015-05-262017-01-12Kabushiki Kaisha ToshibaElectronic appliance control method and electronic appliance control device
CN109327335A (en)*2018-10-072019-02-12杭州安恒信息技术股份有限公司A kind of cloud monitoring solution system and method
CN110071823A (en)*2019-03-152019-07-30中科恒运股份有限公司Middleware system for Internet of things
CN111416821A (en)*2020-03-202020-07-14杭州物源科技有限公司Internet of things equipment information acquisition method, system and device
CN111224817A (en)*2020-04-212020-06-02重庆鲲量科技有限公司Distributed micro-acquisition system and method thereof
WO2021203968A1 (en)*2020-10-282021-10-14平安科技(深圳)有限公司Method for unified management of micro-services of multiple registration centers, and apparatus, device and medium
CN112737855A (en)*2020-12-302021-04-30百视通网络电视技术发展有限责任公司Multi-dimensional terminal configuration system in OTT service
CN113179316A (en)*2021-04-262021-07-27山东新一代信息产业技术研究院有限公司Cloud edge-side cooperative computing system and method based on containerization design

Non-Patent Citations (2)

* Cited by examiner, † Cited by third party
Title
S. SASIREKHA , S. SWAMYNATHAN: "Service Provisioning Middleware for Wireless Sensor Network", Retrieved from the Internet <URL:https://link.springer.com/chapter/10.1007/978-81-322-2695-6_28>*
虞敏;张为民;HORST MEIER;: "分布式设备远程监控系统研究", 计算机工程与应用, no. 05, 11 February 2009 (2009-02-11)*

Cited By (2)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN115314509A (en)*2022-07-272022-11-08上海浦东发展银行股份有限公司 A method, device, device and storage medium for synchronizing application registration information
WO2024087022A1 (en)*2022-10-252024-05-02西门子股份公司Information collection method and system, and storage medium

Similar Documents

PublicationPublication DateTitle
CN110262902B (en)Information processing method and system, medium, and computing device
CN116155978B (en) Multi-registration center adaptation method, device, electronic device and storage medium
CN114124695A (en) A data collection method, device and electronic device
CN107526806A (en)The conversion method and device of data
CN114363170A (en)Container service network configuration method and related product
CN110609755A (en) Cross-blockchain node message processing method, device, device, and medium
CN113821352A (en) Method and device for invoking remote service
CN111294250B (en)Pressure testing method, device and system
CN112291224A (en)Real-time communication interaction method and device and electronic equipment
KR20110065448A (en) Message processing pipeline configuration
CN113434315B (en)Interface management method and device, storage medium and electronic equipment
CN112448833A (en) A multi-administrative domain communication method and device
CN111680032B (en)Method and device for processing information sending task and electronic equipment
CN106802790A (en)Method, equipment and system that application user use information based on cloud platform is managed
CN116132214B (en)Event transmission method, device, equipment and medium based on event bus model
CN116860353B (en)Data processing method, device, electronic equipment and storage medium
CN112099655A (en) Implementation method, device, computer equipment and storage medium for voice mouse mobile office
CN117950628A (en)Plug-in building method and system based on GRPC
CN1973282A (en)System and method for managing a change to a cluster configuration
CN114721732B (en)Method, device and system for acquiring data, electronic equipment and storage medium
CN112948141B (en) A data processing method, device and system based on message middleware
CN116032614A (en) Container network micro-isolation method, device, equipment and medium
CN115102992A (en)Data distribution method and device, electronic equipment and computer readable medium
US8930523B2 (en)Stateful business application processing in an otherwise stateless service-oriented architecture
CN112445850B (en) Data conversion method, device, electronic device and readable medium

Legal Events

DateCodeTitleDescription
PB01Publication
PB01Publication
SE01Entry into force of request for substantive examination
SE01Entry into force of request for substantive examination
AD01Patent right deemed abandoned

Effective date of abandoning:20241213

AD01Patent right deemed abandoned

[8]ページ先頭

©2009-2025 Movatter.jp