[go: up one dir, main page]

WO2018179364A1 - 計算機システム及びデータフロー制御方法 - Google Patents

計算機システム及びデータフロー制御方法 Download PDF

Info

Publication number
WO2018179364A1
WO2018179364A1 PCT/JP2017/013685 JP2017013685W WO2018179364A1 WO 2018179364 A1 WO2018179364 A1 WO 2018179364A1 JP 2017013685 W JP2017013685 W JP 2017013685W WO 2018179364 A1 WO2018179364 A1 WO 2018179364A1
Authority
WO
WIPO (PCT)
Prior art keywords
data
sensor
tag
flow
report
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Ceased
Application number
PCT/JP2017/013685
Other languages
English (en)
French (fr)
Inventor
耕一 村山
裕教 江丸
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Hitachi Ltd
Original Assignee
Hitachi Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Hitachi Ltd filed Critical Hitachi Ltd
Priority to PCT/JP2017/013685 priority Critical patent/WO2018179364A1/ja
Priority to JP2019508133A priority patent/JP6685468B2/ja
Publication of WO2018179364A1 publication Critical patent/WO2018179364A1/ja
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Images

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F13/00Interconnection of, or transfer of information or other signals between, memories, input/output devices or central processing units
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46Multiprogramming arrangements
    • G06F9/50Allocation of resources, e.g. of the central processing unit [CPU]

