JP6907015B2 - Information processing systems, information processing devices, information processing methods, and programs - Google Patents

Description

The present invention relates to an information processing system, an information processing device, an information processing method, and a program.

Information about the environment inside and outside the building (for example, temperature and humidity, CO ₂ concentration, etc.), information about the amount of energy generated in the building (for example, amount of electricity, amount of heat, etc.), information about the physical behavior of the building, people inside the building. A system that collects information about the location of the building and information about the operating status of equipment in the building, analyzes and processes the collected information as appropriate, and performs the desired operation based on the information (hereinafter, There is an "information processing system in the facility"). Nowadays, it is common to install and operate an information processing system in such a facility in a building.

An information processing system in a facility is composed of terminal devices (devices) such as measuring devices (for example, sensors) and control devices, and a system that manages these various terminal devices to realize desired functions. .. For example, in the entry / exit management system described in Patent Document 1, the terminal device (reader / writer unit) that reads the information of the IC card held over and the system (IC card reader / writer main body) that realizes a desired function are inseparable. It is configured.

Japanese Patent No. 5207031

By the way, in an information processing system in a facility, the usable years of each terminal device and the usable years of the system that realizes a desired function may be different from each other. In particular, information processing systems in facilities are often realized by combining multiple devices, and in general, the technological progress and changes of the devices at each end and the system that realizes the desired function are independent of each other. move on. For example, when a terminal device with a relatively short usable life is replaced with a new device due to failure or deterioration over time, a system that realizes the desired function if it can be replaced with an equivalent device or a compatible device. There is no need to repair it. However, if it is not possible to replace the terminal device with an equivalent device or a compatible device due to changes in technology or legal system (for example, change of radio band), the desired function is realized. The system must be modified to work with new terminal terminals. If the technology or legal system changes significantly, there is a problem that the information processing system in the facility needs to be significantly renovated and the renovation cost increases.

In addition, in an information processing system in a facility, there are many cases where data used for a certain purpose can be used for other functions that are seemingly unrelated. For example, observation data such as temperature and humidity have already been acquired for air conditioning control, and observation data such as illuminance have already been acquired for lighting control, so these observation data should be diverted. If possible, the installation cost of new temperature sensors, humidity sensors, illuminance sensors, etc. in other functions can be reduced. However, if the diversion of observation data is not expected from the beginning of the construction of the information processing system in the facility, the data format etc. are often different between each function, and in order to divert the observation data, the observation data is used. You have to interpret and convert the data format. As the number of functions for diverting observation data increases, many modifications are required for the information processing system in the facility to interpret the observation data and convert the data format. There is a problem that major repairs are required and the repair cost increases, for example, many repairs are required to establish a route for distribution in the information processing system.

In view of the above problems, the present invention provides an information processing system, an information processing device, an information processing method, and a program capable of managing a wide variety of data in an integrated manner while suppressing the cost of system repair. The purpose.

The present invention has been made to solve the above problems, and one aspect of the present invention is an information processing system including a data conversion device and an information processing device, and the data conversion device is measured by measurement. a device identifier identifying the respective equipment for generating measurement data, the device type list storage unit that stores device type list is a list that associates the device type information indicating a type of the device, the device transmits The first data including the measurement data generated by the device and the device identifier corresponding to the device is acquired, and the device identifier included in the acquired first data is used as the first data. The device type list including the device type list is detected from the device type list storage unit , and the first data is acquired to indicate the device type information included in the detected device type list and the time when the first data is acquired. includes a first data converter for converting the second data and the time information, which is a data added to the first data, and a transmission unit transmitting the second data to the information processing apparatus, the information processing apparatus includes: the device type information, and a profile list storage unit for storing a profile list is a list that correlates profiles and the for-readable previous SL measurement data corresponding to the device type information, The acquisition unit for acquiring the second data transmitted from the data conversion device and the profile list including the device type information included in the second data are detected from the profile list storage unit and detected. The measurement data included in the first data in the second data is made readable by the profile included in the profile list, and the second data is divided into the readable measurement data and the second data. The information processing system is characterized by including a second data conversion unit that converts the device identifier included in the data, the acquisition time point information, and the device type information into a third data.

Further, one aspect of the present invention is the above-mentioned information processing system, wherein the first data conversion unit converts the first data into a second data in JSON format. ..

Further, one aspect of the present invention is the above-mentioned information processing system, wherein the transmission unit transmits the second data by a communication protocol based on MQTT.

Further, as an aspect of the present invention stores a device identifier for identifying each of the devices for generating measurement data by measuring, device type list which is a list that associates the device type information indicating a type of the device a device type list storage unit, the a measurement data the device has generated a first data to which the device transmits, to get the first data including the device identifier corresponding to the device was obtained The device type list including the device identifier included in the first data is detected from the device type list storage unit, and the first data is obtained with the device type information included in the detected device type list. a first data converter for converting the acquisition time information indicating the time when the first data has been acquired, the second data is data added to the first data, and the device type information, the device It includes a profile list storage unit that stores a profile list and profile for-readable previous SL measurement data corresponding to the type information is a list that associates, the device type information included in said second data The profile list is detected from the profile list storage unit, and the measurement data included in the first data in the second data is made readable by the profile included in the detected profile list, and the second data is read. A second data conversion unit that converts the data into the readable measurement data , the device identifier included in the second data, the acquisition time point information, and the third data including the device type information. It is an information processing apparatus characterized by being provided with.

