JP7102952B2

JP7102952B2 - Data relay device and program

Info

Publication number: JP7102952B2
Application number: JP2018106078A
Authority: JP
Inventors: 研東海
Original assignee: Fuji Xerox Co Ltd; Fujifilm Business Innovation Corp
Current assignee: Fujifilm Business Innovation Corp
Priority date: 2018-06-01
Filing date: 2018-06-01
Publication date: 2022-07-20
Anticipated expiration: 2038-06-01
Also published as: JP2019213004A

Description

本発明は、データ中継装置およびプログラムに関する。 The present invention relates to a data relay device and a program.

特許文献１には、中継装置において複数の識別子と複数のデータを含む結合データを生成して分散ストレージ装置に送出し、分散ストレージ装置では、中継装置から受信した結合データに含まれる複数のデータを、複数の識別子に従って複数のストレージノードに分散して格納するデータ収集システムが開示されている。 In Patent Document 1, a relay device generates combined data including a plurality of identifiers and a plurality of data and sends the combined data to the distributed storage device, and the distributed storage device transmits a plurality of data included in the combined data received from the relay device. , A data collection system that distributes and stores data in a plurality of storage nodes according to a plurality of identifiers is disclosed.

特許文献２には、複数のノードから送信されるパケットをサーバに中継する際に、送信可能な最大のサイズ情報と、パケットのサイズ情報とに基づいて、データベースに蓄積されるパケットの集約可能数を算出し、算出された集約可能数に基づいて、蓄積されたパケットをサーバに送信するようにした中継装置が開示されている。 Patent Document 2 describes the number of packets that can be aggregated in a database based on the maximum size information that can be transmitted and the packet size information when relaying packets transmitted from a plurality of nodes to a server. Is disclosed, and a relay device is disclosed in which the accumulated packets are transmitted to the server based on the calculated aggregateable number.

特開２０１３－２５７７９８号公報Japanese Unexamined Patent Publication No. 2013-257798 特開２０１４－１９２６６１号公報Japanese Unexamined Patent Publication No. 2014-192661

本発明の目的は、複数のシステムから取得したデータを処理装置に送信する際に、それぞれのシステムから受け取ったデータをそのまま順次処理装置に送信する場合と比較して、処理装置の特性に合わせた効率的なデータの送信を行うことが可能なデータ中継装置およびプログラムを提供することである。 An object of the present invention is to match the characteristics of the processing apparatus with the case where the data acquired from a plurality of systems is transmitted to the processing apparatus, as compared with the case where the data received from each system is sequentially transmitted to the processing apparatus. The purpose of the present invention is to provide a data relay device and a program capable of efficiently transmitting data.

［データ中継装置］
請求項１に係る本発明は、複数のシステムからのデータを順次保存する保存手段と、
前記保存手段において保存された複数のデータを、それぞれのデータがどのシステムからのものなのかを特定できる状態で、データを処理する処理装置により提供されるデータ処理サービスの料金体系における最小課金単位毎に合成する合成手段と、
前記合成手段により合成されたデータを前記処理装置に送信する送信手段と、を備えたデータ中継装置である。 [Data relay device]
The present invention according to claim 1 comprises a storage means for sequentially storing data from a plurality of systems and a storage means.
For each of the plurality of data stored in the storage means, each minimum billing unit in the charge system of the data processing service provided by the processing device that processes the data in a state where each data can be specified from which system. And the synthesis means to synthesize
It is a data relay device including a transmission means for transmitting data synthesized by the synthesis means to the processing device.

請求項２に係る本発明は、前記送信手段が前記処理装置に合成されたデータを送信する際の送信間隔が、前記処理装置の特性に合致した送信間隔である請求項１記載のデータ中継装置である。 The data relay device according to claim 1 , wherein the transmission interval when the transmission means transmits data synthesized to the processing device is a transmission interval that matches the characteristics of the processing device. Is.