Definitions

  • the present invention relates to a computer system and a data flow control method, for example, a computer system that monitors and analyzes on-site sensor data.
  • Cloud that collects data from the data provider system at the site, etc., and the data usage destination system monitors the data provider system, analyzes the data provider system, and uses this to improve the data provider system The system is realized.
  • Patent Document 1 a sensor on the site connected to a network is matched with metadata of an application on the sensor data use side so that sensor data meeting the requirements is distributed to the application.
  • the operation information of the operator side system as the data usage destination system is the data provider Feedback is made to the developer side system as a system.
  • the data usage destination system uses, for example, data outside the sensor, such as operation information of time sale events at the shop in the field, monitoring the field information, analyzing the sensor data, etc.
  • data outside the sensor such as operation information of time sale events at the shop in the field, monitoring the field information, analyzing the sensor data, etc.
  • the present invention provides a computer system and a data flow control method capable of appropriately controlling the flow of data outside the sensor in addition to the sensor data in controlling the data flow from the data providing source system to the data using destination system. Objective.
  • a data providing source system is a first management device that manages a device having a sensor, sensor data that is sensor detection data, and tag data that associates data that cannot be directly acquired from the sensor with sensor data.
  • the data use destination system includes a second management device that executes data management using the sensor data based on the tag data, and the data control computer moves from the data providing source system to the data use destination system.
  • Sensor data flow from the data provider system to the data destination system Sensor data sent to the data utilization destination system based on the sensor data flow when the tag data flow is controlled, the tag data flow is determined to be updated, and the determination is affirmative. From this, the tag data transmitted to the data utilization destination system is determined, and the tag data flow is updated based on the determination.
  • the data providing source system uses the detection data of the sensor by the first management device.
  • Some sensor data and tag data in which data that cannot be directly acquired from the sensor is associated with the sensor data are respectively managed, and the data use destination system uses the second management device to manage the sensor data based on the tag data.
  • the data control computer executes the sensor data flow from the data providing source system to the data using destination system, and the tag data flow from the data providing source system to the data using destination system, respectively.
  • Control determine whether the tag data flow needs to be updated, and Then, based on the sensor data flow, the tag data transmitted to the data usage destination system is determined from the sensor data transmitted to the data usage destination system, and the tag data flow is updated based on the determination. did.
  • the present invention provides a computer system and a data flow control method capable of appropriately controlling the flow of data outside the sensor in addition to the sensor data in the control of the data flow from the data providing source system to the data using destination system. be able to.
  • reference numeral 1 denotes a report management system as a computer system according to this embodiment as a whole.
  • This report management system 1 defines sensor data and tag data usage information, which is data obtained by adding on-site information (tags) to sensor data, and generates reports in the form of figures, tables, etc. based on the usage information System to manage.
  • the report management system 1 includes one or more data providing source systems 2, one or more data use destination systems 3, and a data control computer 4, which are connected to each other via a network 5.
  • the network 5 is a network such as a LAN or a WAN, and is provided by wire or wireless.
  • the data providing source system 2 is a system that provides data in its own system to an external system, and is a system that operates on the site such as a store, an airport, a factory, a construction site, an event site, etc. This is referred to as a sensor management computer) and one or more IoT devices 7.
  • the data provider system 2 is a store system, and the IoT device 7 is installed on each floor of the store. Then, the data providing source system 2 acquires, as tags, images in the store, audio, information related to time sales for the installation floor and the entire store, information related to device maintenance, and the like.
  • the sensor management computer 6 is a computer that manages the IoT device 7 and the sensor 25 in the data providing source system 2, and includes a CPU 8, a memory 9, an input / output device 10, a storage device 11, and a network interface 12. Are connected by an internal bus 13.
  • the CPU 8 is a processor that controls the operation of the entire sensor management computer 6.
  • the memory 9 is composed of, for example, a volatile semiconductor memory and is used as a work memory for the CPU 8.
  • the memory 9 temporarily stores a sensor management program 14 that is a program for managing sensor data and a tag management program 17 that is a program for managing tag data when necessary.
  • the input / output device 10 includes, for example, a keyboard, a mouse, and a display, and is used when necessary information such as definition of tag data is input by an operation manager, for example.
  • the storage device 11 is composed of a large-capacity nonvolatile storage device such as a hard disk device or SSD (Solid State Drive), and is used for storing and holding programs and data for a long period of time.
  • a program stored in the storage device 11 is loaded into the memory 9, and the CPU 8 executes this program to execute various processes as the entire report management system 1.
  • the storage device 11 stores and holds a sensor management program 14 and a tag management program 17.
  • the network interface 12 is composed of, for example, a NIC (Network Interface Card) or the like, and performs protocol control during communication with the data use destination system 3, the data control computer 4, the IoT device 7, and the like.
  • NIC Network Interface Card
  • the IoT device 7 is a device that collects information in the data providing source system 2 by the sensor 25 and transmits it to a computer in the data providing source system 2 or a computer outside the data providing source system 2, and includes a CPU 20, a memory 21, An input / output device 22, a storage device 23, a network interface 24, and one or more sensors 25 are connected to each other via an internal bus 26.
  • the CPU 20 is a processor that controls the operation of the entire IoT device 7.
  • the memory 21 is composed of, for example, a volatile semiconductor memory and is used as a work memory for the CPU 20.
  • the input / output device 22 includes, for example, a keyboard, a mouse, and a display, and is used when necessary information such as sensor setting information is input by an operation manager, for example.
  • the storage device 23 is composed of a large-capacity nonvolatile storage device such as a hard disk device or SSD (Solid State Drive), and is used for storing and holding programs and data for a long period of time.
  • a program stored in the storage device 23 is loaded into the memory 21, and the CPU 20 executes the program to execute various processes as the entire report management system 1.
  • the network interface 24 is composed of, for example, a NIC (Network Interface Card) or the like, and performs protocol control during communication with the data use destination system 3, the data control computer 4, the sensor management computer 6, and the like.
  • NIC Network Interface Card
  • the sensor 25 is a device that measures and collects sensor data such as images, moving images, sounds, positions, pressures, accelerations, angles, temperatures, and humidity in the data provider system 2.
  • the IoT device 7 converts the sensor data acquired from this sensor into a data format that can be handled by each program in the report management system 1 and transmits it.
  • the data usage destination system 3 is a system that monitors and analyzes the status of the data providing source system 2 based on the field data provided from the data providing source system 2, and includes a user terminal 27 and a second management device (hereinafter referred to as a “second management device”). This is called a report management computer) 28.
  • the user terminal 27 is a PC, a smartphone, or the like operated by a user such as a developer or an operation manager who uses the report management system 1, and includes a CPU 29, a memory 30, an input / output device 31, a storage device 32, and a network interface 33. Each device is connected by an internal bus 34.
  • the CPU 29 is a processor that controls operation of the entire user terminal 27.
  • the memory 30 is composed of, for example, a volatile semiconductor memory and is used as a work memory for the CPU 29.
  • a user interface program 35 which will be described later, is temporarily stored in the memory 30 when necessary.
  • the input / output device 31 includes, for example, a keyboard, a mouse, and a display.
  • the user defines tag data, sets sensor data transmission destination (hereinafter referred to as sensor data flow definition), and sensor data at the user terminal.
  • tag data usage information hereinafter, this may be used as data management information).
  • the storage device 32 is composed of a large-capacity nonvolatile storage device such as a hard disk device or an SSD (Solid State Drive), and is used for storing and holding programs and data for a long period of time.
  • a program stored in the storage device 32 is loaded into the memory 30, and the CPU 29 executes the program to execute various processes as the entire report management system 1.
  • the storage device 32 stores and holds a user interface program 35.
  • the network interface 33 is composed of, for example, a NIC (Network Interface Card) or the like, and performs protocol control during communication with the data providing source system 2, the data control computer 4, the report management computer 28, and the like.
  • NIC Network Interface Card
  • the report management computer 28 is a computer that generates and displays a report for monitoring and analyzing the site of the data providing source system 2 based on the sensor data and the tag data acquired from the data providing source system 2, and includes a CPU 36, a memory 37, The system includes an input / output device 38, a storage device 39, and a network interface 40. Each device is connected by an internal bus 41.
  • the CPU 36 is a processor that controls the operation of the entire report management computer 28.
  • the memory 37 is composed of, for example, a volatile semiconductor memory and is used as a work memory for the CPU 36.
  • a report management program 42 is temporarily held in the memory 37 when necessary.
  • the report management program 42 is a program that generates and displays a report for monitoring and analyzing the site of the data providing source system 2 based on the sensor data and the tag data acquired from the data providing source system 2.
  • the input / output device 38 includes, for example, a keyboard, a mouse, and a display, and is used when, for example, a developer inputs definitions of sensor data and tag data usage information on a user terminal.
  • the storage device 39 is composed of a large-capacity nonvolatile storage device such as a hard disk device or SSD (Solid State Drive), and is used for storing and holding programs and data for a long period of time.
  • a program stored in the storage device 39 is loaded into the memory 37, and the CPU 36 executes the program to execute various processes as the entire report management system 1.
  • the storage device 39 stores and holds the report management program 42.
  • the network interface 40 is composed of, for example, a NIC (Network Interface Card) or the like, and performs protocol control when communicating with the data providing source system 2, the data control computer 4, the user terminal 27, and the like.
  • NIC Network Interface Card
  • the data control computer 4 is a computer that processes and controls data exchanged between the data providing source system 2 and the data use destination system 3, and includes a CPU 48, a memory 49, an input / output device 50, a storage device 51, and a network interface 52. Each device is connected by an internal bus 53.
  • the CPU 48 is a processor that controls the operation of the entire data control computer 4.
  • the memory 49 is composed of, for example, a volatile semiconductor memory and is used as a work memory for the CPU 48.
  • the memory 49 temporarily stores a sensor data processing program 54 and a tag data flow control program 58 when necessary.
  • the sensor data processing program 54 is a program for processing sensor data received from the IoT device 7 operating in the data providing source system 2, and performs processing such as analysis of the sensor data and receives it based on the sensor data flow definition.
  • the processed sensor data and the processed sensor data are transmitted to the report management computer 28 of the appropriate data usage destination system 3.
  • the tag data flow control program 58 is a program for transmitting the tag data defined by the tag management program 17 to the report management computer 28 of the appropriate data usage destination system 3.
  • the input / output device 50 includes, for example, a keyboard, a mouse, and a display, and is used when, for example, information on a transmission destination of sensor data is input by a developer.
  • the storage device 51 is composed of a large-capacity nonvolatile storage device such as a hard disk device or SSD (Solid State Drive), and is used for storing and holding programs and data for a long period of time.
  • a program stored in the storage device 51 is loaded into the memory 49, and the CPU 48 executes the program to execute various processes as the entire report management system 1.
  • the storage device 32 stores and holds a sensor data processing program 54 and a tag data flow control program 58.
  • the network interface 52 is composed of, for example, a NIC (Network Interface Card) or the like, and performs protocol control during communication with the data providing source system 2, the data use destination system 3, and the like.
  • NIC Network Interface Card
  • the report management system 1 is equipped with a report management function for displaying and managing sensor data and tag data information collectively in a diagram or table as a report based on various definition information input by a user.
  • the user interface program 35 of the report management system 1 displays the definition screen 70 shown in FIG. 2, and the user defines the tag definition from the tag definition screen 71 of the definition screen 70 and the sensor data flow definition from the sensor data flow definition screen 72. Each definition is input from the report definition screen 73 as report definition information.
  • the report management system 1 determines a transmission destination of tag data from the input tag definition, sensor data flow definition, and report definition information.
  • the tag definition screen 71 is a screen on which a tag definition, which is related information (tag data) between sensor data and information on the site of the data providing source system 2, is input by the user.
  • the tag name column 71A, the schedule column 71B, and the sensor A column 71C is provided.
  • a tag name is input to the tag name column 71A
  • a schedule is input to the schedule column 71B in the format of “start time-end time”. Note that the schedule is in one of three types: date only, time only, and date and time.
  • the sensor column 71C displays a list of sensor IDs of the IoT device 7, and one or more sensor IDs are selected and input by the user.
  • the sensor data flow definition screen 72 is a screen in which a sensor data flow definition, which is sensor data flow control information on where to send sensor data, is input by a user, and includes a transmission source column 72A and a transmission destination column 72B. Is done.
  • the transmission source column 72A is input with the transmission source of the sensor data
  • the transmission destination column 72B is input with the transmission destination of the sensor data by separating a plurality of values with commas.
  • the report definition screen 73 is a screen on which a report definition, which is usage information indicating what kind of report is displayed using the sensor data and tag data received by the data usage destination system 3, is entered by the user.
  • a column 73A, a reference data column 73B, and a range column 73C are provided.
  • the report name is input in the report name column 73A
  • the range is input in the format of “start date-end date” in the range column 73C.
  • a list of sensor IDs of the IoT device 7 is displayed as reference data, and one or more sensor IDs are selected and input by the user.
  • tag definition screen 71 the sensor data flow definition screen 72, and the report definition screen 73 may not be displayed together as the definition screen 70, but may be displayed individually.
  • the transmission destination of the tag data can be confirmed from the tag definition screen 121 that can only be referred to as shown in FIG.
  • the user can confirm where the tag data is transmitted and how much the tag data is used.
  • the tag definition screen 121 includes a tag ID field 121A, a tag name field 121B, a transmission destination 121C, and a report number field 121D.
  • the tag ID field 121A includes a tag ID for uniquely identifying tag data.
  • the tag name is displayed in 121B
  • the transmission destination of tag data is displayed in the transmission destination 121C
  • the number of reports described later is displayed in the report number column 121D.
  • the report management system 1 creates a report based on information input from the tag definition screen 71, the sensor data flow definition screen 72, and the report definition screen 73.
  • FIG. 4 displays a report 80 created by the report management system 1.
  • the report 80 displays the volume of noise in the store A for each hour as a line graph 81 based on the sensor data information, and displays the report name 86 as “store A noise data”.
  • the report 80 displays information such as business hours 82, a time sale period 83, a sensor state abnormality 84, and a temporary maintenance period 85 as tag data with the tag name clearly displayed.
  • the sensor management program 14 is provided with a sensor configuration management module 15, a sensor monitoring module 16, and a sensor configuration table TB10.
  • the sensor configuration management module 15 is a program for managing the sensor configuration table TB10, and the sensor monitoring module 16 periodically monitors the IoT device 7 to be managed and determines whether or not an abnormality has occurred in the sensor 25. This is a program to check.
  • the sensor configuration table TB10 is a table for storing sensor configuration information, and includes a sensor ID column TB11, a device ID column TB12, a data type column TB13, and a status column TB14. .
  • a sensor ID for uniquely identifying the sensor 25 is stored.
  • the device ID column TB12 a device ID that uniquely identifies the IoT device 7 is stored.
  • the device ID is, for example, an IP address, a host name, a UUID, or the like used in the report management system 1 of the IoT device 7.
  • the data type column TB13 data types such as “image” and “sound” indicating data handled by the sensor 25 are stored.
  • the sensor data includes data that can be measured by the function of the IoT device 7 itself. Therefore, the data type includes data such as “CPU usage rate” and “memory usage rate”.
  • the sensor ID is stored in the sensor ID column TB11 in a format that combines a device ID such as “D003-1” and a unique ID in the IoT device 7. Is done.
  • the status column TB14 stores a status such as “normal” or “abnormal” indicating whether the IoT device 7 or the sensor 25 can normally collect and transmit sensor data. The status is periodically updated by the sensor monitoring module 16.
  • the tag management program 17 includes a tag management module 18, a tag transmission module 19, and a tag definition table TB20.
  • the tag management module 18 is a program for registering, referring to, editing, and deleting tag data by managing tag data related to the IoT device 7 and the sensor 25 using the tag definition table TB20.
  • the tag transmission module 19 monitors the tag definition table TB20, and when the tag data of the tag definition table TB20 is updated by an input from the tag definition screen 71, the updated tag data is transmitted to the tag data flow control program 58. It is a program.
  • the tag definition table TB20 is a table for storing tag data, and includes a tag ID column TB21, a tag name column TB22, a schedule column TB23, and a related ID column TB24.
  • tag ID column TB21 a tag ID for uniquely identifying tag data is stored.
  • the tag name column TB22 stores the name of the tag data.
  • the schedule column TB23 stores a period or time when an on-site event occurs. For example, the period when the event at the site occurs is the business hours, the time sale period, and the temporary maintenance period of the store A when the IoT device 7 is permanently installed in the store A.
  • the sensor ID included in the tag data is stored in the related ID column TB24.
  • the sensor ID stored in the related ID column TB24 is selected from the sensor IDs stored in the sensor ID column TB11 in the sensor configuration table TB10.
  • the report management program 42 includes a sensor data reception module 43, a tag reception module 44, a report management module 45, a report base generation module 46, a tag synthesis module 47, a sensor data table TB30, a tag data table TB40, and a report metadata table TB50. Is provided.
  • the sensor data receiving module 43 receives the sensor data collected by the data providing source system 2 and the sensor data processed by the data control computer 4, and stores the sensor data and the processed sensor data in the sensor data table TB30. It is.
  • the tag receiving module 44 is a program that receives tag data defined by the data providing system 2 and transferred by the data control computer 4 and stores the tag data in the tag data table TB40.
  • the report management module 45 is a program that defines a report definition that is the contents of a report based on information input on the report definition screen 73 and stores the report definition in the report metadata table TB50.
  • the report base generation module 46 acquires sensor data and the like from the sensor data table TB30 based on the report definition of the report metadata table TB50, and generates a figure, a table, a graph and the like as a report base based on the sensor data and the like It is.
  • the tag synthesis module 47 acquires tag data from the tag data table TB40 based on the report definition of the report metadata table TB50, synthesizes the tag with the report base generated by the report base generation module 46, and generates a report 80 It is.
  • the sensor data table TB30 is a table for storing sensor data transmitted from the IoT device 7 and sensor data processed by the data control computer 4, and includes a sensor ID column TB31 and a time column TB32.
  • the data column TB33 is provided.
  • the sensor ID column TB31 stores the sensor ID of the sensor ID column of the sensor configuration table TB10 that is the sensor ID of the sensor 25 that is the generation source of the received sensor data.
  • the time column TB32 stores a period during which sensor data is measured.
  • sensor data measured by the sensor 25 or sensor data processed by the sensor data processing program 54 is stored.
  • sensor data for example, in the case of image data, “Image” is stored in the data column TB33 as a data type and a byte string of image data as a data value, such as “Image: ⁇ first image data>”. Is done.
  • As the processed sensor data for example, in the case of audio data, “dB: ⁇ value>”, “dB” is stored as the data type, and the sound pressure value is stored in the data column TB33 as the data value. .
  • the tag data table TB40 is a table having the same configuration as the tag definition table TB20, but only the tag data to be stored is included in the report definition of the report management program 42. This is different from the tag definition table TB20.
  • the report metadata table TB50 is a table that stores report definitions defined by the report management program.
  • a report type column TB55 is provided.
  • a report ID that is an ID for uniquely identifying the report 80 is stored.
  • the report ID is created by the report management module 45.
  • the report name column TB52 a character string indicating the name of the report 80 input on the report definition screen 73 is stored.
  • the reference data column TB53 one or more sensor IDs used for report generation are selected from the sensor data table TB30 and stored.
  • the data range column TB54 stores a time range for generating the report 80, which is input on the report definition screen 73.
  • a report type indicating the display format of the report 80 is stored in the report type column TB55.
  • the report type is, for example, “table” in which the display format of the report 80 is a table format, “line” in which the display format of the report 80 is a line graph format for each time series.
  • formats suitable for displaying sensor data such as a pie chart format and a bar graph format are prepared as report types.
  • the sensor data processing program 54 is provided with a sensor data flow management module 55, a sensor data processing module 56, a sensor data flow control module 57, and a sensor data flow table TB60.
  • the sensor data flow management module 55 is a program that manages the transmission destination for each sensor data received from the IoT device 7 and registers, refers to, edits, and deletes the sensor data flow according to the sensor data flow definition.
  • the sensor data flow management module 55 stores the sensor data flow definition in the sensor data flow table TB60.
  • the sensor data processing module 56 is a program for performing processing such as analysis and processing on the sensor data received by the sensor data processing program 54. For example, if the received sensor data is image data, the sensor data processing module 56 performs identification of a person shown in the image, analysis of the number of persons, and the like. When the received sensor data is voice data, the sensor data processing module 56 analyzes conversation contents, extracts a volume, and the like. After processing the sensor data, the sensor data processing module 56 transmits the processed sensor data to the sensor data flow control module 57. When sensor data processing is unnecessary, the sensor data processing module 56 transmits the sensor data as it is to the sensor data flow control module 57.
  • the sensor data flow control module 57 reports the sensor data received from the sensor data processing module 56 and the processed sensor data based on the transmission destination for each sensor data registered in the sensor data flow table TB60 to the report management program 42. Is a program to send to.
  • the sensor ID of the sensor data is information on the transmission source.
  • the sensor data flow table TB60 is a table that defines a transmission destination of sensor data received by the sensor data processing program 54, and includes a transmission source ID column TB61 and a transmission destination column TB62. .
  • the transmission source ID column TB61 stores a sensor ID indicating the transmission source of the sensor data
  • the transmission destination column TB62 stores an ID indicating the report management computer 28 that is the transmission destination of the sensor data.
  • the ID indicating the report management computer 28 is, for example, a host name, an IP address, or the like set in the report management computer 28.
  • the tag data flow control program 58 is provided with a tag data flow management module 59, a tag data flow control module 60, and a tag data flow table TB70.
  • the tag data flow management module 59 is a program that manages the transmission destination of the tag data.
  • the sensor data flow definition stored in is monitored, and if any one or more tables are updated, the report management computer 28 as the tag data transmission destination is determined and the tag data flow table TB70 is updated. It is a program to do.
  • the tag data flow control module 60 is a program that transmits tag data to the report management computer 28 based on the transmission destination of the tag data stored in the tag data flow table TB70.
  • the tag data flow table TB70 is a table for storing tag data flow control information that defines a transmission destination of tag data, and includes a tag ID column TB71 and a transmission destination column TB72.
  • the tag ID column TB71 stores the tag ID of the tag ID column TB21 of the tag definition table TB20
  • the transmission destination column TB72 stores an ID indicating the report management computer 28 that is the transmission destination of the tag data.
  • the ID indicating the report management computer 28 is, for example, a host name, an IP address, or the like set in the report management computer 28.
  • the number of reports described above can be obtained by counting the number of report IDs with overlapping sensor IDs and time ranges stored in the tag data table TB40 and the report metadata table TB50 at the transmission destination in the transmission destination column TB72.
  • FIG. 12 shows a processing procedure for tag data flow update processing executed by the tag data flow management module 59.
  • the tag data flow management module 59 updates the tag data flow table TB70 according to the processing procedure shown in FIG.
  • the tag data flow management module 59 detects the update of any one or more of the tag definition table TB20, the report metadata table TB50, and the sensor data flow table TB60, the tag data flow shown in FIG. Start the update process.
  • the tag data flow management module 59 first acquires the data of the tag definition table TB20 from the tag management program 17, and extracts a sensor related to the tag data whose update has been detected (SP11). Specifically, the value in the related ID column TB24 is compared with the value in the column storing the sensor ID in the updated table, and the matched sensor ID is extracted.
  • the tag data flow management module 59 acquires the data of the sensor data flow table TB60 from the sensor data processing program 54, extracts the transmission destination of the sensor data of the extracted sensor (SP12), and transmits the transmission destination of the tag data. Narrow down the report management computer 28. Specifically, the transmission destination in the transmission destination column TB62 in the sensor data flow table TB60 corresponding to the sensor ID extracted in step SP11 is extracted. However, the report definition is not made at this point, and the transmission destinations that do not need to transmit the tag data are also included.
  • the tag data flow management module 59 obtains the report metadata table TB50 from the report management program 42 of the report management computer 28 narrowed down as the transmission destination of the tag data, and extracts the sensor data used for the report definition. (SP13). Specifically, the sensor ID extracted in step SP12 is compared with the sensor ID in the reference data column TB53 of the report metadata table TB50, and the matched sensor ID is extracted.
  • the tag data flow management module 59 updates the tag data flow by updating the tag data flow table TB70 (SP14). Specifically, the tag data flow management module 59 refers to the tag ID in the tag ID column TB21 in the tag definition table TB20 corresponding to the sensor ID extracted in step SP13. Then, the tag data flow management module 59 updates the tag data flow by storing the transmission destination extracted in step SP12 in the transmission destination column TB72 of the tag data flow table TB70 corresponding to the tag ID. If the sensor ID cannot be extracted in step SP13, the tag data flow management module 59 ends the tag data flow update process as it is.
  • the tag data flow management module 59 determines whether there is tag data within the time range defined in the report definition (SP15). Specifically, the tag data flow management module 59 determines whether or not there is an overlapping portion of the time range between the time range in the data range column TB54 corresponding to the sensor ID extracted in step SP13 and the time range in the schedule column TB23. . If there is no tag data within the time range defined in the report definition and a negative result is obtained in the determination at step SP15, the tag data flow management module 59 ends the tag data flow update process.
  • the tag data flow management module 59 performs report management on the tag data within the time range.
  • the tag data flow control module 60 is instructed to transmit to the computer 28 (SP16), and the tag data flow update process is terminated.
  • the tag data flow control module 60 transmits tag data within the time range to the report management computer 28.
  • FIG. 13 shows a processing procedure for report display processing executed by the report management program 42.
  • the report management program 42 displays the report 80 shown in FIG. 4 according to the processing procedure shown in FIG.
  • the report management program 42 starts the report display processing shown in FIG. 13 when a report display is requested by designating a report name via the input / output device 31, for example.
  • the report base generation module 46 first refers to the report metadata table TB50 and generates a report base based on the report definition corresponding to the designated report name (SP21).
  • the report base generation module 46 acquires the sensor data in the time range of the data range column TB54 from the sensor data table TB30 among the sensor IDs stored in the reference data column TB53. Then, the report base generation module 46 generates a report base in the format stored in the report type column TB55.
  • FIG. 4 shows a case where “Store A noise data” is designated as the report name.
  • the tag synthesis module 47 acquires tag data from the tag data table TB40 (SP22).
  • This acquired tag data has the sensor ID of the reference data column TB53 corresponding to the specified report name as the sensor ID of the related ID column TB44, and the time range of the schedule column TB43 in the time range of the data range column TB54. Is included in the data.
  • the tag synthesis module 47 synthesizes the tag with the report base generated by the report base generation module 46 (SP23). Specifically, the tag synthesis module 47 displays the tag over the time range of the tag data acquired in step SP22 on the report base.
  • the tag data flow control program 58 manages tag data using the tag data flow table TB70, so that the tag definition table TB20.
  • the transmission destination of the tag data is changed based on the change of the report metadata table TB50 and the sensor data flow table TB60.
  • the tag data transmission destination is dynamically and appropriately changed, so that a large amount of sensor data is exchanged and the situation of the data provider and the definition of the report are updated every day. It is possible to add additional information to the report without setting.
  • the user can change the information for displaying the report without being aware of the transmission destination of the tag data which is the additional information, and the data providing source and the data using destination can be changed. It is possible to realize a computer system and a data flow control method that can exchange appropriate additional information without waste.
  • the present invention is not limited to this, and the report management program 42 may access the data provider system 2 to acquire tag data.
  • FIG. 14 shows the configuration of the report management system 90 when the report management program 42 accesses the data provider system 2.
  • the report management system 90 is different from the report management system 1 in that a tag data access control program 93 is provided instead of the tag data flow control program 58. Only this difference will be described.
  • the tag data access management module 94 included in the tag data access control program 93 performs a tag data access update process shown in FIG. Steps SP11 to SP14 of the tag data access update process are the same as steps SP31 to SP34 of the tag data flow update process, and a description thereof will be omitted.
  • the tag data access management module 94 uses an access unit (hereinafter referred to as an API) such as REST API (Representational State Transfer Application State Programming API) for accessing the tag data of the tag data flow table TB70 as tag data access management.
  • an API such as REST API (Representational State Transfer Application State Programming API)
  • REST API Real State Transfer Application State Programming API
  • tag data access management module 94 only has a request ID requesting access to tag data stored in the transmission destination column TB72 as a transmission destination, and the tag ID column TB71 corresponding to the transmission destination. It controls so that the tag data of the tag ID stored in can be accessed.
  • FIG. 16 shows a configuration of the report management system 100 when the information from the third management apparatus (hereinafter referred to as a base management computer) 102 is diverted.
  • the report management system 100 is different from the report management system 1 in that it further includes one or more site management computers 102. Only this difference will be described.
  • the base management computer 102 is a computer for managing the site where the IoT device 7 of the data providing source system 101 is installed as a base, and the memory 104 stores a base management program that is a program for managing base information. 109 is temporarily held when necessary. Note that the hardware configuration of the base management computer 102 is the same as that of the data control computer 4 and the like, and thus the description thereof is omitted.
  • the function of the site management program 109 differs depending on the type of business of the site, but here, a case where the data providing source system 2 is a system that operates at a store will be described.
  • the site management program 109 includes a site management module 110, a store business hours table TB80, a system operation schedule table TB90, and a system event management table TB100.
  • the base management module 110 has a business hours management function managed by the store business hours table TB80 for managing the business hours of the stores, and an operation schedule management for managing the operation schedules of the respective IoT devices 7 operating at the stores by the system operation schedule table TB90.
  • This is a program having a system event management function for managing the function and the state of each IoT device 7 and each sensor 25 operating in the store by the system event management table TB100.
  • the site management module 110 registers, references, updates, deletes values stored in the store business hours table TB80, the system operation schedule table TB90, and the system event management table TB100.
  • the store business hours table TB80 is a table for storing store business hours, and includes a store ID column TB81, a store name column TB82, and a business hours column TB83.
  • Store ID column TB81 which stores a store uniquely showing a store is stored. This store ID is numbered sequentially from 1 at the time of store registration.
  • Store name column TB82 stores a store name indicating the name of the store. This store name is used as a tag name in the tag definition.
  • the business hours column TB83 stores the business hours of the store in the format of “opening time-closing time”. The business hours of this store are used as a schedule in tag definition.
  • the system operation schedule table TB90 is a table for storing an operation schedule of the IoT device 7, and includes an event ID column TB91, an event name column TB92, and a schedule column TB93.
  • the event ID column TB91 stores an event ID that uniquely identifies the operation schedule. This event ID is numbered sequentially from 1 when the operation schedule occurs.
  • the event name column TB92 stores an event name indicating the contents of the operation schedule. This event name is used as a tag name in the tag definition.
  • the schedule column TB93 the operation schedule is stored in the format of “start time-end time”. This operation schedule is used as a schedule in the tag definition.
  • the system event management table TB100 is a table for storing status abnormalities and the like of the IoT device 7 and the sensor 25, and includes a time column TB101, an event ID column TB102, an event name column TB103, and a target sensor column TB104. It is configured with.
  • the time column TB101 stores the time when the state abnormality occurred. This time is used as a schedule in the tag definition.
  • the event ID column TB102 stores an event ID that uniquely identifies a state abnormality or the like. This event ID is numbered in order from 1 when a state abnormality occurs.
  • the event name column TB103 stores an event name indicating contents such as a state abnormality. This event name is used as a tag name in the tag definition.
  • the target sensor column TB104 stores the sensor ID of the sensor in which an error or warning has occurred. This sensor ID is used in the tag definition. When a plurality of sensor IDs are stored in the target sensor column TB104, they are separated by commas or the like.
  • the tag management program 17 accesses the base management program 109 of the base management computer 102 when accepting the input of the tag definition, and stores business hours Information corresponding to the tag name column 71A, schedule column 71B, and sensor column 71C is acquired from the table TB80, system operation schedule table TB90, and system event management table TB100, and acquired in the tag name column 71A, schedule column 71B, and sensor column 71C. Display information as initial value. By displaying the initial value in this way, the user only has to input the change from the initial value, and the input load on the user is reduced.
  • the data providing system 2 is a store system
  • the present invention is not limited to this, and the data providing system 2 may be a system installed at an airport.
  • the data providing source system 2 acquires the airport name, gate number, flight information, boarding rate, and the like as tags.
  • the present invention is not limited to this, and the sensor 25 may be externally attached to the IoT device 7 and connected via the network interface 204.
  • the present invention is not limited to this.
  • the tag definition is input from the input / output device 10 of the sensor management computer 6 as needed by the operation manager
  • the sensor data flow definition is input from the input / output device 50 of the data control computer 4 as needed by the developer. May be input from the report management computer 28 by the developer at any time.
  • the present invention is not limited to this, and the user terminal 27 is other than the data usage destination system 3. You may make it operate

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Software Systems (AREA)
  • Arrangements For Transmission Of Measured Signals (AREA)

