[go: up one dir, main page]

WO2018180369A1 - センサネットワークシステム - Google Patents

センサネットワークシステム Download PDF

Info

Publication number
WO2018180369A1
WO2018180369A1 PCT/JP2018/009230 JP2018009230W WO2018180369A1 WO 2018180369 A1 WO2018180369 A1 WO 2018180369A1 JP 2018009230 W JP2018009230 W JP 2018009230W WO 2018180369 A1 WO2018180369 A1 WO 2018180369A1
Authority
WO
WIPO (PCT)
Prior art keywords
sensor
sensor data
data
communication line
gateway
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/JP2018/009230
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.)
NEC Corp
Original Assignee
NEC Corp
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 NEC Corp filed Critical NEC Corp
Priority to US16/491,232 priority Critical patent/US11102123B2/en
Priority to JP2019509157A priority patent/JP6746087B2/ja
Publication of WO2018180369A1 publication Critical patent/WO2018180369A1/ja
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Images

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00Traffic control in data switching networks
    • H04L47/10Flow control; Congestion control
    • H04L47/11Identifying congestion
    • GPHYSICS
    • G08SIGNALLING
    • G08CTRANSMISSION SYSTEMS FOR MEASURED VALUES, CONTROL OR SIMILAR SIGNALS
    • G08C15/00Arrangements characterised by the use of multiplexing for the transmission of a plurality of signals over a common path
    • GPHYSICS
    • G16INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR SPECIFIC APPLICATION FIELDS
    • G16YINFORMATION AND COMMUNICATION TECHNOLOGY SPECIALLY ADAPTED FOR THE INTERNET OF THINGS [IoT]
    • G16Y40/00IoT characterised by the purpose of the information processing
    • G16Y40/20Analytics; Diagnosis
    • GPHYSICS
    • G16INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR SPECIFIC APPLICATION FIELDS
    • G16YINFORMATION AND COMMUNICATION TECHNOLOGY SPECIALLY ADAPTED FOR THE INTERNET OF THINGS [IoT]
    • G16Y40/00IoT characterised by the purpose of the information processing
    • G16Y40/30Control
    • G16Y40/35Management of things, i.e. controlling in accordance with a policy or in order to achieve specified objectives
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L12/00Data switching networks
    • H04L12/66Arrangements for connecting between networks having differing types of switching systems, e.g. gateways
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00Arrangements for monitoring or testing data switching networks
    • H04L43/08Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
    • H04L43/0852Delays
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00Arrangements for monitoring or testing data switching networks
    • H04L43/08Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
    • H04L43/0876Network utilisation, e.g. volume of load or congestion level
    • H04L43/0894Packet rate
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00Arrangements for monitoring or testing data switching networks
    • H04L43/10Active monitoring, e.g. heartbeat, ping or trace-route
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00Traffic control in data switching networks
    • H04L47/10Flow control; Congestion control
    • H04L47/28Flow control; Congestion control in relation to timing considerations
    • H04L47/283Flow control; Congestion control in relation to timing considerations in response to processing delays, e.g. caused by jitter or round trip time [RTT]
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L49/00Packet switching elements
    • H04L49/30Peripheral units, e.g. input or output ports
    • H04L49/3027Output queuing
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/12Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04QSELECTING
    • H04Q9/00Arrangements in telecontrol or telemetry systems for selectively calling a substation from a main station, in which substation desired apparatus is selected for applying a control signal thereto or for obtaining measured values therefrom