請求項３に係る本発明は、前記送信手段が、データを処理しようとする処理装置が変更された場合、合成されたデータを送信する際の送信間隔を、変更された処理装置の特性に合致した送信間隔に変更する請求項２記載のデータ中継装置である。 According to the third aspect of the present invention, when the processing device for which the data is to be processed is changed, the transmission interval when transmitting the synthesized data matches the characteristics of the changed processing device. The data relay device according to claim 2 , wherein the data relay device is changed to the transmission interval.

請求項４に係る本発明は、前記合成手段が、データを処理しようとする処理装置が変更された場合、前記保存手段において保存された複数のデータを合成する際の単位を、変更された処理装置により提供されるデータ処理サービスの料金体系における最小課金単位に変更する請求項１記載のデータ中継装置である。 In the present invention according to claim 4 , when the processing apparatus for processing data is changed, the unit for synthesizing a plurality of data stored in the storage means is changed. The data relay device according to claim 1, wherein the data relay device is changed to the minimum charging unit in the charge system of the data processing service provided by the device.

請求項５に係る本発明は、前記合成手段が、前記保存手段において保存された複数のデータを、どのシステムからのものなのかを特定できる状態で合成する際に、どのシステムからのものなのかを特定する識別子とともに合成する請求項１から４のいずれか１項記載のデータ中継装置である。 According to the fifth aspect of the present invention, when the synthesis means synthesizes a plurality of data stored in the storage means in a state in which it is possible to identify which system the data is from. The data relay device according to any one of claims 1 to 4 , which is synthesized together with an identifier that specifies.

請求項６に係る本発明は、前記保存手段に保存されているデータのデータ量と前記識別子のデータ量とから、前記合成手段において合成された後のデータの合計量を算出する算出手段をさらに備え、
前記合成手段が、前記算出手段により算出された合計量が、前記処理装置により提供されるデータ処理サービスの料金体系における最小課金単位に達した場合に、前記保存手段に保存されている複数のデータを合成する請求項５記載のデータ中継装置である。 The present invention according to claim 6 further provides a calculation means for calculating the total amount of data after being synthesized by the synthesis means from the amount of data of the data stored in the storage means and the amount of data of the identifier. Prepare,
When the total amount calculated by the synthesis means reaches the minimum billing unit in the charge system of the data processing service provided by the processing apparatus, a plurality of data stored in the storage means. 5 is the data relay device according to claim 5 .

[プログラム]
請求項７に係る本発明は、複数のシステムからのデータを順次保存する保存ステップと、
前記保存ステップにおいて保存された複数のデータを、それぞれのデータがどのシステムからのものなのかを特定できる状態で、データを処理する処理装置により提供されるデータ処理サービスの料金体系における最小課金単位毎に合成する合成ステップと、
前記合成ステップにおいて合成されたデータを前記処理装置に送信する送信ステップとをコンピュータに実行させるためのプログラムである。 [program]
The present invention according to claim 7 includes a storage step for sequentially storing data from a plurality of systems and a storage step.
For each of the plurality of data saved in the storage step, each minimum billing unit in the charge system of the data processing service provided by the processing device that processes the data in a state where each data can be specified from which system. And the synthesis steps to synthesize
This is a program for causing a computer to execute a transmission step of transmitting the data synthesized in the synthesis step to the processing device.

請求項１に係る本発明によれば、複数のシステムから取得したデータを処理装置に送信する際に、それぞれのシステムから受け取ったデータをそのまま順次処理装置に送信する場合と比較して、処理装置においてデータを処理する際に発生する料金を低く抑えることができるデータ中継装置を提供することができる。 According to the first aspect of the present invention, when the data acquired from a plurality of systems is transmitted to the processing device, the processing device is compared with the case where the data received from each system is sequentially transmitted to the processing device as it is. It is possible to provide a data relay device that can keep the charges incurred when processing data in the system low.

請求項２に係る本発明によれば、処理装置においてデータを処理する際にエラーが発生するのを防ぐことができるデータ中継装置を提供することができる。 According to the second aspect of the present invention, it is possible to provide a data relay device capable of preventing an error from occurring when processing data in the processing device.