The device as one aspect of the present invention, showing an information processing method by a computer, device type list storage unit, and a device identifier identifying the respective equipment for generating measurement data by measuring, the type of the device a device type list storage step of storing the device classification list is a list associating the type information, the measurement data first data converter is, that the apparatus a first data the device transmits the generated And the first data including the device identifier corresponding to the device is acquired, and the device type list including the device identifier included in the acquired first data is detected from the device type list storage unit. , the first data, and the device type information contained in the detected the device type list, and acquires the time information indicating the time of acquiring the first data, the data appended to the first data associating a first data conversion step of converting to a second data, the profile list storage unit, and the device type information, and a profile for-readable previous SL measurement data corresponding to the device type information The profile list storage step for storing the profile list, which is a list, and the second data conversion unit detect and detect the profile list including the device type information included in the second data from the profile list storage unit. wherein the measurement data the contained in the first data in the second data by the profile contained in the profile list and readable the measurement data, the second data, which is readable reduction was, the first an information processing method characterized by having the second data conversion step of converting the third data including said device identifier included in the second data and the acquired time information and the device type information.

Further, as an aspect of the present invention, the computer, and the device identifier identifying the respective equipment for generating measurement data by measuring, device classification list is a list that associates the device type information indicating a type of the device a device type list storage step of storing, obtains the the measurement data the first data is a by the device was produced in which the device transmits, the first data including the device identifier corresponding to the device , The device type list including the device identifier included in the acquired first data is detected from the device type list storage unit, and the first data is the device type included in the detected device type list. information, the first data conversion step of converting said acquisition time information indicating the time when the first data has been acquired, the second data is data added to the first data, and the device type information , a profile list storage step of storing the profile list profile and a list that associates to-readable previous SL measurement data corresponding to the device type information, the device type included in said second data The profile list containing information is detected from the profile list storage unit, and the measurement data included in the first data in the second data is made readable by the profile included in the detected profile list, and the measurement data is read. Second data conversion that converts the second data into the readable measurement data, the device identifier included in the second data, the acquisition time point information, and the third data including the device type information. It is a program to execute steps.

According to the present invention, it is possible to manage a wide variety of data in an integrated manner while suppressing the cost of repairing the system.

It is a schematic diagram which shows the outline of the structure of the facility information integrated utilization system which concerns on one Embodiment of this invention. It is a figure which shows an example of the data conversion processing by the gateway of the facility information integrated use system which concerns on one Embodiment of this invention. It is a figure which shows an example of the sensor type list stored in the gateway of the facility information integrated use system which concerns on one Embodiment of the invention. It is a block diagram which shows the functional structure of the gateway of the facility information integrated use system which concerns on one Embodiment of this invention. It is a block diagram which shows the functional structure of the information processing apparatus of the facility information integrated utilization system which concerns on one Embodiment of this invention. It is a figure which shows an example of the profile list stored in the information processing apparatus of the facility information integrated utilization system which concerns on one Embodiment of this invention. It is a flowchart which shows the operation of the gateway of the facility information integrated use system which concerns on one Embodiment of this invention. It is a flowchart which shows the operation of the information processing apparatus of the facility information integrated utilization system which concerns on one Embodiment of this invention.

Hereinafter, embodiments of the present invention will be described.
<Embodiment>
The information processing system described below according to the present embodiment includes various information in the facility (building), for example, data on the environment (temperature, humidity, etc.) inside and outside the facility, data on the position of people in the facility, and the facility. It is a facility information integrated utilization system that collects data related to the amount of activity of people in the facility, converts the collected data into a data format that can be used in various other systems, and stores it.

[Configuration of facility information integrated utilization system]
Hereinafter, the configuration of the facility information integrated utilization system 1 according to the present embodiment will be described with reference to the drawings.
FIG. 1 is a schematic view showing an outline of the configuration of the facility information integrated utilization system 1 according to the embodiment of the present invention. As shown in the figure, the facility information integrated utilization system 1 includes an information processing device 10 including a facility information integrated database 100, a gateway group including a gateway 20a and a gateway 20b, a temperature / humidity sensor 30a-1, a door sensor 30a-2, and the like. A group of sensor nodes including sensors for environmental measurement such as the lighting switch 30a-3, a group of sensor nodes including sensors for measuring activity such as the wearable terminal 30b, an existing monitoring and control system 40, and a terminal for visualization / analysis. It is composed of 50 and.

Further, as shown in the figure, the information processing apparatus 10 and the respective gateways 20a and 20b included in the gateway group are communicated and connected by a communication network 90. Further, each sensor 30 and one of the gateways 20a are communicated and connected by a communication network 91a, respectively. Further, each sensor 30 and the gateway 20b are communicated and connected by a communication network 91b, respectively. Further, the information processing device 10 and the existing monitoring and control system 40 are connected by a communication network 92. Further, the information processing device 10 and the visualization / analysis terminal 50 are communicated and connected by a communication network 93.