Definitions

  • the present invention relates to a sensor network system, a server device, a sensor data collection control method, a gateway device, and a program.
  • the sensor network system is a kind of IoT (Internet of Things) system.
  • the sensor device includes a sensor, a communication device, and a microcomputer, performs observation with the sensor, and transmits the obtained sensor data by wire or wirelessly.
  • the gateway device includes a communication device and a microcomputer, and transmits sensor data received from the sensor device to the server device through a communication line such as Ethernet (registered trademark).
  • the server device collects sensor data from the gateway device through the communication line, and stores, analyzes, displays, and notifies the application of sensor data.
  • An object of the present invention is to provide a sensor network system, a server device, a sensor data collection control method, and a gateway device that solve the above-described problem, that is, when communication line congestion occurs, it is difficult to eliminate the problem. And providing a program.
  • a sensor network system includes: A sensor including one or more gateway devices that collect sensor data from one or more sensor devices, and a server device that is connected to the gateway device through a communication line and collects the sensor data from the gateway device through the communication line A network system, The server device The congestion degree of the communication line is determined based on a difference between a transmission time and a reception time of the sensor data transmitted from the gateway device to the server device and a communication time in a state in which no congestion occurs.
  • a determination unit Based on the determination result of the degree of congestion of the communication line, the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data are determined, and the determination is made to the gateway device.
  • a server device is A server device that is connected to a gateway device that collects sensor data from a sensor device through a communication line, and that collects the sensor data from the gateway device through the communication line, Determining the degree of congestion of the communication line based on the difference between the time difference between the transmission time and the reception time of the sensor data transmitted from the gateway device to the server device and the communication time when no congestion occurs
  • a determination unit to perform, Based on the determination result of the degree of congestion of the communication line, the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data are determined, and the determination is made to the gateway device.
  • a control unit for sending instructions including contents; including.
  • a gateway device is A gateway device that collects sensor data from one or more sensor devices and transmits the sensor data to a server device via a communication line, An instruction for identifying the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data, determined based on the degree of congestion of the communication line, is sent from the server device through the communication line.
  • a control unit that selects the sensor data to be transmitted to the server device from the sensor data of the sensor device according to the instruction and creates transmission data.
  • a sensor data collection control method includes: A sensor data collection control method executed by a server device connected via a communication line to a gateway device that collects sensor data from a sensor device and collecting the sensor data from the gateway device via the communication line, Determining the degree of congestion of the communication line based on the difference between the time difference between the transmission time and the reception time of the sensor data transmitted from the gateway device to the server device and the communication time when no congestion occurs And Based on the determination result of the degree of congestion of the communication line, the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data are determined, and the determination is made to the gateway device. Send out instructions with content.
  • a program is A computer connected through a communication line to a gateway device that collects sensor data from the sensor device, and collecting the sensor data from the gateway device through the communication line;
  • the congestion degree of the communication line is determined based on a difference between a transmission time and a reception time of the sensor data transmitted from the gateway device to the computer and a communication time in a state where no congestion occurs.
  • a determination unit Based on the determination result of the degree of congestion of the communication line, the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data are determined, and the determination is made to the gateway device.
  • a transmission data control unit for sending an instruction including contents; And make it work.
  • the present invention has the above-described configuration, when congestion occurs in the communication line connecting the gateway device and the server device, it can be detected and eliminated.
  • FIG. 1 is a block diagram of a sensor network system according to a first embodiment of the present invention. It is a figure which shows the example of the content of the unsent data list in the 1st Embodiment of this invention. It is a figure which shows the example of the content of the sensor information list in the 1st Embodiment of this invention. It is a figure which shows the example of the content of the edge communication information list in the 1st Embodiment of this invention. It is a block diagram which shows an example of the hardware constitutions of the edge gateway and aggregation server in the 1st Embodiment of this invention. It is a flowchart which shows an example of operation
  • the present embodiment relates to a sensor network system that collects sensor data of a sensor device installed in a remote place by a server via an edge gateway.
  • the server in the present embodiment estimates the congestion state of the communication line connecting the edge gateway and the server from the change in time required for transmission and reception of sensor data sent from the edge gateway to the server. Then, when the communication line is congested, the server issues an instruction to suppress the communication amount to the edge gateway that performs communication related to the extension of the communication time in order to eliminate the congestion state of the communication line.
  • the edge gateway that has received the instruction stops transmission of data of the sensor device designated by the instruction among the connected sensor devices. Or the edge gateway which received the said instruction
  • this embodiment simply estimates the congestion state of the communication line used by the sensor network system.
  • this embodiment limits the communication band used by the sensor network system during congestion. As a result, the congestion state of the communication line is eliminated, and other systems that use the same line can preferentially use the communication line.
  • Such a problem also exists in a sensor network system that is a kind of IoT system that collects sensor data from one or more edge gateways to which sensor devices are connected and stores them in a remote server.
  • a sensor network system shares a communication line with other systems, it is possible to avoid congestion while reducing the impact on each other's system, and to preferentially send and receive data with higher urgency and importance. Is expected.
  • the server calculates the time required for communication from the difference between the data transmission time and the reception time in communication with the edge gateway.
  • the calculated communication time varies depending on the congestion state of the communication line.
  • the server determines whether the communication line is congested by comparing the calculated communication time with the communication time (predetermined) when the communication line is not congested.
  • the server must reduce the amount of transmission data that should be reduced to bring the communication to the normal communication status when the communication line is congested. Calculate Then, the server issues an instruction to stop transmission of a part of the sensor data to the edge gateway in order to reduce the data transmission amount by the calculated amount. As a result, the total amount of sensor data transmitted from the edge gateway to the server is reduced, and congestion of the communication line is alleviated. As a result, communication line congestion is eliminated.
  • the collection of sensor data that does not require real-time characteristics is intentionally delayed in order to contribute to the elimination of congestion on the communication line.
  • the server applies the above measures to a plurality of edge gateways connected through the communication line, thereby suppressing the influence of the IoT system on the congestion of the communication line.
  • FIG. 1 is a block diagram of a sensor network system according to the first embodiment of the present invention.
  • the sensor network system according to the present embodiment is a system that collects and accumulates images of visitors by installing a card reader and a monitoring camera at an appropriate place such as an entrance gate of an office building. Therefore, the sensor network system according to the present embodiment includes the edge gateway 100 connected to the card reader 110 and the monitoring camera 120, the edge gateway 200 connected to the card reader 210 and the monitoring camera 220, the card reader 310 and the monitoring. An edge gateway 300 connected to the camera 320 is included.
  • the sensor network system according to this embodiment includes one aggregation server 400. The aggregation server 400 is connected to the three edge gateways 100, 200, and 300 through the network NW.
  • the network NW is not dedicated to the sensor network system but is shared with other systems.
  • the other system include, but are not limited to, a database system installed in an office building, a mail system, and a voice call system.
  • office building communication communication performed by another system through the network NW is referred to as office building communication.
  • a condition is imposed that communication in an office building is given priority over communication by a sensor network system.
  • the edge gateway 100 includes a network communication unit 101, a transmission data selection creation unit 102, a sensor data storage unit 103, a reception data analysis unit 104, a sensor information storage unit 105, and a sensor control unit 106 as main functional units. .
  • the sensor control unit 106 controls the card reader 110 and the monitoring camera 120 which are sensors. For example, when an employee card is held over the card reader 110, the employee card data is read by the card reader 110 and transmitted to the sensor control unit 106. The sensor control unit 106 receives the transmitted employee ID data and transmits it to the sensor data storage unit 103. In addition, the sensor control unit 106 transmits an image acquisition request to the monitoring camera 120 in conjunction with the reception of the employee card data in order to acquire data such as the face image of the employee holding the employee card. . When the monitoring camera 120 acquires and transmits data such as an employee's face image in response to the acquisition request, the sensor control unit 106 receives this data and transmits it to the sensor data storage unit 103.
  • the sensor data storage unit 103 records and manages the sensor data received from the sensor control unit 106 in the storage unit for each sensor and in the order of arrival.
  • the sensor data storage unit 103 has an untransmitted data list 109 that is management information of the stored sensor data.
  • FIG. 2 shows an example of the contents of the untransmitted data list 109.
  • the untransmitted data list 109 in this example has an entry corresponding to the sensor on a one-to-one basis, and each entry includes a sensor data name and the number of untransmitted data.
  • the entry on the first line of the untransmitted data list 109 indicates that the number of untransmitted data of the card reader 110 is zero.
  • the entry on the second line of the untransmitted data list 109 indicates that the number of untransmitted data of the monitoring camera 120 is zero.
  • the sensor data storage unit 103 increments the number of untransmitted data of the card reader 110 in the untransmitted data list 109 by 1 each time one piece of employee card data is received from the card reader 110. Further, every time one piece of image data is received from the monitoring camera 120, the sensor data storage unit 103 increments the number of untransmitted data of the monitoring camera in the untransmitted data list 109 by one.
  • the sensor information storage unit 105 manages the sensor data names transmitted from the edge gateway 100 to the aggregation server 400 and the number of transmittable data.
  • the sensor information storage unit 105 includes a sensor information list 107.
  • FIG. 3 is a diagram showing an example of the contents of the sensor information list 107.
  • the sensor information list 107 in this example has one-to-one entries corresponding to the sensors, and each entry is composed of a sensor data name and a transmittable number.
  • the entry in the first line of the sensor information list 107 represents that the number of transmittable cards by the card reader 110 is one.
  • the entry in the second row of the sensor information list 107 indicates that the number of transmissions of the monitoring camera 120 is 1.
  • the sensor information storage unit 105 updates the transmittable number in the sensor information list 107 in accordance with the instruction sent from the aggregation server 400 extracted by the received data analysis unit 104.
  • the transmission data selection creation unit 102 creates data to be transmitted from the edge gateway 100 to the aggregation server 400.
  • the transmission data selection creation unit 102 refers to the sensor information list 107 and determines the type and number of sensor data included in the data to be transmitted to the aggregation server 400. For example, when the sensor information list 107 has the contents shown in FIG. 3, the transmission data selection creation unit 102 includes the sensor data of the card reader 110 in the transmission data up to one and includes the sensor data of the monitoring camera 120. 1 is included in the transmission data up to the upper limit.
  • the transmission data selection creation unit 102 extracts sensor data to be included in the transmission data from the sensor data storage unit 103 in chronological order.
  • the transmission data selection creation unit 102 decrements the number of untransmitted data in the untransmitted data list 109 corresponding to the type of extracted sensor data by one. . Further, the transmission data selection creation unit 102 acquires the current time as the transmission time, creates a time stamp of the transmission time, and includes it in the transmission data.
  • the network communication unit 101 manages communication between the edge gateway 100 and the aggregation server 400.
  • the network communication unit 101 transmits the transmission data created by the transmission data selection creation unit 102 to the aggregation server 400 through the network NW. Further, the network communication unit 101 transmits the data received from the aggregation server 400 to the reception data analysis unit 104 through the network NW.
  • the reception data analysis unit 104 analyzes the reception data.
  • the received data analysis unit 104 analyzes the received data and detects an instruction from the aggregation server 400
  • the received data analysis unit 104 transmits the detected instruction to the sensor information storage unit 105.
  • the sensor information storage unit 105 updates the transmittable number of the sensor information list 107 in accordance with the instruction transmitted from the reception data analysis unit 104.
  • the edge gateways 200 and 300 have the same configuration as the edge gateway 100.
  • the aggregation server 400 includes a network communication unit 401, a transmission data creation unit 402, a communication data amount difference calculation unit 403, a reception data analysis unit 404, a sensor data storage unit 405, an edge information storage unit 406, and a sensor as main functional units.
  • a data transmission instruction determination unit 408 is included.
  • the network communication unit 401 manages communication between the aggregation server 400 and the edge gateways 100, 200, and 300.
  • the network communication unit 401 transmits the transmission data created by the transmission data creation unit 402 to the destination edge gateways 100, 200, and 300 via the network NW.
  • the network communication unit 401 acquires the current time as the reception time, creates a timestamp of the reception time, and sets the received data and the reception time.
  • the time stamp is transmitted to the received data analysis unit 404.
  • the network communication unit 401 sets the reception time to, for example, the time when the aggregation server 400 receives the first frame including the time stamp of the transmission time of the sensor data from the edge gateway.
  • the reception data analysis unit 404 analyzes the reception data received from the edge gateways 100, 200, and 300.
  • the reception data analysis unit 404 analyzes the reception data received from the edge gateways 100, 200, and 300 to detect the sensor data and the time stamp of the transmission time, the received data time stamp generated by the network communication unit 401 is received. Is transmitted to the sensor data storage unit 405.
  • the sensor data storage unit 405 stores the sensor data received from the reception data analysis unit 404 from the edge gateways 100, 200, and 300, the time stamp of the transmission time, and the time stamp of the reception time in the storage unit for each edge gateway. save.
  • the sensor data storage unit 405 transmits the sensor data received from the reception data analysis unit 404, the transmission time stamp, and the reception time stamp to the communication data amount difference calculation unit 403 for each edge gateway.
  • the edge information storage unit 406 manages information related to sensor data to be collected from the edge gateway.
  • the edge information storage unit 406 includes an edge communication information list 407.
  • FIG. 4 shows an example of the contents of the edge communication information list 407.
  • the edge communication information list 407 has one-to-one entries corresponding to the sensors, and each entry includes an edge gateway name, a sensor data name, a priority, an average data size, an average transmission time, and a number that can be transmitted. Consists of For example, in the entry on the first line of the edge communication information list 407, the priority of the card reader 110 of the edge gateway 100 is “medium”, the average data size of the sensor data is 10 bytes, and the average transmission time is 0. 00001 ms, indicating that the number of possible transmissions is 1.
  • the priority of the monitoring camera 120 of the edge gateway 100 is “medium”, the average data size of the sensor data is 1 Mbyte, and the average transmission time is 10 s. Yes, the number of possible transmissions is one.
  • the average transmission time represents a communication time required for transmitting sensor data having an average data size from the edge gateway 100 to the aggregation server 400 during a time period when the communication line is free.
  • the edge gateway name, sensor data name, priority, average data size, and average transmission time in the edge communication information list 407 are initially set before the operation of the sensor network system is started. As shown in the example of the average data size, the sensor data amount of the card reader is sufficiently smaller than the sensor data amount of the monitoring camera.
  • the transmittable number in the edge communication information list 407 is dynamically updated by the sensor data transmission instruction determination unit 408 during operation of the sensor network system.
  • the communication data amount difference calculation unit 403 calculates the communication speed S between the edge gateway and the aggregation server 400 from the received data size D and the communication time t by the following equation.
  • S D / t (2)
  • the communication speed S represents the maximum transfer amount per unit time.
  • the communication data amount difference calculation unit 403 acquires the average transmission time required for sensor data transmission from the edge gateway during the time when the communication line is free from the edge communication information list 407, and at the current communication speed S. The amount of communication that can be transmitted during this average transmission time is calculated.
  • the communication data amount difference calculation unit 403 obtains the data amount obtained by subtracting the data amount received this time from the communication amount WD s that can be transmitted at the average transmission time at the current communication speed S, as the excess DF of the communication data amount. Calculate as The excess DF of the communication data amount is 0 or a positive value when the communication line is free. Further, the excess DF of the communication data amount takes a negative value when the communication line is congested.
  • the communication data amount difference calculation unit 403 transmits the excess DF of the communication data related to the edge gateway to the sensor data transmission instruction determination unit 408.
  • the sensor data transmission instruction determination unit 408 determines an instruction including information on sensor data that permits transmission, the number of possible transmissions, and sensor data that prohibits transmission, to the edge gateways 100, 200, and 300.
  • the sensor data transmission instruction determination unit 408 receives an excess of communication data related to a certain edge gateway from the communication data amount difference calculation unit 403, the sensor data transmission instruction determination unit 408 performs the following processing.
  • the sensor data transmission instruction determination unit 408 determines whether the excess of communication data is 0 or more or less than 0. If the excess of communication data is 0 or more, the communication line from the edge gateway to the aggregation server 400 is free, so the sensor data transmission instruction determination unit 408 keeps the communication amount as it is or Judge that it may be increased. On the other hand, if the excess of communication data is less than 0, the communication line from the edge gateway to the aggregation server 400 is congested, so the sensor data transmission instruction determination unit 408 must reduce the communication amount from the current level. Judge that it must be.
  • the sensor data transmission instruction determination unit 408 creates an instruction by using the transmission possible number of each sensor data recorded in the edge communication information list 407 for the edge gateway as it is when the communication amount is kept as it is.
  • the sensor data transmission instruction determination unit 408 reduces at least one of the possible transmission numbers of each sensor data recorded in the edge communication information list 407 for the edge gateway by at least one. Update is performed, and an instruction is generated using the number of transmittable sensor data recorded in the updated edge communication information list 407.
  • the sensor data transmission instruction determination unit 408 determines sensor data for reducing the number of transmissions as follows, for example.
  • the sensor data transmission instruction determination unit 408 confirms the number of transmittable sensor data of the edge gateway from the edge communication information list 407.
  • the sensor data transmission instruction determination unit 408 determines sensor data for reducing the transmittable number from the sensor data whose transmittable number is 1 or more.
  • the sensor data transmission instruction determination unit 408 determines sensor data for reducing the transmittable number in consideration of at least one of sensor data priority, average data size, transmittable number, and excess amount. To do. For example, when there is a difference in the priority of a plurality of sensor data whose transmittable number is 1 or more, the sensor data transmission instruction determining unit 408 keeps the number of transmittable sensor data having the lowest priority among them constant. Reduce by the number.
  • the sensor data transmission instruction determination unit 408 is closest to the excess absolute value of the sensor data amount if there is no difference in the priority of the plurality of sensor data whose transmittable number is 1 or more. The number of transmittable sensor data having an average data size is reduced by one. Alternatively, the sensor data transmission instruction determination unit 408 reduces the number of sensor data transmissions that can be reduced by a data amount that substantially matches the surplus absolute value of the sensor data amount by 1 in order from the lowest priority.
  • the sensor data transmission instruction determination unit 408 increases at least one of the possible transmission numbers of each sensor data recorded in the edge communication information list 407 for the edge gateway by at least one. Update is performed, and an instruction is generated using the number of transmittable sensor data recorded in the updated edge communication information list 407.
  • the sensor data transmission instruction determination unit 408 determines sensor data that increases the number of transmissions as follows, for example.
  • the sensor data transmission instruction determination unit 408 confirms the number of transmittable sensor data of the edge gateway from the edge communication information list 407.
  • the sensor data transmission instruction determination unit 408 has sensor data whose transmission possible number is 0 (if there is no such sensor data, sensor data whose transmission possible number is equal to or less than a threshold such as “1”). ) To determine sensor data that increases the number of possible transmissions.
  • the sensor data transmission instruction determination unit 408 determines sensor data that increases the number of transmissions in consideration of at least one of the priority, average data size, number of transmissions, and excess amount of sensor data. To do.
  • the sensor data transmission instruction determination unit 408 increases the number of sensor data that can be transmitted with the highest priority by a certain number. Alternatively, if there is no difference in the priority of the plurality of sensor data, the sensor data transmission instruction determination unit 408 can transmit the sensor data having the average data size closest to the excess absolute value of the sensor data amount. Is increased by one. Alternatively, the sensor data transmission instruction determination unit 408 increases the number of sensor data transmissions that can be increased by a data amount that substantially matches the excess absolute value of the sensor data amount by 1 in order from the highest priority.
  • the transmission data creation unit 402 creates transmission data including instructions for the edge gateways 100, 200, and 300 received from the sensor data transmission instruction determination unit 408 and transmits the transmission data to the network communication unit 401. This transmission data is created as a response to the sensor data received from the edge gateways 100, 200, 300.
  • Each of the edge gateways 100, 200, 300 and the aggregation server 400 described above includes, for example, an operation input unit 1001 such as a keyboard and a mouse, a screen display unit 1002 such as a liquid crystal display, and a communication interface unit as illustrated in FIG. 1003, an information processing apparatus 1006 such as a personal computer having a storage unit 1004 such as a memory or a hard disk, and an arithmetic processing unit 1005 such as one or more microprocessors, and a program 1007.
  • an operation input unit 1001 such as a keyboard and a mouse
  • a screen display unit 1002 such as a liquid crystal display
  • a communication interface unit as illustrated in FIG. 1003
  • an information processing apparatus 1006 such as a personal computer having a storage unit 1004 such as a memory or a hard disk
  • an arithmetic processing unit 1005 such as one or more microprocessors
  • the program 1007 is read into the memory from an external computer-readable storage medium when the information processing apparatus 1006 is started up, and controls the operation of the arithmetic processing unit 1005.
  • the program 1007 in the edge gateways 100, 200, and 300, on the arithmetic processing unit 1005, the network communication unit 101, the transmission data selection / creation unit 102, the sensor data storage unit 103, the reception data analysis unit 104, Functional means such as the sensor information storage unit 105 and the sensor control unit 106 are realized.
  • the program 1007 includes a network communication unit 401, a transmission data creation unit 402, a communication data amount difference calculation unit 403, a reception data analysis unit 404, a sensor data storage unit 405, and an edge information storage unit 406.
  • Functional means such as the sensor data transmission instruction determination unit 408 are realized.
  • 6 and 7 are flowcharts showing an example of the operation of the edge gateway 100.
  • the operation of the edge gateway 100 will be described with reference to FIGS. 6 and 7.
  • the operations of the edge gateways 200 and 300 are the same as the operation of the edge gateway 100.
  • the sensor control unit 106 of the edge gateway 100 sets the card reader 110 in a standby state (step S101).
  • the sensor control unit 106 determines whether data is generated in the card reader 110 (step S102). For example, as shown in FIG. 8, when the employee ID card 113 is held over the card reader 110, the information on the employee ID card 113 is read by the card reader 110 and data is generated. If data is not generated in the card reader 110, the sensor control unit 106 still places the card reader 110 in a standby state (step S101).
  • the sensor control unit 106 receives data from the card reader 110 (step S103).
  • the sensor control unit 106 issues a recording instruction to the monitoring camera 120 (step S104).
  • the monitoring camera 120 acquires and records image data of employees passing through the card reader 110 as shown in FIG.
  • the sensor control unit 106 receives the recorded data from the monitoring camera 120 (step S105).
  • the sensor data storage unit 103 receives and stores the data of the card reader 110 and the data of the monitoring camera 120 from the sensor control unit 106, and updates the untransmitted data list 109 (step S106). That is, the sensor data storage unit 103 adds 1 to the number of untransmitted data of the card reader 110 and the number of untransmitted data of the monitoring camera 120 recorded in the untransmitted data number list 109.
  • the transmission data selection creation unit 102 acquires the untransmitted data list 109 from the sensor data storage unit 103 and confirms the number of untransmitted data of the card reader 110 and the monitoring camera 120 (step S107). Further, the transmission data selection creation unit 102 acquires the sensor information list 107 from the sensor information storage unit 105, and confirms the transmittable numbers of the card reader 110 and the monitoring camera 120 (step S108). The transmission data selection creation unit 102 then stores the sensor data stored in the sensor data storage unit 103 if the number of transmissions is 1 or more for all sensors (that is, the card reader 110 and the monitoring camera 120). As many sensor data as possible for transmission are extracted from the oldest and added to the transmission target (steps S109 to S112).
  • the transmission data selection creation unit 102 reduces and updates the number of untransmitted data recorded in the untransmitted data list 109 by the amount added to the transmission target for all sensors (step S113).
  • the transmission data selection creation unit 102 creates transmission data from the time stamp of the current time (time stamp of the transmission time) and the transmission target (step S114).
  • the network communication unit 101 transmits the transmission data created by the transmission data selection creation unit 102 to the aggregation server 400 through the communication line of the network NW (step S115). Thereafter, the network communication unit 101 waits to receive a reply from the aggregation server 400 (steps S116 and S117). Then, when the network communication unit 101 receives a reply from the aggregation server 400, the network communication unit 101 transmits the received data to the reception data analysis unit 104 (step S118).
  • the received data analysis unit 104 extracts an indication of the number of sensor data that can be transmitted from the aggregation server 400 from the received data (step S119).
  • the sensor information storage unit 105 updates the value of the transmittable number in the sensor information list 107 in accordance with the instruction extracted by the received data analysis unit 104 (step S120).
  • the edge gateway 100 returns to the process of step S101.
  • FIG. 9 is a flowchart illustrating an example of operations performed by the aggregation server 400 on the edge gateway 100.
  • the operation executed by the aggregation server 400 for the edge gateway 100 will be described with reference to FIG.
  • the operation performed by the aggregation server 400 for the edge gateways 200 and 300 is the same as the operation performed for the edge gateway 100.
  • the network communication unit 401 of the aggregation server 400 is waiting to receive a message from the edge gateway 100 (steps S131 and S132).
  • the network communication unit 401 When receiving a message from the edge gateway 100, the network communication unit 401 generates a time stamp of the reception time, and transmits the reception data and the time stamp of the reception time to the reception data analysis unit 404 (step S133).
  • the reception data analysis unit 404 analyzes the received reception data, extracts sensor data and a time stamp of transmission time, and transmits them and a time stamp of reception time to the sensor data storage unit 405 (step S134). .
  • the sensor data storage unit 405 stores the stored sensor data, the time stamp of the transmission time, and the time stamp of the reception time in the storage device and saves them (step S135). Next, the sensor data storage unit 405 transmits the stored sensor data, transmission time, time stamp, and reception time stamp to the communication data amount difference calculation unit 403 (step S136).
  • the communication data amount difference calculation unit 403 calculates a communication time and a communication speed based on the passed sensor data, the transmission time stamp, and the reception time stamp (step S137).
  • the communication data amount difference calculation unit 403 calculates the difference between the time stamp of the reception time and the time stamp of the transmission time as the time taken for communication. Also, the communication speed is calculated from the size of the received data and the calculated communication time.
  • the communication data amount difference calculation unit 403 determines, based on the edge communication information list 407 in the edge information storage unit 406, the time (average transmission time) required for sensor data transmission from the edge gateway 100 during a time period when the communication line is free. Is acquired (step S138).
  • the communication data amount difference calculation unit 403 calculates an excess of communication data from the acquired average transmission time, the communication speed calculated in step S137, and the received data amount (step S139).
  • the sensor data transmission instruction determination unit 408 acquires the edge communication information list 407, and acquires the priority, average data size, and transmittable number of sensors connected to the edge gateway 100 (step S140). Next, based on the acquired information, the sensor data transmission instruction determination unit 408 can transmit the type of sensor that the edge gateway 100 should transmit in order to add or delete the excess data amount. An instruction including a number is determined (step S141). Next, the transmission data creation unit 402 creates a response including the instruction determined by the sensor data transmission instruction determination unit 408, and transmits the response to the network communication unit 401 (step S142). Next, the network communication unit 401 transmits the created response to the edge gateway 100 through the communication line of the network NW (step S143).
  • the card reader 110 When an employee holds the employee ID card 113 over the card reader 110, the card reader 110 reads the employee ID card and transmits data to the sensor control unit 106.
  • the sensor control unit 106 issues a recording instruction to the monitoring camera 120, and receives employee image data obtained by imaging with the monitoring camera 120 as a result.
  • the sensor control unit 106 passes the sensor data received from the card reader 110 and the sensor data received from the monitoring camera 120 to the sensor data storage unit 103.
  • the sensor data storage unit 103 stores the above two sensor data, and adds 1 to the number of untransmitted data of each sensor in the untransmitted data list 109. Thereafter, the sensor data storage unit 103 requests the transmission data selection creation unit 102 to transmit sensor data.
  • the transmission data selection creation unit 102 receives the untransmitted data list 109 from the sensor data storage unit 103 and receives the sensor information list 107 from the sensor information storage unit 105, and confirms the number of transmittable data for all sensor data. . Then, the transmission data selection creation unit 102 selects the sensor data in the unsent data list 109 in ascending order of the number that can be transmitted, and creates the transmission data by acquiring the current time stamp as the time stamp of the transmission time. To the network communication unit 101 to request transmission. In addition, the transmission data selection creation unit 102 updates the number of untransmitted data recorded in the untransmitted data list 109 of the sensor data storage unit 103 by subtracting the number of data determined to be transmitted.
  • the network communication unit 101 transmits transmission data to the aggregation server 400 through the network NW.
  • the network communication unit 401 of the aggregation server receives the data and passes the received data and the reception time stamp to the received data analysis unit 404.
  • the reception data analysis unit 404 confirms that the reception data includes the sensor data and the time stamp of the transmission time, and the sensor data storage unit 405 stores the sensor data, the time stamp of the transmission time, and the reception time. Request storage of the time stamp.
  • the sensor data storage unit 405 stores the sensor data, the time stamp of the transmission time, and the time stamp of the reception time, and further passes them to the communication data amount difference calculation unit 403.
  • the communication data amount difference calculation unit 403 calculates a communication time required for data transmission from the transmission time stamp and the reception time stamp. Further, the communication data amount difference calculation unit 403 calculates the communication speed between the edge gateway 100 and the aggregation server 400 from the calculated communication time and the received data size. Next, the communication data amount difference calculation unit 403 determines, based on the edge communication information list 407 in the edge information storage unit 406, the time (average transmission time) required for sensor data transmission from the edge gateway 100 during a time period when the communication line is free. And the amount of communication that can be transmitted at this average transmission time at the current communication speed is calculated.
  • the communication data amount difference calculation unit 403 calculates the difference between the currently received data amount and the communication amount that can be transmitted as an excess of the communication data amount. In this case, since the line is free, this excess is 0 or a positive value. In the following description, it is assumed that the surplus is almost zero. The communication data amount difference calculation unit 403 passes this surplus to the sensor data transmission instruction determination unit 408.
  • the sensor data transmission instruction determination unit 408 acquires the edge communication information list 407 in the edge information storage unit 406, and the priority of both the card reader 110 and the monitoring camera 120 connected to the edge gateway 100 is “medium”. , Confirm that the transmission possible number is 1. Also, the sensor data transmission instruction determination unit 408 confirms that the excess of the communication data amount received from the communication data amount difference calculation unit 403 is substantially zero. Based on the above confirmation, the sensor data transmission instruction determination unit 408 determines that the card reader 110 and the monitoring camera 120 can continue to transmit, and the transmission data creation unit 402 can transmit the number of the card reader 110 that can be transmitted. Transmits an instruction that 1 is the number of transmissions of the surveillance camera is 1.
  • the transmission data creation unit 402 creates a response including an instruction from the sensor data transmission instruction determination unit 408 to the edge gateway 100 and passes it to the network communication unit 401.
  • the network communication unit 401 transmits the created response to the edge gateway 100 through the network NW.
  • the network communication unit 101 of the edge gateway 100 receives the response and passes it to the received data analysis unit 104.
  • the received data analysis unit 104 confirms that the instruction from the aggregation server 400 is that the number of transmittable cards by the card reader 110 is 1 and the number of transmittable cameras 120 is 1, and the sensor information storage unit 105 Forward the instructions to.
  • the sensor information storage unit 105 updates the transmittable number column of the sensor information list 107 to 1 and 1, respectively, and ends. To do.
  • the communication data amount difference calculation unit 403 calculates the time required for data transmission from the time stamp of the transmission time in the received data and the time stamp of the reception time acquired by the network communication unit 401. Further, the communication data amount difference calculation unit 403 calculates the communication speed between the edge gateway 100 and the aggregation server 400 from the calculated communication time and the received data size. Next, the communication data amount difference calculation unit 403 determines, based on the edge communication information list 407 in the edge information storage unit 406, the time (average transmission time) required for sensor data transmission from the edge gateway 100 during a time period when the communication line is free. And calculate the amount of communication that can be transmitted at the average transmission time at the current communication speed.
  • the communication data amount difference calculation unit 403 calculates the difference between the currently received data amount and the communication amount that can be transmitted as an excess of the communication data amount. In this case, since the line is congested, it takes a long time to communicate, and this excess is a negative value.
  • the communication data amount difference calculation unit 403 passes this surplus to the sensor data transmission instruction determination unit 408.
  • the sensor data transmission instruction determination unit 408 acquires the edge communication information list 407 of the edge information storage unit 406, and the number of transmittable data of the card reader 110 and the monitoring camera 120 connected to the edge gateway 100 is 1. Make sure. In addition, the sensor data transmission instruction determination unit 408 confirms that the excess of the communication data amount received from the communication data amount difference calculation unit 403 is negative.
  • the sensor data transmission instruction determination unit 408 determines from the average data size of the card reader 110 and the monitoring camera 120 that if the data of the monitoring camera 120 is not transmitted, an excessive amount of communication data can be satisfied, and edge communication is performed.
  • the number of transmissions of the monitoring camera 120 in the information list 407 is reduced by 1 and updated to 0.
  • the sensor data transmission instruction determination unit 408 transmits an instruction to the transmission data creation unit 402 that the card reader 110 can transmit 1 and the monitoring camera 120 can transmit 0.
  • the transmission data creation unit 402 creates a response including the above instruction to the edge gateway 100 and passes it to the network communication unit 401.
  • the network communication unit 401 transmits the passed response to the edge gateway 100 through the network NW.
  • the network communication unit 101 of the edge gateway 100 receives the response and passes it to the received data analysis unit 104.
  • the received data analysis unit 104 confirms that the instruction from the aggregation server 400 indicates that the number of transmittable cards by the card reader 1110 is 1 and the number of transmittable by the monitoring camera 120 is 0, and the sensor information storage unit 105 Forward the instructions.
  • the sensor information storage unit 105 updates the transmission possible number column of the monitoring camera 120 recorded in the sensor information list 107 to 0 based on the instruction from the server received from the received data analysis unit 104. To finish.
  • the above steps (16) to (23) are repeated.
  • step (4) the transmission data selection / creation unit 102 does not include the sensor data of the monitoring camera 120 because the number of transmissions of the monitoring camera 120 recorded in the sensor information list 107 is zero.
  • the transmission data selection / creation unit 102 does not include the sensor data of the monitoring camera 120 because the number of transmissions of the monitoring camera 120 recorded in the sensor information list 107 is zero.
  • the number of untransmitted data of the monitoring camera 120 recorded in the untransmitted data list 109 of the sensor data storage unit 103 is incremented by one as sensor data of a new monitoring camera 120 is stored as a result of not transmitting data. It will increase.
  • step (10) the instruction transmitted to the edge gateway 100 created by the sensor data transmission instruction determination unit 408 is, for example, a value such that the number of transmittable cards 1 is 1, and the number of transmittable cameras 120 is 2. become.
  • step (15) the sensor information storage unit 105 updates the transmission possible number of the monitoring camera 120 recorded in the sensor information list 107 to 2.
  • step (4) the transmission data selection creation unit 102 selects one of the untransmitted data of the card reader 110 and Two transmission data are selected in order of oldest. As a result, transmission data including one sensor data of the card reader 110 and two sensor data of the monitoring camera 120 is transmitted from the edge gateway 100 to the aggregation server 400. (28) The steps (1) to (15) are repeated.
  • the aggregation server 400 calculates the surplus of communication data that is a measure of the congestion state of the communication line, and reduces the amount of sensor data to be collected when the surplus becomes negative or the communication line becomes congested. Therefore, an instruction to reduce the number of sensor data that can be transmitted is generated and transmitted to the edge gateways 100, 200, and 300.
  • the use of the communication line can be prioritized over other systems sharing the communication line in accordance with the degree of congestion of the communication line.
  • the reason is that the sensor network system increases or decreases the bandwidth to be used in accordance with the congestion of the communication line.
  • the aggregation server 400 calculates the surplus of communication data that is a measure of the congestion state of the communication line, and when the surplus becomes positive or the communication line is free, the amount of sensor data to collect is calculated. This is because an instruction to increase the number of sensor data that can be transmitted is generated and transmitted to the edge gateways 100, 200, and 300 in order to increase the number.
  • FIG. 10 is a block diagram of a sensor network system according to the second embodiment of the present invention.
  • the sensor network system according to this embodiment is different from the sensor network system according to the first embodiment shown in FIG. 1 in that the edge gateways 100, 200, and 300 have sensor-specific control units 110C and 120C. The rest is the same as the sensor network system according to the first embodiment.
  • the sensor specific control unit 110C corresponds to the card reader 110.
  • the sensor specific control unit 120C corresponds to the monitoring camera 120.
  • the sensor specific control units 110 ⁇ / b> C and 120 ⁇ / b> C refer to the transmittable number of the corresponding sensor recorded in the sensor information list 107 and determine whether the transmittable number is 0.
  • the sensor specific control units 110C and 120C return a response to the transmission of data from the corresponding sensor if the transmittable number of the corresponding sensor is not zero.
  • the sensor specific control units 110 ⁇ / b> C and 120 ⁇ / b> C do not return a response to the transmission of data from the corresponding sensor if the transmittable number of the corresponding sensor is zero.
  • the card reader 110 and the monitoring camera 120 which are sensors transmit data to the sensor control unit 106, and then wait for responses from the sensor specific control units 110C and 120C. If the card reader 110 and the monitoring camera 120 do not receive a response even after waiting for a predetermined time, they resend the same data and wait for a response again. The card reader 110 and the monitoring camera 120 repeat such an operation until a response can be received. Meanwhile, the sensor data is accumulated in the transmission buffers of the card reader 110 and the monitoring camera 120.
  • sensor data of a sensor that temporarily stops transmission from the edge gateway 100 to the aggregation server 400 is configured to be accumulated on the sensor device side.
  • the storage capacity for storing sensor data in the sensor data storage unit 103 can be reduced.
  • the edge gateway 100 includes the sensor data storage unit 103.
  • the sensor data storage unit 103 may be omitted if there is a sufficient capacity of the transmission buffer for storing sensor data on the sensor device side.
  • the sensor network system according to the present embodiment is different from the sensor network system according to the first embodiment shown in FIG. 1 in the function of the sensor data transmission instruction determination unit 408 of the aggregation server 400, and otherwise. This is the same as the sensor network system according to the first embodiment.
  • the sensor data transmission instruction determination unit 408 collects sensor data based on the excess of the communication data amount calculated by the communication data amount difference calculation unit 403, that is, the degree of congestion of the communication line. When deciding which sensor to hold, both are periodically changed. Specifically, for example, it is assumed that a total of ten sensors from No. 1 to No. 10 are attached to the edge gateway 100, and the priorities thereof are all the same. Further, in order to eliminate the congestion state of the communication line, it is not possible to continue collecting all the sensor data, and for example, it is necessary to suspend collection of half of the sensor data. At this time, as an instruction to be sent to the edge gateway 100, the sensor data transmission instruction determination unit 408 first sets the number of transmittable sensors No. 1, No. 3, No.
  • the sensor data transmission instruction determination unit 408 adjusts the combination of the sensor that permits transmission and the sensor that prohibits transmission for each instruction. Further, the sensor data transmission instruction determination unit 408 determines an instruction to preferentially transmit sensor data of a sensor that has been stopped for a long time. Further, the sensor data transmission instruction determination unit 408 replaces the sensor that stops and does not stop even if the excessive value of the communication amount of the sensor data does not change. As a result, it is possible to prevent a situation where sensor data of a specific sensor is not collected over a long period of time.
  • the sensor network system according to the present embodiment is different from the sensor network system according to the first embodiment shown in FIG. 1 in the function of the transmission data selection creation unit 102 of the edge gateways 100, 200, 300, The rest is the same as the sensor network system according to the first embodiment.
  • the transmission data selection creation unit 102 sets the time of transmission time at a predetermined interval such as 30 seconds or 1 minute when the number of possible transmissions of all sensor data recorded in the sensor information list 107 is 0.
  • a message including a stamp and no sensor data is transmitted from the edge gateway 100 to the aggregation server 400 via the network NW.
  • the message doubles as confirmation of the congestion state of the communication line and the heartbeat of the edge gateway 100. This message is referred to as a heartbeat message in this specification.
  • the aggregation server 400 When the aggregation server 400 receives the heartbeat message from the edge gateway 100, the aggregation server 400 is based on the difference between the time difference between the transmission time and the reception time of the heartbeat message and the communication time of the heartbeat message when no congestion occurs. Then, the degree of congestion of the communication line is determined. Then, the aggregation server 400 returns an instruction to transmit data in units of sensors to the edge gateway 100 by the same operation as steps (7) to (15) in the description of the operation in the first embodiment.
  • the transmission data selection creation unit 102 of the edge gateway 100 stops the transmission of the heartbeat message if the number of transmissions of at least one sensor data is 1 or more according to the instruction returned from the aggregation server 400. In addition, when the transmission data selection creation unit 102 confirms that the situation where the sensor data cannot be transmitted continues, the transmission data selection creation unit 102 continues the transmission of the heartbeat message.
  • the instruction sent from the aggregation server to the edge gateway is an instruction to stop transmission of data of all the sensors connected to the edge gateway, the instruction is transmitted from the edge gateway to the aggregation server. Even in a situation where there is no sensor data to be transmitted, the congestion state of the communication line of the network NW can be continuously monitored.
  • the edge gateway 200 and the edge gateway 300 share a communication line, it is impossible to know that the usable line bandwidth in that part is 30 Mbps. In that case, the aggregation server 400 has no choice but to perform individual optimization that limits the communication band independently for the edge gateway 200 and the edge gateway 300. Even if the usable bandwidth is set to 20 Mbps and 25 Mbps as described in FIG. 11 based on the amount of data transmitted by the respective sensors of the edge gateway 200 and the edge gateway 300 by such individual optimization, the shared portion is a bottle. Congestion occurs as a bottleneck. In this case, the optimum value is set by searching by adjusting the transmittable bandwidth of each edge gateway. Therefore, it is difficult to eliminate congestion early. This embodiment solves such a problem.
  • FIG. 12 is a block diagram of a sensor network system according to the fifth embodiment of the present invention.
  • three edge gateways 100, 200, and 300 are connected to the aggregation server 400 through a network NW.
  • two sensors 111 and 121 are connected to the edge gateway 100
  • two sensors 211 and 221 are connected to the edge gateway 200
  • two sensors 311 and 321 are connected to the edge gateway 300.
  • the edge gateways 100, 200, and 300 are the same as the edge gateways 100, 200, and 300 in the first embodiment shown in FIG.
  • the aggregation server 400 has functions of a communication data amount difference calculation unit 403, an edge information storage unit 406, and a sensor data transmission instruction determination unit 408 compared to the aggregation server 400 in the first embodiment illustrated in FIG. Is the same as the aggregation server 400 in the first embodiment.
  • the communication data amount difference calculation unit 403 of the aggregation server 400 in this embodiment has the same function as the communication data amount difference calculation unit 403 in the first embodiment, and shares the same communication line from the change in communication time. It has a function of determining the combination of edge gateways to be performed. Specifically, the communication data amount difference calculation unit 403 according to the present embodiment, for each edge gateway, the time difference between the transmission time and the reception time of the sensor data transmitted from the edge gateway to the aggregation server 400 corresponds to the passage of time. And a function of generating a pattern (variation pattern) representing how it fluctuates.
  • the communication data amount difference calculation unit 403 compares the variation patterns for each edge gateway, and uses a combination of a plurality of edge gateways having the same or similar variation patterns to share a communication line in which congestion occurs. And a function of determining as a group of edge gateways.
  • the edge information storage unit 406 in the present embodiment has the same function as the edge information storage unit 406 in the first embodiment, and the edge communication information list 407 including the generated variation pattern and group information is displayed. It has a function to accumulate.
  • FIG. 13 shows an example of the contents of the edge communication information list 407 in the present embodiment. Compared with the edge communication information list 407 shown in FIG. 4, fields of a transmission / reception time variation pattern and a group name are added.
  • the sensor data transmission instruction determination unit 408 in this embodiment holds a combination of edge gateways that share a communication line in which congestion is occurring as one group, and sensors that collect sensor data and hold the collection. It has a function to determine a sensor.
  • the sensor data transmission instruction determination unit 408 in the present embodiment is the same as the sensor data transmission instruction determination unit 408 in the first embodiment. To work.
  • the communication time between the aggregation server 400 and the edge gateways 100, 200, 300 is reduced.
  • the fluctuation is the same in a plurality of edge gateways
  • a plurality of edge gateways sharing a communication line are regarded as one group, and determination is made as to whether sensor data to be transmitted can be transmitted in order of importance of the sensor data in units of groups. .
  • the communication data amount difference calculation unit 403 has a similar pattern Y as a result of measuring a transmission / reception time variation pattern of the edge gateway 200 and the edge gateway 300 for a certain period of time.
  • the sensor data transmission instruction determination unit 408 divides the edge gateways 100, 200, and 300 into a group A that includes the edge gateway 100 and a group BC that includes the edge gateways 200 and 300, and the amount of communication in units of groups. Take control.
  • the sensor data transmission instruction determination unit 408 includes four sensors, ie, sensors 211 and 311 having high priority and sensors 221 and 321 having low priority in the group BC.
  • Transmission of sensor data of the sensors 211 and 311 having high priority is permitted, and transmission of sensor data of the sensors 221 and 321 having low priority is temporarily stopped. If the priority of the sensors 211 and 221 is low and the priority of the sensors 311 and 321 is high, the sensor data transmission instruction determination unit 408 selects the sensor 311 having a high priority from these four sensors. The transmission of the sensor data 321 is permitted, and the transmission of the sensor data of the sensors 211 and 321 having low priority is temporarily stopped. Accordingly, transmission of sensor data of the sensors 311 and 321 connected to the edge gateway 300 out of the two edge gateways 200 and 300 sharing the communication line is permitted, and the sensors 211 and 221 connected to the edge gateway 200 are allowed to transmit. Transmission is temporarily stopped. Such an instruction is difficult to realize by individual optimization. Thereby, the optimization of the whole system which considered the data transmission from a some edge gateway is realizable.
  • the sensor network system includes one or more sensor devices 501, one or more gateway devices 502 that collect sensor data from the sensor devices 501, and a gateway device. And a server apparatus 504 that is connected to the communication line 503 through the communication line 503 and collects sensor data from the gateway apparatus 502 through the communication line 503.
  • the server device 504 includes a determination unit 511 and a control unit 512.
  • the determination unit 511 of the server device 504 performs communication based on the difference between the time difference between the transmission time and the reception time of the sensor data transmitted from the gateway device 502 to the server device 504 and the communication time when no congestion occurs.
  • the determination unit 511 can be realized by, for example, the network communication unit 401, the reception data analysis unit 404, the sensor data storage unit 405, and the communication data amount difference calculation unit 403 in FIG. 1, but is not limited thereto.
  • the control unit 512 of the server device 504 has a function of determining the sensor device 501 that collects sensor data and the sensor device 501 that holds the collection of sensor data based on the determination result of the determination unit 511.
  • the control unit 512 has a function of sending an instruction including the determined content to the gateway device 502.
  • the control unit 512 can be realized by, for example, the edge information storage unit 406, the sensor data transmission instruction determination unit 408, the transmission data creation unit 402, and the network communication unit 401 in FIG. 1, but is not limited thereto.
  • the sensor network system operates as follows. That is, the gateway device 502 collects sensor data from the sensor device 501 and transmits it to the server device 504 through the communication line 503. Based on the difference between the time difference between the transmission time and the reception time of the sensor data transmitted from the gateway device 502 to the server device 504, and the communication time when no congestion occurs, the determination unit 511 of the server device 504 The degree of congestion of the communication line 503 is determined. Then, the control unit 512 of the server device 504 determines the sensor device 501 that collects sensor data and the sensor device 501 that holds the collection of sensor data based on the determination result of the degree of congestion of the communication line 503, and the gateway An instruction including the determined content is sent to the device 502. The gateway device 502 selects sensor data to be transmitted to the server device 504 from the sensor data of the sensor device 501 according to the above instruction, creates transmission data, and transmits the transmission data to the server device 504.
  • the determination unit 511 of the server device 504 determines the difference between the time difference between the transmission time and the reception time of the sensor data transmitted from the gateway device 502 to the server device 504 and the communication time when no congestion occurs. Based on the determination result of the determination unit 511, the control unit 512 of the server apparatus 504 determines the degree of congestion of the communication line 503, and the sensor device 501 that collects sensor data and the sensor that suspends the collection of sensor data This is for determining the device 501 and sending an instruction including the determined content to the gateway device 502.
  • This embodiment can be modified as follows.
  • the control unit 512 compares the determined content included in the instruction sent last to the gateway device 502 with the sensor device 501 holding the collection of sensor data.
  • the content may be determined so as to increase the number of.
  • control unit 511 compares the determined content included in the instruction sent last to the gateway device 502 with respect to the sensor device that suspends collection of sensor data. It may be configured to determine the content having a smaller number.
  • control unit 511 may be configured to determine the sensor device 501 that collects sensor data and the sensor device 501 that holds the collection of sensor data based on the priority of the sensor device 501.
  • control unit 511 determines the number of transmissions indicating how many times sensor data is collected according to the degree of congestion of the communication line 503, and this determination The contents may be included in the instruction.
  • control unit 511 may be configured to periodically replace the sensor device 501 that collects sensor data and the sensor device 501 that holds the collection of sensor data.
  • control unit 511 generates a variation pattern associated with the passage of the time difference for each gateway device 502, and compares the generated variation pattern for each gateway device to determine the communication line 503 in which congestion occurs.
  • the combination of the gateway devices 502 that are shared is determined, and the combination of the determined gateway devices 502 is grouped into one group to determine the sensor device 501 that collects sensor data and the sensor device 501 that holds sensor data collection. It may be configured to.
  • the gateway device 502 does not intentionally return a response to the transmission of the sensor data from the sensor device 501 to the sensor device 501 that does not transmit to the server device 504 in accordance with the above instruction. It may be configured to be stored in the transmission buffer of the device 501.
  • the gateway device 502 is configured to periodically transmit a heartbeat message describing the transmission time during a period in which no sensor data of any sensor device 501 is transmitted to the server device 504 according to the above instruction. It's okay.
  • the determination unit 511 of the server apparatus 504 determines the communication line 503 based on the difference between the time difference between the transmission time and the reception time of the heartbeat message and the communication time when no congestion occurs. It may be configured to determine the degree of congestion.
  • the transmission data selection creation unit 102 of the edge gateway 100 adds the transmission data including the sensor data or the transmission data including the sensor data.
  • the number of untransmitted data of each sensor (card reader, monitoring camera) recorded in the untransmitted data list 109 may be transmitted to the aggregation server 400.
  • the edge information storage unit 406 of the aggregation server 400 may record the number of untransmitted data of each sensor data received from the edge gateway 100 as one column of each entry of the edge communication information list 407.
  • the edge information storage unit 406 of the aggregation server 400 is configured so that when one received data includes different numbers of sensor data for the card reader and the monitoring camera, the smaller number of sensor data is edged as untransmitted data. It may be determined that the data remains in the gateway, and the untransmitted data number of the smaller number of sensor data in the edge communication information list 407 may be increased by the smaller number. Then, the sensor data transmission instruction determination unit 408 of the aggregation server 400 collects sensor data based on the number of untransmitted data of each sensor data recorded in the edge communication information list 407, the number of transmittable sensors, It may be configured to determine a sensor to suspend data collection. For example, the sensor data transmission instruction determination unit 408 may preferentially incorporate sensor data having a larger number of untransmitted data into the transmission target when the communication line is free.
  • the present invention can be used for all sensor network systems. Further, the present invention can be used in the field of security configured to additionally install a monitoring camera in an existing building and monitor it remotely via a shared line. Further, the present invention can be used in the field of science configured to collect a large amount of observation data using an existing network.
  • a sensor including one or more gateway devices that collect sensor data from one or more sensor devices, and a server device that is connected to the gateway device through a communication line and collects the sensor data from the gateway device through the communication line
  • the server device The congestion degree of the communication line is determined based on a difference between a transmission time and a reception time of the sensor data transmitted from the gateway device to the server device and a communication time in a state in which no congestion occurs.
  • a determination unit Based on the determination result of the degree of congestion of the communication line, the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data are determined, and the determination is made to the gateway device.
  • the control unit periodically replaces the sensor device that collects the sensor data and the sensor device that suspends collection of the sensor data.
  • the sensor network system according to any one of appendices 1 to 5.
  • the control unit generates a variation pattern of the time difference for each of the gateway devices, and compares the generated variation pattern for each of the generated gateway devices and shares the communication line in which congestion occurs. Determining a combination of gateway devices, determining the combination of the determined gateway devices as one group, and determining the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data; The sensor network system according to any one of appendices 1 to 6.
  • the gateway device is In accordance with the instructions, including a control unit that creates the transmission data by selecting the sensor data to be transmitted to the server device from the sensor data of the sensor device.
  • the sensor network system according to any one of appendices 1 to 7.
  • the control unit of the gateway device does not intentionally return a response to the transmission of the sensor data from the sensor device to the sensor device that is not transmitted to the server device according to the instruction. Leave sensor data stored in the transmission buffer of the sensor device; The sensor network system according to appendix 8.
  • the control unit of the gateway device periodically transmits a heartbeat message describing a transmission time during a period in which the sensor data of any of the sensor devices is not transmitted to the server device,
  • the determination unit determines a degree of congestion of the communication line based on a difference between a time difference between a transmission time and a reception time of the heartbeat message and a communication time in a state in which no congestion occurs.
  • the sensor network system according to appendix 8 or 9.
  • a server device that is connected to a gateway device that collects sensor data from a sensor device through a communication line, and that collects the sensor data from the gateway device through the communication line, Determining the degree of congestion of the communication line based on the difference between the time difference between the transmission time and the reception time of the sensor data transmitted from the gateway device to the server device and the communication time when no congestion occurs A determination unit to perform, Based on the determination result of the degree of congestion of the communication line, the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data are determined, and the determination is made to the gateway device.
  • the control unit suspends collection of the sensor data in comparison with the determined content included in the instruction sent last to the gateway device Determine the content of the more, The server device according to attachment 11.
  • the control unit suspends collection of the sensor data in comparison with the determined content included in the instruction sent last to the gateway device Determine the content of the lesser number, The server device according to appendix 11 or 12.
  • the control unit determines, based on the priority of the sensor device, the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data.
  • the server device according to any one of appendices 11 to 13.
  • the control unit determines, for the sensor device that collects the sensor data, a transmittable number indicating how many times the sensor data is collected according to a degree of congestion of the communication line.
  • the server device according to any one of appendices 11 to 14.
  • the control unit periodically replaces the sensor device that collects the sensor data and the sensor device that suspends collection of the sensor data.
  • the control unit generates a variation pattern of the time difference for each of the gateway devices, and compares the generated variation pattern for each of the generated gateway devices and shares the communication line in which congestion occurs.
  • a sensor data collection control method executed by a server device connected via a communication line to a gateway device that collects sensor data from a sensor device and collecting the sensor data from the gateway device via the communication line, Determining the degree of congestion of the communication line based on the difference between the time difference between the transmission time and the reception time of the sensor data transmitted from the gateway device to the server device and the communication time when no congestion occurs And Based on the determination result of the degree of congestion of the communication line, the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data are determined, and the determination is made to the gateway device.
  • the sensor data collection control method according to any one of appendices 18 to 22.
  • Appendix 24 In the determination of the sensor device that collects the sensor data and the sensor device that suspends the collection of the sensor data, the variation pattern of the time difference is generated for each of the gateway devices, and the generated gateway device The variation patterns are compared to determine a combination of the gateway devices that share the communication line in which congestion occurs, and the sensor data is collected using the determined combination of gateway devices as one group. Determining the sensor device to perform and the sensor device to suspend collection of the sensor data; The sensor data collection control method according to any one of appendices 18 to 23.
  • a computer connected through a communication line to a gateway device that collects sensor data from the sensor device, and collecting the sensor data from the gateway device through the communication line; Determining the degree of congestion of the communication line based on the difference between the time difference between the transmission time and the reception time of the sensor data transmitted from the gateway device to the server device and the communication time when no congestion occurs A determination unit to perform, Based on the determination result of the degree of congestion of the communication line, the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data are determined, and the determination is made to the gateway device.
  • a transmission data control unit for sending an instruction including contents; Program to make it function.
  • a gateway device that collects sensor data from one or more sensor devices and transmits the sensor data to a server device via a communication line, An instruction for identifying the sensor device that collects the sensor data and the sensor device that holds the collection of the sensor data, determined based on the degree of congestion of the communication line, is sent from the server device through the communication line.
  • a control unit that creates the transmission data by selecting the sensor data to be transmitted to the server device from the sensor data of the sensor device according to the instruction. Gateway device.
  • the control unit does not intentionally return a response to the transmission of the sensor data from the sensor device to the sensor device that is not transmitted to the server device according to the instruction, whereby the sensor data is transmitted to the server device.
  • the gateway device according to attachment 26.
  • the control unit periodically transmits a heartbeat message describing a transmission time during a period in which the sensor data of any of the sensor devices is not transmitted to the server device according to the instruction. 28.
  • Sensor data storage unit 406 ... Edge information storage unit 407 ... Edge communication information list 408 ... Sensor data Transmission instruction determination unit 501 ... sensor device 502 ... gateway device 503 ... communication line 504 ... server device 511 ... determination unit 512 ... control unit 1001 ... operation input unit 1002 ... screen display unit 1003 ... communication interface unit 1004 ... storage unit 1005 ... calculation Processing unit 1006 ... Information processing device 1007 ... Program NW ... Network

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Health & Medical Sciences (AREA)
  • General Health & Medical Sciences (AREA)
  • Computing Systems (AREA)
  • Medical Informatics (AREA)
  • Cardiology (AREA)
  • Environmental & Geological Engineering (AREA)
  • Biomedical Technology (AREA)
  • Business, Economics & Management (AREA)
  • General Business, Economics & Management (AREA)
  • Physics & Mathematics (AREA)
  • General Physics & Mathematics (AREA)
  • Arrangements For Transmission Of Measured Signals (AREA)
  • Selective Calling Equipment (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Telephonic Communication Services (AREA)

Abstract

サーバ装置は、判定部と制御部とを含む。判定部は、ゲートウェイ装置からサーバ装置へ送信するセンサデータの送信時刻と受信時刻との時間差と輻輳が発生していない状態での通信時間との差分に基づいて、通信回線の輻輳度合いを判定する。制御部は、通信回線の輻輳度合いの判定結果に基づいて、センサデータの収集を行うセンサ機器とセンサデータの収集を保留するセンサ機器とを決定し、ゲートウェイ装置に対して、上記決定した内容を含む指示を送出する。

Description

センサネットワークシステム
 本発明は、センサネットワークシステム、サーバ装置、センサデータ収集制御方法、ゲートウェイ装置、及びプログラムに関する。
 センサ機器、ゲートウェイ装置、及び、サーバ装置から構成されるセンサネットワークシステムが提案ないし実用化されている。センサネットワークシステムは、IoT(Internet of Things)システムの一種である。
 センサ機器は、センサ、通信装置、及びマイクロコンピュータを備え、センサにより観測を行い、得られたセンサデータを有線または無線によって送信する。ゲートウェイ装置は、通信装置、及びマイクロコンピュータを備え、センサ機器から受信したセンサデータをイーサネット(登録商標)等の通信回線を通じてサーバ装置へ送信する。サーバ装置は、通信回線を通じてゲートウェイ装置からセンサデータを収集し、センサデータの蓄積、解析、表示、及びアプリケーションへの通知等を行う。
 このようなセンサネットワークシステムにおいて、ゲートウェイ装置とサーバ装置とを接続する通信回線の輻輳を防止する技術として、予め設定された最大送信量を超えないように送信量に上限を設定する方法がある(例えば特許文献1参照)。
特許5097631号公報
 上述したように、センサネットワークシステムを構成するゲートウェイ装置とサーバ装置とを接続する通信回線の輻輳を防止する技術が提案されているけれども、そのような技術では輻輳の発生を防止できないことがある。例えば、通信回線がセンサネットワークシステム専用でなく、他のシステムと共用している場合、センサネットワークシステムの通信量に上限を設定しても他のシステムの通信量の増大によって輻輳が発生してしまうことがある。そして、通信回線の輻輳が発生すると、上述した輻輳の防止技術では、発生した輻輳を解消するのは困難である。
 本発明の目的は、上述した課題、即ち、通信回線の輻輳が発生すると、それを解消するのは困難である、という課題を解決するセンサネットワークシステム、サーバ装置、センサデータ収集制御方法、ゲートウェイ装置、及びプログラムを提供することにある。
 本発明の一形態に係るセンサネットワークシステムは、
 1または複数のセンサ機器からセンサデータを収集する1または複数のゲートウェイ装置と、前記ゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するサーバ装置とを含むセンサネットワークシステムであって、
 前記サーバ装置は、
 前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する判定部と、
 前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する制御部と、
を含む。
 また本発明の他の形態に係るサーバ装置は、
 センサ機器からセンサデータを収集するゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するサーバ装置であって、
 前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する判定部と、
 前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する制御部と、
を含む。
 また本発明の他の形態に係るゲートウェイ装置は、
 1または複数のセンサ機器からセンサデータを収集し、前記センサデータを、通信回線を通じてサーバ装置へ送信するゲートウェイ装置であって、
 前記通信回線の輻輳度合いに基づいて決定された、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを特定する指示を、前記通信回線を通じて前記サーバ装置から受信して解析する受信データ解析部と、
 前記指示に従って、前記センサ機器の前記センサデータの中から前記サーバ装置へ送信する前記センサデータを選択して送信データを作成する制御部とを含む。
 また本発明の他の形態に係るセンサデータ収集制御方法は、
 センサ機器からセンサデータを収集するゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するサーバ装置が実行するセンサデータ収集制御方法であって、
 前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定し、
 前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する。
 また本発明の他の形態に係るプログラムは、
 センサ機器からセンサデータを収集するゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するコンピュータを、
 前記ゲートウェイ装置から前記コンピュータへ送信する前記センサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する判定部と、
 前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する送信データ制御部と、
して機能させる。
 本発明は上述した構成を有することにより、ゲートウェイ装置とサーバ装置とを接続する通信回線に輻輳が発生した場合、それを検出して解消させることができる。
本発明の第1の実施形態に係るセンサネットワークシステムのブロック図である。 本発明の第1の実施形態における未送信データ一覧の内容例を示す図である。 本発明の第1の実施形態におけるセンサ情報一覧の内容例を示す図である。 本発明の第1の実施形態におけるエッジ通信情報一覧の内容例を示す図である。 本発明の第1の実施形態におけるエッジゲートウェイおよび集約サーバのハードウェア構成の一例を示すブロック図である。 本発明の第1の実施形態におけるエッジゲートウェイの動作の一例を示すフローチャートである。 本発明の第1の実施形態におけるエッジゲートウェイの動作の一例を示すフローチャートである。 本発明の第1の実施形態におけるカードリーダと監視カメラとでセンサデータを取得する例を示す図である。 本発明の第1の実施形態における集約サーバの動作の一例を示すフローチャートである。 本発明の第2の実施形態に係るセンサネットワークシステムのブロック図である。 本発明の第5の実施形態が解決しようとする課題を説明する図である。 本発明の第5の実施形態に係るセンサネットワークシステムのブロック図である。 本発明の第5の実施形態におけるエッジ通信情報一覧の内容例を示す図である。 本発明の第5の実施形態に係るセンサネットワークシステムのブロック図である。
[第1の実施形態]
 次に本発明の第1の実施形態について図面を参照して詳細に説明する。
<本実施形態の特徴>
 本実施形態は、遠隔地に設置されたセンサ機器のセンサデータをエッジゲートウェイ経由でサーバによって収集するセンサネットワークシステムに関する。本実施形態におけるサーバは、エッジゲートウェイからサーバへ送られるセンサデータの送受信にかかる時間の変動から、エッジゲートウェイとサーバとを接続する通信回線の輻輳状態を推測する。そして、サーバは、通信回線の輻輳時、通信時間の長期化に関わる通信を行っているエッジゲートウェイに対して、通信回線の輻輳状態を解消するために通信量抑制の指示を出す。上記指示を受けたエッジゲートウェイは、接続されているセンサ機器のうち、上記指示で指定されたセンサ機器のデータの送信を停止する。或いは、上記指示を受けたエッジゲートウェイは、接続されているセンサ機器のうち、上記指示で指定されたセンサ機器のデータだけを送信する。
 このように本実施形態は、センサネットワークシステムが使用する通信回線の輻輳状態を簡易に推測する。また、本実施形態は、輻輳時にはセンサネットワークシステムが使用する通信帯域を制限する。これによって通信回線の輻輳状態が解消し、同じ回線を使用する他システムが優先的に通信回線を使用できるようにする。
<本実施形態が解決しようとする課題>
 近年IoTという考え方が浸透してきており、我々の生活がより便利に、大きく変わろうとしている。この考え方は、これまで独立して使われてきた幅広い種類のセンサを組み合わせて、場やモノの状況・状態をデータとして保存、活用していくというものである。IoTと同時に発展してきているビッグデータや人工知能といった技術と組み合わせて、日常生活の様々な事柄に対するオートメーションや最適化が期待できる。
 このようなIoTシステムを既存システムが動作する環境に追加導入する場合、導入したIoTシステムが既存リソースを使いすぎないようにする必要がある。特にネットワークリソースは、共用する他システムに与える影響が大きい。また、IoTシステムは、センサの追加によってセンサデータの送信量が増加する傾向にある。このため、IoTシステムと既存システムとがネットワークリソースを共用する場合、IoTシステムの通信量を適切に管理する必要がある。
 特に、複数のシステムが一つの通信回線を共用する構成では、回線の輻輳による通信時間の長期化がしばしば問題になる。この問題に対しては、サーバがデータを送信してくるクライアントに送信レートの目標値を通達し、クライアント側で送信の全体量を絞る方法が考えられている。また、上記問題に対して、中継するネットワーク機器で制限する方法も考えられている。しかし、これらの解決方法では、クライアントからの送信全体が影響を受けるため、送信の遅延が許容できないデータの通信時間が長くなってしまうという問題がある。
 このような課題は、センサ機器が接続された1以上のエッジゲートウェイからセンサデータを収集し、遠隔地のサーバに格納して活用するIoTシステムの一種であるセンサネットワークシステムでも同様に存在する。このようなセンサネットワークシステムが他システムと通信回線を共用している場合、お互いのシステムに与える影響を少なくしつつ輻輳を回避し、より緊急度や重要度の高いデータを優先的に送受信できるような仕組みが期待されている。
<本実施形態による解決手段>
 一般に通信時間の長期化は通信回線の輻輳が原因であることが多い。そのため、本実施形態では、サーバは、エッジゲートウェイとの間の通信においてデータの送信時刻と受信時刻との差から通信にかかる時間を計算する。この計算した通信時間は、通信回線の輻輳状態に応じて変動する。サーバは、計算した通信時間を、通信回線に輻輳が発生していない場合の通信時間(予め決定されている)と比較することにより、通信回線に輻輳が発生しているかどうかを決定する。
 加えて、サーバは、通信にかかる時間と輻輳が発生していない場合の通信時間との差から、通信回線の輻輳発生時にその通信を通常時の通信状況にするために削減すべき送信データ量を計算する。そして、サーバは、データ送信量を計算した分だけ削減するために、エッジゲートウェイへセンサデータの一部の送信を停止する指示を出す。これにより、エッジゲートウェイからサーバへ送信するセンサデータの総量が減るので、通信回線の混雑が緩和される。その結果、通信回線の輻輳が解消する。ここで、一部のセンサデータの収集にリアルタイム性が不要なIoTシステムの場合、通信回線の輻輳の解消に貢献させるために、リアルタイム性の不要なセンサデータの収集を意図的に遅延させる。サーバは、通信回線を通じてつながる複数のエッジゲートウェイに上記対策を適用することにより、IoTシステムが通信回線の混雑時に与える影響を抑える。
<本実施形態の構成>
 図1は、本発明の第1の実施形態に係るセンサネットワークシステムのブロック図である。本実施形態に係るセンサネットワークシステムは、オフィスビルの入場門等の適所にカードリーダと監視カメラを設置し、入場者の映像を収集・蓄積するシステムである。そのために、本実施形態に係るセンサネットワークシステムは、カードリーダ110と監視カメラ120とに接続されたエッジゲートウェイ100、カードリーダ210と監視カメラ220とに接続されたエッジゲートウェイ200、カードリーダ310と監視カメラ320とに接続されたエッジゲートウェイ300を含んでいる。また、本実施形態に係るセンサネットワークシステムは、1台の集約サーバ400を含む。集約サーバ400は、ネットワークNWを通じて3台のエッジゲートウェイ100、200、300に接続されている。ここで、ネットワークNWは、センサネットワークシステム専用でなく、他システムと共用している。他システムは、例えば、オフィスビルに設置されたデータベースシステム、メールシステム、音声通話システム等が挙げられるが、それらに限定されない。以下、ネットワークNWを通じて他システムが行う通信を、オフィスビルの通信と呼ぶ。ネットワークNWの使用に関して、オフィスビルの通信は、センサネットワークシステムによる通信よりも優先されるという条件が課せられている。
 エッジゲートウェイ100は、主な機能部として、ネットワーク通信部101、送信データ選択作成部102、センサデータ蓄積部103、受信データ解析部104、センサ情報格納部105、およびセンサ制御部106を含んでいる。
 センサ制御部106は、センサであるカードリーダ110、監視カメラ120を制御する。例えば、カードリーダ110に社員証がかざされると、社員証のデータがカードリーダ110で読み取られ、センサ制御部106へ送信される。センサ制御部106は、この送信されてくる社員証のデータを受信し、センサデータ蓄積部103に伝達する。また、センサ制御部106は、社員証をかざした社員の顔画像等のデータを取得するために、社員証のデータの受信に連動して、監視カメラ120に対して画像の取得要求を送信する。また、この取得要求に応じて監視カメラ120が社員の顔画像等のデータを取得し、送信すると、センサ制御部106は、このデータを受信し、センサデータ蓄積部103に伝達する。
 センサデータ蓄積部103は、センサ制御部106から受け取ったセンサデータを、センサ別かつ到着順に記憶部に記録して管理する。センサデータ蓄積部103は、蓄積したセンサデータの管理情報である未送信データ一覧109を有する。
 図2は未送信データ一覧109の内容例を示す。この例の未送信データ一覧109は、センサに1対1に対応するエントリを有し、各エントリは、センサデータ名と未送信データ数とから構成される。例えば、未送信データ一覧109の1行目のエントリは、カードリーダ110の未送信データ数は0であることを表している。また、未送信データ一覧109の2行目のエントリは、監視カメラ120の未送信データ数は0であることを表している。センサデータ蓄積部103は、カードリーダ110から1枚の社員証のデータを受信する毎に、未送信データ一覧109のカードリーダ110の未送信データ数を1だけインクリメントする。またセンサデータ蓄積部103は、監視カメラ120から1枚の画像データを受信する毎に、未送信データ一覧109の監視カメラの未送信データ数を1だけインクリメントする。
 センサ情報格納部105は、エッジゲートウェイ100から集約サーバ400へ送信するセンサデータ名とその送信可能数を管理する。センサ情報格納部105は、センサ情報一覧107を含む。
 図3はセンサ情報一覧107の内容例を示す図である。この例のセンサ情報一覧107は、センサに1対1に対応するエントリを有し、各エントリは、センサデータ名と送信可能数とから構成される。例えば、センサ情報一覧107の1行目のエントリは、カードリーダ110の送信可能数は1であることを表している。また、センサ情報一覧107の2行目のエントリは、監視カメラ120の送信可能数は1であることを表している。センサ情報格納部105は、受信データ解析部104で抽出された集約サーバ400から送られてくる指示に従って、センサ情報一覧107の送信可能数を更新する。
 送信データ選択作成部102は、エッジゲートウェイ100から集約サーバ400へ送信するデータを作成する。送信データ選択作成部102は、センサ情報一覧107を参照して、集約サーバ400へ送信するデータに含めるセンサデータの種類と数を決定する。例えば、センサ情報一覧107が図3に示した内容である場合、送信データ選択作成部102は、カードリーダ110のセンサデータを、1つを上限に送信データに含め、監視カメラ120のセンサデータを、1つを上限に送信データに含める。送信データ選択作成部102は、送信データに含めるセンサデータをセンサデータ蓄積部103から古い順に抽出する。また送信データ選択作成部102は、センサデータ蓄積部103からセンサデータを1つ抽出する毎に、抽出したセンサデータの種類に対応する、未送信データ一覧109の未送信データ数を1だけデクリメントする。更に、送信データ選択作成部102は、現在時刻を送信時刻として取得し、送信時刻のタイムスタンプを作成して、送信データに含める。
 ネットワーク通信部101は、エッジゲートウェイ100と集約サーバ400との間の通信を司る。ネットワーク通信部101は、送信データ選択作成部102で作成された送信データを、ネットワークNWを通じて集約サーバ400へ送信する。また、ネットワーク通信部101は、ネットワークNWを通じて集約サーバ400から受信したデータを受信データ解析部104へ伝達する。
 受信データ解析部104は、受信データを解析する。受信データ解析部104は、受信データを解析して、集約サーバ400からの指示を検出すると、検出した指示をセンサ情報格納部105へ伝達する。前述したように、センサ情報格納部105は、受信データ解析部104から伝達された指示に従って、センサ情報一覧107の送信可能数を更新する。
 エッジゲートウェイ200、300は、エッジゲートウェイ100と同様の構成を有している。
 集約サーバ400は、主な機能部として、ネットワーク通信部401、送信データ作成部402、通信データ量差計算部403、受信データ解析部404、センサデータ蓄積部405、エッジ情報格納部406、およびセンサデータ送信指示決定部408を含んでいる。
 ネットワーク通信部401は、集約サーバ400とエッジゲートウェイ100、200、300との間の通信を司る。ネットワーク通信部401は、送信データ作成部402で作成された送信データを、ネットワークNWを通じて宛先のエッジゲートウェイ100、200、300へ送信する。また、ネットワーク通信部401は、ネットワークNWを通じてエッジゲートウェイ100、200、300からデータを受信すると、現在時刻を受信時刻として取得して、受信時刻のタイムスタンプを作成し、受信したデータ及び受信時刻のタイムスタンプを受信データ解析部404へ伝達する。ここで、ネットワーク通信部401は、受信時刻を、例えば集約サーバ400がエッジゲートウェイからのセンサデータの送信時刻のタイムスタンプが入っている先頭フレームを受信した時刻に設定する。
 受信データ解析部404は、エッジゲートウェイ100、200、300から受信した受信データを解析する。受信データ解析部404は、エッジゲートウェイ100、200、300から受信した受信データを解析してセンサデータおよび送信時刻のタイムスタンプを検出すると、それらとネットワーク通信部401で生成された受信時刻のタイムスタンプとをセンサデータ蓄積部405へ伝達する。
 センサデータ蓄積部405は、受信データ解析部404から受け取ったエッジゲートウェイ100、200、300からのセンサデータと送信時刻のタイムスタンプと受信時刻のタイムスタンプとをエッジゲートウェイ毎に記憶部に記憶して保存する。また、センサデータ蓄積部405は、受信データ解析部404から受け取ったセンサデータと送信時刻のタイムスタンプと受信時刻のタイムスタンプとをエッジゲートウェイ毎に通信データ量差計算部403へ伝達する。
 エッジ情報格納部406は、エッジゲートウェイから収集すべきセンサデータに関する情報を管理する。エッジ情報格納部406は、エッジ通信情報一覧407を含む。
 図4は、エッジ通信情報一覧407の内容例を示す。この例のエッジ通信情報一覧407は、センサに1対1に対応するエントリを有し、各エントリは、エッジゲートウェイ名、センサデータ名、優先度、平均データサイズ、平均伝送時間、および送信可能数から構成される。例えば、エッジ通信情報一覧407の1行目のエントリは、エッジゲートウェイ100のカードリーダ110の優先度は「中」であり、そのセンサデータの平均データサイズは10byteであり、平均伝送時間は0.00001msであり、送信可能数は1であることを表している。また、エッジ通信情報一覧407の2行目のエントリは、エッジゲートウェイ100の監視カメラ120の優先度は「中」であり、そのセンサデータの平均データサイズは1Mbyteであり、平均伝送時間は10sであり、送信可能数は1であることを表している。ここで、上記平均伝送時間は、通信回線が空いている時間帯にエッジゲートウェイ100から集約サーバ400へ平均データサイズのセンサデータを送信するのに要した通信時間を表している。エッジ通信情報一覧407におけるエッジゲートウェイ名、センサデータ名、優先度、平均データサイズ、平均伝送時間は、センサネットワークシステムの運用開始前に初期設定されている。平均データサイズの例に示すように、カードリーダのセンサデータ量は、監視カメラのセンサデータ量に比べて十分に小さい。エッジ通信情報一覧407における送信可能数は、センサネットワークシステムの運用中にセンサデータ送信指示決定部408によって動的に更新される。
 通信データ量差計算部403は、エッジゲートウェイ100、200、300毎に以下のような処理を行う。先ず、センサデータ蓄積部405から受け取ったエッジゲートウェイからの受信データに含まれる送信時刻のタイムスタンプとネットワーク通信部401で取得された受信時刻のタイムスタンプとから、当該受信データの送信にかかった通信時間tを計算する。即ち、受信時刻をtr、送信時刻をtsとすると、通信時間tは、次式で与えられる。
  t=tr-ts   …(1)
 次に、通信データ量差計算部403は、受信データのサイズDと上記通信時間tとから、当該エッジゲートウェイと集約サーバ400間の通信速度Sを次式により計算する。
  S=D/t   …(2)
 通信速度Sは、単位時間当たりの最大転送量を表す。
 次に、通信データ量差計算部403は、エッジ通信情報一覧407から、通信回線が空いている時間帯に当該エッジゲートウェイからセンサデータ送信にかかる平均伝送時間を取得し、現在の通信速度Sでこの平均伝送時間に送信できる通信量を計算する。ここで、通信回線が空いている時間帯に当該エッジゲートウェイからカードリーダのセンサデータ送信にかかる平均伝送時間をtc、監視カメラのセンサデータ送信にかかる平均伝送時間をtpとすると、現在の通信速度Sで平均伝送時間に送信できるカードリーダのセンサデータの通信量CDs、監視カメラのセンサデータの通信量PDsは、それぞれ次式で与えられる。
  CDs=S×tc   …(3)
  PDs=S×tp   …(4)
 従って、現在の通信速度Sで平均伝送時間に送信できるカードリーダおよび監視カメラのセンサデータの合計の通信量WDsは、次式で与えられる。
  WDs=CDs+PDs  …(5)
 次に、通信データ量差計算部403は、現在の通信速度Sで平均伝送時間に送信できる通信量WDsから今回受信したデータ量を減算した結果のデータ量を、通信データ量の余過剰DFとして計算する。通信データ量の余過剰DFは、通信回線が空いている状態では0か正の値になる。また、通信データ量の余過剰DFは、通信回線が輻輳している状態では負の値になる。
 通信データ量差計算部403は、エッジゲートウェイに係る上記の通信データの余過剰DFを、センサデータ送信指示決定部408に伝達する。
 センサデータ送信指示決定部408は、エッジゲートウェイ100、200、300に対して、送信を許可するセンサデータとその送信可能数、及び送信を禁止するセンサデータの情報を含む指示を決定する。センサデータ送信指示決定部408は、通信データ量差計算部403から、或るエッジゲートウェイに係る通信データの余過剰を受け取ると、以下のような処理を行う。
 先ず、センサデータ送信指示決定部408は、通信データの余過剰が0以上か、0未満かを判定する。通信データの余過剰が0以上であれば、当該エッジゲートウェイから集約サーバ400までの通信回線が空いている状態なので、センサデータ送信指示決定部408は、通信量を現状のままとするか、或いは増加させてもよいと判断する。他方、通信データの余過剰が0未満であれば、当該エッジゲートウェイから集約サーバ400までの通信回線が混雑している状態なので、センサデータ送信指示決定部408は、通信量を現状より削減しなければならないと判断する。
 センサデータ送信指示決定部408は、通信量を現状のままとする場合、当該エッジゲートウェイについてエッジ通信情報一覧407に記録されている各センサデータの送信可能数をそのまま使用して指示を作成する。
 また、センサデータ送信指示決定部408は、通信量を現状より削減する場合、当該エッジゲートウェイについてエッジ通信情報一覧407に記録されている各センサデータの送信可能数の少なくとも1つを少なくとも1だけ削減する更新を行い、その更新後のエッジ通信情報一覧407に記録されている各センサデータの送信可能数を使用して指示を作成する。センサデータ送信指示決定部408は、送信可能数を削減するセンサデータを、例えば、以下のようにして決定する。
 先ず、センサデータ送信指示決定部408は、エッジ通信情報一覧407から当該エッジゲートウェイの各センサデータの送信可能数を確認する。次に、センサデータ送信指示決定部408は、送信可能数が1以上になっているセンサデータの中から、送信可能数を削減するセンサデータを決定する。このとき、センサデータ送信指示決定部408は、センサデータの優先度、平均データサイズ、送信可能数、および余過剰の量の少なくとも1つを考慮して、送信可能数を削減するセンサデータを決定する。例えば、センサデータ送信指示決定部408は、送信可能数が1以上になっている複数のセンサデータの優先度に差がある場合、その中で優先度が最も低いセンサデータの送信可能数を一定数だけ削減する。或いは、センサデータ送信指示決定部408は、送信可能数が1以上になっている複数のセンサデータの優先度に差がなければ、その中でセンサデータ量の余過剰の絶対値に一番近い平均データサイズのセンサデータの送信可能数を1だけ削減する。或いは、センサデータ送信指示決定部408は、センサデータ量の余過剰の絶対値にほぼ一致するデータ量だけ削減できるセンサデータの送信可能数を優先度の低いものから順に1だけ削減する。
 また、センサデータ送信指示決定部408は、通信量を現状より増大する場合、当該エッジゲートウェイについてエッジ通信情報一覧407に記録されている各センサデータの送信可能数の少なくとも1つを少なくとも1だけ増大する更新を行い、その更新後のエッジ通信情報一覧407に記録されている各センサデータの送信可能数を使用して指示を作成する。センサデータ送信指示決定部408は、送信可能数を増大するセンサデータを、例えば、以下のようにして決定する。
 先ず、センサデータ送信指示決定部408は、エッジ通信情報一覧407から当該エッジゲートウェイの各センサデータの送信可能数を確認する。次に、センサデータ送信指示決定部408は、送信可能数が0になっているセンサデータ(そのようなセンサデータがなければ、送信可能数が「1」等の閾値以下になっているセンサデータ)の中から、送信可能数を増大するセンサデータを決定する。このとき、センサデータ送信指示決定部408は、センサデータの優先度、平均データサイズ、送信可能数、および余過剰の量の少なくとも1つを考慮して、送信可能数を増大するセンサデータを決定する。例えば、センサデータ送信指示決定部408は、複数のセンサデータの優先度に差がある場合、その中で優先度が最も高いセンサデータの送信可能数を一定数だけ増大する。或いは、センサデータ送信指示決定部408は、複数のセンサデータの優先度に差がなければ、その中でセンサデータ量の余過剰の絶対値に一番近い平均データサイズのセンサデータの送信可能数を1だけ増大する。或いは、センサデータ送信指示決定部408は、センサデータ量の余過剰の絶対値にほぼ一致するデータ量だけ増大できるセンサデータの送信可能数を優先度の高いものから順に1だけ増大する。
 送信データ作成部402は、センサデータ送信指示決定部408から受け取ったエッジゲートウェイ100、200、300に対する指示を含む送信データを作成し、ネットワーク通信部401に伝達する。この送信データは、エッジゲートウェイ100、200、300から受信したセンサデータに対するレスポンスとして作成される。
 上述したエッジゲートウェイ100、200、300、および集約サーバ400のそれぞれは、例えば図5に示すように、キーボードやマウスなどの操作入力部1001と、液晶ディスプレイ等の画面表示部1002と、通信インターフェース部1003と、メモリやハードディスク等の記憶部1004と、1以上のマイクロプロセッサ等の演算処理部1005とを有するパーソナルコンピュータ等の情報処理装置1006と、プログラム1007とで実現することができる。
 プログラム1007は、情報処理装置1006の立ち上げ時等に外部のコンピュータ読み取り可能な記憶媒体からメモリに読み込まれ、演算処理部1005の動作を制御する。これにより、プログラム1007は、エッジゲートウェイ100、200、300にあっては、演算処理部1005上に、ネットワーク通信部101、送信データ選択作成部102、センサデータ蓄積部103、受信データ解析部104、センサ情報格納部105、およびセンサ制御部106といった機能的手段を実現する。また、プログラム1007は、集約サーバ400にあっては、ネットワーク通信部401、送信データ作成部402、通信データ量差計算部403、受信データ解析部404、センサデータ蓄積部405、エッジ情報格納部406、センサデータ送信指示決定部408といった機能的手段を実現する。
<本実施形態の動作>
 次に本実施形態の動作を説明する。
 先ず、エッジゲートウェイ100、200、300の動作を説明する。図6および図7は、エッジゲートウェイ100の動作の一例を示すフローチャートである。以下、図6および図7を参照して、エッジゲートウェイ100の動作を説明する。なお、エッジゲートウェイ200、300の動作は、エッジゲートウェイ100の動作と同じである。
 エッジゲートウェイ100のセンサ制御部106は、先ず、カードリーダ110を待ち受け状態とする(ステップS101)。次に、センサ制御部106は、カードリーダ110でデータが発生したか否かを判定する(ステップS102)。例えば、図8に示すように、社員証113がカードリーダ110にかざされると、カードリーダ110で社員証113の情報が読み取られ、データが発生する。センサ制御部106は、カードリーダ110でデータが発生していなければ、カードリーダ110をなおも待ち受け状態とする(ステップS101)。
 他方、センサ制御部106は、カードリーダ110でデータが発生すると、カードリーダ110からデータを受信する(ステップS103)。次に、センサ制御部106は、監視カメラ120に記録指示を出す(ステップS104)。記録指示が出されると、監視カメラ120は、図8に示すように、カードリーダ110を通過する社員の画像データを取得して記録する。次に、センサ制御部106は、監視カメラ120から上記記録されたデータを受信する(ステップS105)。
 次に、センサデータ蓄積部103は、カードリーダ110のデータと監視カメラ120のデータをセンサ制御部106から受け取って蓄積し、未送信データ一覧109を更新する(ステップS106)。即ち、センサデータ蓄積部103は、未送信データ数一覧109に記録されたカードリーダ110の未送信データ数と監視カメラ120の未送信データ数とを1だけ加算する。
 次に、送信データ選択作成部102は、センサデータ蓄積部103から未送信データ一覧109を取得し、カードリーダ110及び監視カメラ120の未送信データ数を確認する(ステップS107)。また、送信データ選択作成部102は、センサ情報格納部105からセンサ情報一覧107を取得し、カードリーダ110及び監視カメラ120の送信可能数を確認する(ステップS108)。そして、送信データ選択作成部102は、全てのセンサ(即ち、カードリーダ110及び監視カメラ120)に対して、送信可能数が1以上であれば、センサデータ蓄積部103に蓄積されているセンサデータから送信可能数分のセンサデータを古い順に抽出して送信対象に追加する(ステップS109~S112)。次に、送信データ選択作成部102は、全てのセンサについて、送信対象に追加した分だけ未送信データ一覧109に記録された未送信データ数を削減して更新する(ステップS113)。次に、送信データ選択作成部102は、現在時刻のタイムスタンプ(送信時刻のタイムスタンプ)と送信対象とから送信データを作成する(ステップS114)。
 次に、ネットワーク通信部101は、送信データ選択作成部102によって作成された送信データをネットワークNWの通信回線を通じて集約サーバ400へ送信する(ステップS115)。その後、ネットワーク通信部101は、集約サーバ400から返信を受信するのを待ち受ける(ステップS116、S117)。そして、ネットワーク通信部101は、集約サーバ400から返信を受信すると、受信したデータを受信データ解析部104に伝達する(ステップS118)。
 受信データ解析部104は、集約サーバ400からのセンサデータの送信可能数の指示を受信データから抽出する(ステップS119)。次に、センサ情報格納部105は、受信データ解析部104によって抽出された指示に従って、センサ情報一覧107中の送信可能数の値を更新する(ステップS120)。その後、エッジゲートウェイ100は、ステップS101の処理へと戻る。
 次に、集約サーバ400の動作を説明する。図9は、集約サーバ400がエッジゲートウェイ100に対して実行する動作の一例を示すフローチャートである。以下、図9を参照して、集約サーバ400がエッジゲートウェイ100に対して実行する動作を説明する。なお、集約サーバ400がエッジゲートウェイ200、300に対して実行する動作は、エッジゲートウェイ100に対して実行する動作と同じである。
 集約サーバ400のネットワーク通信部401は、エッジゲートウェイ100からメッセージを受信するのを待ち受けている(ステップS131、S132)。ネットワーク通信部401は、エッジゲートウェイ100からメッセージを受信すると、受信時刻のタイムスタンプを生成し、受信データと受信時刻のタイムスタンプとを受信データ解析部404に伝達する(ステップS133)。受信データ解析部404は、渡された受信データを解析してセンサデータと送信時刻のタイムスタンプとを抽出し、それらと受信時刻のタイムスタンプとをセンサデータ蓄積部405へ伝達する(ステップS134)。センサデータ蓄積部405は、渡されたセンサデータと送信時刻のタイムスタンプと受信時刻のタイムスタンプとを記憶装置に記憶して保存する(ステップS135)。次に、センサデータ蓄積部405は、保存したセンサデータと送信時刻とタイムスタンプと受信時刻のタイムスタンプとを通信データ量差計算部403に伝達する(ステップS136)。
 通信データ量差計算部403は、渡されたセンサデータと送信時刻のタイムスタンプと受信時刻のタイムスタンプとに基づいて、通信にかかった時間と通信速度を計算する(ステップS137)。通信データ量差計算部403は、受信時刻のタイムスタンプと送信時刻のタイムスタンプとの差を通信にかかった時間として計算する。また、受信データのサイズと上記計算した通信時間とから、通信速度を計算する。次に、通信データ量差計算部403は、エッジ情報格納部406のエッジ通信情報一覧407から、通信回線が空いている時間帯にエッジゲートウェイ100からのセンサデータ送信にかかる時間(平均伝送時間)を取得する(ステップS138)。次に、通信データ量差計算部403は、上記取得した平均伝送時間とステップS137で計算した通信速度と、受信したデータ量とから、通信データの余過剰を計算する(ステップS139)。
 次に、センサデータ送信指示決定部408は、エッジ通信情報一覧407を取得し、エッジゲートウェイ100につながっているセンサの優先度、平均データサイズ、送信可能数を取得する(ステップS140)。次に、センサデータ送信指示決定部408は、上記取得した情報に基づいて、エッジゲートウェイ100がデータ量の余過剰分を追加または削除するためにエッジゲートウェイ100が送信するべきセンサの種類と送信可能数とを含む指示を決定する(ステップS141)。次に、送信データ作成部402は、センサデータ送信指示決定部408が決定した指示を含むレスポンスを作成し、ネットワーク通信部401に伝達する(ステップS142)。次に、ネットワーク通信部401は、上記作成されたレスポンスをネットワークNWの通信回線を通じてエッジゲートウェイ100へ送信する(ステップS143)。
 次に、本実施形態の動作をより具体的に説明する。前提として、オフィスビル内の既存システムがネットワークNWの通信回線を使用して行う通信は9時から17時までがピークとなり、それ以外の時間はほぼ通信回線を使用していないものとする。
(A)最初に、8時30分にカードリーダ110をオフィスビルの社員が通過したときの動作を説明する。
(1)社員がカードリーダ110に社員証113をかざすと、カードリーダ110は社員証を読み取り、センサ制御部106にデータを送信する。
(2)センサ制御部106は、監視カメラ120に記録指示を出し、監視カメラ120で撮像して得られた社員の画像データを結果として受け取る。センサ制御部106は、カードリーダ110から受信したセンサデータと監視カメラ120から受信したセンサデータとをセンサデータ蓄積部103に渡す。
(3)センサデータ蓄積部103は、上記2つのセンサデータを格納し、未送信データ一覧109の各センサの未送信データ数にそれぞれ1を加える。その後、センサデータ蓄積部103は、送信データ選択作成部102へセンサデータの送信を依頼する。
(4)送信データ選択作成部102は、センサデータ蓄積部103から未送信データ一覧109を受け取り、また、センサ情報格納部105からセンサ情報一覧107を受け取り、全センサデータについて送信可能数を確認する。そして、送信データ選択作成部102は、送信可能数の分だけ未送信データ一覧109内のセンサデータを古い順に選択し、かつ現時点のタイムスタンプを送信時刻のタイムスタンプとして取得して送信データを作成し、ネットワーク通信部101に渡して送信を依頼する。また、送信データ選択作成部102は、センサデータ蓄積部103の未送信データ一覧109に記録された未送信データ数から、送信を決定したデータ数を引いて更新する。
(5)ネットワーク通信部101は、ネットワークNWを通じて送信データを集約サーバ400に向けて送信する。
(6)集約サーバのネットワーク通信部401は、データを受信し、受信データと受信時刻のタイムスタンプとを受信データ解析部404に渡す。
(7)受信データ解析部404は、受信データにセンサデータと送信時刻のタイムスタンプとが含まれていることを確認して、センサデータ蓄積部405にセンサデータと送信時刻のタイムスタンプと受信時刻のタイムスタンプとの格納を依頼する。
(8)センサデータ蓄積部405は、センサデータと送信時刻のタイムスタンプと受信時刻のタイムスタンプとを格納し、さらに通信データ量差計算部403へそれらを渡す。
(9)通信データ量差計算部403は、送信時刻タイムスタンプと受信時刻のタイムスタンプとから、データの送信にかかった通信時間を計算する。更に、通信データ量差計算部403は、上記計算した通信時間と受信したデータサイズとから、エッジゲートウェイ100と集約サーバ400との間の通信速度を計算する。次に、通信データ量差計算部403は、エッジ情報格納部406のエッジ通信情報一覧407から、通信回線が空いている時間帯にエッジゲートウェイ100からのセンサデータ送信にかかる時間(平均伝送時間)を取得し、現在の通信速度でこの平均伝送時間に送信できる通信量を計算する。そして、通信データ量差計算部403は、今回受信したデータ量とその送信できる通信量との差分を、通信データ量の余過剰として計算する。今の場合は、回線が空いている状態なので、この余過剰は0か正の値になる。以下では、余過剰がほぼ0であったものとして説明する。通信データ量差計算部403は、この余過剰をセンサデータ送信指示決定部408に渡す。
(10)センサデータ送信指示決定部408は、エッジ情報格納部406のエッジ通信情報一覧407を取得し、エッジゲートウェイ100に接続されているカードリーダ110と監視カメラ120の優先度が共に「中」、それらの送信可能数が1であることを確認する。また、センサデータ送信指示決定部408は、通信データ量差計算部403から受け取った通信データ量の余過剰がほぼ0になっていることを確認する。そして、センサデータ送信指示決定部408は、上記の確認に基づいて、カードリーダ110と監視カメラ120は引き続き送信可能と判断して、送信データ作成部402に対して、カードリーダ110の送信可能数は1、監視カメラの送信可能数は1、という指示を伝達する。
(11)送信データ作成部402は、エッジゲートウェイ100へのセンサデータ送信指示決定部408からの指示を含むレスポンスを作成し、ネットワーク通信部401に渡す。
(12)ネットワーク通信部401は、作成したレスポンスを、ネットワークNWを通じてエッジゲートウェイ100へ送信する。
(13)エッジゲートウェイ100のネットワーク通信部101は、レスポンスを受信し、受信データ解析部104に渡す。
(14)受信データ解析部104は、集約サーバ400からの指示が、カードリーダ110の送信可能数は1、監視カメラ120の送信可能数は1、であることを確認し、センサ情報格納部105にその指示を転送する。
(15)センサ情報格納部105は、受信データ解析部104から渡されてきた集約サーバ400からの指示を元に、センサ情報一覧107の送信可能数の列をそれぞれ1と1に更新して終了する。
(B)次に、9時にカードリーダ110をオフィスビルの社員が再度通過したときの動作を説明する。
(16)先ず、上記Aのステップ(1)~(8)と同様の動作が行われる。
(17)通信データ量差計算部403は、受信データ内の送信時刻のタイムスタンプとネットワーク通信部401で取得した受信時刻のタイムスタンプとから、データの送信にかかった時間を計算する。更に、通信データ量差計算部403は、上記計算した通信時間と、受信したデータサイズとから、エッジゲートウェイ100と集約サーバ400との間の通信速度を計算する。次に、通信データ量差計算部403は、エッジ情報格納部406のエッジ通信情報一覧407から、通信回線が空いている時間帯にエッジゲートウェイ100からのセンサデータ送信にかかる時間(平均伝送時間)を取得し、現在の通信速度でその平均伝送時間に送信できる通信量を計算する。そして、通信データ量差計算部403は、今回受信したデータ量とその送信できる通信量との差を、通信データ量の余過剰として計算する。今の場合、回線が混雑し出している状態なので、通信に大きな時間がかかり、この余過剰は負の値になっているとする。通信データ量差計算部403は、この余過剰をセンサデータ送信指示決定部408に渡す。
(18)センサデータ送信指示決定部408は、エッジ情報格納部406のエッジ通信情報一覧407を取得し、エッジゲートウェイ100に接続されているカードリーダ110と監視カメラ120の送信可能数が1であることを確認する。また、センサデータ送信指示決定部408は、通信データ量差計算部403から受け取った通信データ量の余過剰が負になっていることを確認する。次に、センサデータ送信指示決定部408は、カードリーダ110と監視カメラ120の平均データサイズから、監視カメラ120のデータを送信しなければ通信データ量の過剰分を満たせると判断して、エッジ通信情報一覧407の監視カメラ120の送信可能数を1減じて0に更新する。そして、センサデータ送信指示決定部408は、送信データ作成部402にカードリーダ110の送信可能数は1、監視カメラ120の送信可能数は0、という指示を伝達する。
(19)送信データ作成部402は、エッジゲートウェイ100へ上記指示を含むレスポンスを作成し、ネットワーク通信部401に渡す。
(20)ネットワーク通信部401は、渡されたレスポンスを、ネットワークNWを通じてエッジゲートウェイ100へ送信する。
(21)エッジゲートウェイ100のネットワーク通信部101は、レスポンスを受信し、受信データ解析部104に渡す。
(22)受信データ解析部104は、集約サーバ400からの指示が、カードリーダ1110の送信可能数は1、監視カメラ120の送信可能数は0であることを確認し、センサ情報格納部105にその指示を転送する。
(23)センサ情報格納部105は、受信データ解析部104から渡されてきたサーバからの指示を元に、センサ情報一覧107に記録された監視カメラ120の送信可能数の列を0に更新して終了する。
(24)上記(16)~(23)のステップを繰り返す。ただしステップ(4)では、送信データ選択作成部102は、センサ情報一覧107に記録された監視カメラ120の送信可能数が0となっていることから、監視カメラ120のセンサデータを含まない送信データを作成する。その結果、センサデータ蓄積部103の未送信データ一覧109に記録された監視カメラ120の未送信データ数は、データを送信しない結果、新たな監視カメラ120のセンサデータが蓄積されるに従って、1ずつ増加していく。
 次に、18時にカードリーダ110をオフィスビルの社員が再度通過したときの動作を説明する。
(25)上記(1)~(15)のステップを繰り返す。ただし、ステップ(9)の計算では、再び通信回線が空いている状態になり、かつ現在の送信データ量が少ないので、余過剰の値が大幅な正の値になる。そのため、ステップ(10)では、センサデータ送信指示決定部408が作成するエッジゲートウェイ100に伝達する指示は、たとえばカードリーダ110の送信可能数は1、監視カメラ120の送信可能数は2、という値になる。
(26)その結果、ステップ(15)では、センサ情報格納部105は、センサ情報一覧107に記録された監視カメラ120の送信可能数を2に更新する。
(27)従って、次のセンサデータの送信タイミングになったときに、ステップ(4)では、送信データ選択作成部102は、カードリーダ110の未送信データを1つ選択し、監視カメラ120の未送信データを古い順に2つ選択する。その結果、カードリーダ110の1つのセンサデータと監視カメラ120の2つのセンサデータとを含む送信データがエッジゲートウェイ100から集約サーバ400へ送信される。
(28)上記(1)~(15)のステップを繰り返す。
 これらのステップにより、通信回線の混雑状況に応じてセンサネットワークシステムが使用する通信帯域を変動させて、他システムの通信を優先させることが可能となる。センサネットワークシステムでは、上述の例の監視カメラ120のように、一部のセンサデータの収集にリアルタイム性が不要であることから、それらのデータの収集を適切に遅延させることで、通信回線の輻輳を緩和する。
<本実施形態の効果>
 本実施形態によれば、エッジゲートウェイ100、200、300と集約サーバ400とを接続する通信回線に輻輳が発生した場合、それを検出して解消させることができる。その理由は、集約サーバ400が、通信回線の輻輳状態の目安となる通信データの余過剰を算出し、余過剰が負となる、通信回線が輻輳状態になると、収集するセンサデータ量を削減すべく、センサデータの送信可能数をより少なくする指示を作成してエッジゲートウェイ100、200、300へ送信するためである。
 また、本実施形態によれば、通信回線の混み具合にあわせて、通信回線を共用する他のシステムに通信回線の使用を優先させることができる。その理由は、センサネットワークシステムが、通信回線の混み具合にあわせて、使用する帯域幅を増減させるためである。
 また本実施形態によれば、通信回線が空いているときに、より多くの未送信データをまとめて送信できる。その理由は、集約サーバ400が、通信回線の輻輳状態の目安となる通信データの余過剰を算出し、余過剰が正となる、通信回線が空いている状態になると、収集するセンサデータ量を増大すべく、センサデータの送信可能数をより多くする指示を作成してエッジゲートウェイ100、200、300へ送信するためである。
[第2の実施形態]
 図10は、本発明の第2の実施形態に係るセンサネットワークシステムのブロック図である。本実施形態に係るセンサネットワークシステムは、図1に示した第1の実施形態に係るセンサネットワークシステムと比較して、エッジゲートウェイ100、200、300がセンサ固有制御部110C、120Cを有する点で相違し、それ以外は第1の実施形態に係るセンサネットワークシステムと同じである。
 センサ固有制御部110Cは、カードリーダ110に対応する。センサ固有制御部120Cは、監視カメラ120に対応する。センサ固有制御部110C、120Cは、センサ情報一覧107に記録された、対応するセンサの送信可能数を参照し、その送信可能数が0であるか否かを判定する。センサ固有制御部110C、120Cは、対応するセンサの送信可能数が0でなければ、対応するセンサからのデータの送信に対して応答を返す。しかし、センサ固有制御部110C、120Cは、対応するセンサの送信可能数が0であれば、対応するセンサからのデータの送信に対して応答を返さない。
 センサであるカードリーダ110、監視カメラ120は、データをセンサ制御部106に送信した後、センサ固有制御部110C、120Cからの応答を待ち合わせる。カードリーダ110、監視カメラ120は、所定時間だけ待ち合わせても応答を受信しない場合、同じデータを再送し、再び応答を待ち合わせる。カードリーダ110、監視カメラ120は、そのような動作を、応答が受信できるまで繰り返す。その間、センサデータは、カードリーダ110および監視カメラ120の送信バッファに蓄積されていく。
 このように本実施形態では、エッジゲートウェイ100から集約サーバ400への送信を一時停止するセンサのセンサデータを、センサのデバイス側で蓄積するように構成されている。その結果、センサデータ蓄積部103でセンサデータを蓄積するための記憶容量を削減することが可能になる。
 本実施形態では、エッジゲートウェイ100にセンサデータ蓄積部103を備えるようにした。しかし、センサのデバイス側でセンサデータを蓄積する送信バッファの容量に余裕がある場合、センサデータ蓄積部103を省略するようにしてもよい。
[第3の実施形態]
 本実施形態に係るセンサネットワークシステムは、図1に示した第1の実施形態に係るセンサネットワークシステムと比較して、集約サーバ400のセンサデータ送信指示決定部408の機能が相違し、それ以外は第1の実施形態に係るセンサネットワークシステムと同じである。
 本実施形態におけるセンサデータ送信指示決定部408は、通信データ量差計算部403で計算された通信データ量の余過剰、即ち通信回線の輻輳度合いに基づいて、センサデータの収集を行うセンサと収集を保留するセンサとを決定する際、両者を定期的に変更する。具体的には、例えば、エッジゲートウェイ100に、1番から10番までの合計10個のセンサが取り付けられており、それらの優先度は全て同じであるとする。また、通信回線の輻輳状態を解消するために、全てのセンサデータの収集を続けることができず、例えば半分のセンサデータの収集を保留にする必要があるとする。このとき、センサデータ送信指示決定部408は、エッジゲートウェイ100に送る指示として、1回目は、1番、3番、5番、7番、9番のセンサの送信可能数を1、残りの2番、4番、6番、8番、10番のセンサの送信可能数を0とする指示を作成する。また、センサデータ送信指示決定部408は、エッジゲートウェイ100に送る指示として、2回目は、2番、4番、6番、8番、10番のセンサの送信可能数を1、残りの1番、3番、5番、7番、9番のセンサの送信可能数を0とする指示を作成する。
 このようにセンサデータ送信指示決定部408は、送信を許可するセンサ、送信を禁止するセンサの組み合わせを指示毎に調整する。また、センサデータ送信指示決定部408は、長時間送信を停止していたセンサのセンサデータを優先的に送信するように指示を決定する。また、センサデータ送信指示決定部408は、センサデータの通信量の余過剰の値が変わらなくても、停止する、停止しないセンサを入れ替える。これによって、特定のセンサのセンサデータが長期間に亘って収集されない事態を防止することができる。
[第4の実施形態]
 本実施形態に係るセンサネットワークシステムは、図1に示した第1の実施形態に係るセンサネットワークシステムと比較して、エッジゲートウェイ100、200、300の送信データ選択作成部102の機能が相違し、それ以外は第1の実施形態に係るセンサネットワークシステムと同じである。
 本実施形態における送信データ選択作成部102は、センサ情報一覧107に記録された全てのセンサデータの送信可能数が0である場合、30秒あるいは1分などの所定の間隔で、送信時刻のタイムスタンプを含みセンサデータは一切含まないメッセージを、ネットワークNWを通じてエッジゲートウェイ100から集約サーバ400へ送信する。上記メッセージは、通信回線の輻輳状況の確認と、エッジゲートウェイ100のハートビートを兼ねる。上記メッセージを、本明細書では、ハートビートメッセージと記す。
 集約サーバ400は、エッジゲートウェイ100からハートビートメッセージを受信すると、ハートビートメッセージの送信時刻と受信時刻との時間差と、輻輳が発生していない状態でのハートビートメッセージの通信時間との差分に基づいて、通信回線の輻輳度合いを判定する。そして、集約サーバ400は、第1の実施形態における動作の説明のステップ(7)~(15)と同様の動作により、センサ単位のデータの送信指示をエッジゲートウェイ100へ返却する。
 エッジゲートウェイ100の送信データ選択作成部102は、集約サーバ400から返信された指示で、少なくとも1つのセンサデータの送信可能数が1以上であれば、ハートビートメッセージの送信を停止する。また、送信データ選択作成部102は、センサデータが送信できない状況が続いていることを確認すると、ハートビートメッセージの送信を継続する。
 このように本実施形態によれば、集約サーバからエッジゲートウェイに送られた指示が、エッジゲートウェイに接続された全センサのデータの送信を停止する指示であることから、エッジゲートウェイから集約サーバへ送信するセンサデータが無い状況であっても、ネットワークNWの通信回線の輻輳状態を継続して監視することができる。
[第5の実施形態]
 次に本発明の第5の実施形態について説明する。
 先ず、本実施形態が解決しようとする課題を説明する。集約サーバ400に、ネットワークNWを通じて3つのエッジゲートウェイ100、200、300が接続されているセンサネットワークシステムにおいて、図11の破線で示すように、エッジゲートウェイ200とエッジゲートウェイ300とがネットワークNWの通信回線を共用している状況を想定する。また、その部分でそのとき使用可能な回線帯域は30Mbpsであると仮定する。
 エッジゲートウェイ200とエッジゲートウェイ300とが通信回線を共用していることを知ることができない場合、その部分での使用可能な回線帯域が30Mbpsであることも知ることはできない。その場合、集約サーバ400は、エッジゲートウェイ200とエッジゲートウェイ300とに対してそれぞれ独立して通信帯域を制限する個別最適を実施するしかない。そのような個別最適によって、エッジゲートウェイ200とエッジゲートウェイ300のそれぞれのセンサが送信するデータ量から、使用可能帯域を例えば図11に記載するように20Mbps、25Mbpsに設定したとしても、共用部分がボトルネックとなり輻輳が発生する。この場合、各エッジゲートウェイの送信可能帯域をそれぞれ調整して最適な値を手探りで設定していくことになる。そのため、輻輳を早期に解消するのは困難である。本実施形態は係る課題を解決する。
 図12は、本発明の第5の実施形態に係るセンサネットワークシステムのブロック図である。本実施形態に係るセンサネットワークシステムは、集約サーバ400に、ネットワークNWを通じて、3つのエッジゲートウェイ100、200、300が接続されている。また、エッジゲートウェイ100には、2つのセンサ111、121が接続され、エッジゲートウェイ200には、2つのセンサ211、221が接続され、エッジゲートウェイ300には、2つのセンサ311、321が接続されている。ここで、エッジゲートウェイ100、200、300は、図1に示した第1の実施形態におけるエッジゲートウェイ100、200、300と同じである。他方、集約サーバ400は、図1に示した第1の実施形態における集約サーバ400と比較して、通信データ量差計算部403、エッジ情報格納部406、およびセンサデータ送信指示決定部408の機能が相違し、それ以外は第1の実施形態における集約サーバ400と同じである。
 本実施形態における集約サーバ400の通信データ量差計算部403は、第1の実施形態における通信データ量差計算部403と同様の機能を有すると共に、通信時間の増減の推移から同じ通信回線を共用するエッジゲートウェイの組み合わせを決定する機能を有している。具体的には、本実施形態の通信データ量差計算部403は、エッジゲートウェイ毎に、エッジゲートウェイから集約サーバ400へ送信するセンサデータの送信時刻と受信時刻との時間差が、時間の経過に応じてどのように変動するかを表すパターン(変動パターン)を生成する機能を有する。また、本実施形態の通信データ量差計算部403は、エッジゲートウェイ毎の変動パターンを比較し、同一あるいは類似する変動パターンの複数のエッジゲートウェイの組み合わせを、輻輳が発生している通信回線を共用しているエッジゲートウェイのグループとして決定する機能を有する。
 また、本実施形態におけるエッジ情報格納部406は、第1の実施形態におけるエッジ情報格納部406と同様の機能を有すると共に、上記生成された変動パターンおよびグループの情報を含むエッジ通信情報一覧407を蓄積する機能を有する。
 図13は、本実施形態におけるエッジ通信情報一覧407の内容の一例を示す。図4に示されるエッジ通信情報一覧407と比較して、送受信時間変動パターンとグループ名の欄が追加されている。
 また、本実施形態におけるセンサデータ送信指示決定部408は、輻輳が発生している通信回線を共用しているエッジゲートウェイの組み合わせを1つのグループとして、センサデータの収集を行うセンサと収集を保留するセンサとを決定する機能を有する。輻輳が発生している通信回線を共用しているエッジゲートウェイの組み合わせが存在しない場合、本実施形態におけるセンサデータ送信指示決定部408は、第1の実施形態におけるセンサデータ送信指示決定部408と同様に機能する。
 このように、本実施形態は、複数のエッジゲートウェイ100、200、300が1つの集約サーバ400に接続されているセンサネットワークシステムにおいて、集約サーバ400とエッジゲートウェイ100、200、300間の通信時間の変動が複数のエッジゲートウェイで同じような動きをしている場合に、それら複数のエッジゲートウェイが集約サーバ400への通信回線を共用していると判断する。そして、本実施形態は、通信回線を共用している複数のエッジゲートウェイを1つのグループとみなして、グループ単位でセンサデータの重要度が高い順番に、送信するセンサデータの送信可能の判断を行う。
 例えば、図12および図13では、通信データ量差計算部403は、エッジゲートウェイ200とエッジゲートウェイ300の送受信時間変動のパターンを一定時間計測した結果、類似するパターンYであったことから、同じボトルネックとなる通信回線を共用していると判断する。その結果、センサデータ送信指示決定部408は、エッジゲートウェイ100、200、300を、エッジゲートウェイ100を含むグループAと、エッジゲートウェイ200、300を含むグループBCとに分割し、グループ単位で通信量の制御を行う。例えば、センサデータ送信指示決定部408は、グループBCには、優先度が高いセンサ211、311、優先度が低いセンサ221、321の4つのセンサが存在するので、これら4つのセンサの中から例えば優先度が高いセンサ211、311のセンサデータの送信を許可し、優先度の低いセンサ221、321のセンサデータの送信を一時的に停止するようにする。また、仮に、センサ211、221の優先度が低く、センサ311、321の優先度が高いとすると、センサデータ送信指示決定部408は、これら4つのセンサの中から、優先度の高いセンサ311、321のセンサデータの送信を許可し、優先度の低いセンサ211、321のセンサデータの送信を一時的に停止するようにする。これによって、通信回線を共用する2つのエッジゲートウェイ200、300のうち、エッジゲートウェイ300に接続されたセンサ311、321のセンサデータの送信を許可し、エッジゲートウェイ200に接続されたセンサ211、221の送信を一時的に停止するようになる。このような指示は、個別最適化では実現することは困難である。これにより、複数のエッジゲートウェイからのデータ送信を考慮したシステム全体の最適化を実現することができる。
[第6の実施形態]
 図14を参照すると、本発明の第5の実施形態に係るセンサネットワークシステムは、1または複数のセンサ機器501と、センサ機器501からセンサデータを収集する1または複数のゲートウェイ装置502と、ゲートウェイ装置502に通信回線503を通じて接続され、ゲートウェイ装置502から通信回線503を通じてセンサデータを収集するサーバ装置504とを含む。また、サーバ装置504は、判定部511と制御部512とを有する。
 サーバ装置504の判定部511は、ゲートウェイ装置502からサーバ装置504へ送信するセンサデータの送信時刻と受信時刻との時間差と輻輳が発生していない状態での通信時間との差分に基づいて、通信回線503の輻輳度合いを判定する機能を有する。判定部511は、例えば図1のネットワーク通信部401、受信データ解析部404、センサデータ蓄積部405、および通信データ量差計算部403によって実現することができるが、それに限定されない。
 サーバ装置504の制御部512は、判定部511の判定結果に基づいて、センサデータの収集を行うセンサ機器501とセンサデータの収集を保留するセンサ機器501とを決定する機能を有する。また、制御部512は、ゲートウェイ装置502に対して、上記決定した内容を含む指示を送出する機能を有する。制御部512は、例えば図1のエッジ情報格納部406、センサデータ送信指示決定部408、送信データ作成部402、およびネットワーク通信部401によって実現することができるが、それに限定されない。
 このように構成された本実施形態に係るセンサネットワークシステムは、以下のように動作する。即ち、ゲートウェイ装置502は、センサ機器501からセンサデータを収集し、通信回線503を通じて、サーバ装置504へ送信する。サーバ装置504の判定部511は、ゲートウェイ装置502からサーバ装置504へ送信するセンサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、通信回線503の輻輳度合いを判定する。そして、サーバ装置504の制御部512は、通信回線503の輻輳度合いの判定結果に基づいて、センサデータの収集を行うセンサ機器501とセンサデータの収集を保留するセンサ機器501とを決定し、ゲートウェイ装置502に対して、上記決定した内容を含む指示を送出する。ゲートウェイ装置502は、上記指示に従って、センサ機器501のセンサデータの中からサーバ装置504へ送信するセンサデータを選択して送信データを作成し、サーバ装置504へ送信する。
 このように本実施形態によれば、ゲートウェイ装置502とサーバ装置504とを接続する通信回線に輻輳が発生した場合、それを検出して解消させることができる。その理由は、サーバ装置504の判定部511は、ゲートウェイ装置502からサーバ装置504へ送信するセンサデータの送信時刻と受信時刻との時間差と輻輳が発生していない状態での通信時間との差分に基づいて、通信回線503の輻輳度合いを判定し、サーバ装置504の制御部512は、判定部511の判定結果に基づいて、センサデータの収集を行うセンサ機器501とセンサデータの収集を保留するセンサ機器501とを決定し、決定した内容を含む指示をゲートウェイ装置502に送出するためである。
 本実施形態は、以下のような変形が可能である。
 例えば、制御部512は、通信回線503が輻輳状態にある場合、ゲートウェイ装置502に対して最後に送出した指示に含まれる上記決定した内容と比較して、センサデータの収集を保留するセンサ機器501の数をより多くした内容を決定するように構成されていてよい。
 また、制御部511は、通信回線503が輻輳状態にない場合、ゲートウェイ装置502に対して最後に送出した指示に含まれる上記決定した内容と比較して、センサデータの収集を保留するセンサ機器の数をより少なくした内容を決定するように構成されていてよい。
 また、制御部511は、センサ機器501の優先度に基づいて、センサデータの収集を行うセンサ機器501とセンサデータの収集を保留するセンサ機器501とを決定するように構成されていてよい。
 また、制御部511は、センサデータの収集を行うセンサ機器501については、何回分のセンサデータの収集を行うかを示す送信可能数を、通信回線503の輻輳度合いに応じて決定し、この決定した内容を前記指示に含ませるように構成されていてよい。
 また、制御部511は、センサデータの収集を行うセンサ機器501とセンサデータの収集を保留するセンサ機器501とを定期的に入れ替えるように構成されていてよい。
 また、制御部511は、上記時間差の時間の経過に伴う変動パターンをゲートウェイ装置502のそれぞれについて生成し、その生成したゲートウェイ装置毎の変動パターンを比較して輻輳が発生している通信回線503を共用しているゲートウェイ装置502の組み合わせを決定し、その決定したゲートウェイ装置502の組み合わせを1つのグループとして、センサデータの収集を行うセンサ機器501とセンサデータの収集を保留するセンサ機器501とを決定するように構成されていてよい。
 また、ゲートウェイ装置502は、上記指示に従って、サーバ装置504へ送信しないセンサ機器501に対してはセンサ機器501からのセンサデータの送信に対して、故意に応答を返さないことにより、センサデータをセンサ機器501の送信バッファに蓄積させたままとするように構成されていてよい。
 また、ゲートウェイ装置502は、上記指示に従って、サーバ装置504へ何れのセンサ機器501のセンサデータをも送信しない期間中、定期的に、送信時刻を記載したハートビートメッセージを送信するように構成されていてよい。そして、その場合、サーバ装置504の判定部511は、ハートビートメッセージの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、通信回線503の輻輳度合いを判定するように構成されていてよい。
 以上、上記各実施形態を参照して本発明を説明したが、本発明は、上述した実施形態に限定されるものではない。本発明の構成や詳細には、本発明の範囲内で当業者が理解しうる様々な変更をすることができる。
 例えば、図1に示した第1の実施形態に係るセンサネットワークシステムにおいて、エッジゲートウェイ100の送信データ選択作成部102は、センサデータを含む送信データに付加して、或いはセンサデータを含む送信データとは独立に、未送信データ一覧109に記録された各センサ(カードリーダ、監視カメラ)の未送信データ数を集約サーバ400へ送信するようにしてよい。また、集約サーバ400のエッジ情報格納部406は、エッジゲートウェイ100から受信した各センサデータの未送信データ数を、エッジ通信情報一覧407の各エントリの1つの列として記録するようにしてよい。また、集約サーバ400のエッジ情報格納部406は、1つの受信データにカードリーダと監視カメラとで異なる数のセンサデータが含まれている場合、数の少ない方のセンサデータが未送信データとしてエッジゲートウェイに残っていると判断して、エッジ通信情報一覧407の上記数の少ない方のセンサデータの未送信データ数を上記少ない数だけ増加させるようにしてもよい。そして、集約サーバ400のセンサデータ送信指示決定部408は、エッジ通信情報一覧407に記録された各センサデータの未送信データ数に基づいて、センサデータの収集を行うセンサとその送信可能数、センサデータの収集を保留するセンサを決定するように構成されていてよい。例えば、センサデータ送信指示決定部408は、通信回線が空いている場合、未送信データ数のより多いセンサデータを優先的に送信対象に組み入れるようにしてよい。
 なお、本発明は、日本国にて2017年3月28日に特許出願された特願2017-062787の特許出願に基づく優先権主張の利益を享受するものであり、当該特許出願に記載された内容は、全て本明細書に含まれるものとする。
 本発明は、センサネットワークシステム全般に利用できる。また、本発明は、既存の建物に監視カメラを追加設置して共用回線を介して遠隔地で監視するような構成のセキュリティの分野で利用できる。また、本発明は、大量の観測データを、既存ネットワークを使って収集するような構成の科学の分野で利用できる。
 上記の実施形態の一部又は全部は、以下の付記のようにも記載され得るが、以下には限られない。
[付記1]
 1または複数のセンサ機器からセンサデータを収集する1または複数のゲートウェイ装置と、前記ゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するサーバ装置とを含むセンサネットワークシステムであって、
 前記サーバ装置は、
 前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する判定部と、
 前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する制御部と、
を含む、
センサネットワークシステム。
[付記2]
 前記制御部は、前記通信回線が輻輳状態にある場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより多くした内容を決定する、
付記1に記載のセンサネットワークシステム。
[付記3]
 前記制御部は、前記通信回線が輻輳状態にない場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより少なくした内容を決定する、
付記1または2に記載のセンサネットワークシステム。
[付記4]
 前記制御部は、前記センサ機器の優先度に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
付記1乃至3の何れかに記載のセンサネットワークシステム。
[付記5]
 前記制御部は、前記センサデータの収集を行う前記センサ機器については、何回分の前記センサデータの収集を行うかを示す送信可能数を、前記通信回線の輻輳度合いに応じて決定する、
付記1乃至4の何れかに記載のセンサネットワークシステム。
[付記6]
 前記制御部は、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを定期的に入れ替える、
付記1乃至5の何れかに記載のセンサネットワークシステム。
[付記7]
 前記制御部は、前記時間差の変動パターンを前記ゲートウェイ装置のそれぞれについて生成し、該生成した前記ゲートウェイ装置毎の前記変動パターンを比較して輻輳が発生している前記通信回線を共用している前記ゲートウェイ装置の組み合わせを決定し、該決定した前記ゲートウェイ装置の組み合わせを1つのグループとして、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
付記1乃至6の何れかに記載のセンサネットワークシステム。
[付記8]
 前記ゲートウェイ装置は、
 前記指示に従って、前記センサ機器の前記センサデータの中から前記サーバ装置へ送信する前記センサデータを選択して送信データを作成する制御部を含む、
付記1乃至7の何れかに記載のセンサネットワークシステム。
[付記9]
 前記ゲートウェイ装置の前記制御部は、前記指示に従って、前記サーバ装置へ送信しない前記センサ機器に対しては前記センサ機器からの前記センサデータの送信に対して、故意に応答を返さないことにより、前記センサデータを前記センサ機器の送信バッファに蓄積させたままとする、
付記8に記載のセンサネットワークシステム。
[付記10]
 前記ゲートウェイ装置の前記制御部は、前記指示に従って、前記サーバ装置へ何れの前記センサ機器の前記センサデータをも送信しない期間中、定期的に、送信時刻を記載したハートビートメッセージを送信し、
 前記判定部は、前記ハートビートメッセージの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する、
付記8または9に記載のセンサネットワークシステム。
[付記11]
 センサ機器からセンサデータを収集するゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するサーバ装置であって、
 前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する判定部と、
 前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する制御部と、
を含むサーバ装置。
[付記12]
 前記制御部は、前記通信回線が輻輳状態にある場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより多くした内容を決定する、
付記11に記載のサーバ装置。
[付記13]
 前記制御部は、前記通信回線が輻輳状態にない場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより少なくした内容を決定する、
付記11または12に記載のサーバ装置。
[付記14]
 前記制御部は、前記センサ機器の優先度に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
付記11乃至13の何れかに記載のサーバ装置。
[付記15]
 前記制御部は、前記センサデータの収集を行う前記センサ機器については、何回分の前記センサデータの収集を行うかを示す送信可能数を、前記通信回線の輻輳度合いに応じて決定する、
付記11乃至14の何れかに記載のサーバ装置。
[付記16]
 前記制御部は、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを定期的に入れ替える、
付記11乃至15の何れかに記載のサーバ装置。
[付記17]
 前記制御部は、前記時間差の変動パターンを前記ゲートウェイ装置のそれぞれについて生成し、該生成した前記ゲートウェイ装置毎の前記変動パターンを比較して輻輳が発生している前記通信回線を共用している前記ゲートウェイ装置の組み合わせを決定し、該決定した前記ゲートウェイ装置の組み合わせを1つのグループとして、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
付記11乃至16の何れかに記載のサーバ装置。
[付記18]
 センサ機器からセンサデータを収集するゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するサーバ装置が実行するセンサデータ収集制御方法であって、
 前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定し、
 前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する、
センサデータ収集制御方法。
[付記19]
 前記指示の送出では、前記通信回線が輻輳状態にある場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより多くした指示を送出する、
付記18に記載のセンサデータ収集制御方法。
[付記20]
 前記指示の送出では、前記通信回線が輻輳状態にない場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより少なくした指示を送出する、
付記18または19に記載のセンサデータ収集制御方法。
[付記21]
 前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器との決定では、前記センサ機器の優先度に基づいて決定する、
付記18乃至20の何れかに記載のセンサデータ収集制御方法。
[付記22]
 前記指示の送出では、前記センサデータの収集を行う前記センサ機器について前記通信回線の輻輳度合いに応じて決定した、何回分の前記センサデータの収集を一度の収集で行うかを示す送信可能数を含む前記指示を送出する、
付記18乃至21の何れかに記載のセンサデータ収集制御方法。
[付記23]
 前記指示の送出では、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを定期的に入れ替えた前記指示を送出する、
付記18乃至22の何れかに記載のセンサデータ収集制御方法。
[付記24]
 前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器との決定では、前記時間差の変動パターンを前記ゲートウェイ装置のそれぞれについて生成し、該生成した前記ゲートウェイ装置毎の前記変動パターンを比較して輻輳が発生している前記通信回線を共用している前記ゲートウェイ装置の組み合わせを決定し、該決定した前記ゲートウェイ装置の組み合わせを1つのグループとして、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
付記18乃至23の何れかに記載のセンサデータ収集制御方法。
[付記25]
 センサ機器からセンサデータを収集するゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するコンピュータを、
 前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する判定部と、
 前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する送信データ制御部と、
して機能させるためのプログラム。
[付記26]
 1または複数のセンサ機器からセンサデータを収集し、前記センサデータを、通信回線を通じてサーバ装置へ送信するゲートウェイ装置であって、
 前記通信回線の輻輳度合いに基づいて決定された、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを特定する指示を、前記通信回線を通じて前記サーバ装置から受信して解析する受信データ解析部と、
 前記指示に従って、前記センサ機器の前記センサデータの中から前記サーバ装置へ送信する前記センサデータを選択して送信データを作成する制御部とを含む、
ゲートウェイ装置。
[付記27]
 前記制御部は、前記指示に従って、前記サーバ装置へ送信しない前記センサ機器に対しては前記センサ機器からの前記センサデータの送信に対して、故意に応答を返さないことにより、前記センサデータを前記センサ機器の送信バッファに蓄積させたままとする、
付記26に記載のゲートウェイ装置。
[付記28]
 前記制御部は、前記指示に従って、前記サーバ装置へ何れの前記センサ機器の前記センサデータをも送信しない期間中、定期的に、送信時刻を記載したハートビートメッセージを送信する、
付記26または27に記載のゲートウェイ装置。
100…エッジゲートウェイ
101…ネットワーク通信部
102…送信データ選択作成部
103…センサデータ蓄積部
104…受信データ解析部
105…センサ情報格納部
106…センサ制御部
107…センサ情報一覧
109…未送信データ一覧
110…カードリーダ
110C…センサ固有制御部
113…社員証
120…監視カメラ
120C…センサ固有制御部
200…エッジゲートウェイ
210…カードリーダ
220…監視カメラ
300…エッジゲートウェイ
310…カードリーダ
320…監視カメラ
400…集約サーバ
401…ネットワーク通信部
402…送信データ作成部
403…通信データ量差計算部
404…受信データ解析部
405…センサデータ蓄積部
406…エッジ情報格納部
407…エッジ通信情報一覧
408…センサデータ送信指示決定部
501…センサ機器
502…ゲートウェイ装置
503…通信回線
504…サーバ装置
511…判定部
512…制御部
1001…操作入力部
1002…画面表示部
1003…通信インターフェース部
1004…記憶部
1005…演算処理部
1006…情報処理装置
1007…プログラム
NW…ネットワーク

Claims (28)

  1.  1または複数のセンサ機器からセンサデータを収集する1または複数のゲートウェイ装置と、前記ゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するサーバ装置とを含むセンサネットワークシステムであって、
     前記サーバ装置は、
     前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する判定部と、
     前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する制御部と、
    を含む、
    センサネットワークシステム。
  2.  前記制御部は、前記通信回線が輻輳状態にある場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより多くした内容を決定する、
    請求項1に記載のセンサネットワークシステム。
  3.  前記制御部は、前記通信回線が輻輳状態にない場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより少なくした内容を決定する、
    請求項1または2に記載のセンサネットワークシステム。
  4.  前記制御部は、前記センサ機器の優先度に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
    請求項1乃至3の何れかに記載のセンサネットワークシステム。
  5.  前記制御部は、前記センサデータの収集を行う前記センサ機器については、何回分の前記センサデータの収集を行うかを示す送信可能数を、前記通信回線の輻輳度合いに応じて決定する、
    請求項1乃至4の何れかに記載のセンサネットワークシステム。
  6.  前記制御部は、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを定期的に入れ替える、
    請求項1乃至5の何れかに記載のセンサネットワークシステム。
  7.  前記制御部は、前記時間差の変動パターンを前記ゲートウェイ装置のそれぞれについて生成し、該生成した前記ゲートウェイ装置毎の前記変動パターンを比較して輻輳が発生している前記通信回線を共用している前記ゲートウェイ装置の組み合わせを決定し、該決定した前記ゲートウェイ装置の組み合わせを1つのグループとして、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
    請求項1乃至6の何れかに記載のセンサネットワークシステム。
  8.  前記ゲートウェイ装置は、
     前記指示に従って、前記センサ機器の前記センサデータの中から前記サーバ装置へ送信する前記センサデータを選択して送信データを作成する制御部を含む、
    請求項1乃至7の何れかに記載のセンサネットワークシステム。
  9.  前記ゲートウェイ装置の前記制御部は、前記指示に従って、前記サーバ装置へ送信しない前記センサ機器に対しては前記センサ機器からの前記センサデータの送信に対して、故意に応答を返さないことにより、前記センサデータを前記センサ機器の送信バッファに蓄積させたままとする、
    請求項8に記載のセンサネットワークシステム。
  10.  前記ゲートウェイ装置の前記制御部は、前記指示に従って、前記サーバ装置へ何れの前記センサ機器の前記センサデータをも送信しない期間中、定期的に、送信時刻を記載したハートビートメッセージを送信し、
     前記判定部は、前記ハートビートメッセージの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する、
    請求項8または9に記載のセンサネットワークシステム。
  11.  センサ機器からセンサデータを収集するゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するサーバ装置であって、
     前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する判定部と、
     前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する制御部と、
    を含むサーバ装置。
  12.  前記制御部は、前記通信回線が輻輳状態にある場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより多くした内容を決定する、
    請求項11に記載のサーバ装置。
  13.  前記制御部は、前記通信回線が輻輳状態にない場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより少なくした内容を決定する、
    請求項11または12に記載のサーバ装置。
  14.  前記制御部は、前記センサ機器の優先度に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
    請求項11乃至13の何れかに記載のサーバ装置。
  15.  前記制御部は、前記センサデータの収集を行う前記センサ機器については、何回分の前記センサデータの収集を行うかを示す送信可能数を、前記通信回線の輻輳度合いに応じて決定する、
    請求項11乃至14の何れかに記載のサーバ装置。
  16.  前記制御部は、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを定期的に入れ替える、
    請求項11乃至15の何れかに記載のサーバ装置。
  17.  前記制御部は、前記時間差の変動パターンを前記ゲートウェイ装置のそれぞれについて生成し、該生成した前記ゲートウェイ装置毎の前記変動パターンを比較して輻輳が発生している前記通信回線を共用している前記ゲートウェイ装置の組み合わせを決定し、該決定した前記ゲートウェイ装置の組み合わせを1つのグループとして、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
    請求項11乃至16の何れかに記載のサーバ装置。
  18.  センサ機器からセンサデータを収集するゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するサーバ装置が実行するセンサデータ収集制御方法であって、
     前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定し、
     前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する、
    センサデータ収集制御方法。
  19.  前記指示の送出では、前記通信回線が輻輳状態にある場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより多くした指示を送出する、
    請求項18に記載のセンサデータ収集制御方法。
  20.  前記指示の送出では、前記通信回線が輻輳状態にない場合、前記ゲートウェイ装置に対して最後に送出した前記指示に含まれる前記決定した内容と比較して、前記センサデータの収集を保留する前記センサ機器の数をより少なくした指示を送出する、
    請求項18または19に記載のセンサデータ収集制御方法。
  21.  前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器との決定では、前記センサ機器の優先度に基づいて決定する、
    請求項18乃至20の何れかに記載のセンサデータ収集制御方法。
  22.  前記指示の送出では、前記センサデータの収集を行う前記センサ機器について前記通信回線の輻輳度合いに応じて決定した、何回分の前記センサデータの収集を一度の収集で行うかを示す送信可能数を含む前記指示を送出する、
    請求項18乃至21の何れかに記載のセンサデータ収集制御方法。
  23.  前記指示の送出では、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを定期的に入れ替えた前記指示を送出する、
    請求項18乃至22の何れかに記載のセンサデータ収集制御方法。
  24.  前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器との決定では、前記時間差の変動パターンを前記ゲートウェイ装置のそれぞれについて生成し、該生成した前記ゲートウェイ装置毎の前記変動パターンを比較して輻輳が発生している前記通信回線を共用している前記ゲートウェイ装置の組み合わせを決定し、該決定した前記ゲートウェイ装置の組み合わせを1つのグループとして、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定する、
    請求項18乃至23の何れかに記載のセンサデータ収集制御方法。
  25.  センサ機器からセンサデータを収集するゲートウェイ装置に通信回線を通じて接続され、前記ゲートウェイ装置から前記通信回線を通じて前記センサデータを収集するコンピュータを、
     前記ゲートウェイ装置から前記サーバ装置へ送信する前記センサデータの送信時刻と受信時刻との時間差と、輻輳が発生していない状態での通信時間との差分に基づいて、前記通信回線の輻輳度合いを判定する判定部と、
     前記通信回線の輻輳度合いの判定結果に基づいて、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを決定し、前記ゲートウェイ装置に対して、前記決定した内容を含む指示を送出する送信データ制御部と、
    して機能させるためのプログラム。
  26.  1または複数のセンサ機器からセンサデータを収集し、前記センサデータを、通信回線を通じてサーバ装置へ送信するゲートウェイ装置であって、
     前記通信回線の輻輳度合いに基づいて決定された、前記センサデータの収集を行う前記センサ機器と前記センサデータの収集を保留する前記センサ機器とを特定する指示を、前記通信回線を通じて前記サーバ装置から受信して解析する受信データ解析部と、
     前記指示に従って、前記センサ機器の前記センサデータの中から前記サーバ装置へ送信する前記センサデータを選択して送信データを作成する制御部とを含む、
    ゲートウェイ装置。
  27.  前記制御部は、前記指示に従って、前記サーバ装置へ送信しない前記センサ機器に対しては前記センサ機器からの前記センサデータの送信に対して、故意に応答を返さないことにより、前記センサデータを前記センサ機器の送信バッファに蓄積させたままとする、
    請求項26に記載のゲートウェイ装置。
  28.  前記制御部は、前記指示に従って、前記サーバ装置へ何れの前記センサ機器の前記センサデータをも送信しない期間中、定期的に、送信時刻を記載したハートビートメッセージを送信する、
    請求項26または27に記載のゲートウェイ装置。
PCT/JP2018/009230 2017-03-28 2018-03-09 センサネットワークシステム Ceased WO2018180369A1 (ja)

Priority Applications (2)

Application Number Priority Date Filing Date Title
US16/491,232 US11102123B2 (en) 2017-03-28 2018-03-09 Sensor network system
JP2019509157A JP6746087B2 (ja) 2017-03-28 2018-03-09 センサネットワークシステム

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
JP2017062787 2017-03-28
JP2017-062787 2017-03-28

Publications (1)

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

Family

ID=63675369

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/JP2018/009230 Ceased WO2018180369A1 (ja) 2017-03-28 2018-03-09 センサネットワークシステム

Country Status (3)

Country Link
US (1) US11102123B2 (ja)
JP (1) JP6746087B2 (ja)
WO (1) WO2018180369A1 (ja)

Cited By (9)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2020136744A (ja) * 2019-02-13 2020-08-31 日本電信電話株式会社 ゲートウェイ、通信システム及び通信方法
CN113347264A (zh) * 2021-06-16 2021-09-03 黑龙江八一农垦大学 智能网络自恢复方法和系统
US20220038535A1 (en) * 2018-12-06 2022-02-03 Ntt Communications Corporation Data search apparatus, and data search method and program thereof, and edge server and program thereof
JP2022038515A (ja) * 2020-08-27 2022-03-10 サクサ株式会社 データ転送装置およびプログラム
JP2023172568A (ja) * 2022-05-24 2023-12-06 日立建機株式会社 遠隔操縦システム、及び遠隔操縦システムのための通信方法
US11886520B2 (en) 2018-12-06 2024-01-30 Ntt Communications Corporation Data search apparatus, and data search method and program thereof, and edge server and program thereof
US12019911B2 (en) 2018-12-06 2024-06-25 Ntt Communications Corporation Storage management apparatus, method and program
WO2025041543A1 (ja) * 2023-08-23 2025-02-27 株式会社日立製作所 車両、サーバ、サービス提供システム、及びデータ送信方法
CN119814824A (zh) * 2024-12-26 2025-04-11 河南融创新合科技有限公司 基于物联网多数据源的信息采集方法、系统及存储介质

Families Citing this family (52)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US11916870B2 (en) 2004-03-16 2024-02-27 Icontrol Networks, Inc. Gateway registry methods and systems
US10237237B2 (en) 2007-06-12 2019-03-19 Icontrol Networks, Inc. Communication protocols in integrated systems
US11811845B2 (en) 2004-03-16 2023-11-07 Icontrol Networks, Inc. Communication protocols over internet protocol (IP) networks
US11190578B2 (en) 2008-08-11 2021-11-30 Icontrol Networks, Inc. Integrated cloud system with lightweight gateway for premises automation
US11677577B2 (en) * 2004-03-16 2023-06-13 Icontrol Networks, Inc. Premises system management using status signal
US11343380B2 (en) 2004-03-16 2022-05-24 Icontrol Networks, Inc. Premises system automation
US11368429B2 (en) 2004-03-16 2022-06-21 Icontrol Networks, Inc. Premises management configuration and control
US11244545B2 (en) 2004-03-16 2022-02-08 Icontrol Networks, Inc. Cross-client sensor user interface in an integrated security network
US10721087B2 (en) 2005-03-16 2020-07-21 Icontrol Networks, Inc. Method for networked touchscreen with integrated interfaces
US12063220B2 (en) 2004-03-16 2024-08-13 Icontrol Networks, Inc. Communication protocols in integrated systems
US9729342B2 (en) 2010-12-20 2017-08-08 Icontrol Networks, Inc. Defining and implementing sensor triggered response rules
WO2005091218A2 (en) 2004-03-16 2005-09-29 Icontrol Networks, Inc Premises management system
US20170118037A1 (en) 2008-08-11 2017-04-27 Icontrol Networks, Inc. Integrated cloud system for premises automation
US10062273B2 (en) 2010-09-28 2018-08-28 Icontrol Networks, Inc. Integrated security system with parallel processing architecture
US11582065B2 (en) 2007-06-12 2023-02-14 Icontrol Networks, Inc. Systems and methods for device communication
US10339791B2 (en) 2007-06-12 2019-07-02 Icontrol Networks, Inc. Security network integrated with premise security system
US11700142B2 (en) 2005-03-16 2023-07-11 Icontrol Networks, Inc. Security network integrating security system and network devices
US10999254B2 (en) 2005-03-16 2021-05-04 Icontrol Networks, Inc. System for data routing in networks
US20110128378A1 (en) 2005-03-16 2011-06-02 Reza Raji Modular Electronic Display Platform
US11615697B2 (en) 2005-03-16 2023-03-28 Icontrol Networks, Inc. Premise management systems and methods
US20120324566A1 (en) 2005-03-16 2012-12-20 Marc Baum Takeover Processes In Security Network Integrated With Premise Security System
US11496568B2 (en) 2005-03-16 2022-11-08 Icontrol Networks, Inc. Security system with networked touchscreen
US12063221B2 (en) 2006-06-12 2024-08-13 Icontrol Networks, Inc. Activation of gateway device
US11706279B2 (en) 2007-01-24 2023-07-18 Icontrol Networks, Inc. Methods and systems for data communication
US7633385B2 (en) 2007-02-28 2009-12-15 Ucontrol, Inc. Method and system for communicating with and controlling an alarm system from a remote server
US8451986B2 (en) 2007-04-23 2013-05-28 Icontrol Networks, Inc. Method and system for automatically providing alternate network access for telecommunications
US11237714B2 (en) 2007-06-12 2022-02-01 Control Networks, Inc. Control system user interface
US12003387B2 (en) 2012-06-27 2024-06-04 Comcast Cable Communications, Llc Control system user interface
US12283172B2 (en) 2007-06-12 2025-04-22 Icontrol Networks, Inc. Communication protocols in integrated systems
US11218878B2 (en) 2007-06-12 2022-01-04 Icontrol Networks, Inc. Communication protocols in integrated systems
US12184443B2 (en) 2007-06-12 2024-12-31 Icontrol Networks, Inc. Controlling data routing among networks
US11212192B2 (en) 2007-06-12 2021-12-28 Icontrol Networks, Inc. Communication protocols in integrated systems
US11646907B2 (en) 2007-06-12 2023-05-09 Icontrol Networks, Inc. Communication protocols in integrated systems
US11316753B2 (en) 2007-06-12 2022-04-26 Icontrol Networks, Inc. Communication protocols in integrated systems
US10523689B2 (en) 2007-06-12 2019-12-31 Icontrol Networks, Inc. Communication protocols over internet protocol (IP) networks
US11831462B2 (en) 2007-08-24 2023-11-28 Icontrol Networks, Inc. Controlling data routing in premises management systems
US11916928B2 (en) 2008-01-24 2024-02-27 Icontrol Networks, Inc. Communication protocols over internet protocol (IP) networks
US20170185278A1 (en) 2008-08-11 2017-06-29 Icontrol Networks, Inc. Automation system user interface
US11792036B2 (en) 2008-08-11 2023-10-17 Icontrol Networks, Inc. Mobile premises automation platform
US11758026B2 (en) 2008-08-11 2023-09-12 Icontrol Networks, Inc. Virtual device systems and methods
US11729255B2 (en) 2008-08-11 2023-08-15 Icontrol Networks, Inc. Integrated cloud system with lightweight gateway for premises automation
US11258625B2 (en) 2008-08-11 2022-02-22 Icontrol Networks, Inc. Mobile premises automation platform
US8638211B2 (en) 2009-04-30 2014-01-28 Icontrol Networks, Inc. Configurable controller and interface for home SMA, phone and multimedia
US8836467B1 (en) 2010-09-28 2014-09-16 Icontrol Networks, Inc. Method, system and apparatus for automated reporting of account and sensor zone information to a central station
US11750414B2 (en) 2010-12-16 2023-09-05 Icontrol Networks, Inc. Bidirectional security sensor communication for a premises security system
US9147337B2 (en) 2010-12-17 2015-09-29 Icontrol Networks, Inc. Method and system for logging security event data
EP2974266A4 (en) * 2013-03-15 2016-11-02 Fluke Corp AUDIOVISUAL VISIBLE REMARK OF INFRARED IMAGES WITH A SEPARATE WIRELESS MOBILE DEVICE
US11405463B2 (en) 2014-03-03 2022-08-02 Icontrol Networks, Inc. Media content management
US10797965B2 (en) * 2018-07-30 2020-10-06 Dell Products L.P. Dynamically selecting or creating a policy to throttle a portion of telemetry data
EP4229880A4 (en) * 2020-10-19 2025-03-12 Cambridge Mobile Telematics, Inc. Method and system for accessing historical sensor data without location services
CN114760285B (zh) * 2022-04-12 2023-06-30 福建新大陆软件工程有限公司 一种物联网传感器配置和控制方法及系统
CN119126757B (zh) * 2024-09-09 2025-04-22 镁佳(武汉)科技有限公司 用于车辆远程控制的方法、装置、设备和存储介质

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2016047096A1 (ja) * 2014-09-24 2016-03-31 日本電気株式会社 アプリケーションサーバ、クラウド装置、記憶媒体アクセス監視方法およびコンピュータ・プログラムが格納されているコンピュータ読み取り可能な記憶媒体
JP2016146542A (ja) * 2015-02-06 2016-08-12 株式会社Kddi研究所 制御装置、通信装置、制御方法及びプログラム
WO2016189926A1 (ja) * 2015-05-27 2016-12-01 日本電気株式会社 情報処理装置、情報処理方法、情報処理プログラムおよび情報処理システム

Family Cites Families (10)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP5097631B2 (ja) 2008-07-10 2012-12-12 日立Geニュークリア・エナジー株式会社 通信制御方法及びセンサネットワークシステム
JP2010178185A (ja) * 2009-01-30 2010-08-12 Fujitsu Ltd 輻輳制御装置および輻輳制御方法ならびに輻輳制御プログラム
JP5430411B2 (ja) * 2010-01-06 2014-02-26 株式会社Kddi研究所 データ収集サーバ
US20130170342A1 (en) 2011-02-03 2013-07-04 King Saud University Data communication systems and methods
JP6010903B2 (ja) 2011-12-09 2016-10-19 富士通株式会社 無線通信装置、無線通信方法および無線通信プログラム
US10412783B2 (en) * 2013-03-14 2019-09-10 Honeywell International Inc. Shadow access point for hierarchical tree network using 802.11 infrastructure nodes in fire detection systems and other systems
JP6339951B2 (ja) * 2015-03-04 2018-06-06 株式会社日立製作所 データ収集システム、データ収集方法、サーバ及びゲートウェイ
US10007710B2 (en) * 2015-09-21 2018-06-26 Splunk Inc. Adaptive control of data collection requests sent to external data sources
US10003549B2 (en) * 2016-04-21 2018-06-19 Google Llc System for allocating sensor network resources
US10630565B2 (en) * 2017-02-15 2020-04-21 Dell Products, L.P. Overload management for internet of things (IoT) gateways

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2016047096A1 (ja) * 2014-09-24 2016-03-31 日本電気株式会社 アプリケーションサーバ、クラウド装置、記憶媒体アクセス監視方法およびコンピュータ・プログラムが格納されているコンピュータ読み取り可能な記憶媒体
JP2016146542A (ja) * 2015-02-06 2016-08-12 株式会社Kddi研究所 制御装置、通信装置、制御方法及びプログラム
WO2016189926A1 (ja) * 2015-05-27 2016-12-01 日本電気株式会社 情報処理装置、情報処理方法、情報処理プログラムおよび情報処理システム

Cited By (12)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20220038535A1 (en) * 2018-12-06 2022-02-03 Ntt Communications Corporation Data search apparatus, and data search method and program thereof, and edge server and program thereof
US11695832B2 (en) * 2018-12-06 2023-07-04 Ntt Communications Corporation Data search apparatus, and data search method and program thereof, and edge server and program thereof
US11886520B2 (en) 2018-12-06 2024-01-30 Ntt Communications Corporation Data search apparatus, and data search method and program thereof, and edge server and program thereof
US12019911B2 (en) 2018-12-06 2024-06-25 Ntt Communications Corporation Storage management apparatus, method and program
JP2020136744A (ja) * 2019-02-13 2020-08-31 日本電信電話株式会社 ゲートウェイ、通信システム及び通信方法
JP7283103B2 (ja) 2019-02-13 2023-05-30 日本電信電話株式会社 ゲートウェイ、通信システム及び通信方法
JP2022038515A (ja) * 2020-08-27 2022-03-10 サクサ株式会社 データ転送装置およびプログラム
JP7501234B2 (ja) 2020-08-27 2024-06-18 サクサ株式会社 データ転送装置およびプログラム
CN113347264A (zh) * 2021-06-16 2021-09-03 黑龙江八一农垦大学 智能网络自恢复方法和系统
JP2023172568A (ja) * 2022-05-24 2023-12-06 日立建機株式会社 遠隔操縦システム、及び遠隔操縦システムのための通信方法
WO2025041543A1 (ja) * 2023-08-23 2025-02-27 株式会社日立製作所 車両、サーバ、サービス提供システム、及びデータ送信方法
CN119814824A (zh) * 2024-12-26 2025-04-11 河南融创新合科技有限公司 基于物联网多数据源的信息采集方法、系统及存储介质

Also Published As

Publication number Publication date
US20200036635A1 (en) 2020-01-30
US11102123B2 (en) 2021-08-24
JP6746087B2 (ja) 2020-08-26
JPWO2018180369A1 (ja) 2020-01-16

Similar Documents

Publication Publication Date Title
JP6746087B2 (ja) センサネットワークシステム
JP6405416B2 (ja) データ送信システム、及びデータ送信方法
CN110535965A (zh) 一种数据处理方法及装置、存储介质
EP3955550A1 (en) Flow-based management of shared buffer resources
CN113141590B (zh) 一种面向工业物联网的无线通信调度方法及装置
JP4893649B2 (ja) 帯域制御サーバ及び帯域制御プログラム並びに監視システム
US9112784B2 (en) Hierarchical occupancy-based congestion management
EP3477917B1 (en) Data collection apparatus and data collection method
EP1107509A2 (en) System, apparatus and method for controlling the communication quality of a network
US5943480A (en) Method and system for detecting camouflaged congestion on a network resource
EP2827559B1 (en) Server system for providing current data and past data to clients
CN119743496B (zh) 一种基于互联网的数据服务系统
GB2497846A (en) Hybrid arrival-occupancy based congestion management
CN119603297B (zh) 一种基于边缘智能物联网的数据实时分析决策系统
JP4574600B2 (ja) ゲートウェイ装置、データ集約装置、データ集約システム、データ送信方法、及びプログラム
US8629907B2 (en) Data acquisition system and transmission control device
US20250301046A1 (en) Data processing system, data processing method and storage medium
EP3295567B1 (en) Pattern-based data collection for a distributed stream data processing system
KR101537723B1 (ko) 영상 분석 필터의 우선 순위를 이용하는 영상 분석 시스템 및 영상 분석 방법
EP3062231A1 (en) Communication system, shared service control unit, data transmission method, and non-transitory computer-readable medium
CN117201428A (zh) 一种多源数据流的实时同步方法
US20140114614A1 (en) Remote monitoring system, remote monitoring apparatus, communication apparatus, and remote monitoring method
US8825850B2 (en) Information processing apparatus and control method
Kathuria et al. Design, Implementation, and Evaluation of Modern Approaches for the Augmentation of QoS in Medical Body Sensor Network.
JP6977699B2 (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: 18778108

Country of ref document: EP

Kind code of ref document: A1

ENP Entry into the national phase

Ref document number: 2019509157

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: 18778108

Country of ref document: EP

Kind code of ref document: A1