請求項３に係る本発明によれば、データを処理する処理装置が変更された場合でも、処理装置においてデータを処理する際にエラーが発生するのを防ぐことができるデータ中継装置を提供することができる。 According to the third aspect of the present invention, there is provided a data relay device capable of preventing an error from occurring when processing data in the processing device even if the processing device for processing the data is changed. Can be done.

請求項４に係る本発明によれば、データを処理する処理装置が変更された場合でも、データを処理する際に発生する料金を低く抑えたデータの送信を行うことができるデータ中継装置を提供することができる。 According to the fourth aspect of the present invention, there is provided a data relay device capable of transmitting data at a low charge incurred when processing the data even if the processing device for processing the data is changed. can do.

請求項５に係る本発明によれば、データを処理する処理装置において、そのデータがどのシステムからのものなのかを容易に判定することができるデータ中継装置を提供することができる。 According to the fifth aspect of the present invention, in the processing device for processing data, it is possible to provide a data relay device capable of easily determining from which system the data comes from.

請求項６に係る本発明によれば、送信しようとするデータとその識別子の全体のデータ量を、処理装置により提供されるデータ処理サービスの料金体系における最小課金単位とすることができるデータ中継装置を提供することができる。 According to the present invention according to claim 6 , the total amount of data of the data to be transmitted and its identifier can be set as the minimum billing unit in the charge system of the data processing service provided by the processing device. Can be provided.

請求項７に係る本発明によれば、複数のシステムから取得したデータを処理装置に送信する際に、それぞれのシステムから受け取ったデータをそのまま順次処理装置に送信する場合と比較して、処理装置においてデータを処理する際に発生する料金を低く抑えることができるプログラムを提供することができる。 According to the seventh aspect of the present invention, when the data acquired from a plurality of systems is transmitted to the processing device, the processing device is compared with the case where the data received from each system is sequentially transmitted to the processing device as it is. It is possible to provide a program that can keep the charges incurred when processing data in .

本発明の一実施形態のデータ管理システムのシステム構成を示す図である。It is a figure which shows the system structure of the data management system of one Embodiment of this invention. 本発明の一実施形態におけるデータ中継装置２０のハードウェア構成を示すブロック図である。It is a block diagram which shows the hardware structure of the data relay device 20 in one Embodiment of this invention. 本発明の一実施形態におけるデータ中継装置２０の機能構成を示すブロック図である。It is a block diagram which shows the functional structure of the data relay device 20 in one Embodiment of this invention. 本発明の一実施形態におけるデータ中継装置２０において行われるデータ合成の具体例を説明するための図である。It is a figure for demonstrating a specific example of data synthesis performed in the data relay apparatus 20 in one Embodiment of this invention. 合成データの一例を説明するための図である。It is a figure for demonstrating an example of synthetic data.

次に、本発明の実施の形態について図面を参照して詳細に説明する。 Next, an embodiment of the present invention will be described in detail with reference to the drawings.

図１は本発明の一実施形態のデータ管理システムのシステム構成を示す図である。 FIG. 1 is a diagram showing a system configuration of a data management system according to an embodiment of the present invention.

本発明の一実施形態のデータ管理システムは、図１に示されるように、複数のセンサ４０からなるシステムＡと、複数のセンサ５０からなるシステムＢと、データ中継装置２０と、複数のデータ処理サーバ１０Ａ～１０Ｃとから構成されている。 As shown in FIG. 1, the data management system according to the embodiment of the present invention includes a system A composed of a plurality of sensors 40, a system B composed of a plurality of sensors 50, a data relay device 20, and a plurality of data processes. It is composed of servers 10A to 10C.

データ中継装置２０とデータ処理サーバ１０Ａ～１０Ｃは、それぞれネットワーク３０を介して相互に接続されている。 The data relay device 20 and the data processing servers 10A to 10C are connected to each other via the network 30.