Hereinafter, when it is not necessary to distinguish between the gateway 20a and the gateway 20b, it may be simply described as "gateway 20". Further, hereinafter, when it is not necessary to particularly distinguish the temperature / humidity sensor 30a-1, the door sensor 30a-2, and the lighting switch 30a-3, it may be simply described as "sensor 30a". Further, hereinafter, when it is not necessary to particularly distinguish between the sensor 30a and the wearable terminal 30b, it may be simply described as "sensor 30". Further, hereinafter, when it is not necessary to particularly distinguish between the communication network 91a and the communication network 91b, it may be simply described as "communication network 91".

The information processing device 10 collects various data related to the facility (hereinafter referred to as "IoT (Internet of Things) log") transmitted from each gateway 20 via the communication network 90. The information processing device 10 interprets and stores the collected IoT log. The information processing device 10 includes a facility information integrated database 100 that stores IoT logs. The information processing device 10 includes a computer device having a server function, for example, a general-purpose computer, a personal computer, or the like. Since a large amount of data is registered in the facility information integrated database 100, the information processing device 10 includes a large-capacity storage device. The communication network 90 is composed of the Internet, various closed networks (for example, a dedicated line, VPN (Virtual Private Network), etc.), or a combination of communication networks thereof. The communication network 90 may be a wired communication network, or a part or all of it may be a wireless communication network.

Further, the information processing device 10 acquires various data related to the environment of the facility (hereinafter, referred to as "environmental data") transmitted from the existing monitoring and control system 40 via the communication network 92. The information processing device 10 interprets and stores the collected environmental data. The communication network 92 is composed of the Internet, various closed networks (for example, a leased line, VPN, etc.), or a combination of communication networks thereof. The communication network 92 may be a wired communication network, or a part or all of it may be a wireless communication network.

The gateway 20 transmits data (hereinafter, referred to as “device log”) including data measured by each sensor 30 (hereinafter, referred to as “measurement data”) transmitted from each sensor 30 to the communication network 91. Get through. The gateway 20 generates information (that is, the above-mentioned "IoT log") in which information necessary for the subsequent processing is added to the device log. Then, the gateway 20 transmits the generated IoT log to the information processing device 10 via the communication network 90. A plurality of gateways 20 are installed in the facility according to the number of sensors 30 and the distribution of installation positions of the sensors 30 in the facility.

As described above, the sensor node group including the sensor for environmental measurement includes the temperature / humidity sensor 30a-1, the door sensor 30a-2, and the lighting switch 30a-3. The temperature / humidity sensor 30a-1 is installed inside and outside the facility, and measures the temperature and humidity inside and outside the facility, respectively. The door sensor 30a-2 is installed on the door of the facility and detects the opening and closing of the door. The lighting switch 30a-3 is installed in the facility and detects the on / off of the lighting in the facility. Each sensor 30a transmits a device log to a specific gateway 20a via the communication network 91a.

As described above, the wearable terminal 30b is included in the sensor node group including the sensor for measuring the amount of activity. The wearable terminal 30b is a terminal device worn by a person (for example, on the wrist) in the facility, and measures an individual's activity amount (for example, pulse rate, step count, etc.). The wearable terminal 30b transmits the device log to the gateway 20b via the communication network 91b.

The communication between the sensor 30a and the gateway 20a performed via the communication network 91a and the communication between the wearable terminal 30b and the gateway 20b performed via the communication network 91b are, for example, short-range. It is done by wireless communication. Further, the sensor 30a is, for example, an environment measurement sensor using the EnOcean (registered trademark) technology, and communication is performed between the sensor 30a and the gateway 20a by a communication method based on the EnOcean technology. Further, the wearable terminal 30b includes, for example, a sensor for measuring the amount of activity based on the BLE (Bluetooth (registered trademark) Low Energy) standard (IEEE 802.5.1), and is a wearable terminal by a communication method based on the BLE standard. Communication is performed between the 30b and the gateway 20b.

The existing monitoring and control system 40 is a monitoring and control system already installed in the facility, and is a building that measures and manages temperature, humidity, illuminance, and the position of a person in the facility, and controls air conditioning and lighting. -Automation system (BAS). The existing monitoring and control system 40 transmits various data to be measured and managed to the information processing device 10 via the communication network 92.

The visualization / analysis terminal 50 is a terminal device that visualizes and analyzes the IoT log stored in the facility information integrated database 100 included in the information processing device 10. The visualization / analysis terminal 50 can access the facility information integrated database of the information processing device 10 via the communication network 93 and acquire a desired IoT log based on the operation of the operator. Then, the visualization / analysis terminal 50 can visualize and display the acquired IoT log and analyze the acquired IoT log based on the operation of the operator.
For example, the visualization / analysis terminal 50 displays the time history of measurement data based on the measurement by each sensor 30, displays the contour diagram based on the environmental data, displays the heat map diagram based on the data related to a large amount of IoT logs, and displays the heat map diagram. Data analysis by machine learning for IoT logs can be performed.

