Source: https://patents.google.com/patent/CN104950836B/en
Timestamp: 2019-10-22 21:48:50
Document Index: 339443382

Matched Legal Cases: ['art 204', 'art 204', 'art 204', 'art 204', 'art 204', 'art 204', 'art 204', 'art 204', 'art 204', 'art 334']

CN104950836B - The preset-type data collection acted on behalf of using industrial cloud and intake - Google Patents
The preset-type data collection acted on behalf of using industrial cloud and intake Download PDF
CN104950836B
CN104950836B CN201510135130.0A CN201510135130A CN104950836B CN 104950836 B CN104950836 B CN 104950836B CN 201510135130 A CN201510135130 A CN 201510135130A CN 104950836 B CN104950836 B CN 104950836B
CN201510135130.0A
CN104950836A (en
弗朗西斯科·P·马图拉纳
2014-03-26 Priority to US61/970,798 priority
2014-10-27 Priority to US14/525,131 priority
2014-10-27 Priority to US14/525,131 priority patent/US9838476B2/en
2015-03-26 Application filed by 罗克韦尔自动化技术公司 filed Critical 罗克韦尔自动化技术公司
2015-09-30 Publication of CN104950836A publication Critical patent/CN104950836A/en
2018-08-31 Publication of CN104950836B publication Critical patent/CN104950836B/en
Cloud acts on behalf of facility convenient for collecting industrial data and by the Data Migration of collection to cloud platform from one or more data sources of factory floor to store and process.With cloud act on behalf of it is associated collect service to directly from agency networking commercial plant or come since device collect data intermediate data concentrate device history, immediately and/or data with alert execute preset-type data collection.Data are bundled in the data packet comprising header information by the queue processing service executed by cloud agency, and header information identifies the other information how associated with industrial enterprise client, processing priority information and the data processing service of informing in cloud platform handled and/or guided the data inputted.Then, cloud agency establishes the communication channel with cloud platform and via the channel transmission data.
The preset-type data collection acted on behalf of using industrial cloud and intake
This application claims entitled " the INDUSTRIAL CLOUD INFRASTRUCTURE submitted on March 26th, 2014 The US provisional patent of FOR DATA INGESTION, MODELING, PROCESSING, ANALYTICS, AND REPORTING " Apply for that the 61/970th, No. 798 preference, entire contents are incorporated herein by reference.
Theme disclosed herein relates generally to factory-data collection, more particularly, to convenient for by industrial data Collect and be uploaded to the preset-type cloud agency of storage and processing infrastructure based on cloud.
It is given below to simplify and summarize in order to provide the basic comprehension to some aspects described herein.The general introduction is not detailed Summary, be not intended to mark key/critical element or describe the range of various aspects described herein.Its sole purpose It is to provide some concepts in simplified form as the preamble in greater detail presented later.
In one or more embodiments, a kind of cloud agency is provided, cloud agency includes：Collect Service Part, by with It is set to from the source devices of industrial enterprise and receives industrial data, and industrial data is compressed to generate compressed data text Part；And queue processing component, be configured to based on the message queueing information being maintained in message queueing data storage device come Compression data file is packaged to generate compressed data packets with header information, and compressed data packets are sent to cloud platform, Wherein, which includes at least voip identifiers associated with industrial enterprise and the processing of specified industrial data is excellent The precedence information of first grade.
In addition, one or more embodiments provide a kind of method for sending industrial data to cloud platform, including：It is logical Cross the industrial data that the cloud agent apparatus including at least one processor collects the source devices from industrial enterprise；Pass through cloud Agent apparatus compresses to generate compression data file industrial data；It is based on being maintained at message queueing by cloud agent apparatus Header information is additional to compression data file to generate compressed data packets by message queueing information in data storage device, In, which includes at least voip identifiers associated with industrial enterprise and the processing of specified industrial data is preferential The precedence information of grade；And compressed data packets are sent to by cloud platform by cloud agent apparatus.
In addition, according to one or more embodiments, a kind of non-transitory computer-readable medium is provided, the non-transient calculating Machine readable medium is stored with instruction, and described instruction so that cloud agent apparatus executes operation in response to execution, and the operation includes： Industrial data is received from source devices associated with industrial enterprise；Based on the type of industrial data come with from message queueing number The header information retrieved according to storage device is packaged to generate compressed data packets compression data file, wherein the header is believed Precedence information of the breath including at least voip identifiers associated with industrial enterprise and the processing priority of specified industrial data； And compressed data packets are sent to cloud platform.
In order to address related purpose before realizing, certain illustrative sides are described herein in conjunction with following description and drawings Face.The various modes that these aspect instructions can be put into practice, all these modes are intended to be included herein.In conjunction with attached drawing When accounting for, other advantages and novel feature can become apparent according to described in detail below.
Fig. 1 is the high-level overview using the industrial enterprise of service based on cloud.
Fig. 2 is the block diagram of example cloud agency.
Fig. 3 is to provide data collection and processing service using the cloud infrastructure based on agency to manufacture website to client The general introduction of system.
Fig. 4 is the block diagram for showing preset-type data collection.
Fig. 5 is the block diagram of the logical architecture for the service for showing to be executed by cloud agency.
Fig. 6 is the conceptual schema of public information engine.
Fig. 7 is the figure of exemplary compression data packet.
Fig. 8 is the block diagram of the exemplary architecture for the communication for coming administration agent and the cloud platform of client using agency of trademark registration table.
Fig. 9 is the block diagram of the example broker architecture for collecting data from preset-type commercial plant.
Figure 10 is the concept map of example manifest component.
Figure 11 is the figure of the example layer architecture of system list.
Figure 12 is for using cloud broker architecture to absorb industrial data to the flow chart of the exemplary method of cloud platform.
Figure 13 is for using cloud agency service data and to send data to showing for cloud platform to be collected from industrial enterprise The flow chart of example method.
Figure 14 is for cloud agent security to be connected to the example of cloud platform by shaking hands with agency of trademark registration table The flow chart of method.
Figure 15 is the stream to the exemplary method of the secure access of the specific cloud platform of client in cloud broker architecture for control Cheng Tu.
Figure 16 is example computing device
Figure 17 is example network environment.
Present disclosure is described referring now to attached drawing, wherein throughout identical reference numeral is for referring to identical member Part.In the following description, in order to illustrate elaborating a large amount of detail in order to provide the comprehensive understanding to it.However, bright It is aobvious, present disclosure can be put into practice without these specific details.In other examples, showing in form of a block diagram Known construction and device is gone out, in order to be described.
Term " component " used in this application, " system ", " platform ", " layer ", " controller ", " terminal ", " station ", " node ", " interface " be intended to refer to computer related entity or to the operation equipment of one or more specific functions it is related or As part thereof of entity, wherein such entity can be the combination of hardware, hardware and software, software or in execution Software.For example, component can be but not limited to the process run on a processor, processor, hard disk drive, (light or magnetic Storage medium) multiple memory drivers (including (such as be threadedly coupled or be bolted) of attachment or moveable attachment Solid state storage drive)；Object；Execute program；Execution thread；Computer executable program and/or computer.As example Show, the application run on the server and the server all can be components.One or more components may reside within process And/or in execution thread, and component can be located on computer and/or be distributed in two or more computers it Between.In addition, component described herein can be executed according to the various computer readable storage mediums for being stored with various data structures. Component can be via locally and/or remotely process such as according to having one or more data packets (for example, coming from and local system System, another component in distributed system interact or via signal, by the network of such as internet and other be Unite interaction a component data) signal communicated.As another example, component can be had by electrically or electronically The equipment for the specific function that the mechanical part of circuit operation is provided, wherein this electrically or electronically circuit is executed by processor Software or firmware application operate, and wherein processor can be inside or outside the equipment, and executes software or firmware application At least part.As another example, component can be following equipment：It provides specific function by electronic unit, and Without mechanical parts, electronic unit processor can be included therein with execute provide electronic unit at least partly function it is soft Part or firmware.As another example, interface may include input/output (I/O) component and associated processor, using or Application Programming Interface (API) component.Although aforementioned exemplary is related to the various aspects of component, illustrated by aspect or feature Suitable for system, platform, interface, layer, controller, terminal etc..
Term " inferring (infer) " used herein and " inferring (inference) " are generally referred to according to via thing One group of observation of part and/or data capture come reasoning or inference system, environment and/or user state process.It may be used Infer to identify specific background or action, or can for example generate the probability distribution about state.Deduction can be probability Property, that is to say, that based on the considerations of the calculating to data and event to the probability distribution about state of interest.Infer also It can refer to and be made of compared with technology used by advanced event one group of event and/or data.Such deduction causes from one group Event and/or the event data of storage build new event or action, regardless of whether event is indirect when close It is related in nearly property, and no matter event or data are from an event source or data source or several event sources or data source.
In addition, term "or" means inclusive "or" rather than exclusive "or".That is, unless in addition It indicates or from the context it is clear that otherwise phrase " X uses A or B " is intended to refer to any naturally inclusive arrangement. That is any one of following Examples meet phrase " X uses A or B "：X uses A；X uses B；Or X uses A and B two Person.In addition, " one (a) " or " one (an) " that is used in the application and in appended claims should generally be interpreted refer to " one or more " is obviously unless specified otherwise herein or to be from the context directed to singulative.
In addition, term " set " used herein excludes empty set, such as the set without element.Therefore, in this public affairs It includes one or more elements or entity to open " set " in content.As illustration, the set of controller includes one or more Controller；The set of data resource includes one or more data resources；Etc..Similarly, term " group " used herein Refer to the set of one or more entities, such as node group refers to one or more nodes.
Various aspects or feature will be presented with the system that may include many devices, component, module etc..It is to be understood that With it is appreciated that each system may include other device, component, module etc., and/or can not include in conjunction with attached drawing institute All devices, component, module for discussing etc..The combination of these methods can also be used.
Industrial control unit (ICU) and its associated I/O devices are the cores for operating Modern Automation System.These controllers and work The field device in factory workshop is interacted to control and such as disposition of product manufacturing, material, batch processing, the purpose of Supervised Control And other are such using relevant automation process.Industrial control unit (ICU) stores and executes user-defined control program with reality Now decision-making related with controlled process.Such program can include but is not limited to ladder logic, sequential function chart, function Block diagram, structured text or other such programming structures.
Due to a large amount of system variables that must be monitored and controlled near real-time, industrial automation system generally produces a large amount of close Real time data.In addition to production statistics data, usually monitoring is fed back with machine health, alarm state, operator (for example, manually The reason-code associated with shut-down situation of ground input), the related data such as electrical or mechanical load at any time, and Under some cases, recorded on a continuous basis.The data are given birth to by many commercial plants for constituting typical automated system At, including industrial control unit (ICU) and its associated I/O, the telemetering equipment near real-time metering, motion control device (for example, with In control constitute kinematic system motor driver), visualization application, batch trackability system (for example, bar code with Track) etc..Further, since many industrial plants work for 24 hours, so its associated automated system can be generated with high-speed Potentially large number of useful data.When additional plant facilities is added in industrial enterprise, the amount of the automated data generated It further increases.
The mass data generated by Modern Automation System allows to be applied to the analysis of extensive factory to constitute industry The automated system and processing of enterprise or business.However, the access to industrial data is normally limited to and collects and generate data Industrial control unit (ICU) shares application and the device of public network.Similarly, it is desirable that it is desirable that in another application (for example, report or analysis Tool, notice system, visualization application, backup data store etc.) in utilize the system generation by these applications and device The factory personnel of industrial data maintain such application at the scene using local resource.In addition, although given industry enterprise Industry may include multiple plant facilities (or multiple mobile systems with variable position) at geographically different location, but this The range of the application of sample is only limitted to reside in available data on the controller in same local network with the application.
In order to solve the problems, such as these and other, one or more embodiments of present disclosure are provided for from factory's vehicle Between device collect industrial data and preset-type broker architecture that the data transmission is handled and stored to cloud repository. The framework based on agency can be including but unlimited in order to collect industrial data from the data source of all ranks in industrial enterprise In commercial plant (for example, controller, driver, telemetering equipment etc.), data historian (historian), tables of data, business level Data source as other system (for example, Enterprise Resource Planning System, manufacturing execution system, accounting system etc.) and others. The data of collection can be sent to infrastructure based on cloud by the cloud agency on factory floor, the infrastructure based on cloud Based on context and/or user-defined parameter (for example, time, priority etc. that factory floor event occurs) come intelligently Acquired data are classified and organized.
Cloud broker architecture use priority message queue and blob storages carry out basis in cloud platform to collected data Processing and using removing the transmission to the data.Cloud agency can also support torrent data flow (torrential data Stream) and parallel pipeline, so as to cause high-performance data transmittability.Queue processing service with client's particular header information come Collected industrial data is packaged, which includes subscriber identity information, specifies for flat in cloud (it can be based on the type of data for the relative priority of processing data in platform；For example, history, instant, alarm etc.) place Data will be held by the data processing service of cloud platform by managing precedence information and being utilized to identification in cloud platform The other information of the type of capable processing.
Fig. 1 shows the high-level overview of the industrial enterprise using service based on cloud.Enterprise includes one or more industry Facility 104, each industrial plants have multiple commercial plants 108 and 110 in use.Commercial plant 108 and 110 may be constructed The one or more automated systems operated in each facility 104.Exemplary automated system may include but unlimited In lot control system (for example, hybrid system), continuous control system (for example, PID control system) or discrete control system.Work Industry device 108 and 110 may include device such as below：Industrial control unit (ICU) is (for example, programmable logic controller (PLC) or other classes The programmable automation controller of type)；The field device of such as sensor and instrument；Motor driver；Operator interface (example Such as, man-machine interface, industry monitoring device, graphic terminal, message display etc.)；Industrial robot, bar code marker and reading Device；Vision system device (for example, vision camera)；Intelligent welding device；Or other such commercial plants.
Exemplary automated system may include convenient for monitoring and controlling one or more Industry Controls of its each process Device.Controller is using intrinsic hardwired I/O or via such as Ethernet/IP, Data highway+(Data Highway Plus), the plant networks such as control net (ControlNet), facility network (DeviceNet) exchange data with field device.Given Controller usually receives the current state for indicating these devices and its association process (for example, temperature, position, portion from field device Part whether there is, fluid water equality) digital or analog signal arbitrary combination, and based on received signal execute to by Control process carries out the user-defined control program of automated decision-making formulation.Controller is then according to by controlling program formulation Decision exports number appropriate and/or analog control signalling to field device.These outputs may include device actuating signal, temperature Degree or position control signal dispose the operational order of robot, mixer control signal, motion control to mechanical processing or material Signal etc..Control program may include for handling the output signal read in the input signal of controller and control controller generation Any suitable type code, including but not limited to ladder logic, sequential function chart, functional block diagram, structured text or its Platform as him.
Although commercial plant 108 and 110 is described as resident in the fixed industry in position by exemplary overview shown in Fig. 1 In facility 104, but commercial plant 108 and 110 can also be a part for mobile control application, be such as included in truck or its System in his service vehicle.
According to one or more embodiments, preset-type cloud agency 106 can from commercial plant 108 and 110 or from other Data source collects data, and sends the data to cloud platform 102 to be handled and be stored, other data sources include but not It is limited to data historian, commercial level system etc..Cloud platform 102 can allow that there is the device of cloud ability to access and use cloud The arbitrary infrastructure of service 112.Cloud platform 102 can be that there is internet to connect and using the proper authorization for servicing 112 Device can be via the public cloud of internet access.In some cases, cloud provider can provide cloud platform 102 and be used as platform (PaaS) is serviced, and services 112 (all operator interface systems as described herein) and may reside in cloud platform 102 And it is executed as service based on cloud in cloud platform 102.It, can will be to cloud platform 102 in some such configurations Access with service 112 is supplied to client, the subscription service of the owner as service 112.As an alternative, cloud platform 102 can be with It is privately owned or half private clound of enterprises operation, or shared or company's cloud environment.Exemplary private clound may include support Pipe (host) cloud service 112 and reside in one group of server on the corporate networks of firewall protection.
Cloud service 112 can include but is not limited to data storage, data analysis, control application (for example, can be based on to reality When system data or the analyses of other factors generate control instruction and be passed to the application of commercial plant 108 and 110), Visualization application, report application, the Enterprise Resources Planning (ERP) of all operator interface systems based on cloud as described herein Using, notice service or other such applications.Cloud platform 102 can also include one or more object models in order in cloud Middle progress data intake and processing.If cloud platform 102 is network-based cloud, the cloud generation at each industrial plants 104 Reason 106 can interact directly or via internet with cloud service 112.In exemplary configuration, commercial plant 108 and 110 is logical It crosses physics or WLAN or radio link is connected to preset-type cloud agency 106.In another exemplary configuration, industry Device 108 and 110 can use integrated-type cloud agency directly to access cloud platform 102.In further detail below discuss cloud agency and its Associated data is collected and processing service.
Commercial plant data are absorbed in cloud platform 102 by using cloud agency 106 can provide industrial automation institute spy Some many advantages.One of advantage is easily to be adjusted the storage based on cloud provided by cloud platform 102 with suitable Answer the mass data that industrial enterprise generates daily.In addition, multiple industrial plants at diverse geographic location can be by it respectively Automated data be transferred to cloud to be assembled, be arranged, the report of comprehensive analysis, visualization and enterprise level, without Private network is established between facility.Cloud agency 106 alleviates the establishment of industrial Internet of Things (IoT).Cloud agency 106 can be configured At automatically detecting cloud platform 102 when at any facility and communicating with, show with what enterprise used to simplify Data based on cloud storage, analysis or the report application having integrate.In another sample application, diagnostic application based on cloud can To monitor each automated system or its association industry in entire factory or in the multiple industrial plants for being constituted enterprise The health of device.Based on cloud batch of control application can be used for by production phase of unit product track unit product and Its by collected when each stage each unit creation data (for example, barcode identifiers, production each stage production Statistical data, quality test-data, abnormality mark etc.).In addition, control application based on cloud can be based in cloud from industry system The data collected of uniting execute Remote Decision-making formulation to be directed to controlled industrial system, and are acted on behalf of to system via cloud and send out control life It enables.These industrial cloud computing applications are meant only to be illustrative, and system and method described herein are not limited to these Specific application.Cloud platform 102 can allow software vendor to provide software as service, to eliminate from the soft of its client The burden that part is safeguarded, upgrades and backed up.
Fig. 2 is the block diagram according to the example cloud of one or more embodiments of present disclosure agency 202.Although Fig. 2 will Certain functional components, which are portrayed as, to be resided on cloud agency 202, it should be understood that in some embodiments, it is shown in Fig. 2 One or more of functional component functional component may reside within opposite cloud and act on behalf of on 202 separated devices.In the disclosure The various aspects of the system, equipment or the process that illustrate in appearance may be constructed in (one or more) machine (for example, being included in It is associated with one or more machines one or more computer-readable medium in) machine can perform component.Such portion Part by one or more machines (for example, (one or more) computer), (one or more) computing device, (one or more It is a) automation equipment, (one or more) virtual machine etc.) come described by can making that (one or more) machine executes when executing Operation.
Cloud agency 202 may include collecting Service Part 204, queue processing component 206, subscription management component 208, user Interface unit 210, one or more processors 212 and memory 214.In various embodiments, collect Service Part 204, One or more in queue processing component 206, subscription management component 208, one or more processors 212 and memory 214 A component can electrically and/or communicatedly be coupled to each other with execute cloud agency 202 function in one or more functions. In some embodiments, component 204,206,208 and 210 may include being stored on memory 214 and by (one or more) The software instruction that processor 212 executes.Cloud agency 202 can also be with other hardware and/or software component for not describing in fig. 2 Interaction.For example, (one or more) processor 212 can be with one or more external user interface device (such as, keyboard, mouse Mark, the display monitor, touch screen or other such interface arrangements) interaction.
Service Part 204 is collected to may be configured to collect industry dress from data concentrator or directly from device itself Set data.Service Part 204 is collected to can be configured to pre-process to be transmitted to cloud platform collected data；Example Such as, it by compressed data and stores data in compression data file.Queue processing component 206 may be configured to by by The compression data file that Service Part 204 prepares is collected to be packaged into data packet and the data packet is pushed to cloud platform.It subscribes to Management component 208 may be configured to keep user's specific configuration and subscription information.The information can be by queue processing component 206 Access with it is determined that how to compression data file be packaged and how be connected to the cloud platform of client with transmission data Packet.User interface component 210 may be configured to receive with arbitrary appropriate form (for example, vision, the sense of hearing, tactile etc.) User inputs and is presented to user and exported.In some embodiments, user interface component 210 may be configured to and graphical user Interface is communicated, which is being communicatively connected to the separated hardware device of cloud agency 202 (for example, above-knee Type computer, tablet computer, smart phone etc.) on execute.In such a configuration, user interface component 210 can receive The input parameter data that user inputs via graphical user interface, and by output data (for example, drive performance measures number According to) it is transferred to interface.
It is described herein to execute that one or more processors 212 are referred to disclosed system and or method One or more functions in function.Memory 214 can be following computer readable storage medium：It is stored for reference to institute Disclosed system and or method executes the computer executable instructions and/or information of function described herein.
Fig. 3 is to provide data collection and processing service using the cloud infrastructure based on agency to manufacture website to client The general introduction of system.The system can in conjunction with for crucial industrial assets alarm and event notice, history data collection, remotely System access, system optimization, Remote closed loop control and other such applications service to provide long range acquisition and monitoring.It is based on The infrastructure of cloud makes it possible to remotely monitor preset-type assets by realizing following six general domains of function And report：Data intake enters cloud, data prioritization, object modeling, data processing, data analysis and report.
In the example depicted in fig. 3, data concentrator 328 is collected at plant facilities from one or more industrial assets Plant data (for example, data that one or more industrial control unit (ICU) (such as commercial plant 108 or 110) generates).These works Industry assets may include industrial control unit (ICU), data server and the history library that industry I/O devices are monitored and controlled, motor driving Device, remote I/O interface, the pot that I/O devices group is remotely docked to one or more of industrial control unit (ICU) industrial control unit (ICU) Stove or other industrial machines or other such assets.For example, data concentrator 328 can monitor defined in label archive One or more controller tags and store data in local data storage associated with history library 338 336 In (for example, local structured query language or SQL, server).Collected data may include historical data (for example, alert Report history, state history, trend data etc.), the instant data value that is read from industrial assets, the alarm number generated by industrial assets According to or other kinds of data.
Preset-type cloud agency 202 is configured to directly or through access data associated with data concentrator 228 Storage device 336 collects instant or historical data from industrial assets.Cloud agency 202 can be in any suitable hardware platform It is executed on (for example, server, LINUX frames etc.), and serves as universal gateway, the universal gateway is from the various works on plant network Industry assets collect data item and according to the general uniform data packing sides for preset-type data to be moved to cloud platform 302 Case is packaged collected data.Cloud agency 202 provide to dynamically link preset-type to cloud gateway software mechanism. Cloud agency 202 provides permission and new data type is added to the expansible of cloud without redeploying monitoring system Data type scheme.
During data collection, cloud agency 202 can the criterion based on definition come intelligently to data carry out classification and group It knits, the criterion of definition includes but not limited to time of origin and/or user-defined priority.Cloud agency 202 can for example be made Data that periodically collect serializing with the standard Web Services about HTTPS/SSL and compression simultaneously convert thereof into cloud The service (for example, Windows is serviced) of domain name.
Fig. 3 depicts the data concentrator 328 as the data source for cloud agency 202.The configuration will be monitored in presence Mass data point in the case of be it is useful, this is because data concentrator 328 can by multiple commercial plants or other number According to linking sources to single cloud agency 202.However, some embodiments of cloud agency 202 can for example pass through public industrial protocol chain Data are directly collected in road by the middleware application of such as OPC client from industrial assets itself.
Cloud agent functionality is illustrated in greater detail with reference to Fig. 4.By playing the virtual support engineer for handling data The set of service of effect realize preset-type data collection.Data concentrator 328 and cloud agency 202 respectively realize and data Associated two kinds of major functions-usage history library 338 and associated data storage device 336 are collected (for example, SQL is serviced Device) data set in and using by cloud agency 202 execute cloud agency service cloud data realize.As noted above As, plant data 410 is collected by data concentrator 328 at plant facilities.In an exemplary situation, plant data 410 can To include the punching press time series sensing data by being constituted with the newer thousands of a data points of the rate less than the second rate.
The collection Service Part 204 of cloud agency 202 realizes following collection and services, and the collection service is from data concentrator Associated data storage device (for example, via SQL query) or via public industrial protocol (CIP) link or other are appropriate logical Believe agreement directly from device collection device data itself.For example, in order to obtain data from data concentrator 328, service is collected Data extraction inquiry (for example, SQL query) can be periodically run with from associated with data concentrator 328 in component 204 Data storage device 336 extracts data.Then compression can be stored in compressed data and by the data by collecting Service Part 204 In data file 412.Then, the queue processing service executed by queue processing component 206 can read compression data file 412 And Reference News's data queued library 414, which keeps and managing customer specific data collects and matches confidence Breath and information related with client's subscription cloud platform and associated cloud service.Based on matching in message queueing database 414 Confidence ceases, and compression data file 412 is packaged into data packet and the data packet is pushed to cloud and put down by queue processing component 206 Platform.In some embodiments, cloud agency 202 can support injection data packet as torrent data 416.
Message queueing database 414 may include identifying the website specific information of the data item to be collected (for example, data mark Note identifier), for data markers user-defined processing priority, allow cloud to act on behalf of 202 to pass through factory's fire wall and cloud The fire wall setting and other such configuration informations that platform is communicated.Configuration information in message queueing database 414 How Indicated Cloud agency 202 is communicated with the data markers identified and with the remote data capture service in cloud platform.
In addition to collecting and shifting data, one or more embodiments of cloud agency 202 can also be moved to by data Portion of data executive board is analyzed before cloud platform.This may include that can be convenient for data being efficiently transmitted to cloud, for the increasing in cloud Strong analyze prepares the substantially any type of of cloud storage amount or other such benefits needed for data, reduction storage data Pretreatment or data fining (data refinement).For example, cloud agency 202 may be configured to be transferred to by data Collected data are compressed using any suitable data compression algorithm before cloud platform.This may include detection and deletes superfluous Remaining data bit intercepts accurate position or other squeeze operations appropriate.In another example, cloud agency 202 may be configured to Data are polymerize by being combined to the related data from multiple sources.For example, cloud agency 202 can identify and come from The data of multiple sensors of the related fields of Measurement ＆ automation system are simultaneously polymerized into single cloud upload packet.Cloud agency 202 It can also be encrypted before sensitive data is uploaded to cloud.In another embodiment, cloud agency 202 can according to appoint Meaning particular filter criterion (for example, filter criteria defined in the filter profiles stored on cloud agency) carried out filter data.For example, The filter criteria of definition can specify to be filtered before pressure value is uploaded to cloud be more than defined set point pressure Value.
In some embodiments, cloud agency 202 can also be according to the requirement of analysis application based on cloud by industrial data Specific subset from the first formal argument be the second form.For example, report application based on cloud can require the measurement for ASCII fromat Value.Therefore, cloud agency 202 can by data-pushing to cloud platform with before being stored and processed by the data acquired Selection subsets are converted into ASCII from floating-point format.It is turned before the initial data at commercial plant is uploaded to cloud It changes rather than processing load amount beyond the clouds can be reduced by requiring to execute the transformation on cloud.
Cloud agency 202 can also be associated with the selection subsets of data by metadata before migrating to cloud, to count It is studied according to being placed in industrial environment.For example, cloud agency 202 can be using following items come the selection subsets of flag data：It is specified Generate time indicator, quality indicator, the specified production area out of it collects data industrial enterprise of the time of data State when generating data of production area indicator, specified machine or process machine or process status indicator, specified The personal indicator of the employee to go to work when generating data or other such context metadatas.In this manner, cloud agency 202 Layered shaping can be executed to collected data, then utilizable first rank is known to generate analysis tool based on cloud Know, the case where in order in view of larger factory and to the enhancing type analysis of data.
In order to ensure that can support HTTPS/ to one or more embodiments of the outbound traffic of cloud safety, cloud agency 202 SSL, the enabled transmission of certificate authority and/or the unique mark using MAC Address.Cloud agency 202 can also support storage to turn Hair ability is to ensure not lose data in the case where agency disconnects with cloud.
Now, it is back to Fig. 3, cloud agency 202 is via cloud storage structure (storage fabric) 316 by compressed data packets 324 are sent to data collection based on cloud and monitoring system in cloud platform 302.Data packet 324 transmits cloud service and is used Parameter and data (compression and serializing), to use auxiliary tenant's grade inventory (tenant-level manifest) Numeric field data structure is reconstructed in cloud.Cloud service by the long-range storage of received data guiding to pre-adjusted transient state blob (two into Blob processed) in 310.Cloud platform 302 can determine data storage using the protocol characteristic for acting on behalf of reasoning and collection.
By by cloud agency 330 provide configuration interfaces, the user at plant facilities can dynamically configure one or Multiple priority queries 304, the one or more priority query 304 are correspondingly defined in cloud platform 302 how to handle number According to packet.For example, individual queue can be defined for alarm, instant data and historical data, to allow according to these data Type carries out tissue to data.Historical data queue can be recorded with time series it is related, time series record can be by answering It is accessed with programming interface (API) (for example, SQL API or other suitable API).Alarm queue can have with unusual condition It closes, wherein data with alert can also pass through API Access.The alarm queue may include associated from different alarm priorities Multiple queues, with allow for the different alarms with different critical rank independent processing.It in some embodiments, can be with Come monitoring server, controller, interchanger etc. using various protocols, and (that is, in the ending of monitoring cycle at specified point Place), alarm can be made to be lined up, and alarm can be sent to cloud by cloud agency 202.Alarm can be reaction (for example, in electricity When machine is out of order, when CPU collapses, when interlocking device malfunctions etc. triggerings alarm) or can be active (for example, prison Examining system can track the consumables on machine when to the time of record and generate alarm, be supervised when arranging preventive maintenance Survey machine on cycle count and generate alarm, alarm is generated when except the bandwidth that temperature drops to definition, in computer In send notice etc. when saving as 80% occupancy).
Instant data queue can be related with the data (such as, Current Temperatures, current pressure etc.) that monitor in real time substantially.I.e. When data value can also be accessed by API (for example, AQL API).Above-mentioned queue is not intended to be limited, and be appreciated that It is that other kinds of priority query can be defined according to the demand of end user.For example, can be directed to for uploading device The specific device or type of device (for example, motor driver) of parameter and/or performance data defines queue.
In some embodiments, cloud agency 202 can allow user according to the position on website to define these priority Queue 304, and define how to handle the data in each queue.For example, user, which can be directed to each queue definitions, uploads frequency Rate, should wherein deposit at priority level (for example, which data queue should obtain processing priority compared to other data queues) Store up the cloud subregion of the data from corresponding queue or the mark and other such information of database.In a kind of illustrative case In, instant data queue, which may be defined as handling being applied by remote operator interface, to be used for checking from the basic of plant facilities The instant data value of real time data, and historical data queue can be used for handling historical data and be stored in cloud storage device to file On historical data base in.Accordingly, with respect to historical data queue, higher priority can be distributed to instant data queue, This is because immediately the data in data queue required in time than the data in historical queue it is tightened up.
By cloud act on behalf of 202, user can at customer rs site corresponding data markers or labeling component match priority. These priority can be distributed in the message queueing database 414 for being stored in cloud agency 202.Therefore, in queue processing component It, can be according to (such as in message queueing database 414 when 206 pairs of collected data that be moved to cloud platform are packaged It is defined) collected data item is packaged into data packet by priority, and corresponding packet header be filled with it is appropriate excellent First grade.If not using the access to cloud, data will continue to be collected by collection Service Part 204 and be taken with collection It is engaged in being locally stored in associated be locally stored on cloud agency.When restoring the communication with cloud, the data stored will be turned It is sent to cloud storage device.Queue processing service can also test storage account key encrypting and transmitting to cloud platform to carry out user Card.
When cloud agency 202 sends data packets to remote processing service based on cloud, which reads the header of the packet Information distributes to the priority (for example, as defined in data priority field of data packet) of data to determine, And data packet (or compressed data therein) is sent to by the choosing in user-defined priority query 304 based on priority A fixed priority query.In the another side of priority query 304, data processing service 308 is fixed according to predefined processing Justice handles the data in corresponding priority query 304.Data processing service includes worker role 332, worker role 332 based on be stored in client's specific list component 334 inventory (for example, system list, label inventory and measurement inventory) come How determination will handle the data of queuing.Inventory defines and realizes the peculiar ability of client, using and for handling receipts in cloud Collect the preference of data.Inventory can dynamically be uploaded by cloud agency 202 in plant facilities by user, this facility cloud computing energy The dynamic expansion of power.
For example, if new data point to be added to the data gathering system for needing to create new queue, user 202 can be acted on behalf of with cloud to interact, to configure new inventory for new queue, which defines all aspects described as follows： The processing priority of data, the upload frequencies of data, data to be route or be stored in position in cloud storage device and its Information as him.Then, cloud agency 202 can upload new inventory 306 together with data (or independently of data). Then, new inventory 306 is added into the manifest component 334 of clients with other inventories for client definition so that work Author role 332 can determine the data that how handle in new queue using new inventory 306.It only needs this is new clear Single 306 are uploaded to long-range monitoring service based on cloud once.Hereafter, by by worker role 332 according to being stored in the clear of client New inventory 306 in unimodule 334 handles the data being placed in new priority query.For example, inventory can define number According to the position in cloud storage device to be stored in (for example, in historical data base and alarm and instant data database, big data In storage device 312 etc.) and new queue processing whether compared to other data queues have priority.At some In embodiment, if inventory has unique key associated with client, manifest component 334 can only receive new clear It is single.
Once long-range monitoring infrastructure based on cloud is processed according to above-mentioned technology and stores by 202 offer of cloud agency Data can then make client terminal device 322 may have access to data to check.The data analysis of cloud platform 302 can will be used In one group of technology enabled based on network and browser of retrieval, guiding reconciliation compressed data client is provided to from cloud platform 302 End device 322.For this purpose, report services 314 can be by the number of (for example, coming from big data storage device 312) in cloud storage device According to being transferred to client terminal device 322 in a defined format.It is stored in cloud repository for example, report services 314 can utilize Data are collected so that remote operator interface is supplied to client terminal device 322 via internet.Point executed in cloud platform 302 Analysis engine 318 can also execute the data that are stored in big data storage device 312 various types of analyses and by result It is provided to client terminal device 322.
Fig. 5 is the block diagram of the logical architecture for the service for showing to be executed by cloud agency 202.In this example, several data are received Collection is configured to collect data from corresponding industrial assets or industrial assets group using 504.Data collection can be suitable using 504 When hardware device (for example, data collection server or other such devices) on execute, and as cloud act on behalf of 202 Data source.Each data collection is configured with corresponding application configuration 502 using 504, and the definition instruction of application configuration 502 is corresponding Data collection how to be connected to device using 504 and to retrieve the data source parameter of the application of data from it.Application configuration 502 can also include that data collection is connected to specified device using 504 and applies required configuration data.Using by applying The configuration informations that configuration 502 provides, corresponding data collection using the connection of 504 devices that can be established and specify and application with And retrieve data from various devices and the associated specified data markers of application or element.Application configuration also indicates data collection How to prepare retrieved data using 504 in order to which cloud agency 202 collects.
Once data collection has been configured using 504 and has collected data in the commercial plant and application distributed from it When in process, each data collection can feed the data collected via corresponding data using 504 and be provided to cloud agency 202.Each data collection using 504 can via factory or office network (for example, Ethernet, universal industrial protocol etc.) or It is communicably linked to cloud agency 202 via wireless link (for example, WLAN, radio link etc.).In some embodiments In, data collection using 504 may be configured to be either periodically or in response to definition upload trigger (for example, in response to The data volume of the collection of definition) data-pushing collected is to cloud agency 202.In other embodiments, cloud agency 202 can be with The data periodically collected from each data collection using 504 extractions.In such embodiments, cloud agency 202 can week Phase property operation data extraction inquiry (for example, SQL query), the data extraction inquiry from corresponding data collection using 504 inspection Rope data.
In some embodiments, cloud agency 202 can use general information engine 516 to be carried out using 504 with data collection Communication, general information engine 516 are used as the symmetric information Fabric Interface for agency.General information engine 516 can be supported to use In the multiple communication protocols communicated using 504 with various data collections (for example, the transfer of declarative state, data distribution take Be engaged in (DDS), WebSocket etc.), and as parallel processing engines simultaneously to manage to data collection the multithreading for applying 504 Connector.It returns briefly to Fig. 6, shows the conceptual schema of general information engine 516.By new data collection application or For other new data sources-for example, when data source 606-is added to cloud agency 202, general information engine 516 is directed to new connection To illustrate Agent Analysis component 602.Agent Analysis component 602 is extracted via service interface management from the data of data source 606.Institute The Agent Analysis component 602 of illustration calls connector process 604 via general information engine 516 for new data source.Connection Device process 604 is the special of the service interface connection of establishment and management to destination adapter associated with new data source 606 Perform script.General information engine 516 can support multiple communication protocols.Similarly, Agent Analysis component 602 can generate branch The agreement used by destination adapter is held (for example, the CIP for universal industrial protocol adapter；For supporting the data of OLE to go through The object linked and embedding etc. of history) connector process 604 appropriate.Destination adapter can have associated communication port 608-for example, declarative state transfer (REST) connector, WebSocket etc.-, connector process 604 passes through associated logical Believe that the communication channel with data source 606 is established in port 608.Then, connector process 604 via communication channel from data source 606 Extract data.Application configuration 502 applied to data source 606 (as above in conjunction with described in Fig. 5), which can be defined from it, will extract data Data source 606 in Data Position (for example, data markers, record etc.).
Returning now to Fig. 5, prepares (via corresponding connector process 604) using local cloud agency service and received from data The data that collection is received using 504 are to be transmitted to cloud.Specifically, serializing, encryption and the compression service executed on cloud agency 202 510 (can be realized by collection Service Part 204) are according to the user-defined preference defined by application configuration 506 come to data It is pre-processed.For example, application configuration 506 can define before data are injected into cloud platform will be applied to received number According to compression and/or encrypted preferred type.Application configuration 506 can be acted on behalf of via user interface (not shown) applied to cloud 202, which allows the configuration parameter that user inputs or selection is acted on behalf of for cloud.Service 510 pairs of data extracted into Row is encrypted and is compressed to generate compression data file (for example, compression data file 412 shown in Fig. 4).
Then, the message queuing services (can be realized by queue processing component 206) of cache layer 512 are by adding client Particular header information is packaged compression data file or is packaged to generate compressed data packets (for example, the compressed data of Fig. 3 Packet is 324).For example, message queuing services can access message queueing database (for example, message queueing database 414 of Fig. 4), The subscription of message queueing database stores customer site configuration information and managing customer to cloud platform service.Message queueing data Library may include information such as below：The associated voip identifiers of associated with same industrial enterprise client entity, with from It has collected that the associated site identifier of specific plant facility of data, distributing to the priority of data, (it can depend on In the type of the information just sent；For example, data with alert, historical data, real time operation data etc.), convenient for specific to client Information needed for the connection of cloud structure or other such information.It is based on being maintained at message queueing number including information in the header According to the customer specific information in library.Exemplary compression data packet is shown in Fig. 7.It is shown that the message row of cloud agency Header 704 is added in compression data file 412 to generate compressed data packets 324 by team uniform business.Header 704 includes to be arranged from message Client's specific data that team's database 414 is read.For example, header 704 may include unique voip identifiers, indicate specific work The site identifier of factory's facility, virtual support engineer's identifier, data in compression data file 412 data priority, Type of message and the Process identifier for specifying the specific list for the data that should be used to handle high in the clouds to apply in cloud platform.With This mode packaged data can allow will be from the data one of different data sources using unified conventional data packing pattern It rises and is packaged so that data can be moved to cloud infrastructure.
Now, it is back to Fig. 5, before being transmitted to cloud platform, the cache layer 512 of cloud agency 202 can temporarily store pressure Contracting data packet.For example, cache layer 512 can be come temporarily using message queuing services and file system before being transmitted to compressing number It is lined up according to file.These queuing services enable cloud agency 202 to support storage transfer capability, so that can will be from number The data retrieved according to source are locally stored on cloud agency 202, until using until the communication channel of cloud platform.
Once compression data file has been packaged and has been lined up in cloud agency, 604 notification agent of connector process point Data extraction is completed in analysis component 602.In response, analysis agent component 602 illustrated by asks directory services functionality to create Build the cloud connector port as the communication channel between cloud agency 202 and cloud platform.In response, it is held on cloud agency 202 Capable live load service 514 is opened to the channel of cloud storage structure 316.Application configuration applied to live load service 514 508 can be arranged the attribute in channel.With for being arranged for serializing, encrypting and the application of user's defined parameters of compression service Configure it is 506 similar, can via the user interface or instrument board for allowing user to be arranged for the import of services or selection attribute come Application configuration 508 is applied to live load and services 514.For example, if cloud agency is communicated using REST with cloud platform, Then application configuration 508 can be used for being arranged by the attribute of the REST Application Programming Interface (API) of live load service creation.
In one or more embodiments, the communication channel between the workload service 514 and cloud platform of cloud agency 202 It can be by the agency of trademark registration table management in cloud.Fig. 8 is to manage the agent communication with the cloud platform of client using agency of trademark registration table Exemplary architecture block diagram.In this example, preset-type agency of trademark registration table 802 is present in identical cloud space with client's cloud, but It is to be present on individual registration table cloud.Registration table cloud and agency of trademark registration table 802 can be from providing to client by client's cloud platform Service provider as PaaS (service be platform) manages.Agency of trademark registration table 802 can reinforce the peace to client's cloud platform The full collection data for accessing and ensuring the client in cloud platform are only accessed by certified device and user.By new client's cloud When platform is established as a part for PaaS agreements, new client's cloud platform can be with subscription agent registration table 802 so that can pass through note Volume table carrys out the agent communication of control and new cloud platform.
Cloud agency 202 can be one of several clouds agency being distributed among the industrial enterprise of entire client.It is shown in Fig. 8 Example in, cloud agency 202 is identified as cloud agency 1, is distinguished so that the agency and other preset-types are acted on behalf of.Cloud agency 202 It is executed on computing device 808, which can be server, LINUX machines or other hardware platforms.Calculate dress Setting 808 has the physical address (for example, MAC Address or other physical address) for uniquely identifying computing device.Agency of trademark registration Table 802 stores the related to physical address (being 99-03-71-4B-LO-F 1 in this example) of computing device 808 of cloud agency 202 The record of connection so that the physical unit logical connection that cloud agency 1 executes on it with agency.Associated with cloud service provider Backup facility at system administration side 806 this between cloud agency 1 and the physical address of computing device 808 is associated with and is input to In agency of trademark registration table 802.System administration side 806 can also be inputted to be connected by the safety of the cloud platform of agency of trademark registration table management to client Connect the other configurations parameter that will be used.The configuration information of connection for administration agent to cloud platform may remain in registration table cloud On registration table storage device 804 in.
When cloud agency 202 is packaged compression data file as described above and is lined up and connector process 604 When notification agent analysis component 602 has completed data extraction, Agent Analysis component 602 can be sent out to agency of trademark registration table 802 Send license creation will act as cloud agency 202 and cloud platform between communication port cloud connector port request.The request can The specific client that it is connected to the physical address and request of mark, computing device 808 including such as cloud agency 1 is specific The mark of cloud platform.Agency of trademark registration table 802 will be used for agency to be granted or denied based on the information provided in proxy requests Establish the voucher in channel.For example, agency of trademark registration table 802 can receive from it this with reference to registration table storage device 804 to confirm The physical address of the computing device 808 of request is associated with the particular cloud of request channel agency (cloud agency 1).By confirm from The computing device 808 of earlier registration receives the connection request for cloud agency 1, and agency of trademark registration table ensures cloud agency 1 by not The connection established to cloud platform is not used in the case of being suitably moved or copied into another physical unit.If not utilizing Cloud agency 1 is moved into different computing devices in the case that agency of trademark registration table 802 registers new equipment, then registration table will represent generation It manages to refuse any communication request from new equipment.
Determine that connection request effectively (is deposited based on the information and registration table received in the request in agency of trademark registration table 802 The earlier registration information for cloud agency 1 in storage device 804) when, agency of trademark registration table 802 will allow agency to open to client's cloud The voucher of the temporary communication channel of platform authorizes cloud agency 202.Therefore, 514 (for example, REST API) pipes are serviced by live load The cloud API of reason is established to the communication channel of cloud platform and compression data file is sent to cloud platform to carry out as above combining figure 3 described storage and processing.In one or more embodiments, live load service divides when creating channel to communication channel With deadline.Can by service provider via agency of trademark registration table 802 or by end user via applied in client The application configuration 508 of live load service define.In general, deadline, which will be set to more than, sends compressed data packets institute The expected duration needed.If compressed package is completed to cloud platform in cloud agency 202 before the deadline that have passed through channel Transmission, then when completing data transmission or when have passed through deadline, channel will be automatically closed.If cloud agency 202 Compressed data packets are all not yet completed until when have passed through deadline to the transmission of cloud platform, then cloud agency 202 can be in generation The reason request of registration table 802 executes other shake hands in the case of reactivating the channel to allow to complete data transmission.
Fig. 9 is the example agency for collecting data from preset-type commercial plant shown according to one or more embodiments The block diagram of framework.In this example, if from customer rs site equipment for drying and application 902 collect data, these devices and answer With including alerts database 902a, data history 902b, motor driver 902c and motor driver 902d, instant data service Device 902e and customer database 902f.Although these data sources include the set of a variety of different devices and application, to coming It can be executed from the collection and pretreatment of the data in these sources by generic service 904 (for example, service library).Generic service 904 May include for identification from its to retrieve the entity of the Data Position of data (for example, device, application, label, register etc.), For compress or preprocessed data and provide data to cloud agency message queueing layer 906 entity (such as above in association with Fig. 5 Cache layer 512 described in).The live load service 908 of cloud agency can also be encapsulated data concurrent using generic service 910 It send to cloud structure.The trunk of the broker architecture of 908 composition separation of message queueing layer 906 and live load service.
Due to cloud agency 202 by from data collection using 504 collect preset-type data be packaged into it is specific comprising client and Using the envelope of specific information, therefore compressed data packets transmit cloud mark and are stored in the manifest component of client (for example, inventory group Part 334) in appropriate inventory needed for parameter and data with manipulate, handle and/or routing compaction data file in include number According to.Figure 10 is the concept map of example manifest component 1002.In this example, the system list being maintained in manifest component 334 1004 may include to the link of application particular customer inventory.Client list may include label inventory 1006 and measurement inventory 1008.When acting on behalf of receiving compressed data packet (for example, compressed data packets 324 of Fig. 7) from cloud at cloud platform, data processing clothes Business 308 identifies measurement inventory appropriate using the information in the header 704 for being packaged in the packet and label inventory includes to handle Data in compression data file 412.Worker role (for example, worker role 332 of Fig. 3) loads identified measurement Then the data received are executed these measurement inventories and label inventory by inventory and label inventory.In general, measurement inventory mark It can be with logarithm according to this and can be for delivery to one be retrieved and executed using particular range, coefficient and threshold value for the program retrieved Or multiple general programs.Inventory is marked to identify the general program for being retrieved the maps data items in compression data file Defined in variable or label label title.
Figure 11 shows the example layer architecture 1100 according to the system list of one or more embodiments.In cloud platform The example system inventory 1116 being maintained in manifest component 334 can be organized into multiple levels.It can be in voip identifiers grade The individual client entity of each of other 1104 manifest components given a definition by access for handling preset-type data.Due to each visitor Family entity can operate multiple plant facilities or website, so for each voip identifiers in site identifier rank 1106 Node definition one or more site identifier node.For the website of each definition, identified at virtual support engineer (VSE) It accords with and defines one or more VSE nodes in rank 1108.Give a definition 1112 He of type of message rank in VSE identifiers rank 1108 Process identifier rank 1114.
Constitute system list logical architecture level describe collected from the various data sources of entire industrial enterprise it is pre- Set the hierarchical relationship between type industrial data group.It should be noted that the level for the example manifest described in Figure 11 and being included in compression number It is corresponded to according to the data field in the header 704 (referring to Fig. 7) of packet 324.Therefore, it acts on behalf of to send to cloud platform when preset-type cloud and compress When data packet, data processing service 308 in cloud platform using comprising information in the header come the layer architecture to inventory 1100 navigate with identify will to manifest component that the data included in compression data file 412 execute (measurement inventory with Mark inventory).
In the example depicted in fig. 11, when system based on cloud receives compressed data packets, measurement inventory 1102 is called. Measurement inventory 1102 defines the one or more measurements that can be executed to data (by the Process identifier of compressed data packet head Field identification), and especially define coefficient, threshold value and the range for each identified measurement.Each measurement (process) Corresponding to the general program being stored in association with manifest component 334 in cloud platform.
Which measurement is applied to the data received in order to determine, worker role 332 (referring to Fig. 3) uses header 704 voip identifiers, site identifier and VSE identifier fields come to the corresponding level of inventory level navigate with identify Label inventory 1110 appropriate.Mark the mark of inventory 1110 for will extremely carry out the maps data items in data file to data The label title of one or more measurements (process) of operation.Which process identifier label inventory 1110 also identifies to each mark Weighing-appliance of signing has ownership.By header 704 type of message and process identifier field mark by data execute it is specific into Journey.In this regard, system list can define multiple type of messages (for example, alarm, historical data, instant data etc.), and For each type of message of definition, one or more NameSpaces corresponding with given Process identifier are defined.NameSpace Pair be identified with the corresponding application that manifest component stores in association, the inventory component can by worker role 332 plus It carries and the data included in encapsulation of data file is executed.These application can specify data final destination (for example, Big data storage device, one or more specified client terminal devices, visualization application etc.), or may include will be to data The algorithm or calculation procedure of execution are to generate expected result (for example, net power calculating, efficiency calculation, power assurance calculating etc.).
By the framework, the worker role in cloud platform will be based on the client for receiving from it data and by compression number According to other data attributes of header identification of packet, (such as, customer facilities or website, data type are (for example, data with alert, history Data, instant data from commercial plant etc.), specified process or measurement etc.) load the number for being suitable for processing and receiving According to the inventory component of packet.By to being packaged with to including these before cloud transmission data in the data that factory floor is collected Client's particular model is effectively applied to the data and number of the context of the data in description factory level by attribute, cloud agency According to the relationship of other data item with entire enterprise.It is then possible to be utilized the information to beyond the clouds based on the number in large enterprise According to effect and it is user-defined processing and storage preference be properly manipulated and handle data.
Figure 12 to Figure 15 shows the various methods of one or more embodiments according to this subject application.Although in order to say Bright concise purpose and will herein shown in one or more methods be shown and described as a series of actions, it should be understood that simultaneously Recognize, this new invention is not limited by the sequence that acts because some actions can occur in a different order as needed and/ Or occur simultaneously with other actions of shown and description method herein.For example, it should be appreciated by those skilled in the art that and It recognizes, method can be represented as a series of correlated conditions or event such as in state diagram as an alternative.In addition, and being not required to All of the illustrated actions is wanted to realize according to this neoteric method.In addition, when different entities implement the different portions of these methods Timesharing, (one or more) interaction figure can indicate the methodology or method according to present disclosure.In addition, disclosed shows Two or more in example method can be realized in conjunction, to realize one or more features described herein or excellent Point.
Figure 12 is shown for using cloud broker architecture by the exemplary method 1200 of industrial data intake to cloud platform.Most Just, at 1202, the industrial data collected from one or more preset-type data sources is received in cloud Agency.For example, data source It can be the number that data are collected from one or more commercial plants (for example, industrial control unit (ICU), motor driver, telemetering equipment etc.) According to collection system.Cloud agency directly can also receive industry via the appropriate communication link to these devices from commercial plant itself Data.At 1204, industrial data is encrypted in cloud Agency and is compressed to generate compression data file.At 1206, From message queueing database retrieval customer rs site configuration information associated with cloud agency.For example, customer rs site configuration information can To include the associated voip identifiers of client entity associated with same industrial enterprise and have collected the specific work of data from it The associated site identifier of factory's facility, distribute to data priority (its can depend on send information type；Example Such as, data with alert, historical data, real time operation data etc.), the information convenient for being connected to needed for the particular cloud storage organization of client Or other such information.
At 1208, cloud agency is packaged to generate data packet the compression data file created at step 1204. Data packet is packaged into the header including being generated based on the customer rs site configuration information retrieved at step 1206 and believed by cloud agency Breath.For example, header information may include message queue in the cloud platform for specify at least industrial data to be sent to and answer The information of manifest component for the industrial data in cloud platform.At 1210, starts the communication from cloud agency to cloud platform and believe Road.At 1212, the data packet including header is sent to cloud platform via communication channel.Data processing service in cloud platform It places data into based in the selected priority query of header information and using identified manifest component and handle number According to.
Figure 13 is shown for collecting data from industrial enterprise and using cloud agency service to cloud platform transmission data Illustrative methods 1300.Initially, at 1302, it is specific with client to be directed to that instruction resides in the agency's foundation of the cloud in industrial enterprise Handle and provided to cloud platform the communication of industrial data, newly added data source.At 1304, the public information of cloud agency is drawn It holds up and Agent Analysis component is instantiated to manage the new connection between cloud agency and new data source.At 1306, agency Analysis component calls new connector process for the new data source.Connector process by public information engine implementation, and The special perform script that service interface including creating and managing destination adapter associated with new data source connects.It is public Co-information engine can create connector process come the spy for supporting the destination adapter (for example, CIP, OLE etc.) of data source to use Determine communication protocol.
At 1308, connector process creation acts on behalf of the first communication channel to the communication port of new data source from cloud. At 1310, connector process start from data source extraction industrial data (for example, data with alert, historical data, field device or Process data etc.).At 1312, by acted on behalf of in cloud the queue processing service executed by client's particular header Information application in The data extracted are to generate compressed data packets.At 1314, Agent Analysis component, which starts to create on cloud agency, serves as cloud generation The cloud connector port of the second communication channel between reason and cloud platform.At 1316, number will be compressed via the second communication channel It is sent to cloud platform according to packet.
Figure 14 is shown for cloud agent security to be connected to the example of cloud platform by shaking hands with agency of trademark registration table Method 1400.Initially, at 1402, the connector process creation of cloud agency is acted on behalf of from cloud to the work for including cloud platform to be sent to The first communication channel of the communication port of the data source of industry data.At 1404, connector process starts to believe via the first communication Industrial data is extracted from data source in road.At 1406, by client's particular header Information application in the data extracted to generate pressure Contracting data packet.
At 1408, license creation cloud is acted on behalf of to the request of the communication channel between cloud platform it is sent to from cloud agency and stayed Stay in the agency of trademark registration table on registration table cloud.The request can include at least the identifier of cloud agency and cloud agency is resident on it And the device identification of the physical unit executed.For example, device identification can be device MAC Address or other physically Location.
At 1410, determine about whether from agency of trademark registration table receive instruction authorize for agency establish communication channel License voucher.If not yet receiving voucher, this method moves to step 1412, in step 1412, refusal cloud agency It accesses cloud platform and does not establish communication channel between cloud agency and cloud platform.As an alternative, if receiving voucher, method Move to step 1414, in step 1414, cloud agency Agent Analysis component start cloud agency on create serve as cloud agency with The cloud connector port of the second communication channel between cloud platform.At 1416, via the second communication channel by compressed data packets It is sent to cloud.
Figure 15 shows the exemplary method to the secure access of the specific cloud platform of client in cloud broker architecture for control 1500.Initially, at 1502, cloud subscription information is received at the agency of trademark registration table on residing in registration table cloud.Cloud subscription information It is related to the specific cloud platform of client that the control to cloud platform for the ease of safety is accessed and registered to agency of trademark registration table. At 1504, the specific cloud platform of client is registered in agency of trademark registration table based on cloud subscription information.
At 1506, cloud agency of trademark registration information is received at agency of trademark registration table.Cloud agency of trademark registration information can be by registration table The administrator of cloud provides, and can include at least cloud agent identifier and dispose the physics of identified cloud agency on it The device identification of device.At 1508, based on cloud agency of trademark registration information come with device identification in association to agency of trademark registration Table registers cloud agent identifier.
At 1510, is acted on behalf of from cloud at agency of trademark registration table and receive license creation to the communication channel of the specific cloud platform of client Request.At 1512, whether carry out about the cloud agent identifier being included in the request by pre-registered determination (example Such as, using the method summarized in step 1506 to step 1508).If had not yet registered including cloud Agent ID in the request, Method moves to step 1514, in step 1514, refuses cloud proxy access cloud platform.As an alternative, if to agency of trademark registration table Registration includes cloud Agent ID in the request, then carried out at 1516 about including device ID in the request whether with same agency note The associated device identification matching of cloud agent identifier in volume table.If acted on behalf of with cloud including device ID in the request Device identification that identifier is registered in association mismatch (Indicated Cloud agency be mounted on it is registered for cloud agency On the different physical unit of physical unit), then method moves to step 1514, and in step 1514, refusal cloud proxy access cloud is flat Platform.As an alternative, if including the device identification matching that device ID in the request is registered together with same cloud agent identifier, Method moves to step 1518, in step 1518, will permit cloud agency creates to the voucher of the communication channel of cloud platform to be sent to Cloud is acted on behalf of.
Embodiments described herein, system and component and the various aspects illustrated in the present specification can be executed Industrial control system and industrial automation environment may include computer or network components, can such as be handed on network It is mutual server, client, programmable logic controller (PLC) (PLC), automation controller, communication module, mobile computer, wireless Component, control unit etc..Computer and server include the one or more for being configured to execute the instruction of storage in the medium Processor (electronic integrated circuit that logical operation is executed using electronic signal), the medium such as random access memory (RAM), read-only memory (ROM), hard disk drive and removable memory device, may include memory stick, storage card, Flash drive, external fixed disk drive etc..
Similarly, term PLC or automation controller used herein may include can with multiple components, system and/ Or the function of being shared between network.As an example, one or more PLC or automation controller can by network with it is each The communication of kind network equipment and cooperation.This can generally comprise via the network including control, automation, and/or public network into Row communication any kind of controller, communication module, computer, input/output (I/O) device, sensor, actuator, with And man-machine interface (HMI).PLC or automation controller can also communicate and control these devices with following various other devices, Such as standard or load rated safety I/O modules (including simulation, number, programming/intelligence I/O modules), are led to other programmable controllers Believe module, sensor, actuator, output device etc..
Network may include such as the public network of internet, Intranet and such as including facility network, control net and with The too automated network of the control of net/IP and information protocol (CIP) network.Other networks include Ethernet, DH/DH+, remote I/ O, fieldbus, Modbus, Profibus, CAN (controller zone network), wireless network, serial protocol etc..In addition, network Device may include various possible (hardware and/or software component).These include with lower component, such as with virtual LAN (VLAN) interchanger, LAN, WAN of ability, proxy server (proxy), gateway, router, fire wall, Virtual Private Network (VPN) device, server, client computer, computer, configuration tool, monitoring instrument and/or other devices.
In order to provide published subject various aspects situation, Figure 16 and Figure 17 and following discussion are intended to provide can be with Realize the brief general description of the appropriate environment of the various aspects of published subject.
Referring to Fig.1 6, the example context 1610 for realizing the various aspects of above-mentioned theme includes computer 1612.It calculates Machine 1612 includes processing unit 1614, system storage 1616 and system bus 1618.System bus 1618 (wraps system unit Include but be not limited to system storage 1616) it is coupled to processing unit 1614.Processing unit 1614 can be it is various can be available Any one of processor.Multi-core microprocessor or other microprocessor architecture designs can also be used as processing unit 1614.
System bus 1618 can be using in any various types using several bus structures of bus architecture Any, which includes that memory bus or Memory Controller, peripheral bus or external bus and/or part are total Line.The bus architecture includes but not limited to 8 BITBUS networks, Industry Standard Architecture (ISA), Micro Channel Architecture (MSA), extension ISA (EISA), Intelligent Drive Electronics (IDE), VESA local bus (VLB), peripheral parts interconnected (PCI), universal serial bus (USB), advanced graphics port (AGP), Personal Computer Memory Card International Association bus (PCMCIA) and miniature computer System interface (SCSI).
System storage 1616 includes volatile memory 1620 and nonvolatile memory 1622.Including such as starting The basic input/output (BIOS) that the basic routine of information is transmitted between element of the period in computer 1612 is stored in In nonvolatile memory 1622.Unrestricted as illustration, nonvolatile memory 1622 may include read-only memory (ROM), programming ROM (PROM), electrically programmable ROM (EPROM), electric erasable PROM (EEPROM) or flash memory.Easily The property lost memory 1620 includes the random access memory (RAM) for serving as external cache.As illustration rather than limit System, RAM can be obtained in a variety of forms, such as synchronous random access memory (SRAM), dynamic ram (DRAM), synchronous dram (SDRAM), double number According to rate SDRAM (DDR SDRAM), enhanced SDRAM (ESDRAM), synchronization link DRAM (SLDRAM) and Direct-type RamBus RAM(DRRAM)。
Computer 1612 further includes moving/non-removable, volatibility/non-volatile computer storage media.Figure 16 shows Such as disk storage device 1624 is gone out.Disk storage device 1624 includes but not limited to following device：Disc driver, floppy disk Driver, tape drive, Jaz drivers, Zip drive, LS-100 drivers, flash memory card or memory stick.In addition, magnetic Disc memory device 1624 may include the storage medium combined individually or with other storage mediums, other storage mediums include but It is not limited to CD drive, such as compact disk ROM device (CD-ROM), CD can record driver (CD-R drive), CD can be weighed Write driver (CD-RW drive) or digital versatile disc ROM drive (DVD-ROM).For the ease of disk storage device 1624 It is connected to system bus 1618, usually using removable or immovable interface, such as interface 1626.
It is provided in user and the basic computer described in operating environment 1610 appropriate it should be understood that Figure 16 is described The software of medium is served as between source.Such software includes operating system 1628.It can be stored on disk storage device 1624 Operating system 1628 be used to controlling and distributing the resource of computer 1612.System is utilized using 1630 is led to by operating system 1628 It crosses and is stored in program module 1632 in system storage 1616 or on disk storage device 1624 and program data 1634 to money The management in source.It should be understood that one or more embodiments of present disclosure can utilize various operating systems or operation system The combination of system is realized.
User will be ordered by (one or more) input unit 1636 or information input is to computer 1612.Input unit 1636 include but not limited to instruction device, such as mouse, tracking ball, stylus, touch tablet, keyboard, microphone, control stick, game Pad, satellite disk (satellite dish), scanner, TV tuner cards, digital camera, DV, web camera etc..This A little and other input units are connected to processing unit by system bus 1618 via (one or more) interface port 1638 1614.(one or more) interface port 1638 includes that such as serial port, parallel port, game port and general serial are total Line (USB).(one or more) output device 1640 uses some ports in same type of port to be used as (one or more It is a) input unit 1636.Thus, for example, USB port can be used for providing input to computer 1612, and from computer 1612 to 1640 output information of output device.O adapter 1642 is provided, to show the output in addition to needing special adapter Device 1640 is outer, and there is also some output devices 1640 of such as display, loud speaker and printer etc..As an example, not a limit, O adapter 1642 includes the video card and sound card for providing the connection means between output device 1640 and system bus 1618. It should be noted that the system of other devices and/or device provides both input capability and fan-out capability, such as (one or more) Remote computer 1644.
Computer 1612 can be used to one or more remote computer (such as (one or more) remote computers 1644) logical connection is operated in a network environment.(one or more) remote computer 1644 can be personal meter Calculation machine, server, router, network PC, work station, the equipment based on microprocessor, peer device or other universal network sections Point etc., and generally include many or all in the element described about computer 1612.For purposes of brevity, for (one or more) remote computer 1644, illustrates only memory storage 1646.(one or more) remote computer 1644 are logically connected to computer 1612 by network interface 1648, then, are physically connected via communication connection 1650.Net Network interface 1648 includes communication network, such as LAN (LAN) and wide area network (WAN).Lan technology includes fiber distributed data Interface (FDDI), copper distributed data interface (CDDI), Ethernet/IEEE 802.3, token ring/IEEE 802.5 etc..WAN skills Art includes but not limited to point-to-point link, such as Circuit Switching Network, the packet switch of ISDN (ISDN) and its modification Net and Digital Subscriber Line (DSL).
(one or more) communication connection 1650, which is directed to network interface 1648 being connected to system bus 1618, is adopted Hardware/software.Although showing communication connection 1650 inside computer 1612 for clear explanation, it also may be used With outside computer 1612.Merely for the purpose of citing, it includes inside that required hardware/software is connect with network interface 1648 And exterior technology, such as include the modulatedemodulate of regular telephone grade modem, cable modem and DSL modem Adjust device, ISDN adapters and Ethernet card.
Figure 17 is the schematic block diagram for the example computing device 1700 that can be interacted with published subject.Example computing device 1700 include one or more clients 1702.(one or more) client 1702 can be hardware and/or software (for example, Thread, process, computing device).Example computing device 1700 further includes one or more servers 1704.Server 1704 also may be used To be hardware and/or software (for example, thread, process, computing device).For example, (one or more) server 1704 can hold Thread is set to execute conversion by using one or more embodiments described herein.Client 1702 and server 1704 Between a kind of possible communication can be adapted for the form of the data packet transmitted between two or more computer processes. Example computing device 1700 includes communications framework 1706, can be used for convenient for (one or more) client 1702 and (one Or multiple) communication between server 1704.(one or more) client 1702 is operably coupled to one or more visitors Family end data storage device 1708, the client data store 1708 can be used for storing (one or more) client 1702 local information.Similarly, (one or more) server 1704 is operably coupled to one or more server counts According to storage device 1710, server data store 1710 can be used for the local information of storage server 1704.
The above includes the example of the present invention.It is, of course, not possible to describe component to describe disclosed theme Or the combination that each of method is contemplated that, however, those skilled in the art will recognize, of the invention is very much In addition combination and displacement is all possible.Thus, disclosed theme be intended to include fall into appended claims spirit and All such changes in range, modifications and variations.
Specifically, about the various functions by execution such as above-mentioned component, device, circuit, systems, for describing such portion The term (including being related to " means ") of part unless otherwise noted, is otherwise intended to correspond to appointing for the specified function of executing the component Meaning component (for example, function is equivalent), even if being not equal to execute the exemplary side shown in this article for being disclosed theme in structure The disclosed structure of function in face.In this regard, it will also be recognized that disclosed theme include system and with calculate The computer-readable medium of machine executable instruction, these computer executable instructions are used to execute the various sides of disclosed theme The action of method and/or event.
In addition, although the specific features of disclosed theme may be disclosed for a kind of realization in several realizations, But by such feature and can be the one of other desired and advantageous realization methods for any given or specific application A or multiple other features combinations.In addition, " including with regard to the term used in specific implementation mode or claim (includes/including) " and its for variant, these terms using with it is similar as term " including (comprising) " As mode mean be included (inclusive).
In this application, word is " exemplary " for referring to as example, the meaning of example or illustration.Here depicted as Any aspect or design of " exemplary " are not necessarily to be interpreted that compared to other aspects or design be preferred or advantageous 's.On the contrary, the use of word " exemplary " is intended to that concept is presented in a concrete fashion.
Various aspects and feature described herein may be implemented as method, equipment or using standard program and/or The product of engineering technology.Term " product " used herein be intended to include can be from arbitrary computer readable device, carrier Or the computer program of medium access.For example, computer-readable medium can include but is not limited to magnetic memory apparatus (for example, hard Disk, floppy disk, magnetic stripe ...), CD (for example, compact disk (CD), digital versatile disc (DVD) ...), smart card and flash memory device (example Such as, card, item, key drive ...).
1. a kind of cloud agent apparatus, including：
Memory, storage computer can perform component；
Processor, is operationally couple to the memory, and the processor executes the computer and can perform component, the meter Calculation machine can perform component：
Service Part is collected, is configured to receive industrial data from the source devices of industrial enterprise, and to the industrial data It is compressed to generate compression data file；And
Queue processing component is configured to use report based on the message queueing information being maintained in message queueing data storage device Header is packaged the compression data file to generate compressed data packets, and the compressed data packets are sent to cloud and are put down Platform, wherein the message queueing information includes at least voip identifiers associated with the industrial enterprise and specifies the work The precedence information of the processing priority of industry data, wherein the queue processing component is further configured to inventory being uploaded to institute Cloud platform is stated, the inventory defines for the respective priority queue configured in the cloud platform and in the cloud platform The peculiar preference of the relevant client of processing of data that are that place receives and being assigned to the priority query, and the client Peculiar preference at least defined for respective priority queue the processing priority of the data, the upload frequencies of the data and Data will be route or be stored in the position in cloud storage device,
The industrial data included in the compressed data packets is assigned to based on included in the compressed data packets The header information and the priority query selected, and the data processing service by being executed in the cloud platform according to The inventory is handled to generate treated data, and
Treated that data are transferred to client terminal device in a defined format by described for report services component in the cloud platform.
2. cloud agent apparatus according to claim 1, wherein the precedence information defines multiple processing priorities and will The multiple processing priority is associated with corresponding data type.
3. cloud agent apparatus according to claim 2, wherein the data type include data with alert, historical data or At least one of instant data.
4. cloud agent apparatus according to claim 1, wherein the header information includes at least one of the following：Visitor Family identifier, Virtual Service engineer identifier, the precedence information, refers to site identifier associated with plant facilities The message type identifier or instruction for showing the type of the industrial data will be to the types for the processing that the industrial data executes Manipulation designator.
5. cloud agent apparatus according to claim 1 comprising information in the header information correspond to will be by The data processing service in the cloud platform is retrieved and is executed to the industrial data included in the compression data file The inventory subset mark.
6. cloud agent apparatus according to claim 1, wherein the queue processing component is further configured in response to described The generation of compressed data packets and be sent to request data resides in the agency of trademark registration device in registration cloud platform, and wherein, The request data includes the cloud agent identifier for identifying the queue processing component and the device for identifying the cloud agent apparatus Identifier.
7. cloud agent apparatus according to claim 6, wherein the queue processing component is further configured in response to coming The communication channel with the cloud platform is created from the reception of the Credential data of the agency of trademark registration device, the Credential data refers to Show that the license queue processing component exchanges data with the cloud platform.
8. cloud agent apparatus according to claim 1, wherein the message queueing information further includes allowing through the cloud Agent apparatus accesses the security setting of the cloud platform.
9. cloud agent apparatus according to claim 1, further includes interface unit, the interface unit is configured to receive and set The configuration input of at least one parameter of one or more of the collection Service Part or described queue processing component is set, In, at least one parameter includes at least one of the following：Will to the industrial data execute data compression type, It will cutting to the communication channel between the encrypted type of industrial data execution, the cloud agent apparatus and the cloud platform Only time or processing priority associated with specified data type.
10. cloud agent apparatus according to claim 1, wherein the queue processing component is further configured in response to true Fixed communication channel between the cloud agent apparatus and the cloud platform fails and the compressed data packets is stored in described deposit On reservoir, and is re-established in response to the determination communication channel and the compressed data packets are forwarded to the cloud and are put down Platform.
11. a kind of method for sending industrial data to cloud platform, including：
Inventory is uploaded into the cloud platform by the cloud agent apparatus including at least one processor, wherein the inventory needle The respective priority queue configured in the cloud platform is defined and to being received at the cloud platform and assigned To the peculiar preference of the relevant client of processing of the data of the priority query, and the peculiar preference of the client is for corresponding excellent First grade queue and at least defining the processing priority of the data, the upload frequencies of the data and data will be route or be stored Position in cloud storage device；
The industrial data of the source devices from industrial enterprise is collected by the cloud agent apparatus；
The industrial data is compressed to generate compression data file by the cloud agent apparatus；
By the cloud agent apparatus based on the message queueing information being maintained in message queueing data storage device come by header Information is additional to the compression data file to generate compressed data packets, wherein the message queueing information includes at least and institute It states the associated voip identifiers of industrial enterprise and specifies the precedence information of the processing priority of the industrial data；And
The compressed data packets are sent to the cloud platform by the cloud agent apparatus, wherein described to send so that described The industrial data included in compressed data packets is by the data processing service that is executed in the cloud platform according to described clear It singly handles to generate treated data, and wherein, described treated that data are sent to client in a defined format End device.
12. according to the method for claim 11, further including：
Multiple processing priorities are defined with the precedence information；And
Associated data is stored in the message queueing data storage device, wherein the associated data makes the multiple place It is associated with corresponding data type to manage priority.
13. according to the method for claim 11, wherein it includes at least one in adding below to add the header information It is a：Voip identifiers, site identifier associated with plant facilities, Virtual Service engineer identifier, priority letter Cease, indicate the message type identifier of the type of the industrial data or the class of processing that instruction will execute the industrial data The manipulation designator of type.
14. according to the method for claim 11, wherein the header information mark will be by the number in the cloud platform The subset of the inventory according to processing service retrieval and to the industrial data execution included in the compression data file.
15. according to the method for claim 11, further including：In response to the compressed data packets generation and by request data The agency of trademark registration device being sent in registration cloud platform, wherein the request data includes that mark is filled in cloud agency It sets the cloud agent identifier of the cloud instance of agent of execution and identifies the hardware platform that the cloud instance of agent executes on it Device identification.
The Credential data from the agency of trademark registration device is received by the cloud agent apparatus；And
In response to receiving the Credential data, the communication channel with the cloud platform is established by the cloud agent apparatus.
17. a kind of non-transitory computer-readable medium, the non-transitory computer-readable medium is stored with instruction, and described instruction is rung Should be in execution and so that the cloud agent apparatus for including processor execute operation, the operation includes：
Inventory is uploaded into cloud platform, wherein the inventory be directed to the respective priority queue that is configured in the cloud platform and It defines and the relevant client of processing to data that are being received at the cloud platform and being assigned to the priority query Peculiar preference, and the processing that the peculiar preference of the client at least defines the data for respective priority queue is preferential Grade, the upload frequencies of the data and data will be route or are stored in the position in cloud storage device；
Industrial data is received from source devices associated with industrial enterprise；
The industrial data is compressed to generate compression data file；
Based on the type of the industrial data come with the header information retrieved from message queueing storage device to the compressed data File is packaged to generate compressed data packets, wherein the header information includes at least associated with the industrial enterprise The precedence information of voip identifiers and the processing priority of the specified industrial data；And
The compressed data packets are sent to the cloud platform, wherein described to send so that included in the compressed data packets The industrial data handled according to the inventory to generate processing by the data processing service that is executed in the cloud platform Data afterwards, and wherein, described treated that data are sent to client terminal device in a defined format.
18. non-transitory computer-readable medium according to claim 17, further includes：
Request data is sent to the agency of trademark registration executed in registration cloud platform in response to the generation of the compressed data packets Device, wherein the request data includes identifying the cloud agent identification of the cloud instance of agent executed on the cloud agent apparatus The device identification for the hardware platform that symbol and mark cloud instance of agent execute on it；And
In response to receiving Credential data from the agency of trademark registration device, the communication channel with the cloud platform is established.
CN201510135130.0A 2014-03-26 2015-03-26 The preset-type data collection acted on behalf of using industrial cloud and intake CN104950836B (en)
US61/970,798 2014-03-26
US14/525,131 2014-10-27
US14/525,131 US9838476B2 (en) 2014-03-26 2014-10-27 On-premise data collection and ingestion using industrial cloud agents
CN104950836A CN104950836A (en) 2015-09-30
CN104950836B true CN104950836B (en) 2018-08-31
ID=52824030
CN201510135130.0A CN104950836B (en) 2014-03-26 2015-03-26 The preset-type data collection acted on behalf of using industrial cloud and intake
US (2) US9838476B2 (en)
EP (1) EP2924573B1 (en)
CN (1) CN104950836B (en)
US20150317330A1 (en) * 2014-05-05 2015-11-05 Invensys Systems, Inc. Storing data to multiple storage location types in a distributed historization system
US20180314603A1 (en) * 2015-10-29 2018-11-01 Datto, Inc. Apparatuses, methods, and systems for storage and analysis of saas data and non-saas data for businesses and other organizations
CN105376335A (en) * 2015-12-15 2016-03-02 北京奇虎科技有限公司 Method and device for collection data uploading
EP3249481B1 (en) * 2016-05-25 2019-10-02 Siemens Aktiengesellschaft System, industrial controller and method configured to execute a closed loop control on data for cloud based applications
DE102016124350A1 (en) * 2016-12-14 2018-06-14 Codewrights Gmbh Method and system for monitoring a process automation system
DE102016124348A1 (en) * 2016-12-14 2018-06-14 Codewrights Gmbh System and microservice for monitoring a process automation system
CN109995782A (en) * 2019-03-31 2019-07-09 深圳联想懂的通信有限公司 A kind of information processing method, equipment, system and computer storage medium
JPWO2004077765A1 (en) * 2003-02-27 2006-06-08 富士通株式会社 Communication charge separation method and apparatus
US8577655B2 (en) 2008-06-26 2013-11-05 Siemens Product Lifecycle Management Software Inc. System and method for constructing virtual NC controllers for machine tool simulation
US8275653B2 (en) 2009-04-13 2012-09-25 Vardaman, Ltd. Industrial status viewer system and method
NZ586691A (en) 2010-07-08 2013-03-28 Greenbutton Ltd Method for estimating time required for a data processing job based on job parameters and known times for similar jobs
JP5899749B2 (en) 2011-09-27 2016-04-06 株式会社リコー Control system, control device, and control program
US9189210B2 (en) 2012-02-29 2015-11-17 Avaya Inc. Using source code generated from a data model file to generate a graphical user interface from objects in a database
JP5782468B2 (en) 2013-01-31 2015-09-24 日本瓦斯株式会社 Security inspection result automatic pass / fail judgment notification system and method
WO2014178920A2 (en) 2013-04-30 2014-11-06 Flood Monkey Inc. Intelligent electronic water flow regulation system
US20150316904A1 (en) 2014-05-01 2015-11-05 Rockwell Automation Technologies, Inc. Systems and methods for adjusting operations of an industrial automation system based on multiple data sources
WO2016018249A1 (en) 2014-07-29 2016-02-04 Hewlett-Packard Development Company, L.P. Processor monitoring of thermal degradation
US20160125487A1 (en) 2014-10-30 2016-05-05 Burton Energy Group Optimization of utility consumption for property
US9741230B2 (en) 2014-12-08 2017-08-22 Kabushiki Kaisha Toshiba Plant monitoring system, plant monitoring method, and program storage medium
US20160349140A1 (en) 2015-05-25 2016-12-01 Sassan Teymouri Methond and apparatus for water leak detection
US10302454B2 (en) 2016-02-15 2019-05-28 Olea Networks, Inc. Retrofit device and method of retrofitting a flow meter
US20180033087A1 (en) 2016-07-28 2018-02-01 Accenture Global Solutions Limited Connected devices for detecting and responding to events in an environment
US20180300639A1 (en) 2017-04-13 2018-10-18 Oracle International Corporation Novel autonomous artificially intelligent system to predict pipe leaks
WO2019032970A1 (en) 2017-08-10 2019-02-14 Panoramic Power Ltd. Identification of air leaks in a compressed air system using a plurality of current measurement sensors
2014-10-27 US US14/525,131 patent/US9838476B2/en active Active
2015-03-26 CN CN201510135130.0A patent/CN104950836B/en active IP Right Grant
2015-03-26 EP EP15160984.9A patent/EP2924573B1/en active Active
2017-10-27 US US15/795,512 patent/US10334048B2/en active Active
US9838476B2 (en) 2017-12-05
US10334048B2 (en) 2019-06-25
US20150281355A1 (en) 2015-10-01
US20180063244A1 (en) 2018-03-01
CN104950836A (en) 2015-09-30
EP2924573B1 (en) 2019-06-19
EP2924573A3 (en) 2016-08-03
EP2924573A2 (en) 2015-09-30
WO2013075297A1 (en) 2013-05-30 Remote real-time monitoring system based on cloud computing
2017-12-05 CB02 Change of applicant information