システムＡ、Ｂは、それぞれ、複数のセンサ４０、センサ５０により検出されたデータをデータ中継装置２０に送信している。例えば、システムＡ、Ｂは、それぞれ、ある施設内の温度、湿度等の様々な情報を取得することにより、その施設の状態を監視するためのシステムである。 The systems A and B transmit the data detected by the plurality of sensors 40 and the sensors 50 to the data relay device 20, respectively. For example, the systems A and B are systems for monitoring the state of a facility by acquiring various information such as temperature and humidity in the facility, respectively.

データ中継装置２０は、システムＡ、システムＢからのデータを収集して、ネットワーク３０を経由してデータ処理サーバ１０Ａ～１０Ｃのうちのいずれかのデータ処理サーバに送信している。 The data relay device 20 collects data from the system A and the system B and transmits the data to any of the data processing servers 10A to 10C via the network 30.

なお、本実施形態では、データ中継装置２０が、システムＡ、Ｂにおけるセンサデータをデータ処理サーバ１０Ａ～１０Ｃに転送する場合を用いて説明するが、本発明はこのような構成に限定されるものではなく、センサデータ以外の他のデータをデータ処理サーバ等の処理装置に送信して処理するような場合でも同様に適用可能である。 In the present embodiment, the case where the data relay device 20 transfers the sensor data in the systems A and B to the data processing servers 10A to 10C will be described, but the present invention is limited to such a configuration. It is also applicable to the case where data other than sensor data is transmitted to a processing device such as a data processing server for processing.

データ処理サーバ１０Ａ～１０Ｂは、受信した各種データを処理するためのデータ処理サービスを提供するそれぞれ異なる業者により運営されている処理装置である。 The data processing servers 10A to 10B are processing devices operated by different companies that provide data processing services for processing various received data.

そして、このようなデータ処理サービスを利用する際の料金体系は、それぞれの業者により異なっている。例えば、ある業者では、受信するデータのデータ量が５ｋＢ（バイト）増える毎に利用料金が高くなるが、他の業者では、受信するデータのデータ量が３ｋＢ増える毎に利用料金が高くなるというように異なっている。 The fee structure for using such a data processing service differs depending on each vendor. For example, at one vendor, the usage fee increases every time the amount of data received increases by 5 kB (bytes), but at another vendor, the usage fee increases every time the amount of data received increases by 3 kB. Is different.

このような料金体系では、１回のデータ送信について、送信するデータ量が少ない場合でも最小課金単位に対する利用料金が発生する場合がある。例えば、５ｋＢのデータ量毎に利用料金が定められている場合、送信するデータ量が１ｋＢであろうと２ｋＢであろうと同じ利用料金が発生する。そのため、このような料金体系のデータ処理サーバにデータを送信する場合には、データ量が少ない場合でも、最小課金単位、例えば５ｋＢまでまとめてからデータを送信にすることにより、発生する利用料金が低く抑えられ効率的なデータ送信を実現できることになる。 In such a charge system, a usage charge for the minimum charge unit may be incurred for one data transmission even if the amount of data to be transmitted is small. For example, if a usage fee is set for each amount of data of 5 kB, the same usage fee will be incurred regardless of whether the amount of data to be transmitted is 1 kB or 2 kB. Therefore, when sending data to a data processing server with such a fee structure, even if the amount of data is small, the usage fee generated by sending the data after collecting up to the minimum billing unit, for example, 5 kB, will be charged. It will be possible to keep it low and realize efficient data transmission.

そこで、本実施形態のデータ管理システムでは、データ中継装置２０は、後述するような処理を行うことにより、システムＡ、Ｂからのデータを、利用するデータ処理サービスにおける最小課金単位毎に合成してデータ処理サーバ１０Ａ～１０Ｃのいずれかに転送するようにしている。 Therefore, in the data management system of the present embodiment, the data relay device 20 synthesizes the data from the systems A and B for each minimum billing unit in the data processing service to be used by performing the processing as described later. The data is transferred to any of the data processing servers 10A to 10C.

次に、本実施形態のデータ管理システムにおけるデータ中継装置２０のハードウェア構成を図２に示す。 Next, FIG. 2 shows the hardware configuration of the data relay device 20 in the data management system of the present embodiment.