The visualization / analysis terminal 50 includes a computer device including a display, for example, a personal computer, a tablet-type small information terminal, and the like. The communication network 93 is composed of the Internet, various closed networks (for example, a leased line, VPN, etc.), or a combination of communication networks thereof. The communication network 93 may be a wired communication network, or a part or all of it may be a wireless communication network.

[Data conversion process by gateway]
Hereinafter, the data conversion process by the gateway 20 will be described with reference to the drawings.
FIG. 2 is a diagram showing an example of data conversion processing by the gateway 20 of the facility information integrated utilization system 1 according to the embodiment of the present invention.

As described above, the gateway 20 acquires the device log from the sensor 30. Further, the gateway 20 stores the date and time when the device log was acquired (hereinafter, referred to as “acquisition date and time”). The device log includes measurement data measured by the sensor 30 and a sensor ID (identifier) that identifies the sensor 30.
The gateway 20 stores in advance a sensor type list, which is a list in which the sensor ID and the sensor type indicating the type of the sensor 30 are associated with each other. The configuration of the sensor type list will be described later. The gateway 20 refers to the sensor type list and acquires the sensor type associated with the sensor ID included in the acquired device log.

Further, the gateway 20 is associated with a gateway ID that identifies the gateway 20 in advance.
The gateway 20 adds the gateway ID, the information indicating the acquisition date and time, and the information indicating the sensor type to the acquired device log to convert the device log into standard format data (that is, IoT log). Convert. Then, the gateway 20 adds an arbitrarily designated topic to the IoT log and transmits the IoT log to the information processing apparatus 10.

The above-mentioned standard format is, for example, a JSON (Javascript® Object Notation) format.

For example, as shown in FIG. 2, the gateway 20 transmits a device log including measurement data of “550007020a0a2104000bce08720149ed” and data of a value of “04000bce” indicating a sensor ID from the sensor 30. get.
The gateway 20 has the data of the value "gw01" indicating the gateway ID associated with its own gateway 20 with respect to the acquired device log, and "2016-07" indicating the acquisition date and time when the gateway 20 acquired the device log. "Temperature" indicating the sensor type associated (in the sensor type list) with the data of the value "-27 14:06:06" and the sensor ID value "04000 bce" included in the acquired device log. Generates a JSON format IoT log with the data of the value.

As illustrated in FIG. 2, for example, the IoT log generated by the above is "{" sensor_id ":" 04000bce "," timestamp ":" 2016-07-27 14:06:06 "," sensor_class ": The value data is "temperature", "gateway_id": "gw01", "data": "550007020a0a2104000bce08720149ed"} ".
The gateway 20 adds the data "topic = / building01 / 04 / swp / temp" indicating the topic to the IoT log, and transmits the data to the information processing apparatus 10.

[Sensor type list configuration]
Hereinafter, the configuration of the sensor type list stored in the gateway 20 will be described with reference to the drawings.
FIG. 3 is a diagram showing an example of a sensor type list stored in the gateway 20 of the facility information integrated utilization system 1 according to the embodiment of the invention. As shown in the figure, the sensor type list is two-dimensional tabular data composed of columns of two items, "sensor ID" and "sensor type". As shown in the figure, for example, a sensor ID having a value of "04000 bce" is associated with a data type having a value of "temperature", and a sensor ID having a value of "05000 cdf" is referred to as "illumination". The data type of the value is associated.

[Gateway function configuration]
Hereinafter, the functional configuration of the gateway 20 will be described with reference to the drawings.
FIG. 4 is a block diagram showing a functional configuration of the gateway 20 of the facility information integrated utilization system 1 according to the embodiment of the present invention. As shown in the figure, the gateway 20 (data conversion device) includes a sensor type list storage unit 200, a device log data acquisition unit 201, a data conversion unit 202, and an IoT log transmission unit 203.

The sensor type list storage unit 200 (device type list storage unit) is a sensor type list (device type list) that is a list in which the sensor 30 (device) and the sensor type (device type) indicating the type of the sensor 30 are associated with each other. Remember. The sensor type list storage unit 200 includes a storage medium, for example, an HDD (Hard Disk Drive), a flash memory, an EEPROM (Electrically Erasable Programmable Read Only Memory), a RAM (Random Access), and a RAM (Random Access). It consists of a possible memory), a ROM (Read Only Memory; read-only memory), or any combination of these storage media.

The device log data acquisition unit 201 is a communication interface for communicating with each sensor 30 via the communication network 91. The device log data acquisition unit 201 acquires the device log transmitted from each sensor 30 via the communication network 91. The device log data acquisition unit 201 outputs the acquired device log to the data conversion unit 202.