Abstract

【課題】データ提供元システムからデータ利用先システムへのデータフローの制御において、センサデータに加えて、センサ外のデータのフローも適切に制御できる計算機システム及びデータフロー制御方法を提供する。 【解決手段】データ制御計算機は、データ提供元システムからデータ利用先システムへのセンサデータのフローと、データ提供元システムからデータ利用先システムへのタグデータのフローと、を夫々制御し、タグデータのフローの更新の要否を判定し、当該判定を肯定すると、センサデータのフローに基づいて、データ利用先システムに送信されるセンサデータから、データ利用先システムに送信されるタグデータを決定し、当該決定に基づいて、タグデータのフローを更新するようにした。

Description

計算機システム及びデータフロー制御方法
 本発明は、計算機システム及びデータフロー制御方法に関し、例えば、現場のセンサデータをモニタリング及び分析する計算機システムである。
 現場等のデータ提供元システムからデータを収集し、データの利用先システムはデータ提供元システムのモニタリング、データ提供元システムの分析を行い、これをデータ提供元のシステムの改善等に役立てるためのクラウドシステムが実現されている。
 このようなシステムとして、例えば、特許文献1には、ネットワークに接続された現場のセンサと、センサデータ利用側のアプリケーションのメタデータとをマッチングして、要件に合うセンサデータをアプリケーションに流通させるようにセンサデータのフローを制御し、アプリケーションに仮想的なセンサを提供する発明が開示されている。
 なお、開発者(Development)と運用管理者(Operations)が連携して協力する開発手法であるDevOps環境のクラウドシステムにおいても、データ利用先システムとしての運用者側システムの運用情報が、データ提供元システムとしての開発者側システムにフィードバックされることが行われている。