データ中継装置２０は、図２に示されるように、ＣＰＵ１１、メモリ１２、ハードディスクドライブ（ＨＤＤ）等の記憶装置１３、ネットワーク３０を介して外部の装置等との間でデータの送信及び受信を行う通信インタフェース（ＩＦ）１４、タッチパネル又は液晶ディスプレイ並びにキーボードを含むユーザインタフェース（ＵＩ）装置１５を有する。これらの構成要素は、制御バス１６を介して互いに接続されている。 As shown in FIG. 2, the data relay device 20 transmits and receives data to and from an external device and the like via a CPU 11, a memory 12, a storage device 13 such as a hard disk drive (HDD), and a network 30. It has a communication interface (IF) 14, a user interface (UI) device 15 including a touch panel or liquid crystal display and a keyboard. These components are connected to each other via a control bus 16.

ＣＰＵ１１は、メモリ１２または記憶装置１３に格納された制御プログラムに基づいて所定の処理を実行して、データ中継装置２０の動作を制御する。なお、本実施形態では、ＣＰＵ１１は、メモリ１２または記憶装置１３内に格納された制御プログラムを読み出して実行するものとして説明するが、当該プログラムをＣＤ－ＲＯＭ等の記憶媒体に格納してＣＰＵ１１に提供することも可能である。 The CPU 11 executes a predetermined process based on the control program stored in the memory 12 or the storage device 13 to control the operation of the data relay device 20. In the present embodiment, the CPU 11 will be described as reading and executing the control program stored in the memory 12 or the storage device 13, but the program is stored in a storage medium such as a CD-ROM and stored in the CPU 11. It is also possible to provide.

図３は、上記の制御プログラムが実行されることにより実現されるデータ中継装置２０の機能構成を示すブロック図である。 FIG. 3 is a block diagram showing a functional configuration of the data relay device 20 realized by executing the above control program.

本実施形態のデータ中継装置２０は、図３に示されるように、データ受信部３１と、制御部３２と、データ保存部３３と、データ送信部３４を備えている。また、制御部３２は、データ中継装置２０の動作全体を制御しており、算出部４１と、合成部４２を備えている。 As shown in FIG. 3, the data relay device 20 of the present embodiment includes a data receiving unit 31, a control unit 32, a data storage unit 33, and a data transmitting unit 34. Further, the control unit 32 controls the entire operation of the data relay device 20, and includes a calculation unit 41 and a synthesis unit 42.

データ受信部３１は、システムＡ、Ｂのセンサ４０、５０からのデータを順次受信する。 The data receiving unit 31 sequentially receives data from the sensors 40 and 50 of the systems A and B.

データ保存部３３は、複数のシステムであるシステムＡ、Ｂからデータ受信部３１により受信されたデータを順次保存する。つまり、システムＡ、Ｂから送信されてきたデータは、データ保存部３３において一旦バッファリングされることになる。 The data storage unit 33 sequentially stores the data received by the data reception unit 31 from the systems A and B, which are a plurality of systems. That is, the data transmitted from the systems A and B is temporarily buffered in the data storage unit 33.

合成部４２は、データ保存部３３において保存された複数のデータを、それぞれのデータがどのシステムからのものなのかを特定できる状態で、データを処理する処理装置であるデータ処理サーバの特性に合わせた単位毎に合成する。 The synthesizing unit 42 matches a plurality of data stored in the data storage unit 33 with the characteristics of a data processing server which is a processing device for processing data in a state where each data can be specified from which system. It is synthesized for each unit.

具体的には、合成部４２は、データ保存部３３において保存された複数のデータを、どのシステムからのものなのかを特定できる状態で合成する際に、どのシステムからのものなのかを特定する識別子とともに合成する。 Specifically, the synthesizing unit 42 specifies from which system when synthesizing a plurality of data stored in the data storage unit 33 in a state in which it is possible to identify from which system. Synthesize with an identifier.