The data conversion unit 202 (first data conversion unit) acquires the device log (first data) output from the device log data acquisition unit 201, and uses the device log as a sensor ID (device) for identifying the sensor 30. Identifier), information indicating the time when the device log was acquired (acquisition time information), and sensor type information (device type) indicating the sensor type (device type) corresponding to the sensor 30 based on the sensor type list (device type list). (Type information) and is converted into an IoT log (second data) which is data added to the device log (first data).
The data conversion unit 202 outputs the above IoT log to the IoT log transmission unit 203.

The IoT log transmission unit 203 acquires the IoT log output from the data conversion unit 202. The IoT log transmission unit 203 adds data indicating a topic to the acquired IoT log, and transmits the IoT log and the data indicating the topic to the information processing device 10 via the communication network 90.

The IoT log transmission unit 203 transmits, for example, the IoT log and the data indicating the topic to the information processing apparatus 10 by a communication protocol based on MQTT (Message Queue Telemetry Transport).

[Functional configuration of information processing device]
Hereinafter, the functional configuration of the information processing apparatus 10 will be described with reference to the drawings.
FIG. 5 is a block diagram showing a functional configuration of the information processing device 10 of the facility information integrated utilization system 1 according to the embodiment of the present invention. As shown in the figure, the information processing apparatus 10 includes a facility information integrated database 100, a data collector group 110, and a broker 120.

The facility information integrated database 100 is a database that stores information based on the above-mentioned IoT log, and is open to an external system that uses the information. The information stored in the facility information integrated database 100 is provided (transmitted) to the external system via the communication network 93 in response to a request from the external system.
As illustrated in FIG. 5, the facility information integrated database 100 includes a time series database 101 and a text file 102.

The time-series database 101 is a database that stores a data group using the combination of the above-mentioned "acquisition date and time" and "sensor ID" as a primary key. The data group is a set of data (hereinafter, referred to as "facility information") in which the above-mentioned IoT log is data-converted by the data collector group 110 described later.
The text file 102 is a file in which a set of facility information stored in the time series database 101 is collectively described in a text format. The text file 102 is a file generated for backing up the facility information stored in the time series database 101 and for facilitating the collective use of the facility information by an external system.

The data collector group 110 is a software program group that operates in the information processing apparatus 10. The data collector group 110 includes a software program that periodically collects IoT logs, a software program that interprets data of IoT logs, a software program that converts data for IoT logs, and software that processes data for IoT logs. It includes a program and a software program that outputs an IoT log (that is, "facility information") that has undergone data conversion and data processing as appropriate in a format corresponding to the output destination API.
As shown in FIG. 5, the data collector group 110 includes a subscriber 111, a filter processing unit 112, a profile list storage unit 113, a database registration unit 114, a Raw data output unit 115, and an existing system data acquisition unit 116. And are configured to include.

Subscriber 111 requests broker 120 to acquire an IoT log associated with the desired topic. The subscriber 111 acquires the IoT log transmitted from the broker 120 and outputs it to the filter processing unit 112.
Note that, for example, when the broker 120 acquires an IoT log associated with a desired topic from the gateway 20, the subscriber 111 sends the IoT log to its own subscriber 111, so that the subscriber 111 sends the IoT log to the broker 120. Give instructions to (subscribe). As a result, the IoT log associated with the topic specified by the subscriber 111 is appropriately transmitted from the broker 120 to the subscriber 111.

The filter processing unit 112 (second data conversion unit) classifies the information (device type information) indicating the sensor type included in the IoT log (second data), and the sensor type (device) based on the information indicating the sensor type. The profile corresponding to the type) is acquired from the profile list stored in the profile list storage unit 113. The filter processing unit 112 makes the measurement data of the device log (first data) included in each IoT log readable according to the acquired profile, and makes the IoT log a device log including the readable measurement data and a sensor. It is converted into facility information (third data) which is data including an ID (device identifier), information indicating the acquisition date and time (acquisition time point information), and information indicating the sensor type. Then, the filter processing unit 112 outputs the facility information to the database registration unit 114 and the Raw data output unit 115.

The profile list storage unit 113 associates a sensor type (device type) with a profile for making the measurement data of the device log (first data) acquired from the sensor 30 corresponding to the sensor type readable. The profile list, which is a created list, is stored in advance. The structure of the profile list will be described later.
The profile list storage unit 113 is composed of a storage medium, for example, an HDD, a flash memory, an EEPROM, a RAM, a ROM, or any combination of these storage media.

The database registration unit 114 acquires the facility information output from the filter processing unit 112, and registers the facility information in the time series database 101.
The Raw data output unit 115 acquires the facility information output from the filter processing unit 112, and adds the facility information to the text file 102.

The existing system data acquisition unit 116 includes a communication interface for communicating with the existing monitoring and control system 40 via the communication network 92. The existing system data acquisition unit 116 periodically (for example, every 10 minutes) makes an inquiry to the existing monitoring and control system 40, and acquires the above-mentioned environmental data transmitted from the existing monitoring and control system 40. .. The existing system data acquisition unit 116 makes an inquiry by, for example, a communication protocol of HTTP (Hypertext Transfer Protocol). The existing system data acquisition unit 116 forms the acquired environmental data into a data format similar to the IoT log, and outputs the formed IoT log to the filter processing unit 112.