国際公開2013/055414号公報
 データ利用先システムが、センサによって取得されるセンサデータに加えて、例えば、現場店舗でのタイムセールイベントの運営情報等のセンサ外のデータを利用して、現場情報のモニタリング、センサデータの分析等データ処理を実行しようとすると、センサデータに加えて、センサ外データのフローも制御する必要がある。
 しかしながら、従来のシステムでは、センサ外データがデータ提供元において任意かつ頻繁に変更され得るものであるにも拘わらず、センサ外データのフローを適切に制御することに対する配慮が十分でないために、センサデータのフローとセンサ外データのフローとの乖離を避けることができために、データ提供元からデータ利用先に、データ分析のために必要な付加情報が通知されない、反対に、不要な付加情報が大量に通知される、そして、データフロー定義を頻繁に行わなければならないことによるシステムのメンテナンスコストが嵩む等の課題が生じている。
 本発明は、データ提供元システムからデータ利用先システムへのデータフローの制御において、センサデータに加えて、センサ外のデータのフローも適切に制御できる計算機システム及びデータフロー制御方法を提供することを目的とする。
 かかる課題を解決するため本発明においては、データ提供元システムと、データ利用先システムと、データ提供元システムからデータ利用先システムへのデータフローを制御するデータ制御計算機と、を備える計算機システムにおいて、データ提供元システムは、センサを有する機器と、センサの検出データであるセンサデータと、センサから直接取得することができないデータをセンサデータと関連付けたタグデータと、を夫々管理する第1の管理装置と、を備え、データ利用先システムは、タグデータに基づいて、センサデータを利用するデータ管理を実行する第2の管理装置を備え、データ制御計算機は、データ提供元システムからデータ利用先システムへのセンサデータのフローと、データ提供元システムからデータ利用先システムへのタグデータのフローと、を夫々制御し、タグデータのフローの更新の要否を判定し、当該判定を肯定すると、センサデータのフローに基づいて、データ利用先システムに送信されるセンサデータから、データ利用先システムに送信されるタグデータを決定し、当該決定に基づいて、タグデータのフローを更新するようにした。
 また本発明においては、データ提供元システムからデータ利用先システムへのデータフローをデータ制御計算機が制御する計算機システム制御方法において、データ提供元システムが、第1の管理装置によって、センサの検出データであるセンサデータと、センサから直接取得することができないデータをセンサデータと関連付けたタグデータと、を夫々管理し、データ利用先システムが、第2の管理装置によって、タグデータに基づいて、センサデータを利用するデータ管理を実行し、データ制御計算機が、データ提供元システムからデータ利用先システムへのセンサデータのフローと、データ提供元システムからデータ利用先システムへのタグデータのフローと、を夫々制御し、タグデータのフローの更新の要否を判定し、当該判定を肯定すると、センサデータのフローに基づいて、データ利用先システムに送信されるセンサデータからデータ利用先システムに送信されるタグデータを決定し、当該決定に基づいてタグデータのフローを更新するようにした。
 本発明によれば、データ提供元システムからデータ利用先システムへのデータフローの制御において、センサデータに加えて、センサ外のデータのフローも適切に制御できる計算機システム及びデータフロー制御方法を提供することができる。
本実施形態によるレポート管理システムの構成を示すブロック図である。 定義画面の構成を略線的に示す略線図である。 タグ定義画面の構成を略線的に示す略線図である。 本実施の形態による生成されるレポートの構成を示す概念図である。 センサ構成テーブルの構成を示す概念図である。 タグ定義テーブルの構成を示す概念図である。 センサデータテーブルの構成を示す概念図である。 タグデータテーブルの構成を示す概念図である。 レポートメタデータテーブルの構成を示す概念図である。 センサデータフローテーブルの構成を示す概念図である。 タグデータフローテーブルの構成を示す概念図である。 本実施形態によるタグデータフロー更新処理の処理手順を示すフローチャートである。 レポート表示処理の処理手順を示すフローチャートである。 他の実施形態によるレポート管理システムの構成を示すブロック図である。 他の実施形態によるタグデータアクセス更新処理の処理手順を示すフローチャートである。 他の実施形態によるレポート管理システムの構成を示すブロック図である。 店舗営業時間テーブルの構成を示す概念図である。 システム稼働スケジュールテーブルの構成を示す概念図である。 システムイベント管理テーブルの構成を示す概念図である。
 以下図面について、本発明の一実施の形態を詳述する。なお、各図に示す同一の符号は同一の機能又は構成を有することを示しているため、重複した説明は省略する。