算出部４１は、データ保存部３３に保存されているデータのデータ量と、データを合成する際にそれぞれのデータに付加する識別子のデータ量とから、合成手段において合成された後のデータの合計量を算出する。 The calculation unit 41 totals the data after being synthesized by the synthesis means from the data amount of the data stored in the data storage unit 33 and the data amount of the identifier added to each data when synthesizing the data. Calculate the amount.

そして、合成部４２は、算出部４１により算出された合計量が、データ処理サーバの特性に合わせた単位に達した場合に、データ保存部３３に保存されている複数のデータを合成する。 Then, when the total amount calculated by the calculation unit 41 reaches a unit that matches the characteristics of the data processing server, the synthesis unit 42 synthesizes a plurality of data stored in the data storage unit 33.

ここで、合成部４２が複数のデータを合成する際の単位は、データ処理サーバ１０Ａ～１０Ｃのうちのデータを実際に処理するデータ処理サーバにおいてデータを処理する際の最小単位である。具体的には、データ処理サーバにおいてデータを処理する際の最小単位とは、そのデータ処理サーバにより提供されるデータ処理サービスの料金体系における最小課金単位である。 Here, the unit when the synthesizing unit 42 synthesizes a plurality of data is the minimum unit when processing the data in the data processing server which actually processes the data among the data processing servers 10A to 10C. Specifically, the minimum unit when processing data in a data processing server is the minimum charging unit in the charge system of the data processing service provided by the data processing server.

なお、データ処理サーバ１０Ａ～１０Ｃを用いたデータ処理サービスの料金体系はそれぞれ異なっている。そのため、合成部４２は、データを送信しようとするデータ処理サーバが変更された場合、データ保存部３３において保存された複数のデータを合成する際の単位を、変更されたデータ処理サーバの特性に合致した単位に変更する。 The charge system of the data processing service using the data processing servers 10A to 10C is different. Therefore, when the data processing server to which the data is to be transmitted is changed, the synthesis unit 42 sets the unit for synthesizing the plurality of data stored in the data storage unit 33 to the characteristics of the changed data processing server. Change to a matching unit.

つまり、データの送信先が、最小課金単位が５ｋＢのデータ処理サーバから、最小課金単位が３ｋＢのデータ処理サーバに変更になった場合、合成部４２は、データ保存部３３におけるデータを５ｋＢ毎ではなく３ｋＢ毎に合成するように変更する。 That is, when the data transmission destination is changed from a data processing server having a minimum charge unit of 5 kB to a data processing server having a minimum charge unit of 3 kB, the synthesis unit 42 transfers the data in the data storage unit 33 every 5 kB. Change so that it is synthesized every 3 kB.

データ送信部３４は、合成部４２により合成されたデータを、データ処理サーバ１０Ａ～１０Ｃのうちの送信先として指定されたデータ処理装置に送信する。 The data transmission unit 34 transmits the data synthesized by the synthesis unit 42 to the data processing apparatus designated as the transmission destination among the data processing servers 10A to 10C.

なお、データ処理サーバ１０Ａ～１０Ｃでは、データ中継装置２０から受信したデータを複数のデータに分割して、分割した複数のデータのそれぞれに付加されている識別子によりシステムＡ、システムＢのうちのいずれのシステムのデータであるかを分別する。そして、データ処理サーバ１０Ａ～１０Ｃでは、システムＡのデータ、システムＢのデータは、それぞれどのシステムのデータかを弁別して処理されることになる。 In the data processing servers 10A to 10C, the data received from the data relay device 20 is divided into a plurality of data, and either system A or system B is used according to the identifier attached to each of the divided data. It distinguishes whether it is the data of the system of. Then, in the data processing servers 10A to 10C, the data of the system A and the data of the system B are processed by discriminating which system the data is.

ここで、データ処理サーバ１０Ａ～１０Ｃでは、様々な装置からのデータを受信して処理を行っている。また、データ処理サーバ１０Ａ～１０Ｃでは、それぞれデータを受信して処理する処理能力が異なっている。そのため、データ処理サーバ１０Ａ～１０Ｃでは、１つの装置からデータを受信して処理を行うことができる時間間隔がそれぞれ決まっている。 Here, the data processing servers 10A to 10C receive data from various devices and perform processing. Further, the data processing servers 10A to 10C have different processing capacities for receiving and processing data. Therefore, in the data processing servers 10A to 10C, the time intervals during which data can be received from one device and processed are determined.