As a result, the filter processing unit 112 uses the same data format (that is, the IoT log data format) for the device log acquired from the sensor 30 via the gateway 20 and the environment data acquired from the existing monitoring and control system 40. ) Can be obtained and processed.
Further, as a result, the information processing apparatus 10 can manage the facility information based on the device log and the facility information based on the environmental data by one facility information integrated database.

The broker 120 (acquisition unit) acquires the IoT log (second data) transmitted from the IoT log transmission unit 203 of the gateway 20 (data conversion device) and the data indicating the topic via the communication network 90.
The broker 120 refers to a topic based on the acquired data, and if the topic is a topic specified (subscribed) by the subscriber 111, the subscriber displays the IoT log and data indicating the topic. Output to 111.

[Profile list configuration]
Hereinafter, the configuration of the profile list stored in the information processing apparatus 10 will be described with reference to the drawings.
FIG. 6 is a diagram showing an example of a profile list stored in the information processing device 10 of the facility information integrated utilization system 1 according to the embodiment of the present invention. As shown in the figure, the profile list is two-dimensional tabular data composed of columns of two items, "sensor type" and "profile". As shown in the figure, for example, a profile called "profile A" is associated with a sensor type with a value of "temperature", and a profile called "profile B" is associated with a sensor type with a value of "illumination". Are associated with each other.

[Gateway operation]
Hereinafter, the operation of the gateway 20 will be described with reference to the drawings.
FIG. 7 is a flowchart showing the operation of the gateway 20 of the facility information integrated utilization system 1 according to the embodiment of the present invention. This flowchart starts when the device log is transmitted from the sensor 30 to the gateway 20 via the communication network 91.

(Step S001) The device log data acquisition unit 201 of the gateway 20 acquires the device log transmitted from the sensor 30. Then, the process proceeds to step S002.
(Step S002) The device log data acquisition unit 201 of the gateway 20 records information indicating an acquisition date and time, which is the acquisition date and time of the device log acquisition. The device log data acquisition unit 201 outputs the device log to the data conversion unit 202 together with the information indicating the acquisition date and time. After that, the process proceeds to step S003.

(Step S003) The data conversion unit 202 of the gateway 20 searches the sensor type list stored in the sensor type list storage unit 200 using the sensor ID included in the acquired device log as a search key. Then, the process proceeds to step S004.
(Step S004) If the same sensor ID as the sensor ID included in the device log acquired by the gateway 20 exists in the sensor type list, the process proceeds to step S005. If not, the processing of this flowchart ends.

(Step S005) The data conversion unit 202 of the gateway 20 acquires information indicating the sensor type associated with the sensor ID included in the acquired device log from the sensor type list. Then, the process proceeds to step S006.

(Step S006) The data conversion unit 202 of the gateway 20 adds the gateway ID, the information indicating the acquisition date and time, and the information indicating the sensor type to the acquired device log to format the device log in a standard format. Data (that is, IoT log) is converted. Then, the gateway 20 assigns an arbitrarily designated topic to the IoT log. Then, the process proceeds to step S007.

(Step S007) The data conversion unit 202 of the gateway 20 outputs the IoT log to which the topic is added to the IoT log transmission unit 203. Then, the IoT log transmission unit 203 transmits the IoT log to which the topic is assigned to the information processing device 10 via the communication network 90.
This completes the processing of this flowchart.

[Operation of information processing device]
Hereinafter, the operation of the information processing apparatus 10 will be described with reference to the drawings.
FIG. 8 is a flowchart showing the operation of the information processing device 10 of the facility information integrated utilization system 1 according to the embodiment of the present invention. This flowchart starts when the subscriber 111 of the information processing apparatus 10 specifies a topic (subscribes) to the broker 120.

(Step S101) The subscriber 111 of the information processing apparatus 10 transmits information indicating a designated (subscription application) topic to the broker 120. The broker 120 stores information indicating the acquired topic. Then, the process proceeds to step S102.
(Step S102) When the broker 120 of the information processing device 10 acquires the IoT log transmitted from the gateway 20 via the communication network 90, the process proceeds to step S103. If not, it stays in step S102.

(Step S103) If the topic assigned to the IoT log acquired by the broker 120 of the information processing apparatus 10 is a topic based on the information specified (subscribed) by the subscriber 111 in step S101, step S104 Proceed to. If not, the process returns to step S102.
(Step S104) The broker 120 of the information processing device 10 outputs the IoT log to the subscriber 111. The subscriber 111 outputs the IoT log output from the broker 120 to the filter processing unit 112. The filter processing unit 112 classifies the sensor type based on the information indicating the sensor type included in the IoT log output from the subscriber 111. Then, the process proceeds to step S105.

(Step S105) The filter processing unit 112 of the information processing apparatus 10 searches the profile list stored in the profile list storage unit 113 using the sensor type classified in step S104 as a search key. Then, the process proceeds to step S106.
(Step S106) If the profile list contains information indicating the same sensor type as the sensor type classified in step S104, the process proceeds to step S107. If not, the process proceeds to step S110.