(1)本実施の形態によるレポート管理システムの構成
 図1において、1は全体として本実施の形態による計算機システムとしてのレポート管理システムを示す。このレポート管理システム1は、センサデータ及びセンサデータに現場の情報(タグ)を付与したデータであるタグデータの利用情報を定義して、利用情報に基づいて図、表等の態様のレポートを生成して管理するシステムである。このレポート管理システム1は、1つ以上のデータ提供元システム2、1つ以上のデータ利用先システム3及びデータ制御計算機4を備えて構成され、これらがネットワーク5を介して相互に接続されている。ネットワーク5は、LAN、WAN等のネットワークであり、有線又は無線で提供される。
 データ提供元システム2は、自システム内のデータを外部システムに提供するシステムであり、店舗、空港、工場、建設現場、イベント会場等の現場で動作するシステムであり、第1の管理装置(以下、これをセンサ管理計算機と呼ぶ)6及び1つ以上のIoT機器7を備えて構成される。ここでは、データ提供元システム2は店舗のシステムであって、IoT機器7は、店舗の各フロアに設置される。そしてデータ提供元システム2は店舗内の画像、音声、設置フロアや店舗全体のタイムセールに関する情報、機器のメンテナンスに関する情報等をタグとして取得する。
 センサ管理計算機6は、データ提供元システム2内のIoT機器7及びセンサ25を管理する計算機であり、CPU8、メモリ9、入出力装置10、ストレージ装置11及びネットワークインタフェース12から構成され、それぞれの機器が内部バス13で接続される。
 CPU8は、センサ管理計算機6全体の動作制御を司るプロセッサである。またメモリ9は、例えば揮発性の半導体メモリから構成され、CPU8のワークメモリとして利用される。メモリ9には、センサデータを管理するプログラムであるセンサ管理プログラム14及びタグデータを管理するプログラムであるタグ管理プログラム17が、必要な際に一時的に保持される。
 入出力装置10は、例えばキーボード、マウス及びディスプレイから構成され、例えば運用管理者によってタグデータの定義等の必要な情報が入力される際に使用される。
 ストレージ装置11は、例えばハードディスク装置、SSD(Solid State Drive)等の大容量の不揮発性記憶装置から構成され、プログラムやデータを長期間記憶保持するために利用される。ストレージ装置11に格納されたプログラムがメモリ9にロードされ、このプログラムをCPU8が実行することによりレポート管理システム1全体としての各種処理が実行される。なお、ストレージ装置11には、センサ管理プログラム14及びタグ管理プログラム17が格納されて保持される。
 ネットワークインタフェース12は、例えばNIC(Network Interface Card)等から構成され、データ利用先システム3、データ制御計算機4、IoT機器7等との通信時におけるプロトコル制御を行う。
 IoT機器7は、データ提供元システム2内の情報をセンサ25により収集し、データ提供元システム2内の計算機やデータ提供元システム2の外部の計算機に送信する機器であり、CPU20、メモリ21、入出力装置22、ストレージ装置23、ネットワークインタフェース24及び1つ以上のセンサ25から構成され、それぞれの機器が内部バス26で接続される。
 CPU20は、IoT機器7全体の動作制御を司るプロセッサである。またメモリ21は、例えば揮発性の半導体メモリから構成され、CPU20のワークメモリとして利用される。
 入出力装置22は、例えばキーボード、マウス及びディスプレイから構成され、例えば運用管理者によってセンサの設定情報等の必要な情報が入力される際に使用される。
 ストレージ装置23は、例えばハードディスク装置、SSD(Solid State Drive)等の大容量の不揮発性記憶装置から構成され、プログラムやデータを長期間記憶保持するために利用される。ストレージ装置23に格納されたプログラムがメモリ21にロードされ、このプログラムをCPU20が実行することによりレポート管理システム1全体としての各種処理が実行される。
 ネットワークインタフェース24は、例えばNIC(Network Interface Card)等から構成され、データ利用先システム3、データ制御計算機4、センサ管理計算機6等との通信時におけるプロトコル制御を行う。
 センサ25は、データ提供元システム2内の画像、動画、音声、位置、圧力、加速度、角度、温度、湿度等のセンサデータを測定、収集等する機器である。IoT機器7は、このセンサから取得したセンサデータをレポート管理システム1内の各プログラムが扱えるデータ形式に変換して送信する。
 データ利用先システム3は、データ提供元システム2から提供された現場のデータを基に、データ提供元システム2の状況をモニタリング、分析するシステムであり、ユーザ端末27及び第2の管理装置(以下、これをレポート管理計算機と呼ぶ)28を備えて構成される。
 ユーザ端末27は、レポート管理システム1を利用する開発者、運用管理者等のユーザが操作するPC、スマートフォン等であり、CPU29、メモリ30、入出力装置31、ストレージ装置32及びネットワークインタフェース33から構成され、それぞれの機器が内部バス34で接続される。
 CPU29は、ユーザ端末27全体の動作制御を司るプロセッサである。またメモリ30は、例えば揮発性の半導体メモリから構成され、CPU29のワークメモリとして利用される。メモリ30には、後述するユーザインタフェースプログラム35が、必要な際に一時的に保持される。
 入出力装置31は、例えばキーボード、マウス及びディスプレイから構成され、例えばユーザによってタグデータの定義、センサデータの送信先の設定(以下、これをセンサデータフロー定義と呼ぶ)、ユーザ端末でのセンサデータ及びタグデータの利用情報(以下、これをデータ管理の情報としてもよい)の定義が入力される際に使用される。
 ストレージ装置32は、例えばハードディスク装置、SSD(Solid State Drive)等の大容量の不揮発性記憶装置から構成され、プログラムやデータを長期間記憶保持するために利用される。ストレージ装置32に格納されたプログラムがメモリ30にロードされ、このプログラムをCPU29が実行することによりレポート管理システム1全体としての各種処理が実行される。なお、ストレージ装置32には、ユーザインタフェースプログラム35が格納されて保持される。
 ネットワークインタフェース33は、例えばNIC(Network Interface Card)等から構成され、データ提供元システム2、データ制御計算機4、レポート管理計算機28等との通信時におけるプロトコル制御を行う。
 レポート管理計算機28は、データ提供元システム2から取得したセンサデータ及びタグデータを基に、データ提供元システム2の現場をモニタリング、分析するレポートを生成、表示する計算機であり、CPU36、メモリ37、入出力装置38、ストレージ装置39及びネットワークインタフェース40から構成され、それぞれの機器が内部バス41で接続される。
 CPU36は、レポート管理計算機28全体の動作制御を司るプロセッサである。またメモリ37は、例えば揮発性の半導体メモリから構成され、CPU36のワークメモリとして利用される。メモリ37には、レポート管理プログラム42が、必要な際に一時的に保持される。なおレポート管理プログラム42は、データ提供元システム2から取得したセンサデータ及びタグデータを基に、データ提供元システム2の現場をモニタリング及び分析するためのレポートを生成して表示するプログラムである。
 入出力装置38は、例えばキーボード、マウス及びディスプレイから構成され、例えば開発者によってセンサデータ及びタグデータのユーザ端末での利用情報の定義を入力する際に使用される。
 ストレージ装置39は、例えばハードディスク装置、SSD(Solid State Drive)等の大容量の不揮発性記憶装置から構成され、プログラムやデータを長期間記憶保持するために利用される。ストレージ装置39に格納されたプログラムがメモリ37にロードされ、このプログラムをCPU36が実行することによりレポート管理システム1全体としての各種処理が実行される。なお、ストレージ装置39には、レポート管理プログラム42が格納されて保持される。
 ネットワークインタフェース40は、例えばNIC(Network Interface Card)等から構成され、データ提供元システム2、データ制御計算機4、ユーザ端末27等との通信時におけるプロトコル制御を行う。
 データ制御計算機4は、データ提供元システム2とデータ利用先システム3の間でやり取りされるデータを処理、制御する計算機であり、CPU48、メモリ49、入出力装置50、ストレージ装置51及びネットワークインタフェース52から構成され、それぞれの機器が内部バス53で接続される。
 CPU48は、データ制御計算機4全体の動作制御を司るプロセッサである。またメモリ49は、例えば揮発性の半導体メモリから構成され、CPU48のワークメモリとして利用される。メモリ49には、センサデータ処理プログラム54及びタグデータフロー制御プログラム58が、必要な際に一時的に保持される。
 なおセンサデータ処理プログラム54は、データ提供元システム2で動作するIoT機器7から受信したセンサデータを処理するプログラムであり、センサデータを解析等の処理をし、センサデータフロー定義に基づいて、受信したセンサデータ、及び、処理をしたセンサデータを適切なデータ利用先システム3のレポート管理計算機28に送信する。
 またタグデータフロー制御プログラム58は、タグ管理プログラム17で定義されたタグデータを、適切なデータ利用先システム3のレポート管理計算機28に送信するプログラムである。
 入出力装置50は、例えばキーボード、マウス及びディスプレイから構成され、例えば開発者によってセンサデータの送信先の情報が入力される際に使用される。
 ストレージ装置51は、例えばハードディスク装置、SSD(Solid State Drive)等の大容量の不揮発性記憶装置から構成され、プログラムやデータを長期間記憶保持するために利用される。ストレージ装置51に格納されたプログラムがメモリ49にロードされ、このプログラムをCPU48が実行することによりレポート管理システム1全体としての各種処理が実行される。なお、ストレージ装置32には、センサデータ処理プログラム54及びタグデータフロー制御プログラム58が格納されて保持される。
 ネットワークインタフェース52は、例えばNIC(Network Interface Card)等から構成され、データ提供元システム2、データ利用先システム3等との通信時におけるプロトコル制御を行う。