そのため、データ送信部３４は、合成されたデータをデータ処理サーバに送信する際の送信間隔を、送信先のデータ処理サーバの特性に合致した送信間隔としている。つまり、データ送信部３４は、１回データをデータ処理サーバに送信した場合、予め設定された期間が経過するまで次のデータ送信を行わないようにしている。 Therefore, the data transmission unit 34 sets the transmission interval when transmitting the synthesized data to the data processing server as a transmission interval that matches the characteristics of the data processing server of the transmission destination. That is, when the data transmission unit 34 transmits the data to the data processing server once, the next data transmission is not performed until the preset period elapses.

そして、データ送信部３４は、データ処理サーバが変更された場合、合成されたデータを送信する際の送信間隔を、変更されたデータ処理サーバの特性に合致した送信間隔に変更する。 Then, when the data processing server is changed, the data transmission unit 34 changes the transmission interval when transmitting the synthesized data to a transmission interval that matches the characteristics of the changed data processing server.

次に、本実施形態のデータ管理システムにおけるデータ中継装置２０の動作について図面を参照して詳細に説明する。 Next, the operation of the data relay device 20 in the data management system of the present embodiment will be described in detail with reference to the drawings.

図４は、本実施形態におけるデータ中継装置２０において行われるデータ合成の具体例を説明するための図である。 FIG. 4 is a diagram for explaining a specific example of data synthesis performed in the data relay device 20 in the present embodiment.

図４に示した具体例では、システムＡからのデータは、１回あたりのデータ量は少ないが送信されてくる頻度が高く、システムＢからのデータは、送信されてくる頻度は低いが１回あたりのデータ量が多くなっている。なお、この図４では、システムＡ、Ｂからのそれぞれデータに対して、合成処理が分かり易くなるように番号を付して示す。 In the specific example shown in FIG. 4, the data from the system A is transmitted frequently although the amount of data is small, and the data from the system B is transmitted once but frequently. The amount of data per is increasing. In FIG. 4, the data from the systems A and B are numbered so that the synthesis process can be easily understood.

本発明のデータ中継装置２０における合成部４２は、このようにして送信されているシステムＡ、システムＢからのデータを、データ処理サーバ１０Ａ～１０Ｃのうちの送信先として設定されているデータ処理サーバの特性に合致したデータ単位毎に合成して送信する。 The synthesis unit 42 in the data relay device 20 of the present invention is a data processing server in which the data from the system A and the system B transmitted in this way is set as a transmission destination among the data processing servers 10A to 10C. It is synthesized and transmitted for each data unit that matches the characteristics of.

例えば、図４では、システムＡからの３つのデータとシステムＢからの１つのデータが合成されて送信される様子が示されている。 For example, FIG. 4 shows how three data from the system A and one data from the system B are combined and transmitted.

そして、このようにして合成されるデータ（以下合成データと称する。）では、それぞれのデータに対してシステムＡ、Ｂいずれかの識別子が付加されている。 Then, in the data synthesized in this way (hereinafter referred to as synthetic data), an identifier of either system A or B is added to each data.

この合成データの具体例を拡大したものを、図５を参照して説明する。 An enlarged version of a specific example of this composite data will be described with reference to FIG.

図５に示された合成データ例では、システムＡの４番目、５番目、６番目のデータに対してシステムＡからのデータであることを示す識別子６１が付加され、システムＢの２番目のデータに対してシステムＢからのデータであることを示す識別子６２が付加される様子が示されている。 In the synthetic data example shown in FIG. 5, an identifier 61 indicating that the data is from the system A is added to the fourth, fifth, and sixth data of the system A, and the second data of the system B is added. It is shown that the identifier 62 indicating that the data is from the system B is added to the data.