(Step S107) The filter processing unit 112 of the information processing apparatus 10 acquires a profile corresponding to the sensor type classified in step S104 from the profile list. Then, the process proceeds to step S108.

(Step S108) The filter processing unit 112 of the information processing apparatus 10 makes the measurement data of the device log included in the IoT log readable by the profile acquired in step S107. Then, the filter processing unit 112 converts the IoT log into facility information which is data including a device log including the readable measurement data, a sensor ID, information indicating the acquisition date and time, and information indicating the sensor type. Then, the filter processing unit 112 outputs the facility information to the database registration unit 114 and the Raw data output unit 115. After that, the process proceeds to step S109.

(Step S109) The database registration unit 114 of the information processing apparatus 10 acquires the facility information output from the filter processing unit 112 in step S108, and registers the facility information in the time series database 101. Further, the Raw data output unit 115 acquires the facility information output from the filter processing unit 112 in step S108, and adds the facility information to the text file 102. Then, the process proceeds to step S110.

(Step S110) If information indicating that the designation (subscription) of the topic specified in step S101 (subscription application) is terminated is transmitted from the subscriber 111 of the information processing apparatus 10 to the flowchart 120, the present invention is used. Flowchart processing ends. If not, the process returns to step S102.

As described above, the facility information integrated utilization system 1 according to the present embodiment uses the device log acquired from each sensor 30 and the environmental data acquired from the existing monitoring and control system 40 in a common data format (for example, JSON). Data is converted to facility information in format) and stored. Further, since the facility information integrated utilization system 1 converts the acquired data into facility information in which the acquisition date and time of the data and the sensor ID are added, each data is unique depending on the data acquisition date and time and the sensor ID. Can be identified.
As a result, the facility information integrated utilization system 1 will be distributed even if it is not possible to replace the terminal equipment with an equivalent equipment or a compatible equipment due to changes in technology, legal system, etc. By converting the data to a common data format, it is not necessary to make major modifications to the information processing system in the facility, and it is possible to manage a wide variety of data in an integrated manner while suppressing the system modification costs. ..
In addition, as a result, the facility information integrated utilization system 1 makes the data distributed between each function into a common data format even when the diversion of observation data is not expected from the beginning of the construction of the information processing system in the facility. By data conversion, it is not necessary to make many modifications to interpret the observation data and convert the data format so that the observation data can be diverted to the information processing system in the facility, and the system modification cost It is possible to manage a wide variety of data in an integrated manner while suppressing the amount of data.

Further, since the facility information integrated utilization system 1 according to the present embodiment performs processing by a data collector group in which a data collector which is a modular processing is combined, it can correspond to processing for various purposes. Further, as a result, the facility information integrated utilization system 1 can easily add or customize modules for processing for new uses.

Further, since the facility information integrated utilization system 1 according to the present embodiment executes the use of data (visualization, analysis, etc.) on the client side, new visualization algorithms and expression methods can be freely separated from the restrictions of system management. It is possible to introduce it to the system, diversify the user interface, and individualize and decentralize the computational resources by a large number of clients.

Although the embodiments of the present invention have been described in detail above, the specific configuration is not limited to the above, and various design changes and the like can be made without departing from the gist of the present invention. be.

In addition, a part or all of the facility information integrated utilization system 1 in the above-described embodiment may be realized by a computer. In that case, the program for realizing this control function may be recorded on a computer-readable recording medium, and the program recorded on the recording medium may be read by the computer system and executed.

The "computer system" referred to here is a computer system built in the facility information integrated utilization system 1, and includes hardware such as an OS and peripheral devices. Further, the "computer-readable recording medium" refers to a portable medium such as a flexible disk, a magneto-optical disk, a ROM, or a CD-ROM, or a storage device such as a hard disk built in a computer system.

Furthermore, a "computer-readable recording medium" is a medium that dynamically holds a program for a short period of time, such as a communication line when a program is transmitted via a network such as the Internet or a communication line such as a telephone line. In that case, a program may be held for a certain period of time, such as a volatile memory inside a computer system serving as a server or a client. Further, the above-mentioned program may be a program for realizing a part of the above-mentioned functions, and may be a program for realizing the above-mentioned functions in combination with a program already recorded in the computer system.

Further, the facility information integrated utilization system 1 in the above-described embodiment may be realized as an integrated circuit such as an LSI (Large Scale Integration). Each functional block of the facility information integrated utilization system 1 may be individually made into a processor, or a part or all of them may be integrated into a processor. Further, the method of making an integrated circuit is not limited to LSI, and may be realized by a dedicated circuit or a general-purpose processor. Further, when an integrated circuit technology that replaces an LSI appears due to advances in semiconductor technology, an integrated circuit based on this technology may be used.