(2)本実施の形態によるレポート管理機能
 次に、本実施の形態のレポート管理機能について説明する。本レポート管理システム1は、ユーザにより入力された各種定義情報に基づいて、レポートとして図や表にセンサデータやタグデータの情報をまとめて表示し、管理するレポート管理機能が搭載されている。
 実際上、レポート管理システム1のユーザインタフェースプログラム35は図2に示す定義画面70を表示し、ユーザは、定義画面70のタグ定義画面71からタグ定義を、センサデータフロー定義画面72からセンサデータフロー定義を、レポート定義画面73からレポート定義の情報をそれぞれ入力する。レポート管理システム1は、入力されたタグ定義、センサデータフロー定義及びレポート定義の情報から、タグデータの送信先を決定する。
 タグ定義画面71は、センサデータとデータ提供元システム2の現場の情報との関連情報(タグデータ)であるタグ定義がユーザによって入力される画面であり、タグ名欄71A、スケジュール欄71B及びセンサ欄71Cを備えて構成される。タグ名欄71Aにはタグ名が入力され、スケジュール欄71Bには、スケジュールが「開始時-終了時」の形式で入力される。なおスケジュールは、日付のみ、時刻のみ、日付と時刻の3種類の何れか1つの形式とする。またセンサ欄71Cには、IoT機器7のセンサIDの一覧が表示され、ユーザによってセンサIDが1つ以上選択され入力される。
 センサデータフロー定義画面72は、センサデータをどこに送信するかのセンサデータフロー制御情報であるセンサデータフロー定義がユーザによって入力される画面であり、送信元欄72A及び送信先欄72Bを備えて構成される。送信元欄72Aにはセンサデータの送信元が、送信先欄72Bにはセンサデータの送信先が、ユーザによって複数の値をカンマで区切って入力される。
 レポート定義画面73は、データ利用先システム3が受信したセンサデータやタグデータを利用してどのようなレポートを表示するかの利用情報であるレポート定義がユーザによって入力される画面であり、レポート名欄73A、参照データ欄73B及び範囲欄73Cを備えて構成される。レポート名欄73Aにはレポート名が入力され、範囲欄73Cには範囲が「開始日付-終了日付」の形式で入力される。また参照データ欄73Bには参照データとして、IoT機器7のセンサIDの一覧が表示され、ユーザによってセンサIDが1つ以上選択され入力される。
 なお、タグ定義画面71、センサデータフロー定義画面72及びレポート定義画面73は、定義画面70としてひとまとめに表示されなくてもよく、個別に表示されてもよい。
 また、タグデータの送信先は、図3に示す参照のみ可能なタグ定義画面121から確認することができる。このタグ定義画面121を参照することで、ユーザはタグデータがどこに送信されているかを確認することや、タグデータがどれだけ利用されているかを確認することができる。
 タグ定義画面121は、タグID欄121A、タグ名欄121B、送信先121C及びレポート数欄121Dを備えて構成され、タグID欄121Aにはタグデータを一意に識別するタグIDが、タグ名欄121Bにはタグ名が、送信先121Cにはタグデータの送信先が、レポート数欄121Dには後述のレポート数が表示される。
 そしてレポート管理システム1は、タグ定義画面71、センサデータフロー定義画面72及びレポート定義画面73から入力された情報を基に、レポートを作成する。図4は、レポート管理システム1が作成するレポート80を表示する。
 レポート80は、センサデータの情報を基に店舗A内の騒音の時間毎の音量を折れ線グラフ81として表示し、レポート名86を「店舗A騒音データ」として表示している。またレポート80は、タグデータとして営業時間82、タイムセール期間83、センサ状態異常84、臨時メンテナンス期間85の情報等を、タグ名を明示して表示している。
 以上のようなレポート管理機能を実現するための手段として、図1に示すように、センサ管理プログラム14には、センサ構成管理モジュール15、センサ監視モジュール16及びセンサ構成テーブルTB10が設けられている。
 センサ構成管理モジュール15は、センサ構成テーブルTB10を管理するプログラムであり、センサ監視モジュール16は、定期的に管理対象のIoT機器7を監視し、センサ25に異常が発生していないか否かを確認するプログラムである。
 またセンサ構成テーブルTB10は、図5に示すように、センサの構成情報を格納するテーブルであって、センサID欄TB11、機器ID欄TB12、データ種別欄TB13及びステータス欄TB14を備えて構成される。
 センサID欄TB11には、センサ25を一意に識別するセンサIDが格納される。機器ID欄TB12には、IoT機器7を一意に識別する機器IDが格納される。なお機器IDは例えば、IoT機器7のレポート管理システム1内で利用されるIPアドレス、ホスト名、UUID等である。
 データ種別欄TB13には、センサ25が扱うデータを示す「画像」、「音声」といったデータ種別が格納される。なおセンサデータにはIoT機器7自身が備える機能によって測定可能なデータも含むものとし、従ってデータ種別には「CPU使用率」、「メモリ使用率」といったものも含む。センサデータがIoT機器7自身の備える機能によって測定可能なデータの場合、センサIDは、「D003-1」といった機器ID及びIoT機器7内でユニークなIDを組み合わせたフォーマットでセンサID欄TB11に格納される。
 ステータス欄TB14には、IoT機器7又はセンサ25が正常にセンサデータを収集及び送信できるかの状態を示す「正常」又は「異常」といったステータスが格納される。ステータスはセンサ監視モジュール16によって定期的に更新される。
 またタグ管理プログラム17には、タグ管理モジュール18、タグ送信モジュール19及びタグ定義テーブルTB20が設けられている。
 タグ管理モジュール18は、IoT機器7及びセンサ25に関連するタグデータをタグ定義テーブルTB20によって管理することで、タグデータの登録、参照、編集及び削除を行うプログラムである。
 タグ送信モジュール19は、タグ定義テーブルTB20を監視し、タグ定義画面71からの入力によってタグ定義テーブルTB20のタグデータが更新されると、更新されたタグデータをタグデータフロー制御プログラム58に送信するプログラムである。
 タグ定義テーブルTB20は、図6に示すように、タグデータを格納するテーブルであって、タグID欄TB21、タグ名欄TB22、スケジュール欄TB23及び関連ID欄TB24を備えて構成される。
 タグID欄TB21には、タグデータを一意に識別するタグIDが格納される。またタグ名欄TB22には、タグデータの名称が格納される。スケジュール欄TB23には、現場のイベントが発生した期間又は時間が格納される。例えば、現場のイベントが発生した期間は、IoT機器7がある店舗Aに常設されている場合の店舗Aの営業時間、タイムセール期間、臨時メンテナンス期間である。
 関連ID欄TB24には、タグデータに含まれるセンサIDが格納される。この関連ID欄TB24に格納されるセンサIDは、センサ構成テーブルTB10をセンサID欄TB11に格納されているセンサIDから選択される。
 さらにレポート管理プログラム42には、センサデータ受信モジュール43、タグ受信モジュール44、レポート管理モジュール45、レポートベース生成モジュール46、タグ合成モジュール47、センサデータテーブルTB30、タグデータテーブルTB40及びレポートメタデータテーブルTB50が設けられている。
 センサデータ受信モジュール43は、データ提供元システム2で収集されたセンサデータ及びデータ制御計算機4によって処理されたセンサデータを受信し、センサデータ及び処理されたセンサデータをセンサデータテーブルTB30に格納するプログラムである。
 タグ受信モジュール44は、データ提供元システム2で定義されデータ制御計算機4によって転送されるタグデータを受信し、タグデータをタグデータテーブルTB40に格納するプログラムである。
 レポート管理モジュール45は、レポート定義画面73で入力された情報を基にレポートの内容であるレポート定義を定義し、レポート定義をレポートメタデータテーブルTB50に格納するプログラムである。
 レポートベース生成モジュール46は、レポートメタデータテーブルTB50のレポート定義を基に、センサデータテーブルTB30からセンサデータ等を取得し、センサデータ等に基づいてレポートベースとして図、表、グラフ等を生成するプログラムである。
 タグ合成モジュール47は、レポートメタデータテーブルTB50のレポート定義を基に、タグデータテーブルTB40からタグデータを取得し、レポートベース生成モジュール46が生成したレポートベースにタグを合成しレポート80を生成するプログラムである。
 センサデータテーブルTB30は、図7に示すように、IoT機器7から送信されたセンサデータ、及び、データ制御計算機4で処理されたセンサデータを格納するテーブルであり、センサID欄TB31、時刻欄TB32、データ欄TB33を備えて構成される。
 センサID欄TB31には、受信したセンサデータの生成元となるセンサ25のセンサIDである、センサ構成テーブルTB10のセンサID欄のセンサIDが格納される。時刻欄TB32には、センサデータが測定された期間が格納されている。データ欄TB33には、センサ25が測定したセンサデータ、又は、センサデータ処理プログラム54で処理されたセンサデータが格納される。センサデータとしては、例えば、画像データの場合、「Image:<第1の画像データ>」のように、データ種別として「Image」が、データ値として画像データのバイト列が、データ欄TB33に格納される。処理されたセンサデータとしては、例えば、音声データの場合、「dB:<値>」のように、データ種別として「dB」が、データ値として音圧の数値が、データ欄TB33に格納される。
 タグデータテーブルTB40は、図8に示すように、タグ定義テーブルTB20と同一の構成のテーブルであるが、格納されるタグデータがレポート管理プログラム42のレポート定義に含まれているもののみであるという点でタグ定義テーブルTB20と異なる。
 レポートメタデータテーブルTB50は、図9に示すように、レポート管理プログラムが定義するレポート定義が格納されるテーブルであり、レポートID欄TB51、レポート名欄TB52、参照データ欄TB53、データ範囲欄TB54及びレポート種別欄TB55を備えて構成される。
 レポートID欄TB51には、レポート80を一意に識別するIDであるレポートIDが格納される。なおレポートIDはレポート管理モジュール45によって作成される。レポート名欄TB52には、レポート定義画面73で入力されたレポート80の名称を示す文字列が格納される。参照データ欄TB53には、レポート生成に使用されるセンサIDが、センサデータテーブルTB30から1つ以上選択されて格納される。データ範囲欄TB54には、レポート定義画面73で入力された、レポート80を生成する時間的な範囲が格納される。
 レポート種別欄TB55には、レポート80の表示形式を示すレポート種別が格納される。レポート種別は例えば、レポート80の表示形式を表形式とする「表」、レポート80の表示形式を時系列毎の折れ線グラフ形式とする「折れ線」等とする。この他にも、レポート種別には円グラフ形式、棒グラフ形式等、センサデータの表示に適した形式が用意される。
 さらにセンサデータ処理プログラム54には、センサデータフロー管理モジュール55、センサデータ処理モジュール56、センサデータフロー制御モジュール57及びセンサデータフローテーブルTB60が設けられている。
 センサデータフロー管理モジュール55は、IoT機器7から受信したセンサデータ毎の送信先を管理し、センサデータフロー定義によってセンサデータフローの登録、参照、編集及び削除を行うプログラムである。なおセンサデータフロー管理モジュール55は、センサデータフロー定義をセンサデータフローテーブルTB60に格納する。
 センサデータ処理モジュール56は、センサデータ処理プログラム54が受信したセンサデータに分析、加工等の処理をするプログラムである。例えば、受信したセンサデータが画像データの場合、センサデータ処理モジュール56は、画像に映っている人物の特定、人数の解析等を行う。また受信したセンサデータが音声データの場合、センサデータ処理モジュール56は、会話内容の分析、音量の抽出等を行う。センサデータ処理モジュール56は、センサデータを処理した後、処理したセンサデータをセンサデータフロー制御モジュール57に送信する。なおセンサデータの処理が不要の場合は、センサデータ処理モジュール56は、センサデータフロー制御モジュール57にそのままのセンサデータを送信する。
 センサデータフロー制御モジュール57は、センサデータフローテーブルTB60に登録されているセンサデータ毎の送信先に基づいて、センサデータ処理モジュール56から受信したセンサデータ及び処理されたセンサデータを、レポート管理プログラム42に送信するプログラムである。なおセンサデータのセンサIDは送信元の情報となる。
 センサデータフローテーブルTB60は、図10に示すように、センサデータ処理プログラム54が受信したセンサデータの送信先を定義するテーブルであり、送信元ID欄TB61及び送信先欄TB62を備えて構成される。送信元ID欄TB61には、センサデータの送信元を示すセンサIDが格納され、送信先欄TB62には、センサデータの送信先であるレポート管理計算機28を示すIDが格納される。レポート管理計算機28を示すIDは、例えばレポート管理計算機28に設定されたホスト名、IPアドレス等である。
 さらにタグデータフロー制御プログラム58には、タグデータフロー管理モジュール59、タグデータフロー制御モジュール60及びタグデータフローテーブルTB70が設けられている。
 タグデータフロー管理モジュール59は、タグデータの送信先を管理するプログラムであり、タグ定義テーブルTB20に格納されているタグデータ、レポートメタデータテーブルTB50に格納されているレポート定義及びセンサデータフローテーブルTB60に格納されているセンサデータフロー定義を監視し、何れか1つ以上のテーブルの更新があった場合に、タグデータの送信先となるレポート管理計算機28を決定し、タグデータフローテーブルTB70を更新するプログラムである。
 タグデータフロー制御モジュール60は、タグデータフローテーブルTB70に格納されているタグデータの送信先に基づいて、タグデータをレポート管理計算機28に送信するプログラムである。
 タグデータフローテーブルTB70は、図11に示すように、タグデータの送信先を定義するタグデータフロー制御情報を格納するテーブルであり、タグID欄TB71及び送信先欄TB72を備えて構成される。タグID欄TB71には、タグ定義テーブルTB20のタグID欄TB21のタグIDが格納され、送信先欄TB72には、タグデータの送信先であるレポート管理計算機28を示すIDが格納される。レポート管理計算機28を示すIDは、例えばレポート管理計算機28に設定されたホスト名、IPアドレス等である。
 なお送信先欄TB72の送信先にあるタグデータテーブルTB40及びレポートメタデータテーブルTB50に格納されているセンサID及び時刻範囲が共に重複するレポートIDの数をカウントすることで上述のレポート数が求まる。
(3)レポート管理機能に関する各種処理
 次に、上述したレポート管理機能に関連して本レポート管理システム1において実行される各種処理について説明する。なお、以下においては、各種処理の処理主体を「プログラム」として説明するが、実際上は、CPU8,29,36,48がその「プログラム」に基づいてその処理を実行することは言うまでもない。