そして、このような合成データを受信したデータ処理サーバでは、合成データにおけるそれぞれのデータに付加されている識別子を参照することにより、そのデータがいずれのシステムのものであるのかを特定して、それぞれのシステム毎に処理する。 Then, in the data processing server that receives such synthetic data, by referring to the identifier attached to each data in the synthetic data, it is possible to identify which system the data belongs to, and each of them. Process for each system.

[変形例]
上記実施形態では、データを取得するシステムがシステムＡ、Ｂという２つのシステムである場合を用いて説明したが、本発明はこれに限定されるものではなく、さらに多くのシステムからのデータを取得するようなシステムに対しても本発明を適用することができるものである。 [Modification example]
In the above embodiment, the case where the system for acquiring data is two systems, systems A and B, has been described, but the present invention is not limited to this, and data is acquired from more systems. The present invention can also be applied to such a system.

さらに、上記実施形態では、データ処理サーバにおけるデータ処理時の最小単位が、それぞれの料金体系における最小課金単位の場合であったが、本発明はこのような場合に限定されるものではない。例えば、それぞれのデータ処理サーバにおいてデータ処理を効率的に行える最小単位がそれぞれのデータ処理サーバによって異なるような場合でも本発明は同様に適用可能である。 Further, in the above embodiment, the minimum unit for data processing in the data processing server is the case of the minimum charge unit in each charge system, but the present invention is not limited to such a case. For example, the present invention can be similarly applied even when the minimum unit capable of efficiently performing data processing in each data processing server differs depending on each data processing server.

１０Ａ～１０Ｃデータ処理サーバ
１１ＣＰＵ
１２メモリ
１３記憶装置
１４通信インタフェース（ＩＦ）
１５ユーザインタフェース（ＵＩ）装置
１６制御バス
２０データ中継装置
３０ネットワーク
３１データ受信部
３２制御部
３３データ保存部
３４データ送信部
４０センサ
４１算出部
４２合成部
５０センサ
６１識別子（システムＡ）
６２識別子（システムＢ） 10A-10C data processing server 11 CPU
12 Memory 13 Storage device 14 Communication interface (IF)
15 User interface (UI) device 16 Control bus 20 Data relay device 30 Network 31 Data reception unit 32 Control unit 33 Data storage unit 34 Data transmission unit 40 Sensor 41 Calculation unit 42 Synthesis unit 50 Sensor 61 Identifier (system A)
62 Identifier (system B)

Claims

A storage method that sequentially stores data from multiple systems,
For each of the plurality of data stored in the storage means, each minimum charge unit in the charge system of the data processing service provided by the processing device that processes the data in a state where each data can be specified from which system. And the synthesis means to synthesize
A transmission means for transmitting the data synthesized by the synthesis means to the processing device, and
Data relay device equipped with.

The data relay device according to claim 1 , wherein the transmission interval when the transmission means transmits the synthesized data to the processing device is a transmission interval that matches the characteristics of the processing device.

2 . The data relay device described.

When the processing device for which the synthesis means is to process data is changed, the unit for synthesizing a plurality of data stored in the storage means is the unit of the data processing service provided by the changed processing device. The data relay device according to claim 1, wherein the data relay device is changed to the minimum charge unit in the charge system .

Claim that when the synthesis means synthesizes a plurality of data stored in the storage means in a state where it is possible to specify which system the data is from, the synthesis means is combined with an identifier that identifies which system the data is from. The data relay device according to any one of 1 to 4 .

Further provided with a calculation means for calculating the total amount of data after being synthesized by the synthesis means from the amount of data of the data stored in the storage means and the amount of data of the identifier.
When the total amount calculated by the synthesis means reaches the minimum billing unit in the charge system of the data processing service provided by the processing apparatus, a plurality of data stored in the storage means. 5. The data relay device according to claim 5 .

A save step to save data from multiple systems in sequence,
For each of the plurality of data saved in the storage step, each minimum billing unit in the charge system of the data processing service provided by the processing device that processes the data in a state where each data can be specified from which system. And the synthesis steps to synthesize
A transmission step of transmitting the data synthesized in the synthesis step to the processing device, and
A program that lets your computer run.