1 ... Facility information integrated utilization system, 10 ... Information processing device, 20 ... Gateway, 30 ... Sensor, 40 ... Existing monitoring and control system, 50 ... Visualization / analysis terminal, 90・ ・ ・ Communication network, 91 ・ ・ ・ Communication network, 92 ・ ・ ・ Communication network, 93 ・ ・ ・ Communication network, 100 ・ ・ ・ Facility information integrated database, 101 ・ ・ ・ Time series database, 102 ・ ・ ・ Text file , 110 ... Data collector group, 111 ... Subscriber, 112 ... Filter processing unit, 113 ... Profile list storage unit, 114 ... Database registration unit, 115 ... Raw data output unit, 116 ... Existing system data acquisition unit, 120 ... Broker, 200 ... Sensor type list storage unit, 201 ... Device log data acquisition unit, 202 ... Data conversion unit, 203 ... IoT log transmission Department

Claims (6)

An information processing system having a data conversion device and an information processing device.
The data conversion device is
A device identifier identifying the respective equipment for generating measurement data by measuring a device type list storage unit that stores device type list is a list that associates the device type information indicating a type of the device,
Wherein the measurement data the device has generated the device is a first data to be transmitted, and obtains the first data including the device identifier corresponding to the device, contained in the acquired first data The device type list including the device identifier is detected from the device type list storage unit , and the first data is acquired , the device type information included in the detected device type list, and the first data. a first data converter for converting the second data is data acquisition time information, was added to the first data indicating the time points,
A transmission unit that transmits the second data to the information processing device, and
With
The information processing device
And the device type information, and a profile list storage unit for storing a profile list is a list that correlates profiles and the for-readable previous SL measurement data corresponding to the device type information,
An acquisition unit that acquires the second data transmitted from the data conversion device, and
The profile list including the device type information included in the second data is detected from the profile list storage unit, and the first data in the second data is obtained by the profile included in the detected profile list. The measurement data included in the data is made readable, and the second data includes the readable measurement data , the device identifier included in the second data, the acquisition time point information, and the device type information. The second data conversion unit that converts to the third data,
An information processing system characterized by being equipped with. The information processing system according to claim 1, wherein the first data conversion unit converts the first data into second data in a JSON format. The information processing system according to claim 1 or 2, wherein the transmission unit transmits the second data by a communication protocol based on MQTT. A device identifier identifying the respective equipment for generating measurement data by measuring a device type list storage unit that stores device type list is a list that associates the device type information indicating a type of the device,
Wherein the measurement data the device has generated the device is a first data to be transmitted, and obtains the first data including the device identifier corresponding to the device, contained in the acquired first data The device type list including the device identifier is detected from the device type list storage unit , and the first data is acquired , the device type information included in the detected device type list, and the first data. a first data converter for converting the second data is data acquisition time information, was added to the first data indicating the time points,
And the device type information, and a profile list storage unit for storing a profile list is a list that correlates profiles and the for-readable previous SL measurement data corresponding to the device type information,
The profile list including the device type information included in the second data is detected from the profile list storage unit, and the first data in the second data is obtained by the profile included in the detected profile list. The measurement data included in the data is made readable, and the second data includes the readable measurement data , the device identifier included in the second data, the acquisition time point information, and the device type information. The second data conversion unit that converts to the third data,
An information processing device characterized by being equipped with. Information processing method by computer
Device classification list storage unit, and a device identifier identifying the respective equipment for generating measurement data by measuring, device type list that stores the device classification list is a list that associates the device type information indicating a type of the device Memory step and
First data conversion section obtains the the measurement data the device has generated the device is a first data to be transmitted, the first data including the device identifier corresponding to the device was obtained The device type list including the device identifier included in the first data is detected from the device type list storage unit, and the first data is obtained with the device type information included in the detected device type list. The acquisition time point information indicating the time point when the first data is acquired, and the first data conversion step of converting the acquisition time point information into the second data which is the data added to the first data, and
Profile list storage unit, and the device type information, a profile list storage step of storing the profile list is a list that associates a profile for-readable previous SL measurement data corresponding to the device type information,
The second data conversion unit detects the profile list including the device type information included in the second data from the profile list storage unit, and the second data is based on the profile included in the detected profile list. The measurement data included in the first data is readable, and the second data is the readable measurement data , the device identifier included in the second data, and the acquisition time point information. A second data conversion step for converting to the third data including the device type information, and
An information processing method characterized by having. On the computer
A device identifier identifying the respective equipment for generating measurement data by measuring a device type list storage step of storing the device classification list is a list that associates the device type information indicating a type of the device,
Wherein the measurement data the device has generated the device is a first data to be transmitted, and obtains the first data including the device identifier corresponding to the device, contained in the acquired first data The device type list including the device identifier is detected from the device type list storage unit , and the first data is acquired , the device type information included in the detected device type list, and the first data. a first data conversion step of converting the second data is data acquisition time information, was added to the first data indicating the time points,
And the device type information, a profile list storage step of storing the profile list is a list that associates a profile for-readable previous SL measurement data corresponding to the device type information,
The profile list including the device type information included in the second data is detected from the profile list storage unit, and the first data in the second data is obtained by the profile included in the detected profile list. The measurement data included in the data is made readable, and the second data includes the readable measurement data, the device identifier included in the second data, the acquisition time point information, and the device type information. The second data conversion step to convert to the third data,
A program to execute.

Images