(3-1)タグデータフロー更新処理
 図12は、タグデータフロー管理モジュール59が実行するタグデータフロー更新処理の処理手順を示す。タグデータフロー管理モジュール59は、この図12に示す処理手順に従って、タグデータフローテーブルTB70を更新する。
 実際上、タグデータフロー管理モジュール59は、タグ定義テーブルTB20、レポートメタデータテーブルTB50及びセンサデータフローテーブルTB60のうちいずれか1つ以上のテーブルの更新を検知すると、この図12に示すタグデータフロー更新処理を開始する。
 そして、タグデータフロー管理モジュール59は、まず、タグ管理プログラム17からタグ定義テーブルTB20のデータを取得して、更新を検知したタグデータに関連するセンサを抽出する(SP11)。具体的には、関連ID欄TB24の値と、更新のあったテーブル中のセンサIDが格納されている欄の値を比較し、一致したセンサIDを抽出する。
 続いて、タグデータフロー管理モジュール59は、センサデータ処理プログラム54からセンサデータフローテーブルTB60のデータを取得して、抽出したセンサのセンサデータの送信先を抽出し(SP12)、タグデータの送信先となるレポート管理計算機28を絞り込む。具体的には、ステップSP11で抽出したセンサIDに対応するセンサデータフローテーブルTB60における送信先欄TB62の送信先を抽出する。ただし、この時点ではレポート定義がなされておらず、タグデータを送信する必要がない送信先も含まれている。
 次いで、タグデータフロー管理モジュール59は、タグデータの送信先として絞り込んだレポート管理計算機28のレポート管理プログラム42からレポートメタデータテーブルTB50を取得して、レポート定義に使用されているセンサデータを抽出する(SP13)。具体的には、ステップSP12で抽出したセンサIDとレポートメタデータテーブルTB50の参照データ欄TB53のセンサIDとを比較し、一致したセンサIDを抽出する。
 次いで、タグデータフロー管理モジュール59は、タグデータフローテーブルTB70を更新することで、タグデータフローを更新する(SP14)。具体的には、タグデータフロー管理モジュール59は、ステップSP13で抽出したセンサIDに対応するタグ定義テーブルTB20におけるタグID欄TB21のタグIDを参照する。そして、タグデータフロー管理モジュール59は、当該タグIDに対応するタグデータフローテーブルTB70の送信先欄TB72に、ステップSP12で抽出した送信先を格納することでタグデータフローを更新する。なお、ステップSP13でセンサIDが抽出できない場合は、タグデータフロー管理モジュール59は、そのままタグデータフロー更新処理を終了する。
 次いで、タグデータフロー管理モジュール59は、レポート定義に定義されている時刻範囲内のタグデータの有無を判定する(SP15)。具体的には、タグデータフロー管理モジュール59は、ステップSP13で抽出したセンサIDに対応するデータ範囲欄TB54の時刻範囲と、スケジュール欄TB23の時刻範囲との時刻範囲の重複部分の有無を判定する。タグデータフロー管理モジュール59は、レポート定義に定義されている時刻範囲内のタグデータが無く、ステップSP15の判定で否定結果を得ると、タグデータフロー更新処理を終了する。
 これに対して、タグデータフロー管理モジュール59は、レポート定義に定義されている時刻範囲内のタグデータが有り、ステップSP15の判定で肯定結果を得ると、当該時刻範囲内のタグデータをレポート管理計算機28に送信するように、タグデータフロー制御モジュール60に指示をし(SP16)、タグデータフロー更新処理を終了する。タグデータフロー管理モジュール59からの指示により、タグデータフロー制御モジュール60は、レポート管理計算機28に当該時刻範囲内のタグデータを送信する。
(3-2)レポート表示処理
 図13は、レポート管理プログラム42が実行するレポート表示処理の処理手順を示す。レポート管理プログラム42は、この図13に示す処理手順に従って、図4に示すレポート80を表示する。
 実際上、レポート管理プログラム42は、例えばユーザから入出力装置31を介してレポート名を指定してレポート表示を要求されると、この図13に示すレポート表示処理を開始する。
 そして、レポートベース生成モジュール46は、まず、レポートメタデータテーブルTB50を参照し、指定されたレポート名に対応するレポート定義に基づいて、レポートベースを生成する(SP21)。
 具体的には、レポートベース生成モジュール46は、参照データ欄TB53に格納されているセンサIDのうち、データ範囲欄TB54の時刻範囲のセンサデータを、センサデータテーブルTB30から取得する。そしてレポートベース生成モジュール46は、レポート種別欄TB55に格納されている形式でレポートベースを生成する。図4では、レポート名として「店舗A騒音データ」が指定された場合を示している。
 続いて、タグ合成モジュール47は、タグデータテーブルTB40からタグデータを取得する(SP22)。この取得するタグデータは、指定されたレポート名に対応する参照データ欄TB53のセンサIDを、関連ID欄TB44のセンサIDとして持ち、かつ、データ範囲欄TB54の時刻範囲にスケジュール欄TB43の時刻範囲が含まれるデータとする。
 図4に示すように例えば、2016年12月23日のセンサIDがS002のセンサデータを表示するレポートIDがR002のレポートの場合、タグデータテーブルTB40に格納されているタグデータのうち、関連ID欄TB44の関連IDが“S002“で、かつ、スケジュール欄TB43の時刻範囲が”2016年12月23日00:00から2016年12月24日00:00“に該当するタグデータが取得される。レポートIDがR002の場合、図9に示すようにタグIDがE001、E003、E005、E006のタグデータが取得される。
 次いで、タグ合成モジュール47は、レポートベース生成モジュール46が生成したレポートベースにタグを合成する(SP23)。具体的には、タグ合成モジュール47は、レポートベース上に、ステップSP22で取得したタグデータの時刻範囲に渡ってタグを表示する。
(4)本実施の形態の効果
 以上のように本実施の形態のレポート管理システム1では、タグデータフロー制御プログラム58によって、タグデータをタグデータフローテーブルTB70によって管理することで、タグ定義テーブルTB20、レポートメタデータテーブルTB50及びセンサデータフローテーブルTB60の変更に基づいて、タグデータの送信先を変更する。このようにタグデータの送信先が動的に適切に変更されることで、大量のセンサデータがやり取りされ、日々データ提供元の状況や、レポートの定義が更新されるような環境でも、煩雑な設定をせずにレポートに付加情報を付与することが可能となる。
 従って、本レポート管理システム1によれば、ユーザは付加情報であるタグデータの送信先を意識することなく、レポートを表示するための情報を変更することが可能となり、データ提供元及びデータ利用先間において適切な付加情報を無駄なくやり取りし得る計算機システム及びデータフロー制御方法を実現できる。
(5)他の実施の形態
 なお上述の実施の形態においては、データ制御計算機4を、データ提供元システム2及びデータ利用先システム3から独立させた場合について述べたが、本発明はこれに限らず、データ制御計算機4をデータ提供元システム2又はデータ利用先システム3内で動作させる等し、レポート管理システム1の構成として広く適用することができる。
 また上述の実施の形態においては、タグデータの送信先を制御して、データ提供元システム2からタグデータを送信することで、レポート管理プログラム42にタグデータが格納される場合について述べたが、本発明はこれに限らず、レポート管理プログラム42がデータ提供元システム2にアクセスしてタグデータを取得しても良い。
 図14にレポート管理プログラム42がデータ提供元システム2にアクセスする場合のレポート管理システム90の構成を示す。レポート管理システム90は、タグデータフロー制御プログラム58を備える代わりにタグデータアクセス制御プログラム93を備える点においてレポート管理システム1と異なる。この差異点のみの説明を行う。
 このタグデータアクセス制御プログラム93が備えるタグデータアクセス管理モジュール94は、図15に示すタグデータアクセス更新処理を行う。タグデータアクセス更新処理のステップSP11~SP14は、タグデータフロー更新処理のステップSP31~SP34と同じであるため、説明を省略する。
 タグデータアクセス管理モジュール94は、タグデータフローテーブルTB70のタグデータにアクセスするための例えばREST API(Representational State Transfer Application Programming Interface)等のアクセス部(以下、これをAPIと呼ぶ)をタグデータアクセス管理モジュール94内に作成することで(SP35)、タグデータへのアクセスを制御する。具体的には、タグデータアクセス管理モジュール94は、タグデータへのアクセスを要求してきた要求元が送信先欄TB72に送信先として格納されている場合のみ、当該送信先と対応するタグID欄TB71に格納されているタグIDのタグデータにアクセスできるように制御する。
 タグデータが大量にある場合や更新頻度が頻繁であるために更新の度にタグデータを送信するのが計算機システムの要件上困難な場合等には、レポートが定義される際や、レポートが生成される際に、レポート管理プログラム42がデータ提供元システム2のタグデータにアクセスすることは有効である。
 さらに上述の実施の形態においては、ユーザによって各種定義情報が入力される場合について述べたが、本発明はこれに限らず、他のシステムで使用している情報を流用しても良い。
 図16に第3の管理装置(以下、これを拠点管理計算機と呼ぶ)102からの情報を流用する場合のレポート管理システム100の構成を示す。レポート管理システム100は、1つ以上の拠点管理計算機102をさらに備える点においてレポート管理システム1と異なる。この差異点のみの説明を行う。
 拠点管理計算機102は、データ提供元システム101のIoT機器7が設置されている現場を拠点として管理するための計算機であって、メモリ104には、拠点の情報を管理するプログラムである拠点管理プログラム109が必要な際に一時的に保持される。なお拠点管理計算機102のハードウェア構成は、データ制御計算機4等と同じであるため説明を省略する。なお拠点管理プログラム109は、拠点の業種等によって機能が異なるが、ここでは、データ提供元システム2が販売店で動作するシステムの場合について説明する。
 拠点管理プログラム109には、拠点管理モジュール110、店舗営業時間テーブルTB80、システム稼働スケジュールテーブルTB90及びシステムイベント管理テーブルTB100が設けられている。
 拠点管理モジュール110は、店舗の営業時間を管理する店舗営業時間テーブルTB80によって管理する営業時間管理機能、販売店で動作する各IoT機器7の稼働スケジュールをシステム稼働スケジュールテーブルTB90によって管理する稼働スケジュール管理機能及び販売店で動作する各IoT機器7や各センサ25の状態をシステムイベント管理テーブルTB100によって管理するシステムイベント管理機能を有するプログラムである。拠点管理モジュール110は、店舗営業時間テーブルTB80、システム稼働スケジュールテーブルTB90及びシステムイベント管理テーブルTB100に格納される値を登録、参照、更新、削除等する。
 店舗営業時間テーブルTB80は、図17に示すように、店舗営業時間を格納するテーブルであって、店舗ID欄TB81、店舗名欄TB82及び営業時間欄TB83を備えて構成される。
 店舗ID欄TB81には、店舗を一意に示す店舗IDが格納される。この店舗IDは、店舗登録時に1から順に採番される。店舗名欄TB82には、店舗の名称を示す店舗名が格納される。この店舗名はタグ定義においてタグ名として使用される。営業時間欄TB83には、店舗の営業時間が「開店時間-閉店時間」の形式で格納される。この店舗の営業時間はタグ定義においてスケジュールとして使用される。
 システム稼働スケジュールテーブルTB90は、図18に示すように、IoT機器7の稼働スケジュールを格納するテーブルであって、イベントID欄TB91、イベント名欄TB92及びスケジュール欄TB93を備えて構成される。イベントID欄TB91には、稼働スケジュールを一意に識別するイベントIDが格納される。このイベントIDは稼働スケジュールの発生時に1から順に採番される。イベント名欄TB92には、稼働スケジュールの内容を示すイベント名が格納されている。このイベント名はタグ定義においてタグ名として使用される。スケジュール欄TB93には、稼働スケジュールが「開始時間-終了時間」の形式で格納される。この稼働スケジュールはタグ定義においてスケジュールとして使用される。
 システムイベント管理テーブルTB100は、図19に示すように、IoT機器7やセンサ25のステータス異常等を格納するテーブルであって、時刻欄TB101、イベントID欄TB102、イベント名欄TB103及び対象センサ欄TB104を備えて構成される。
 時刻欄TB101には、状態異常等が発生した時刻が格納されている。この時刻はタグ定義においてスケジュールとして使用される。イベントID欄TB102には、状態異常等を一意に識別するイベントIDが格納されている。このイベントIDは状態異常時の発生時に1から順に採番される。イベント名欄TB103には、状態異常等の内容を示すイベント名が格納されている。このイベント名はタグ定義においてタグ名として使用される。対象センサ欄TB104には、エラーや警告等が発生したセンサのセンサIDが格納されている。このセンサIDはタグ定義において使用される。なお対象センサ欄TB104に複数のセンサIDが格納される場合はカンマ等で区切られる。
 拠点管理計算機102からの情報を流用する場合には、そのまま使用してもよいし、タグ定義画面71の初期値として使用してもよい。拠点管理計算機102からの情報をタグ定義画面の初期値として使用する場合、タグ管理プログラム17は、タグ定義の入力を受け付ける際に、拠点管理計算機102の拠点管理プログラム109にアクセスし、店舗営業時間テーブルTB80、システム稼働スケジュールテーブルTB90及びシステムイベント管理テーブルTB100からタグ名欄71A、スケジュール欄71B及びセンサ欄71Cに対応する情報を取得し、タグ名欄71A、スケジュール欄71B及びセンサ欄71Cに取得した情報を初期値として表示する。このように初期値が表示されることで、ユーザは初期値からの変更分のみを入力すればよくなり、ユーザの入力負荷が軽減される。
 さらに上述の実施の形態においては、データ提供元システム2は店舗のシステムである場合について述べたが、本発明はこれに限らず、データ提供元システム2は空港に設置されるシステムであっても良く、この場合、データ提供元システム2は、空港名やゲート番号、フライト情報、搭乗率等をタグとして取得する。
 さらに上述の実施の形態においては、IoT機器7に接続されるセンサ25がIoT機器7に内蔵され、内部バスで接続されるようにした場合について述べたが、本発明はこれに限らず、センサ25はIoT機器7に外付けされネットワークインタフェース204を介して接続されるようにしても良い。
 さらに上述の実施の形態においては、1つのユーザインタフェースプログラム35でレポート管理システム1の各種定義情報をユーザが集中管理する構成とするようにした場合について述べたが、本発明はこれに限らず、対象となるプログラムに応じて、複数のユーザインタフェースに分かれるようにしても良い。例えば、タグ定義に関してはセンサ管理計算機6の入出力装置10から運用管理者によって随時入力され、センサデータフロー定義に関してはデータ制御計算機4の入出力装置50から開発者によって随時入力され、レポート定義に関してはレポート管理計算機28から開発者によって随時入力されるようにしてもよい。
 さらに上述の実施の形態においては、ユーザ端末27がデータ利用先システム3上で動作するようにした場合について述べたが、本発明はこれに限らず、ユーザ端末27がデータ利用先システム3以外で動作するようにしても良い。
 1,90,100……レポート管理システム、2……データ提供元システム、3……データ利用先システム、4,91……データ制御計算機、5……ネットワーク、6……センサ管理計算機、7……IoT機器、8,20,29,36,48,103……CPU、9,21,30,37,49,92,104……メモリ、10,22,31,38,50,105……入出力装置、11,23,32,39,51,106……ストレージ装置、12,24,33,40,52,107……ネットワークインタフェース、14……センサ管理プログラム、17……タグ管理プログラム、35……ユーザインタフェースプログラム、42……レポート管理プログラム、54……センサデータ処理プログラム、58……タグデータフロー制御プログラム。

