CN108009258B - Data acquisition and analysis platform capable of being configured online - Google Patents
Data acquisition and analysis platform capable of being configured online Download PDFInfo
- Publication number
- CN108009258B CN108009258B CN201711301865.1A CN201711301865A CN108009258B CN 108009258 B CN108009258 B CN 108009258B CN 201711301865 A CN201711301865 A CN 201711301865A CN 108009258 B CN108009258 B CN 108009258B
- Authority
- CN
- China
- Prior art keywords
- module
- data
- service
- subscription
- acquisition
- 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.)
- Active
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/25—Integrating or interfacing systems involving database management systems
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/44—Arrangements for executing specific programs
- G06F9/445—Program loading or initiating
- G06F9/44521—Dynamic linking or loading; Link editing at or after load time, e.g. Java class loading
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/08—Configuration management of networks or network elements
- H04L41/0803—Configuration setting
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/51—Discovery or management thereof, e.g. service location protocol [SLP] or web services
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/55—Push-based network services
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/16—Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP]
- H04L69/161—Implementation details of TCP/IP or UDP/IP stack architecture; Specification of modified or new header fields
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Databases & Information Systems (AREA)
- Software Systems (AREA)
- Signal Processing (AREA)
- Computer Networks & Wireless Communication (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Data Mining & Analysis (AREA)
- Computing Systems (AREA)
- Computer Security & Cryptography (AREA)
- Information Transfer Between Computers (AREA)
- Computer And Data Communications (AREA)
Abstract
The invention provides an online configurable data acquisition and analysis platform, which comprises six modules: the system comprises an OPC data acquisition module, a service module scheduling module, a data distribution module, a real-time data storage module, a TCP/IP data release module and a UI man-machine interface module. And the service scheduling module is responsible for starting and stopping each service function according to the module configuration. And the data distribution module is responsible for distributing OPC data and service data to each service module in real time according to distribution configuration. And the real-time data storage module is responsible for storing the data points to be stored into the database according to the storage configuration. The TCP/IP data publishing module receives a subscription request from a TCP/IP client on a local area network in a subscription < - > mode and publishes data to each subscription client according to the request. The UI human-computer interface module provides a human-computer interaction interface. The invention can realize the instant data sharing between the system modules and the service modules and realize the real-time data storage.
Description
Technical Field
The invention relates to a data acquisition and analysis platform, in particular to an online configurable data acquisition and analysis platform.
Background
The modern rolling mill control system generally comprises four parts, namely a basic automation part, a secondary monitoring system, a regional management system, an integral production and marketing management system and an equipment management system. The secondary monitoring system is mainly used for completing functions of acquisition, processing, real-time monitoring and the like of real-time data of the primary control system, and comprises various system technologies such as information transmission, fault detection, remote diagnosis, maintenance and the like. In the general structure of the secondary system, the secondary system mainly comprises an OPC data acquisition module, one or more service logic judgment and analysis modules, and a data storage module, and the common method is to separately program three functional modules and share and transmit data among the three modules by adopting a database or an online communication (such as Net Remoting, TCP/IP, WCF, and the like). The variability of the service causes the three modules to need to modify the configuration from time to time, and in addition, one service module is difficult to complete all service logics at one time; if a plurality of service modules are used for processing service logic, data sharing cannot be well realized among the service modules, and the problems can cause that the whole system can be restarted every time the service is modified.
Disclosure of Invention
In order to enable all modules in the overall structure of a secondary system to be capable of being edited on line and realize instant data sharing and real-time data storage between system modules and between service modules, the invention provides a data acquisition and analysis platform capable of being configured on line. The specific technical scheme for realizing the purpose is as follows:
an online configurable data acquisition and analysis platform mainly comprises six modules: the system comprises an OPC data acquisition module, a service module scheduling module, a data distribution module, a real-time data storage module, a TCP/IP data release module and a UI man-machine interface module.
And the OPC data acquisition is responsible for reading data in an automatic control system in real time according to acquisition configuration and basic automatic communication.
And the service scheduling module is responsible for starting and stopping each service function according to the module configuration.
And the data distribution module is responsible for distributing OPC data and service data to each service module in real time according to distribution configuration.
The real-time data storage module is responsible for periodically storing data points to be stored into a database according to storage configuration, wherein the database is preferably a distributed document storage database (MongoDB), the MongoDB is a product between a relational database and a non-relational database, and the data structure supported by the MongoDB is very loose, so that more complex data types can be stored.
The TCP/IP data publishing module receives a subscription request from a TCP/IP client on a local area network in a subscription < - > mode and publishes data to each subscription client according to the request.
The UI man-machine interface module provides a man-machine interaction interface for updating the configuration of each module and monitoring the operation log of each module.
The invention also provides a construction method of the online configurable data acquisition and analysis platform, which comprises the following specific steps:
the method comprises the following steps: platform construction
And deploying an installation Server, connecting the installation Server to a PLC network of the automatic control system, installing the industrial remote communication control assembly, and configuring an OPC Server, wherein a platform can access data points in the PLC of the automatic control system through the OPC Server.
And installing database software on the server, and newly building a database, wherein data tables about various configurations of the platform are added in the database.
Step two: OPC data acquisition
Opc (OLE for Process control), an industry standard based on microsoft OLE (Active X), COM (component object model) and DCOM (distributed component object model) technologies, comprises a standard set of a whole set of interfaces, properties and methods for Process control and manufacturing automation systems. The set of standards is currently managed by the OPC foundation.
1. And enumerating the instance name of the OPC service installed in the local computer by using the OPCAutomation.dll provided by the OPC fund, inputting an acquisition group and an acquisition period and storing the configuration, storing the OPC acquisition configuration into a database by the system, starting an OPC data acquisition client, and monitoring the running state and the data point change event of the OPC Server.
2. And adding an acquisition point according to the service requirement. The content of the acquisition point comprises an acquisition point name, an expansion code, a data type and whether real-time storage is needed or not; wherein the collected roll names refer to label names in an OPC Server; spreading codes are used to distinguish acquisition points in a service system.
Step three: dynamic loading of linked libraries
1. And compiling a thread unit module based on the unified base class, finishing service logic judgment in the thread, and compiling into a dll file.
2. And configuring the operation mode, the data distribution mode and the operation period of the module in the platform, and storing the operation mode, the data distribution mode and the operation period in a platform database.
3. And reading the configuration of each module in the platform, reading the dll file of each module according to the configuration, and starting the thread unit in the dll file.
The execution modes of the service processing unit in the module are divided into synchronous execution and asynchronous execution: synchronous execution means that the logic module in the thread unit can continue to execute after the last execution is finished; asynchronous execution means that logic modules in a thread unit are executed in a single thread without waiting for the completion of the last execution; the synchronous execution mode is used in the logic module with the service priority, and the asynchronous execution mode does not need to consider the service priority, but ensures the service processing capacity and does not cause a collection point.
Step four: real-time data distribution
1. And the platform traverses each service module, and submits a subscription point set to a queue in the module according to the configured OPC acquisition point subscription and the service output point subscription.
2. After receiving the subscribed acquisition point and the subscribed service output point, the module completes service logic by using the subscription point in the thread unit.
3. And optimizing data distribution.
And distributing data to the modules according to the data receiving and processing capacity (the number of the subscription point sets capable of being processed in each period) of the modules by combining the operating cycles of the module thread units and the actual service logic processing duration.
Step five: real-time data storage
The data points to be stored are stored periodically in a database, preferably a distributed document storage database (MongoDB), according to the storage configuration.
Step six: real-time data distribution
The data publishing method comprises the steps that a subscription request from a TCP/IP client on a local area network is received in a subscription < - - > publishing mode, subscription content comprises a request type and a subscription point list, wherein the request type is a reading request and a writing request, and when the request type is the reading request, the subscription list content is a collection roll name; and when the request type is a write request, the subscription list content is a collection roll name and a collection point value.
And after receiving the client subscription request, the platform processes the request according to the request type. When the request type is a reading request, finding out a collection roll call and a value thereof which accord with the subscription list from the platform cache to form a set, and serializing the collection roll call and the value thereof into binary stream to be sent to the client; and when the request type is a write request, the platform reads the collection point name and the collection point value in the list and writes the collection point name and the collection point value into the OPC Server through the OPC Client.
The invention has the beneficial effects that:
1. the invention can carry out data acquisition based on the OPC of Com protocol
When the platform is running, the local OPC Server can be browsed, user-defined data acquisition is carried out on the local OPC Server, the OPC data acquisition can be started and stopped at any time, and the data acquisition period and the data acquisition point can be modified;
2. the invention can perform real-time storage based on MongoDB
When the platform is running, the real-time storage function of MongoDB can be added, and the storage period and the data points needing to be stored can be updated or deleted at any time;
3. the invention can carry out module calling based on the dynamic service of the file flow
Based on a common base class, business modules based on different businesses or different logics can be compiled, the logic operation unit of the business module can be called under the condition that the reference of the business module is not added, and meanwhile, the deletion covering operation of files is carried out on the business module under the condition that the business module runs;
4. the invention can realize the distribution and sharing of OPC data acquisition data and service data
The data generated by OPC data acquisition and the service data generated by each service module can be distributed to each service module in the platform according to the subscription configuration of the module;
5. the invention can adopt multi TCP/IP client data distribution
The data subscription request from the TCP/IP client can be received, and data publishing is carried out according to the data subscription requirements (subscription points and subscription periods) of different users;
6. the invention can lead the secondary system developer to focus on the service logic analysis mainly without concerning the function of the background through the 5-phase function, realize the instant data sharing between the system modules and the service modules and realize the real-time data storage.
Detailed Description
The following detailed description of the invention refers to specific embodiments for facilitating understanding by those skilled in the art.
An online configurable data acquisition and analysis platform mainly comprises six modules: the system comprises an OPC data acquisition module, a service module scheduling module, a data distribution module, a real-time data storage module, a TCP/IP data release module and a UI man-machine interface module.
And the OPC data acquisition is responsible for reading data in an automatic control system in real time according to acquisition configuration and basic automatic communication. And the service scheduling module is responsible for starting and stopping each service function according to the module configuration. And the data distribution module is responsible for distributing OPC data and service data to each service module in real time according to distribution configuration. And the real-time data storage is responsible for storing the data points needing to be stored into the MongoDB according to the storage configuration. And the TCP/IP data publishing adopts a subscription mode to receive subscription requests from TCP/IP clients on a local area network, and publishes the data to each subscription client according to the requests. The UI human-computer interface provides a human-computer interaction interface for updating the configuration of each module and monitoring the operation log of each module.
The invention also provides a construction method of the online configurable data acquisition and analysis platform, which comprises the following specific steps:
the method comprises the following steps: platform construction
A Server provided with a Windows Server 2008 operating system is deployed, connected to a PLC network of an automatic control system, provided with a Simtic.Net component and configured with an OPC Server named Simtic Net.OPC, and a platform can access data points in the PLC of the automatic control system through the OPC Server.
The method comprises the steps that SQL Server 2008 database software is installed on a Server, a database named BMplatform is newly built, and a data table about each configuration of a platform is added into the database;
step two: OPC data acquisition
1. Enumerating an OPC service instance name installed in a local computer by using an OPCAutomation.dll provided by an OPC fund, inputting an acquisition group and an acquisition period and storing the OPC service instance name, storing the OPC acquisition configuration into a database by a system, starting an OPC data acquisition client, and monitoring the running state and data point change events of the OPC Server;
2. and adding an acquisition point according to the service requirement. The content of the acquisition point comprises an acquisition point name, an expansion code, a data type and whether real-time storage is needed or not; wherein the collected roll names refer to label names in an OPC Server; spreading codes are used to distinguish acquisition points in a service system;
step three: dynamic loading of linked libraries
1. And compiling a thread unit module based on the unified base class, finishing service logic judgment in the thread, and compiling into a dll file.
2. Configuring the operation mode, the data distribution mode and the operation cycle of the module in the platform, and storing the operation mode, the data distribution mode and the operation cycle into a platform database;
3. reading the configuration of each module in the platform, reading the dll file of each module according to the configuration, and starting a thread unit in the dll file;
the execution mode of the service processing unit in the module adopts synchronous execution and asynchronous execution:
the synchronous execution mode is used in a logic module with service priority, and the asynchronous execution mode does not need to consider the service priority, but ensures the service processing capacity and cannot cause the blockage of an acquisition point queue;
4. configuring OPC acquisition point subscription of a module;
5. configuring a service output point of the module, wherein the content comprises a source module of the service point and a name of the service point;
6. configuring a service subscription point of a module;
step four: real-time data distribution
1. The platform traverses each service module, and submits a subscription point set to a queue in the module according to configured OPC acquisition point subscription and service output point subscription;
2. after receiving the subscribed acquisition point and the subscribed service output point, the module completes service logic by using the subscription point in the thread unit;
3. and optimizing data distribution.
And distributing data to the modules according to the data receiving and processing capacity (the number of the subscription point sets capable of being processed in each period) of the modules by combining the operating cycles of the module thread units and the actual service logic processing duration.
Step five: real-time data storage
And storing the collection roll name, the collection point value and the time when the collection point value is changed into a MongoDB as an entity.
Step six: real-time data distribution
Receiving a subscription request from a TCP/IP client on a local area network by adopting a data publishing mode of subscription < - > publishing, wherein the subscription content comprises a request type and a subscription point list, the request type is a read request and a write request, and when the request type is the read request, the subscription list content is a collection roll name; and when the request type is a write request, the subscription list content is a collection roll name and a collection point value.
And after receiving the client subscription request, the platform processes the request according to the request type. When the request type is a reading request, finding out a collection roll call and a value thereof which accord with the subscription list from the platform cache to form a set, and serializing the collection roll call and the value thereof into binary stream to be sent to the client; and when the request type is a write request, the platform reads the collection point name and the collection point value in the list and writes the collection point name and the collection point value into the OPC Server through the OPC Client.
Claims (4)
1. A method for constructing a data acquisition and analysis platform capable of being configured online is characterized by comprising the following steps:
the method comprises the following steps: platform construction
The system comprises six modules: the system comprises an OPC data acquisition module, a service scheduling module, a data distribution module, a real-time data storage module, a TCP/IP data release module and a UI man-machine interface module; the service scheduling module is responsible for starting and stopping each service function according to module configuration; the data distribution module is responsible for distributing OPC data and service data to each service module in real time according to distribution configuration; the real-time data storage module is responsible for storing data points to be stored into a database according to storage configuration; the TCP/IP data publishing module receives a subscription request from a TCP/IP client on a local area network in a subscription and publishing mode and publishes data to each subscription client according to the request; the UI human-computer interface module provides a human-computer interaction interface;
the platform is mainly built by deploying an installation Server, connecting the installation Server to a PLC network of an automatic control system, installing an industrial remote communication control assembly and configuring an OPC Server, and the platform can access data points in the PLC of the automatic control system through the OPC Server;
the first step also comprises the steps of installing database software on the server, newly building a database, and adding a data table related to each configuration of the platform in the database;
step two: OPC data acquisition
The second step comprises the following operations:
(1) after an acquisition group and an acquisition period are input and saved, the system saves OPC acquisition configuration into a database, simultaneously starts an OPC data acquisition client and starts monitoring the running state and data point change events of the OPC Server;
(2) adding an acquisition point according to the service requirement;
the content of the acquisition point in the second step comprises an acquisition point name, an expansion code, a data type and whether real-time storage is needed or not; wherein the collected roll names refer to label names in an OPC Server; spreading codes are used to distinguish acquisition points in a service system;
step three: dynamic loading of linked libraries
(1) Compiling a thread unit module based on the unified base class, finishing service logic judgment in a thread, and compiling into a dll file;
(2) configuring the operation mode and the operation period of the module in the platform, and storing the operation mode and the operation period in a platform database;
(3) reading the configuration of each module in the platform, reading the dll file of each module according to the configuration, and starting a thread unit in the dll file;
the execution modes of the service processing unit of the thread unit module in the step three are divided into synchronous execution and asynchronous execution: synchronous execution means that the logic module in the thread unit can continue to execute after the last execution is finished; asynchronous execution means that logic modules in a thread unit are executed in a single thread without waiting for the completion of the last execution;
step four: real-time data distribution
(1) The platform traverses each service module, and submits a subscription point set to a queue in the module according to configured OPC acquisition point subscription and service output point subscription;
(2) after receiving the subscribed acquisition point and the subscribed service output point, the module completes service logic by using the subscription point in the thread unit;
(3) optimizing data distribution;
combining the operation cycle of the module thread unit and the actual service logic processing duration, and according to the data receiving and processing capacity of the module; the processing capacity refers to the number of the subscription point sets which can be processed in each period; distributing data to the modules;
step five: real-time data storage
The real-time data storage is responsible for storing data points to be stored into a database according to storage configuration;
step six: real-time data distribution
Data release is adopted; the subscription publishing mode receives a subscription request from a TCP/IP client on a local area network, and the subscription content comprises a request type and a subscription point list.
2. The method for building the online configurable data acquisition and analysis platform according to claim 1, wherein the database in the fifth step is a distributed document storage database, mongoDB.
3. The method for building the online-configurable data acquisition and analysis platform according to claim 1, wherein the request type in the sixth step is a read request and a write request, and when the request type is a read request, the content of the subscription list is an acquisition roll name; and when the request type is a write request, the subscription list content is a collection roll name and a collection point value.
4. The method for building the online configurable data acquisition and analysis platform according to claim 1, wherein the platform processes the request according to the request type after receiving the client subscription request, finds out the collection roll names and the values thereof which conform to the subscription list from the platform cache to form a set when the request type is a read request, and serializes the collection roll names and the values into a binary stream to be sent to the client; and when the request type is a write request, the platform reads the collection point name and the collection point value in the list and writes the collection point name and the collection point value into the OPC Server through the OPC Client.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201711301865.1A CN108009258B (en) | 2017-12-10 | 2017-12-10 | Data acquisition and analysis platform capable of being configured online |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201711301865.1A CN108009258B (en) | 2017-12-10 | 2017-12-10 | Data acquisition and analysis platform capable of being configured online |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN108009258A CN108009258A (en) | 2018-05-08 |
| CN108009258B true CN108009258B (en) | 2022-03-15 |
Family
ID=62057533
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201711301865.1A Active CN108009258B (en) | 2017-12-10 | 2017-12-10 | Data acquisition and analysis platform capable of being configured online |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN108009258B (en) |
Families Citing this family (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110609707B (en) * | 2018-06-14 | 2021-11-02 | 北京嘀嘀无限科技发展有限公司 | Online data processing system generation method, device and equipment |
| CN111090267A (en) * | 2019-12-10 | 2020-05-01 | 金川集团股份有限公司 | Real-time data acquisition method for sulfuric acid workshop |
| CN113076359B (en) * | 2020-01-05 | 2024-01-05 | 上海梅山钢铁股份有限公司 | Method for directly downloading database data into OPC (optical proximity correction) based on RSSQL (RSSQL communication software) |
| CN113157796B (en) * | 2020-01-22 | 2023-06-30 | 中国科学院沈阳自动化研究所 | Data acquisition display system based on micro-service |
| CN111830926A (en) * | 2020-08-19 | 2020-10-27 | 江苏天宏机械工业有限公司 | A Configurable Data Acquisition System for Industrial Equipment |
| CN112987667B (en) * | 2021-02-08 | 2022-05-31 | 上海交通大学 | A system and method for remote configuration of equipment for flexible manufacturing production line based on OPC UA |
| CN113395180B (en) * | 2021-06-11 | 2023-04-18 | 上海企翔智能科技有限公司 | Industrial real-time big data acquisition and release method and industrial real-time big data platform |
| CN113741378B (en) * | 2021-11-04 | 2022-03-15 | 西安热工研究院有限公司 | A fault analysis method and system for high-frequency acquisition of abnormal points in the background of a decentralized control system |
| CN114442577A (en) * | 2022-01-24 | 2022-05-06 | 山东钢铁集团永锋临港有限公司 | Centralized management's distributed data acquisition system |
| CN117348545A (en) * | 2023-10-11 | 2024-01-05 | 中冶南方工程技术有限公司 | Industrial data acquisition and distribution method, middleware and storage medium |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101615176A (en) * | 2009-08-07 | 2009-12-30 | 北京协成致远网络科技有限公司 | A kind of data monitoring system and implementation method |
| CN101848236A (en) * | 2010-05-06 | 2010-09-29 | 北京邮电大学 | Real-time data distribution system with distributed network architecture and working method thereof |
| CN103064382A (en) * | 2012-12-21 | 2013-04-24 | 南京富岛信息工程有限公司 | Optical proximity correction (OPC) embedded-type remote data collecting system and method based on ARM framework |
Family Cites Families (11)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CA2199108C (en) * | 1996-03-05 | 2002-04-23 | Hirotoshi Maegawa | Parallel distributed processing system and method of same |
| AU3268201A (en) * | 1999-11-03 | 2001-05-14 | Accenture Llp | Method for evaluating and selecting middleware |
| US7958251B2 (en) * | 2000-08-04 | 2011-06-07 | Goldman Sachs & Co. | Method and system for processing raw financial data streams to produce and distribute structured and validated product offering data to subscribing clients |
| US20040002988A1 (en) * | 2002-06-26 | 2004-01-01 | Praveen Seshadri | System and method for modeling subscriptions and subscribers as data |
| US20080125877A1 (en) * | 2006-09-12 | 2008-05-29 | Fisher-Rosemount Systems, Inc. | Process data collection system configuration for process plant diagnostics development |
| US20080065705A1 (en) * | 2006-09-12 | 2008-03-13 | Fisher-Rosemount Systems, Inc. | Process Data Collection for Process Plant Diagnostics Development |
| US8196155B2 (en) * | 2008-10-08 | 2012-06-05 | Oracle International Corporation | XML-based event driven interface for OPC data access |
| US20130066980A1 (en) * | 2011-09-12 | 2013-03-14 | Microsoft Corporation | Mapping raw event data to customized notifications |
| US20130218592A1 (en) * | 2012-02-16 | 2013-08-22 | CurePet, Inc. | Systems and methods for facilitating consolidated management and distribution of veterinary care data |
| US9396051B2 (en) * | 2014-10-06 | 2016-07-19 | Oracle International Corporation | Integration application building tool |
| CN110832808B (en) * | 2017-06-09 | 2023-06-20 | 环球互连及数据中心公司 | Method, storage medium, and computing system for messaging service |
-
2017
- 2017-12-10 CN CN201711301865.1A patent/CN108009258B/en active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101615176A (en) * | 2009-08-07 | 2009-12-30 | 北京协成致远网络科技有限公司 | A kind of data monitoring system and implementation method |
| CN101848236A (en) * | 2010-05-06 | 2010-09-29 | 北京邮电大学 | Real-time data distribution system with distributed network architecture and working method thereof |
| CN103064382A (en) * | 2012-12-21 | 2013-04-24 | 南京富岛信息工程有限公司 | Optical proximity correction (OPC) embedded-type remote data collecting system and method based on ARM framework |
Non-Patent Citations (3)
| Title |
|---|
| Zookeeper原理及使用;xinguan1267;《https://blog.csdn.net/xinguan1267/article/details/38422149》;20140807;第1,3-4,6,8页 * |
| 基于OPC技术的Web工控系统的研究与实现;赵晓峰;《自动化与仪表》;20160215(第02期);第62-64页 * |
| 电力调度数据平台中统一任务调度器的设计与实现;王渊等;《电力信息化》;20071015(第10期);1-8 * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN108009258A (en) | 2018-05-08 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN108009258B (en) | Data acquisition and analysis platform capable of being configured online | |
| US9336288B2 (en) | Workflow controller compatibility | |
| CN103441900A (en) | Centralization cross-platform automated testing system and control method thereof | |
| CN102968339B (en) | System and method for realizing complicated event handling based on cloud computing architecture | |
| CN109901948A (en) | Shared-nothing database cluster strange land dual-active disaster tolerance system | |
| CN112379884A (en) | Spark and parallel memory computing-based process engine implementation method and system | |
| US7974937B2 (en) | Adaptive embedded historians with aggregator component | |
| CN102937964A (en) | Intelligent data service method based on distributed system | |
| CN105608126A (en) | Method and apparatus for establishing secondary indexes for massive databases | |
| CN110704465A (en) | Method, device and storage medium for processing service work order table | |
| CN110705891A (en) | Data processing method based on high-allocable changeability | |
| CN114430353A (en) | Modbus protocol-based data acquisition method, system, device and medium | |
| CN113535837B (en) | Unified data development and distributed scheduling system | |
| US20200019382A1 (en) | Constraint programming using block-based workflows | |
| CN102122302B (en) | Centralized processing system and method for documents | |
| CN105260297B (en) | A kind of test data management system and method | |
| CN118916431B (en) | A method, system, device and medium for collecting data of GoldenDB database | |
| CN114116223B (en) | A request response method, device, system and readable storage medium | |
| CN114416868A (en) | Data synchronization method, device, equipment and storage medium | |
| CN113742393A (en) | Time sequence data processing system suitable for internet application | |
| CN117312446A (en) | Data synchronization method, device, electronic equipment and medium | |
| CN117455160A (en) | Production scheduling methods and related equipment | |
| US12021997B2 (en) | Blockchain tokenization of aircraft and other complex machinery | |
| KR102681450B1 (en) | Big data preprocessing method and apparatus using distributed nodes | |
| CN116795816A (en) | A data warehouse construction method and system based on streaming processing |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| CB02 | Change of applicant information | ||
| CB02 | Change of applicant information |
Address after: 215628 Yonglian Industrial Park, Nanfeng Town, Suzhou City, Jiangsu Province Applicant after: HENGCHUANG digital technology (Jiangsu) Co.,Ltd. Address before: 215628 Yonglian Industrial Park, Nanfeng Town, Suzhou City, Jiangsu Province Applicant before: JIANGSU HENGCHUANG SOFTWARE CO.,LTD. |
|
| GR01 | Patent grant | ||
| GR01 | Patent grant |