Claims (8)

  1.  データ提供元システムと、
     データ利用先システムと、
     データ提供元システムからデータ利用先システムへのデータフローを制御するデータ制御計算機と、
     を備える計算機システムであって、
     前記データ提供元システムは、
     センサを有する機器と、
     前記センサの検出データであるセンサデータと、前記センサから直接取得することができないデータを前記センサデータと関連付けたタグデータと、を夫々管理する第1の管理装置と、
     を備え、
     前記データ利用先システムは、
     前記タグデータに基づいて、前記センサデータを利用するデータ管理を実行する第2の管理装置を備え、
     前記データ制御計算機は、
     前記データ提供元システムから前記データ利用先システムへの前記センサデータのフローと、
     前記データ提供元システムから前記データ利用先システムへの前記タグデータのフローと、
     を夫々制御し、
     前記タグデータのフローの更新の要否を判定し、
     当該判定を肯定すると、前記センサデータのフローに基づいて、前記データ利用先システムに送信される前記センサデータから、前記データ利用先システムに送信される前記タグデータを決定し、
     当該決定に基づいて、前記タグデータのフローを更新する
     計算機システム。
  2.  前記データ制御計算機は、
     前記センサデータのフロー、前記データ管理及び前記タグデータのいずれか1つ以上の情報が更新されたことを検知すると、当該情報に含まれる前記センサデータを利用する前記データ利用先システムに対して、当該センサデータに関連する前記タグデータを送信するように、前記タグデータのフローに含まれる前記タグデータの送信先を更新する
     請求項1記載の計算機システム。
  3.  第1の管理装置は、
     前記タグデータの送信先の更新に基づいて、前記第2の管理装置に前記タグデータを送信する
     請求項2記載の計算機システム。
  4.  前記データ制御計算機は、前記タグデータの送信先の更新に基づいて、前記第2の管理装置が前記タグデータにアクセスできるようにするためのアクセス部を作成し、
     前記第2の管理装置は、前記アクセス部を介して、前記第1の管理装置の前記タグデータにアクセスする
     請求項2記載の計算機システム。
  5.  前記データ提供元システムは、第3の管理装置を備え、
     第3の管理装置は、前記センサから直接取得することができないデータを管理し、
     第1の管理装置は、第3の管理装置から前記センサから直接取得することができないデータを取得する
     請求項2記載の計算機システム。
  6.  前記センサデータのフロー、前記データ管理及び前記タグデータの前記情報を表示する
     請求項2記載の計算機システム。
  7.  前記タグデータのフローを表示する
     請求項2記載の計算機システム。
  8.  データ提供元システムからデータ利用先システムへのデータフローをデータ制御計算機が制御する計算機システム制御方法であって、
     前記データ提供元システムが、
     第1の管理装置によって、センサの検出データであるセンサデータと、センサから直接取得することができないデータをセンサデータと関連付けたタグデータと、を夫々管理し、
     前記データ利用先システムが、
     第2の管理装置によって、前記タグデータに基づいて、前記センサデータを利用するデータ管理を実行し、
     前記データ制御計算機が、
     前記データ提供元システムから前記データ利用先システムへの前記センサデータのフローと、前記データ提供元システムから前記データ利用先システムへの前記タグデータのフローと、を夫々制御し、前記タグデータのフローの更新の要否を判定し、当該判定を肯定すると、前記センサデータのフローに基づいて、前記データ利用先システムに送信される前記センサデータから前記データ利用先システムに送信される前記タグデータを決定し、当該決定に基づいて前記タグデータのフローを更新する
     データフロー制御方法。
PCT/JP2017/013685 2017-03-31 2017-03-31 計算機システム及びデータフロー制御方法 Ceased WO2018179364A1 (ja)

Priority Applications (2)

Application Number Priority Date Filing Date Title
PCT/JP2017/013685 WO2018179364A1 (ja) 2017-03-31 2017-03-31 計算機システム及びデータフロー制御方法
JP2019508133A JP6685468B2 (ja) 2017-03-31 2017-03-31 計算機システム及びデータフロー制御方法

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
PCT/JP2017/013685 WO2018179364A1 (ja) 2017-03-31 2017-03-31 計算機システム及びデータフロー制御方法

Publications (1)

Publication Number Publication Date
WO2018179364A1 true WO2018179364A1 (ja) 2018-10-04

Family

ID=63677435

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/JP2017/013685 Ceased WO2018179364A1 (ja) 2017-03-31 2017-03-31 計算機システム及びデータフロー制御方法

Country Status (2)

Country Link
JP (1) JP6685468B2 (ja)
WO (1) WO2018179364A1 (ja)

Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2014041826A1 (ja) * 2012-09-12 2014-03-20 オムロン株式会社 データフロー制御指令発生装置およびセンサ管理装置
JP2015226102A (ja) * 2014-05-26 2015-12-14 オムロン株式会社 仮想センサのメタデータ構造

Patent Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2014041826A1 (ja) * 2012-09-12 2014-03-20 オムロン株式会社 データフロー制御指令発生装置およびセンサ管理装置
JP2015226102A (ja) * 2014-05-26 2015-12-14 オムロン株式会社 仮想センサのメタデータ構造

Also Published As

Publication number Publication date
JPWO2018179364A1 (ja) 2019-06-27
JP6685468B2 (ja) 2020-04-22

Similar Documents

Publication Publication Date Title
JP6879961B2 (ja) プロセスデータを表示するための方法および装置、及び機械アクセス可能媒体
US11181382B2 (en) Generating maps of private spaces using mobile computing device sensors
US20160103750A1 (en) Application programming interface monitoring tool notification and escalation method and system
AU2017261597B2 (en) Portal for automatic software installation and configuration
US20170372010A1 (en) Using sensors and location to trigger events and share data
CN102473228A (zh) 终端设备、通信系统、数据管理方法、服务器设备和记录介质
JP2021502732A (ja) ゲートウェイ管理コンソールにアクセスするためのコンピュータ処理方法、装置、システム、およびプログラム
US20190272728A1 (en) Translating building automation events into mobile notifications
US9888084B2 (en) Automatic network domain diagnostic repair and mapping
EP4033467B1 (en) Instructions and method for commissioning a fire system
CN110598093B (zh) 一种业务规则管理方法及装置
US20090138510A1 (en) Method and apparatus for associating help desk ticket with affected data processing system
JP6685468B2 (ja) 計算機システム及びデータフロー制御方法
WO2019031161A1 (ja) センサ管理ユニット、センサ装置、センサ管理方法及びセンサ管理プログラム
CN112558983A (zh) 可执行文件的生成和执行方法、装置、电子终端及介质
CN110083509A (zh) 一种日志数据的规整方法及装置
US20220291954A1 (en) Computer System and Field Operation Supporting Method
US10930390B2 (en) Task management tool for patient discharge
JP5233121B2 (ja) 画面表示情報連携方法および画面表示情報連携システム
KR101580037B1 (ko) Vdi의 클라이언트 제어를 이용한 관제 시스템
HK1171842B (en) Generating maps of private spaces using mobile computing device sensors
WO2017199336A1 (ja) 保守管理装置、保守管理システム及びプログラム
JP2009157644A (ja) 統合運用管理システム、統合運用管理方法及びプログラム及び記録媒体

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 17903937

Country of ref document: EP

Kind code of ref document: A1

ENP Entry into the national phase

Ref document number: 2019508133

Country of ref document: JP

Kind code of ref document: A

NENP Non-entry into the national phase

Ref country code: DE

122 Ep: pct application non-entry in european phase

Ref document number: 17903937

Country of ref document: EP

Kind code of ref document: A1