JP7597290B2 - Transmitting Device - Google Patents
Transmitting Device Download PDFInfo
- Publication number
- JP7597290B2 JP7597290B2 JP2021016242A JP2021016242A JP7597290B2 JP 7597290 B2 JP7597290 B2 JP 7597290B2 JP 2021016242 A JP2021016242 A JP 2021016242A JP 2021016242 A JP2021016242 A JP 2021016242A JP 7597290 B2 JP7597290 B2 JP 7597290B2
- Authority
- JP
- Japan
- Prior art keywords
- data
- block
- recording
- transmitting device
- unit
- 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.)
- Active
Links
- 230000005540 biological transmission Effects 0.000 claims description 105
- 238000004891 communication Methods 0.000 claims description 40
- 238000013523 data management Methods 0.000 claims description 32
- 239000000872 buffer Substances 0.000 claims description 7
- 238000005259 measurement Methods 0.000 description 78
- 238000000034 method Methods 0.000 description 76
- 238000012545 processing Methods 0.000 description 53
- 238000010586 diagram Methods 0.000 description 19
- 230000007704 transition Effects 0.000 description 13
- 230000006870 function Effects 0.000 description 12
- 238000012935 Averaging Methods 0.000 description 10
- 230000001133 acceleration Effects 0.000 description 3
- 230000010365 information processing Effects 0.000 description 2
- 238000012544 monitoring process Methods 0.000 description 2
- 230000000295 complement effect Effects 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
Images
Landscapes
- Recording Measured Values (AREA)
Description
本発明は、送信装置に関する。 The present invention relates to a transmitting device .
各種のセンサで計測した温度、湿度、気圧、照度、加速度、音量等の計測データを記録する装置が実用化されており、「データロガー」等の名称で市販されている。 Devices that record measurement data such as temperature, humidity, air pressure, illuminance, acceleration, and sound volume measured by various sensors have been put to practical use and are sold commercially under names such as "data loggers."
また、記録データを記録する複数段のリングバッファを有し、リングバッファに所定数の記録データが書き込まれる毎に平均値を算出し、算出した平均値を次段のリングバッファに書き込む記録装置が知られている（特許文献１参照）。 There is also a known recording device that has multiple stages of ring buffers for recording data, calculates an average value each time a predetermined number of pieces of recording data are written to a ring buffer, and writes the calculated average value to the next ring buffer (see Patent Document 1).
測定した計測データをＢｌｕｅｔｏｏｔｈ（登録商標） Ｌｏｗ Ｅｎｅｒｇｙ（以下ＢＬＥと呼ぶ）等の低消費電力の無線通信で送信する送信装置も知られている。しかし、このような送信装置には、受信装置が送信装置から過去のデータを取得することができないという問題がある。 Transmitting devices that transmit measured data using low-power wireless communication such as Bluetooth (registered trademark) Low Energy (hereinafter referred to as BLE) are also known. However, such transmitting devices have a problem in that the receiving device cannot obtain past data from the transmitting device.
過去のデータを取得できるように送信装置に計測データを蓄積しておくことも考えられるが、ＢＬＥのような低消費電力の無線通信は通信速度が遅いため、蓄積したデータを送信先に送信するためには時間を要する。また、このような送信装置はバッテリからの供給電力で動作するため、消費電力が大きい比較的高速な無線通信を利用することは望ましくない。 It is possible to store measurement data in the transmitting device so that past data can be obtained, but low-power wireless communication such as BLE has a slow communication speed, so it takes time to transmit the stored data to the destination. In addition, such transmitting devices operate on power supplied from a battery, so it is not desirable to use relatively high-speed wireless communication that consumes a lot of power.
このように、取得したデータを記録しつつ送信先に送信する送信装置において、最新の計測データだけではなく過去のデータを取得可能とすることには困難を伴っていた。 As such, in a transmitting device that records acquired data while transmitting it to a destination, it was difficult to make it possible to acquire not only the most recent measurement data but also past data.
本発明の一実施形態は、上記の問題点に鑑みてなされたものであって、取得したデータを記録しつつ送信先に送信する送信装置において、最新の計測データだけではなく、過去のデータも容易に取得できるようにする。 One embodiment of the present invention has been made in consideration of the above problems, and enables a transmitting device that records acquired data while transmitting it to a destination to easily acquire not only the most recent measurement data, but also past data.
上記の課題を解決するため、本発明の一実施形態に係る送信装置は、取得したデータを記録し、送信する送信装置であって、環状バッファで構成されるデータ記録用の複数の記録ブロックと、前記記録ブロックにおける記録が一巡するタイミングで、当該記録ブロックに記録されているデータの代表値を、当該記録ブロックとは異なる他の記録ブロックに記録するデータ管理部と、前記複数の記録ブロックに重み付けし、前記重み付けに基づいて前記複数の記録ブロックに記録されているデータを送信するデータ送信部と、を有し、 前記データ送信部は、前記送信するデータを、前記重み付けに基づいてランダムに決定する。
In order to solve the above problems, a transmitting device according to one embodiment of the present invention is a transmitting device that records and transmits acquired data, and has a plurality of recording blocks for recording data constituted by a circular buffer, a data management unit that records a representative value of the data recorded in a recording block in another recording block different from the recording block when recording in the recording block completes a cycle, and a data transmitting unit that weights the plurality of recording blocks and transmits the data recorded in the plurality of recording blocks based on the weighting, and the data transmitting unit randomly determines the data to be transmitted based on the weighting.
本発明の一実施形態によれば、取得したデータを記録しつつ送信する送信装置において、最新の計測データだけではなく、過去のデータも容易に取得できるようになる。 According to one embodiment of the present invention, a transmitting device that records and transmits acquired data can easily acquire not only the most recent measurement data, but also past data.
以下、添付図面を参照しながら実施形態について説明する。説明の理解を容易にするため、各図面において同一の構成要素に対しては可能な限り同一の符号を付して、重複する説明は省略する。 The following describes the embodiments with reference to the attached drawings. To facilitate understanding of the description, the same components in each drawing are denoted by the same reference numerals as much as possible, and duplicate descriptions are omitted.
＜システム構成＞
図１は、一実施形態に係るデータ通信システムのシステム構成を示す図である。図１（Ａ）に示すデータ通信システム１００は、データを送信する送信装置１０１と、送信装置１０１が送信したデータを受信する受信装置１０２とを含む。
<System Configuration>
Fig. 1 is a diagram showing a system configuration of a data communication system according to an embodiment. The
送信装置１０１は、温度、湿度、気圧、照度、加速度、音量等の計測データを含む送信データを、例えばＢＬＥ通信等の低消費電力の無線通信１０３で送信する。例えば、送信装置１０１は、ＢＬＥ通信のアドバタイズデータ（ビーコン）を用いて、送信データをブロードキャスト送信する。
The transmitting
また、送信装置１０１は、取得した計測データを記憶部等に記憶しておき、最新の計測データだけではなく過去のデータも送信する機能を有している。好ましくは、送信装置１０１は、過去のデータを、古いほど低頻度で送信する。また、送信装置１０１は、過去のデータをデータ処理（例えば平均化）して送信する。
The transmitting
図１（Ｂ）は、一実施形態に係るデータ通信システム１００のシステム構成の別の一例を示している。図１（Ｂ）に示すように、送信装置１０１は、データを受信装置（受信サーバ）１０２に転送するゲートウェイ１１１や情報端末１１２等を介して、送信データを受信装置１０２に送信するものであっても良い。
Figure 1 (B) shows another example of the system configuration of a
ゲートウェイ１１１は、例えばＢＬＥ通信等の低消費電力の無線通信１０３で、送信装置１０１が送信した送信データを受信し、通信ネットワーク１１３を介して受信装置１０２に転送する中継装置である。
The
情報端末１１２は、例えば、ＰＣ、タブレット端末、スマートフォン等の情報処理装置であり、ＢＬＥ通信等の低消費電力の無線通信１０３で、送信装置１０１が送信した送信データを受信し、受信装置１０２に転送する機能を有している。情報端末１１２は例えば、データ通信システム１００に対応するアプリケーションを実行することにより、送信装置１０１から受信した送信データを、無線ＷＡＮ（Wide Area Network）等の無線通信１１４を介して受信装置１０２に転送する。
受信装置１０２は、１つ以上の情報処理装置で構成されるデータ受信サーバや、クラウドシステム等であっても良い。
The
The
なお、図１に示すデータ通信システムのシステム構成は一例である。送信装置１０１は、Ｚｉｇｂｅｅ（登録商標）、Ｗｉｒｅｐａｓ（登録商標） Ｍｅｓｈ等のＢＬＥ以外の無線通信方式で送信データを送信するものであっても良い。また、送信装置１０１は、ＰＬＣ（Power Line Communication）等の比較的低速な有線通信方式で送信データを送信するものでも良い。
The system configuration of the data communication system shown in FIG. 1 is an example. The transmitting
＜処理の概要＞
図２は、一実施形態に係る送信装置の処理を説明する図である。送信装置１０１は、図２に示すように、データ記録用の複数の記録ブロック（ブロックＡ２０１、ブロックＢ２０２、ブロックＣ２０３、・・・）を有している。
<Processing Overview>
2 is a diagram illustrating processing by a transmitting device according to an embodiment. As shown in FIG. 2, the
各記録ブロックは、送信装置１０１の記録領域に設けられ、論理的な環状バッファとして機能する。なお、各記録ブロックは、記録順序を管理可能であり、古いデータを順次に上書きする制御ができるものであれば良く、物理的な構成は任意である。ブロックＡ２０１、ブロックＢ２０２、ブロックＣ２０３には、それぞれ１０個のデータを書き込むことができる。
Each recording block is provided in the recording area of the
図２において、送信装置１０１が取得した計測データは、まずブロックＡ２０１に順次格納される。送信装置１０１は、ブロックＡ２０１のアドレスＡ＿０に計測データを記録すると、次の書き込み位置を示すポインタをインクリメントしてアドレスＡ＿１に進め、次の計測データをアドレスＡ＿１に記録する。また、送信装置１０１は、末尾のアドレスＡ＿９に計測データを記録すると、書き込みポインタを先頭のアドレスＡ＿０に戻す。
In FIG. 2, the measurement data acquired by the transmitting
送信装置１０１は、ブロックＡ２０１における記録が一巡するタイミングで、ブロックＡ２０１に格納されている１０データの代表値を算出して、ブロックＢ２０２に記録する。例えば、送信装置１０１は、ブロックＡ２０１の書き込みポインタをアドレスＡ＿０に戻すときに、アドレスＡ＿０～Ａ＿９に格納されている計測データを平均化した平均値を、代表値としてブロックＢ２０２の次の書き込み位置に記録する。次に取得された計測データはブロックＡ２０１のアドレスＡ＿０に上書きされる。
When the recording in block A201 is completed, the
同様に、送信装置１０１は、ブロックＢ２０２における記録が一巡するタイミングで、ブロックＢ２０２に格納されている１０データの代表値を算出して、ブロックＣ２０３の次の書き込み位置に記録する。
Similarly, when recording in block B202 is completed, the
このように、比較的新しく取得されたデータは加工せずに元データのままブロックＡ２０１に蓄積され、古いデータは代表値として次段以降のブロックＢ２０２、ブロックＣ２０３に蓄積される。このため、送信装置１０１では、古いデータほど記憶領域を節約して計測データを蓄積することができる。
In this way, relatively recently acquired data is stored in block A201 as original data without processing, while older data is stored as representative values in subsequent blocks B202 and C203. Therefore, the transmitting
また、送信装置１０１は、複数のブロックＡ２０１、ブロックＢ２０２、ブロックＣ２０３に重み付けし、重み付けに基づいて複数の記録ブロックに記録されているデータを選択・送信する。
The transmitting
例えば、送信装置１０１は、ブロックＢ２０２（第２記録ブロック）の重みがブロックＡ２０１（第１記録ブロック）の重みより小さくなるように重み付けする。また、送信装置１０１は、ブロックＣ２０３（第３記録ブロック）の重みがブロックＢ２０２の重みより小さくなるように重み付けする。
For example, the transmitting
重みづけの大きいブロックに格納されているデータの送信頻度を高くすることにより、送信装置１０１は、比較的最近のデータを加工なしでより高頻度で送信し、比較的古いデータを、例えば平均化により加工し、より低頻度で送信することができる。
By increasing the transmission frequency of data stored in blocks with high weighting, the transmitting
送信装置１０１は、送信先に送信するデータを、上記の重み付けに基づいてランダムに決定することができる。
The transmitting
送信装置１０１はまた、送信先に、データとともに、当該データの取得時間（時刻等）、データの取得期間などを示す付加情報を送信する。なお、付加情報は送信先に送信するデータに含まれていても良いし、データとは別に送信しても良い。
The transmitting
一方、受信装置１０２は、送信装置１０１から送信データ（又は送信データと付加情報）を受信すると、送信データ（又は付加情報）に含まれる取得時間、取得期間などに基づいて、送信データに含まれるデータ（計測データ、代表値）を記憶部に記憶する。例えば、受信装置１０２は、送信装置１０１が送信した送信データを、付加情報が示す取得時間、又は取得期間に対応する記憶部の記憶領域に記憶する。
On the other hand, when the receiving
受信装置１０２は、記憶部に記憶したデータに基づいて、計測データの推移をグラフ化などにより表示する機能を有している。
The receiving
このように、本実施形態に係るデータ通信システム１００によれば、送信装置１０１は、比較的最近のデータをより多いデータ量で記録するとともに、古いデータをより少ないデータ量で記録することができる。従って、送信装置１０１の限られたメモリ容量で、より長期間のデータを記録することができる。
In this way, according to the
送信装置１０１は、例えば、モニタリングやデモンストレーション等の用途で比較的重要度が高い「直近」のデータをより高頻度で、比較的重要度が低い過去のデータを低頻度で送信することができる。また、受信装置１０２は、古いデータをより少ないデータ量で記憶するので、過去から現在に至るまでの、計測データの推移の概要／アウトラインを比較的短時間で、取得し把握することができる。
The transmitting
＜ハードウェア構成＞
図３は、一実施形態に係る送信装置及び受信装置のハードウェア構成を示す図である。
<Hardware Configuration>
FIG. 3 is a diagram showing the hardware configuration of a transmitting device and a receiving device according to an embodiment.
（送信装置のハードウェア構成）
図３（Ａ）に示す送信装置１０１は、ＣＰＵ（Central Processing Unit）３０１、メモリ３０２、ストレージデバイス３０３、無線通信デバイス３０４、センサ３０５、外部接続Ｉ／Ｆ（Interface）、バス３０７を有する。
(Hardware configuration of the transmitting device)
The
ＣＰＵ３０１は、ストレージデバイス３０３、メモリ３０２等に記憶したプログラムを実行することにより、送信装置１０１の様々な機能を実現するプロセッサ（演算装置）である。メモリ３０２には、例えば、ＣＰＵ３０１のワークエリアとして用いられるＲＡＭ（Random Access Memory）、ＣＰＵ３０１の起動用のプログラム等を予め記憶したＲＯＭ（Read Only memory）が含まれる。ストレージデバイス３０３は、例えば、ＯＳ（Operating System）、アプリケーション等のプログラムや各種のデータを記憶する、大容量の記憶装置である。
The
無線通信デバイス３０４は、ＢＬＥ等の無線通信を行うための無線回路、無線モジュール、又は無線ＩＣ（Integrated Circuit）である。なお、無線通信デバイス３０４は、Ｚｉｇｂｅｅ、Ｗｉｒｅｐａｓ Ｍｅｓｈ等のＢＬＥ以外の無線通信方式を採用しても良い。
The
センサ３０５は、温度センサ、湿度センサ、気圧センサ、照度センサ、加速度センサ、音量センサ等の各種センサである。外部接続Ｉ／Ｆ３０６は、送信装置１０１に外部装置を接続するためのインタフェースである。送信装置１０１は、１つ以上のセンサ３０５、又は外部接続Ｉ／Ｆ３０６に接続された外部センサから、計測データを取得する。
The
バス３０７は、上記の各構成要素に共通に接続され、例えば、アドレス信号、データ信号、各種の制御信号等を伝送する。
（受信装置のハードウェア構成）
図３（Ｂ）に示す受信装置１０２は、ＣＰＵ３１１、メモリ３１２、ストレージデバイス３１３、ネットワークＩ／Ｆ３１４、表示装置３１５、入力装置３１６、無線通信デバイス３１７、バス３１８を有する。
(Hardware configuration of the receiving device)
The receiving
ＣＰＵ３１１は、ストレージデバイス３１３、メモリ３１２等に記憶したプログラムを実行することにより、受信装置１０２の様々な機能を実現するプロセッサである。メモリ３１２には、ＣＰＵ３１１のワークエリアとして用いられるＲＡＭ、及びＣＰＵ３１１の起動用のプログラム等を予め記憶したＲＯＭ等が含まれる。ストレージデバイス３１３は、ＯＳ、アプリケーション等のプログラムや、各種データを記憶する大容量の記憶装置である。
The
ネットワークＩ／Ｆ３１４は、受信装置１０２を通信ネットワークに接続し、例えばゲートウェイ１１１や情報端末１１２と通信するための通信インタフェースである。
The network I/
表示装置３１５は、各種の表示画面を表示する、液晶ディスプレイ、有機ＥＬディスプレイ等の表示デバイスである。入力装置は、ユーザの入力操作を受け付ける、タッチパネル、キーボード、操作ボタン等の入力デバイスである。なお、表示装置３１５、及び入力装置３１６は、タッチパネルディスプレイ等の表示入力装置であっても良い。
The
無線通信デバイス３１７は、無線通信デバイス３０４と同じ無線通信方式で送信装置１０１と無線通信を行うための無線回路、無線モジュール、無線ＩＣ等である。
The
バス３１８は、上記の各構成要素に共通に接続され、例えば、アドレス信号、データ信号、各種の制御信号等を伝送する。
＜機能構成＞
続いて、送信装置１０１、及び受信装置の機能構成について説明する。
<Functional configuration>
Next, the functional configurations of the transmitting
（送信装置の機能構成）
図４は、一実施形態に係る送信装置の機能構成を示す図である。送信装置１０１は、ＣＰＵ３０１で所定のプログラムを実行することにより、データ取得部４０１、データ管理部４０２、データ送信部４０３、記憶部４０４等の機能を実現している。なお、上記の各機能のうち、少なくとも一部はハードウェアによって実現されるものであっても良い。
(Functional configuration of the transmitting device)
4 is a diagram showing the functional configuration of a transmission device according to an embodiment. The
データ取得部４０１は、センサ３０５等から計測データを取得する。好ましくは、データ取得部４０１は、センサ３０５等から所定の間隔（例えば、数秒から数十分程度）で計測データを取得する。なお、データ取得部４０１は、外部接続Ｉ／Ｆ３０６に接続された外部センサから計測データを取得しても良い。
The
データ管理部４０２は、図２で説明したように、ブロックＡ２０１における記録が一巡するタイミングで、ブロックＡ２０１に記録されているデータの代表値（例えば平均値）を算出し、ブロックＢ２０２に記録する。また、データ管理部４０２は、ブロックＢ２０２における記録が一巡するタイミングで、ブロックＢ２０２に記録されているデータの代表値を算出し、ブロックＣ２０３に記録する。
As described in FIG. 2, when recording in block A201 completes a cycle,
データ送信部４０３は、複数の記録ブロック（ブロックＡ２０１～ブロックＣ２０３）に重み付けし、重み付けに基づいて記録ブロックに記録されているデータを送信する。例えば、データ送信部４０３は、図３（Ａ）の無線通信デバイスを用いて、データを送信する。データ送信部４０３は、ブロードキャストにデータを送信しても良いし、受信装置１０２にデータを送信しても良い。或いは、データ送信部４０３は、ゲートウェイ１１１、又は情報端末１１２を介して受信装置１０２にデータを送信しても良い。
The
複数の記録ブロックの重み付けの方法、及び送信するデータの選択方法のバリエーションは、複数の実施形態を例示して後述する。 Variations in the method of weighting multiple recording blocks and the method of selecting data to transmit will be described later using multiple examples.
記憶部４０４の機能は、ＣＰＵ３０１で実行されるプログラム、及びストレージデバイス３０３、メモリ３０２等によって実現され、ブロックＡ２０１～ブロックＣ２０３等の機能を実現している。
The functions of the
（受信装置の機能構成）
図５は、一実施形態に係る受信装置の機能構成を示す図である。受信装置１０２は、ＣＰＵ３１１で所定のプログラムを実行することにより、データ受信部５０１、データ処理部５０２、表示制御部５０３、操作受付部５０４、及び記憶部５０５の機能を実現する。なお、上記の各機能構成のうち一部は、ハードウェアによって実現されても良い。
(Functional configuration of the receiving device)
5 is a diagram showing the functional configuration of a receiving device according to an embodiment. The receiving
データ受信部５０１は、送信装置１０１から、計測データや代表値のようなデータと、当該データの取得時間又は取得期間を示す付加情報とを含む送信データを受信する。データ受信部５０１はまた、無線通信デバイス３１７を用いて、送信装置１０１が送信した送信データを受信する。或いは、データ受信部５０１は、ネットワークＩ／Ｆ３１４を用いて、送信装置１０１が送信した送信データをゲートウェイ１１１、情報端末１１２等を介して受信する。
The
データ処理部５０２は、データ受信部５０１が受信した送信データに含まれるデータを記憶部５０５等に記憶する。図５に示すデータ処理部５０２は、第１処理部５０２ａ及び第２処理部５０２ｂを含む。
The
第１処理部５０２ａは、データ受信部５０１が受信した送信データに、データと、当該データを取得した取得時間（例えばタイムスタンプ）とが含まれる場合、当該データを計測データとして取得時間と対応付けて記憶部５０５に記憶する。
When the transmission data received by the
第２処理部５０２ｂは、データ受信部５０１が受信した送信データに、データと、当該データの取得期間が含まれる場合、送信データに含まれるデータを当該取得期間の代表値として、当該取得期間に含まれる取得時間と対応付けて、記憶部５０５等に記憶する。なお、第１処理部５０２ａ及び第２処理部５０２ｂの処理は、１つのデータ処理部５０２で実行するものであっても良い。
When the transmission data received by the
表示制御部５０３は、データ処理部５０２が記憶部５０５等に記憶した計測データとその取得時間に基づいて、例えば、過去から現在までの計測データの推移をグラフ化して、表示装置３１５等に表示する。例えば、表示制御部５０３は、横軸を取得時間とし、縦軸を計測データの値とした折れ線グラフ、又は棒グラフ等を表示装置３１５に表示する。
The
操作受付部５０４は、入力装置３１６等を用いてユーザによる入力操作を受け付ける。
The
記憶部５０５の機能は、ＣＰＵ３１１で実行されるプログラム、及びストレージデバイス３１３、メモリ３１２等によって実現され、データ処理部５０２が記憶する計測データ、取得日時の情報等の様々な情報やデータを記憶する。
The function of the
＜処理の流れ＞
続いて、本実施形態に係るデータ通信方法の処理の流れについて説明する。
<Processing flow>
Next, the process flow of the data communication method according to this embodiment will be described.
（送信装置の処理）
図６は、一実施形態に係る送信装置の処理を示すフローチャートである。図６は、送信装置１０１が計測データを取得し送信先に送信する処理の全体の流れを示している。
(Transmitter Processing)
6 is a flowchart showing the process of the transmitting device according to an embodiment of the present invention, which illustrates the overall flow of the process in which the
Ｓ６０１において、データ管理部４０２は、例えば、図２に示すように、格納可能なデータ数がそれぞれ１０の３つの記録ブロック（ブロックＡ２０１、ブロックＢ２０２、ブロックＣ２０３）を定義して、各ブロックの次の記録位置を示すポインタを初期化する。
In S601, the
なお、図２に示す記録ブロックの数「３」、及び各記録ブロック内のデータの数「１０」は一例である。記録ブロックの数は２つ以上の他の数であっても良い。各記録ブロック内に記録可能なデータの数は、２以上の他の数であっても良いし、記録ブロック毎に異なる数であっても良い。 Note that the number of recording blocks "3" and the number of data in each recording block "10" shown in FIG. 2 are merely examples. The number of recording blocks may be another number greater than or equal to two. The number of data that can be recorded in each recording block may be another number greater than or equal to two, or may be a different number for each recording block.
Ｓ６０２において、データ管理部４０２は、記憶部４０４内に、図２に示すような３つのブロックＡ２０１、ブロックＢ２０２、及びブロックＣ２０３の記憶領域を確保する。
In S602, the
Ｓ６０３において、データ管理部４０２は、記憶部４０４内に、３つの各記録ブロックに対応する３つの付加情報の記憶領域を確保する。なお、付加情報の記憶領域は、３つの記録ブロックに含まれていても良い。
In S603, the
Ｓ６０４において、送信装置１０１は現在の時刻を取得する。
In S604, the transmitting
Ｓ６０５において、送信装置１０１は、取得した現在の時刻に基づいて、計測タイミングであるか否かを判断する。例えば、送信装置１０１は、前回の計測データの取得から予め設定された第１の時間を経過している場合、計測タイミングであると判断する。
In S605, the transmitting
計測タイミングである場合、送信装置１０１は、Ｓ６０６において、図７で後述する計測処理を実行する。一方、計測タイミングでない場合、送信装置１０１は、計測処理を行わず処理をＳ６０７に移行させる。
If it is measurement timing, the transmitting
Ｓ６０７に移行すると、送信装置１０１は、取得した現在の時刻に基づいて、送信タイミングであるか否かを判断する。送信装置１０１は例えば、前回のデータ送信から予め設定された第２の時間を経過している場合、記録ブロックに格納されているデータを送信するタイミングであると判断する。
When the process proceeds to S607, the transmitting
送信タイミングである場合、送信装置１０１は、Ｓ６０８において図８で後述する送信処理を実行する。一方、送信タイミングでない場合、送信装置１０１は送信処理を行わずに処理をＳ６０９に移行させる。
If it is time to transmit, the transmitting
Ｓ６０９において、送信装置１０１は、処理を終了するか否かを判断する。送信装置１０１は、予め設定された処理終了時刻になった場合、又はユーザによる終了操作を受け付けた場合等に、処理を終了すると判断し、図６の処理を終了する。
In S609, the transmitting
処理を終了しないと判断した場合、送信装置１０１は処理をＳ６０４に戻して、Ｓ６０４以降の処理を再び実行する。
If it is determined that the processing should not be terminated, the transmitting
（計測処理）
図７は、一実施形態に係る計測処理を示すフローチャートである。この処理は、Ｓ６０６において送信装置１０１が実行する計測処理の例を示している。計測処理では、センサからの計測データ取得と、取得した計測データの記録ブロックへの格納の処理が行われる。
(Measurement processing)
7 is a flowchart showing a measurement process according to an embodiment. This process shows an example of the measurement process executed by the
Ｓ７０１において、データ管理部４０２は、記録ブロック用のカウンタであるｂｌｏｃｋ＿ｃｏｕｎｔに「０」を設定し、ブロックＡ２０１を選択する。
In S701, the
Ｓ７０２において、データ取得部４０１は、計測データを取得して、最新データを格納する領域ｃｕｒｒｅｎｔ＿ｄａｔａに格納する。
In S702, the
Ｓ７０３において、データ管理部４０２は、ｂｌｏｃｋ＿ｃｏｕｎｔで示される記録ブロックの次の書き込み位置であるｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃｌｋ＿ｃｏｕｎｔ］に、ｃｕｒｒｅｎｔ＿ｄａｔａに格納された計測データを記録する。
In S703, the
この処理により、ｂｌｏｃｋ＿ｃｏｕｎｔが「０」である場合、ｂｌｏｃｋ＿ｃｏｕｎｔ＝０に対応するブロックＡ２０１の次の書き込み位置ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃｌｋ＿ｃｏｕｎｔ］に計測データが記録される。 When block_count is "0", this process records the measurement data in the next write position data_count[block_count] of block A201 corresponding to block_count = 0.
Ｓ７０４において、データ管理部４０２は、Ｓ７０３で記録した計測データの取得時間を取得し、取得時間を含む付加情報を、当該計測データに対応するブロックＡ２０１の付加情報の記憶領域に記録する。
In S704, the
Ｓ７０５において、ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃｋ＿ｃｏｕｎｔ］の値をインクリメントする。 At S705, the value of data_count[block_count] is incremented.
Ｓ７０６において、データ管理部４０２は、ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃ＿ｃｏｕｎｔ］の値が当該記録ブロックの最大データ数（Ｎ＿ＭＡＸ＿ＤＡＴＡ）より小さいか否かを判断する。
At S706, the
ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃ＿ｃｏｕｎｔ］の値がＮ＿ＭＡＸ＿ＤＡＴＡより小さい場合（Ｓ７０６ＹＥＳ）、データ管理部４０２は図７の処理を終了する。一方、ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃ＿ｃｏｕｎｔ］の値がＮ＿ＭＡＸ＿ＤＡＴＡ以上である場合（Ｓ７０６ＮＯ）、データ管理部４０２は環状バッファである記録ブロックの末尾までデータを記録したと判断し、処理をＳ７０７に移行させる。
If the value of data_count[bloc_count] is smaller than N_MAX_DATA (S706 YES), the
Ｓ７０７に移行すると、データ管理部４０２は、ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃｋ＿ｃｏｕｎｔ］の値を「０」に戻す。
When proceeding to S707, the
Ｓ７０８において、データ管理部４０２は、ｂｌｏｃｋ＿ｃｏｕｎｔで示される記録ブロックに記録されているデータの平均値を算出し、ｃｕｒｒｅｎｔ＿ｄａｔａに格納する。なお、平均値は代表値の一例であり、代表値は最大値、最小値、中央値、標準偏差等の他の値であっても良い。
In S708, the
Ｓ７０９において、ｂｌｏｃｋ＿ｃｏｕｎｔの値が記録ブロックの最大値（Ｎ＿ＭＡＸ＿ＢＬＯＣＫ）より小さいか否かを判断する。この処理により、データ管理部４０２は、次の記録ブロックの有無を判断することができる。
In S709, it is determined whether the value of block_count is smaller than the maximum value of the recording block (N_MAX_BLOCK). This process allows the
ｂｌｏｃｋ＿ｃｏｕｎｔの値がＮ＿ＭＡＸ＿ＢＬＯＣＫより小さい場合（Ｓ７０９ＹＥＳ）、データ管理部４０２は、ｂｌｏｃｋ＿ｃｏｕｎｔの値をインクリメントして、処理をＳ７０３に戻す。一方、ｂｌｏｃｋ＿ｃｏｕｎｔの値がＮ＿ＭＡＸ＿ＢＬＯＣＫ以上である場合（Ｓ７０９ＮＯ）、データ管理部４０２は図７の処理を終了させる。
If the value of block_count is smaller than N_MAX_BLOCK (S709 YES), the
Ｓ７０３に戻ると、ｂｌｏｃｋ＿ｃｏｕｎｔを「１」とし、ブロックＢ２０２を選択した状態でＳ７０３以降の処理を再び実行する。 When the process returns to S703, block_count is set to "1" and block B202 is selected, and the process from S703 onwards is executed again.
Ｓ７０３において、データ管理部４０２は、ｂｌｏｃｋ＿ｃｏｕｎｔで示される記録ブロックの次の書き込み位置であるｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃｌｋ＿ｃｏｕｎｔ］に、ｃｕｒｒｅｎｔ＿ｄａｔａに格納されているデータを記録する。ここではｂｌｏｃｋ＿ｃｏｕｎｔが「１」であるため、対応するブロックＢ２０２の次の書き込み位置に、ｃｕｒｒｅｎｔ＿ｄａｔａに格納されている、ブロックＡ２０１に格納されたデータの平均値が記録される。
In S703, the
Ｓ７０４において、データ管理部４０２は、Ｓ７０３で記録した計測データに対応する付加情報を、当該計測データに対応する付加情報の記憶領域に記録する。ここではｂｌｏｃｋ＿ｃｏｕｎｔが「１」であるため、ブロックＢ２０２に記録した平均値に対応するブロックＢ２０２の付加情報の記憶領域に、平均値に対応する取得期間を含む付加情報が記録される。例えば、データ管理部４０２は、ブロックＡ２０１に記録されている複数の計測データの取得時間を、付加情報を参照して取得する。また、データ管理部４０２は、一例として、ブロックＡ２０１のアドレスＡ＿０～Ａ＿９に記録されている計測データの取得時間、計測データの取得間隔、及び計測データのデータ数等を、平均値に対応する取得期間として付加情報に記録する。
In S704, the
Ｓ７０５において、ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃｋ＿ｃｏｕｎｔ］の値をインクリメントする。 At S705, the value of data_count[block_count] is incremented.
Ｓ７０６において、データ管理部４０２は、ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃ＿ｃｏｕｎｔ］の値が、当該記録ブロックのＮ＿ＭＡＸ＿ＤＡＴＡより小さいか否かを判断する。ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃ＿ｃｏｕｎｔ］の値がＮ＿ＭＡＸ＿ＤＡＴＡより小さい場合（Ｓ７０６ＹＥＳ）、データ管理部４０２は図７の処理を終了させる。一方、ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃ＿ｃｏｕｎｔ］の値がＮ＿ＭＡＸ＿ＤＡＴＡより小さくない場合（Ｓ７０６ＮＯ）、データ管理部４０２は処理をＳ７０７に移行させる。
In S706, the
Ｓ７０７に移行すると、データ管理部４０２は、ｄａｔａ＿ｃｏｕｎｔ［ｂｌｏｃｋ＿ｃｏｕｎｔ］の値を「０」に戻す。
When proceeding to S707, the
Ｓ７０８において、データ管理部４０２は、ｂｌｏｃｋ＿ｃｏｕｎｔで示される記録ブロックに記録されているデータの平均値を算出する。
In S708, the
Ｓ７０９において、データ管理部４０２は、ｂｌｏｃｋ＿ｃｏｕｎｔの値が記録ブロックの最大値（Ｎ＿ＭＡＸ＿ＢＬＯＣＫ）より小さいか否かを判断する。ｂｌｏｃｋ＿ｃｏｕｎｔの値がＮ＿ＭＡＸ＿ＢＬＯＣＫより小さい場合（Ｓ７０９ＹＥＳ）、データ管理部４０２は、ｂｌｏｃｋ＿ｃｏｕｎｔの値をインクリメントして、処理をＳ７０３に戻す。これによりｂｌｏｃｋ＿ｃｏｕｎｔ＝２となり、ブロックＣ２０３においてＳ７０３以降の処理が実行される。
In S709, the
一方、ｂｌｏｃｋ＿ｃｏｕｎｔの値がＮ＿ＭＡＸ＿ＢＬＯＣＫ以上である場合、データ管理部４０２は図７の処理を終了させる。
On the other hand, if the value of block_count is greater than or equal to N_MAX_BLOCK, the
上記の処理により、送信装置１０１は、取得した計測データをブロックＡ２０１に順次に格納し、末尾のアドレスＡ＿９に計測データを記録したときに、次の書き込みポインタを先頭のアドレスＡ＿０に戻す。また、送信装置１０１は、ブロックＡ２０１における記録が一巡するタイミングで、ブロックＡ２０１に格納されているデータの平均値（代表値）を算出して、ブロックＢ２０２に記録することができる。
By the above process, the transmitting
同様に、送信装置１０１は、ブロックＢ２０２における記録が一巡するタイミングで、ブロックＢ２０２に格納されているデータの代表値を算出してブロックＣ２０３に記録する。このように、送信装置１０１は、古いデータほど、記憶領域を節約して計測データを蓄積するとともに、比較的新しいデータを加工せずに元データのまま蓄積する。
Similarly, when recording in block B202 is completed, the transmitting
（送信処理）
図８は、一実施形態に係る送信処理を示すフローチャートである。この処理は、Ｓ６０８において送信装置１０１が実行する送信処理の例を示している。
(Transmission process)
8 is a flowchart showing a transmission process according to an embodiment of the present invention, which illustrates an example of the transmission process executed by the transmitting
Ｓ８０１において、データ送信部４０３は、複数の記録ブロックを重み付けし、重み付けに基づいて、複数の記録ブロックのうち送信するデータを格納している記録ブロックを選択し、選択する記録ブロックを示す変数をｂｌｏｃｋ＿ｓｅｌｅｃｔに設定する。例えば、データ送信部４０３は、図９に示すブロック選択処理を実行して、データを送信する記録ブロックを選択する。
In S801, the
Ｓ８０２において、データ送信部４０３は、選択された記録ブロックに記録されている複数のデータの中から送信するデータを選択し、ｄａｔａ＿ｓｅｌｅｃｔに設定する。例えば、データ送信部４０３は、選択された記録ブロックに記録されている複数のデータの中から送信するデータをランダムに選択する。或いは、データ送信部４０３は、選択された記録ブロックに記録されている複数のデータを重み付けして、重み付けに基づいて送信するデータをランダムに選択する。
In S802, the
Ｓ８０３において、データ送信部４０３は、Ｓ８０２で選択されたデータを送信データのデータ領域であるｓｅｎｄ＿ｄａｔａに設定する。
In S803, the
Ｓ８０４において、データ送信部４０３は、Ｓ８０２で選択されたデータの付加情報を、送信データの付加情報領域であるｓｅｎｄ＿ｉｎｆｏに設定する。なお、選択されたデータが計測データである場合、この付加情報には当該計測データを取得した取得時間の情報が含まれる。また、選択されたデータが平均値（代表値）である場合、この付加情報には平均したデータを取得した期間を示す取得期間の情報が含まれる。
In S804, the
Ｓ８０５において、データ送信部４０３は、送信するデータ（ｓｅｎｄ＿Ｄａｔａ）と、当該データに対応する付加情報（ｓｅｎｄ＿ｉｎｆｏ）とを含む送信データを、受信装置１０２などの送信先に無線通信で送信する。
In S805, the
（ブロック選択処理）
図９は、一実施形態に係るブロック選択処理を示すフローチャートである。この処理は、Ｓ８０１で送信装置１０１が実行するブロック選択処理の一例を示している。
(Block selection process)
9 is a flowchart showing a block selection process according to an embodiment of the present invention, which illustrates an example of the block selection process executed by the transmitting
Ｓ９０１において、データ送信部４０３は、一例として、０～９９の範囲で乱数を発生して、発生した乱数をｒａｎｄ領域に格納する。
In S901, the
Ｓ９０２において、データ送信部４０３は、ブロック数が２であるか否かを判断する。ここで、ブロック数は記録ブロックの数を表しており、ブロック数＝２は、記録ブロックの数が２つであることを表すものとする。
In S902, the
ブロック数＝２であるとき、ブロックＡ２０１とブロックＢ２０２の２つの記録ブロックがあるため、データ送信部４０３は処理をＳ９０３に移行させる。一方、ブロック数＝２でない場合、データ送信部４０３は処理をＳ９０６に移行させる。
When the number of blocks is 2, there are two recording blocks, block A201 and block B202, so the
Ｓ９０３に移行すると、データ送信部４０３は、発生した乱数ｒａｎｄの値が７０より小さいか否かを判断する。ｒａｎｄの値が７０より小さい場合、データ送信部４０３は処理をＳ９０４に移行させる。一方、ｒａｎｄの値が７０以上である場合、データ送信部４０３は処理をＳ９０５に移行させる。
When the process proceeds to S903, the
Ｓ９０４に移行すると、データ送信部４０３は、ｂｌｏｃｋ＿ｓｅｌｅｃｔの値を「０」として、ブロックＡ２０１を選択する。
When the process proceeds to S904, the
一方、Ｓ９０５に移行すると、データ送信部４０３は、ｂｌｏｃｋ＿ｓｅｌｅｃｔの値を「１」として、ブロックＢ２０２を選択する。
On the other hand, when the process proceeds to S905, the
上記の処理により、データ送信部４０３は、記録ブロックの数が２つである場合、乱数を用いて、ブロックＡ２０１を７０％の確率で選択し、ブロックＢ２０２を３０％の確率で選択することができる。
なお、上記の確率は一例であり、他の値であっても良い。この場合、発生させる乱数の数を変える、Ｓ９０３の判断での乱数の閾値を変える、などの対応を取ればよい。
By the above process, when the number of recording blocks is two, the
The above probability is merely an example, and other values may be used. In this case, measures may be taken such as changing the number of random numbers to be generated or changing the threshold value of the random numbers used in the determination in S903.
一方、Ｓ９０２からＳ９０６に移行すると、データ送信部４０３はブロック数＝３であるか否かを判断する。なお、ブロック数＝３は記録ブロックの数が３つであることを表すものとする。
On the other hand, when the process moves from S902 to S906, the
ブロック数＝３である場合、記録ブロックがブロックＡ２０１～ブロックＣ２０３の３つあるので、データ送信部４０３は処理をＳ９０７に移行させる。一方、ブロック数＝３でない場合、データ送信部４０３は処理をＳ９１３に移行させる。なお、Ｓ９０６の処理はＳ９０２の前に実行しても良い。
If the number of blocks is 3, there are three recording blocks, block A201 to block C203, and so the
Ｓ９０７に移行すると、データ送信部４０３は、発生した乱数ｒａｎｄの値が５０より小さいか否かを判断する。ｒａｎｄの値が５０より小さい場合、データ送信部４０３は処理をＳ９０８に移行させる。一方、ｒａｎｄの値が５０以上である場合、データ送信部４０３は処理をＳ９０９に移行させる。
When the process proceeds to S907, the
Ｓ９０８に移行すると、データ送信部４０３は、ｂｌｏｃｋ＿ｓｅｌｅｃｔの値を「０」として、ブロックＡ２０１を選択する。
When the process proceeds to S908, the
一方、Ｓ９０９に移行すると、データ送信部は、発生した乱数ｒａｎｄの値が７５より小さいか否かを判断する。ｒａｎｄの値が７５より小さい場合、データ送信部４０３は処理をＳ９１１に移行させる。一方、ｒａｎｄの値が７５以上である場合、データ送信部４０３は処理をＳ９１２に移行させる。
On the other hand, when the process proceeds to S909, the
Ｓ９１１に移行すると、データ送信部４０３は、ｂｌｏｃｋ＿ｓｅｌｅｃｔの値を「１」として、ブロックＢ２０２を選択する。
When the process proceeds to S911, the
一方、Ｓ９１２に移行すると、データ送信部４０３は、ｂｌｏｃｋ＿ｓｅｌｅｃｔの値を「２」として、ブロックＣ２０３を選択する。
On the other hand, when the process proceeds to S912, the
上記の処理により、データ送信部４０３は、記録ブロックの数が３つである場合、乱数を用いて、ブロックＡ２０１を５０％の確率で選択し、ブロックＢ２０２、及びブロックＣ２０３をそれぞれ２５％の確率選択することができる。なお、上記の確率は一例であり、他の値であっても良い。
By the above process, when the number of recording blocks is three, the
一方、Ｓ９０６からＳ９１３に移行すると、データ送信部４０３は、ブロック数＝１であるか否かを判断する。なお、ブロック数＝１は記録ブロックの数が１つであることを表すものとする。
On the other hand, when the process moves from S906 to S913, the
ブロック数＝１である場合、記録ブロックがブロックＡ２０１のみであるので、データ送信部４０３は処理をＳ９１４に移行させる。一方、ブロック数＝１でない場合、データ送信部４０３は処理をＳ９１５に移行させる。
If the number of blocks is 1, the only recorded block is block A201, so the
Ｓ９１４に移行すると、データ送信部４０３は、ｂｌｏｃｋ＿ｓｅｌｅｃｔの値を「０」として、ブロックＡ２０１を選択する。
When the process proceeds to S914, the
Ｓ９１５において、データ送信部４０３は、Ｓ９０２～Ｓ９１４で設定されたｂｌｏｃｋ＿ｓｅｌｅｃｔの値をＳ８０１に返す。
In S915, the
このように、本実施形態に係るデータ送信部４０３は、図２に示すように３つの記録ブロックがある場合、例えば、ｒａｎｄの値によってブロックＢ２０２の重みをブロックＡ２０１の重みより小さく設定し、ブロックＣ２０３の重みをブロックＢ２０２の重みより小さく設定する。これにより、データ送信部４０３は、送信先に、直近の計測データを優先的に送信しつつ、過去のデータも送信することができる。
続いて、データ送信部４０３が選択する記録ブロック、及びデータの重み付けについて、複数の実施形態を例示して説明する。
2, the
Next, the recording blocks selected by the
［第１の実施形態］
図１０は、第１の実施形態に係る記録ブロック及びデータの重み付けを示す図である。図９のフローチャートでは記録ブロックの数が１～３の場合について説明したが、記録ブロックの数は４つ以上であっても良い。
[First embodiment]
Fig. 10 is a diagram showing the weighting of recording blocks and data according to the first embodiment. In the flowchart of Fig. 9, the case where the number of recording blocks is 1 to 3 has been described, but the number of recording blocks may be 4 or more.
図１０の例では、ブロックＡの重みを１／２とし、残りの重み１／２をブロックＢ、Ｃ、Ｄ、・・・に割り当てている。また、ブロックＢの重みを１／４（＝１／２×１／２）とし、残りの重み１／４をブロックＣ、Ｄ、・・・に割り当てている。さらに、ブロックＣの重みを１／８（＝１／４×１／２）とし、残りの重み１／８をブロックＤ、・・・に割り当てている。
In the example of Figure 10, the weight of block A is set to 1/2, and the remaining
つまり、Ｎを１以上の整数、Ｘを１未満の有理数とした場合、第（Ｎ＋１）の記録ブロックの重みが、第Ｎの記録ブロックの重みのＸ倍となるように設定されている。この方法により、例えば記録ブロックの数が４つ以上の場合でも、各記録ブロックの重みを容易に決定することができる。 In other words, if N is an integer equal to or greater than 1 and X is a rational number less than 1, the weight of the (N+1)th recording block is set to be X times the weight of the Nth recording block. With this method, the weight of each recording block can be easily determined even when there are four or more recording blocks.
図１０の例では、各記録ブロック内のデータは平等に重み付けされ、重み付けに応じた確率で送信するデータが選択される。これにより、ブロックＡ内の各データは１／２＊１／１０＝１／２０の確率で送信される。同様に、ブロックＢ内の各データは、１／４＊１／１０＝１／４０の確率で送信され、ブロックＣ内の各データは１／８＊１／１０＝１／８０の確率で送信され、ブロックＤ内の各データは１／１６＊１／１０＝１／１６０の確率で送信される。 In the example of Figure 10, the data in each recording block is weighted equally, and data to be transmitted is selected with a probability according to the weighting. As a result, each piece of data in block A is transmitted with a probability of 1/2 * 1/10 = 1/20. Similarly, each piece of data in block B is transmitted with a probability of 1/4 * 1/10 = 1/40, each piece of data in block C with a probability of 1/8 * 1/10 = 1/80, and each piece of data in block D with a probability of 1/16 * 1/10 = 1/160.
［第２の実施形態］
図１１は、第２の実施形態に係る記録ブロック及びデータの重み付けを示す図である。図１１では、ブロックＡ内の各データ（アドレスＡ＿０～Ａ＿９）と、ブロックＢ＋ブロックＣに均等に重みを与えた場合の重み付けの例を示している。図１１の例では各記録ブロックは１０個のデータを格納可能であり、ブロックＡの各データに１／１１の重みづけを与えており、ブロックＢとブロックＣとに合わせて１／１１の重みづけを与えている。
Second Embodiment
Fig. 11 is a diagram showing recording blocks and weighting of data according to the second embodiment. Fig. 11 shows an example of weighting when equal weights are given to each data (addresses A_0 to A_9) in block A and to block B+block C. In the example of Fig. 11, each recording block can store 10 data, and a weighting of 1/11 is given to each data in block A, and a weighting of 1/11 is given to blocks B and C together.
図１１では、ブロックＡ内の各データは、１／１１の確率で送信先に送信される。また、ブロックＢ＋ブロックＣが選択される確率も１／１１となる。 In FIG. 11, each data in block A has a probability of 1/11 being sent to the destination. Also, the probability that block B + block C are selected is also 1/11.
また、図１１では、ブロックＢ内の各データ（アドレスＢ＿０～Ｂ＿９）と、ブロックＣに均等に１／１１の重みを与えている。ブロックＢ内の各データは１／１１＊１／１１＝１／１２１の確率で送信される。また、ブロックＣが選択される確率も１／１２１となる。さらに、ブロックＣ内の各データには１／１１の重みづけが与えられており、ブロックＣのデータは１／１２１＊１／１１＝１／１３３１の確率で送信される。 In addition, in FIG. 11, each data in block B (addresses B_0 to B_9) and block C are equally weighted at 1/11. Each data in block B is transmitted with a probability of 1/11*1/11=1/121. The probability that block C is selected is also 1/121. Furthermore, each data in block C is weighted at 1/11, and the data in block C is transmitted with a probability of 1/121*1/11=1/1331.
［第３の実施形態］
図１２は、第３の実施形態に係る記録ブロック及びデータの重み付けを示す図である。第２の実施形態では、各記録ブロック内のデータには均等に重みが与えられていたが、図１２に示す例では、直近に取得したデータ（＜現在＞）の重みを大きく設定している。
[Third embodiment]
Fig. 12 is a diagram showing the weighting of recording blocks and data according to the third embodiment. In the second embodiment, the data in each recording block is weighted equally, but in the example shown in Fig. 12, the most recently acquired data (<present>) is weighted heavily.
図１２のブロックＡにおいて、現在のデータがアドレスＡ＿９に記録されているものとする。＜現在＞のデータに１／２の重みを設定することにより、１／２の確率でアドレスＡ＿９に格納されているデータが選択されるようにする。 In block A of FIG. 12, assume that the current data is stored at address A_9. By setting a weight of 1/2 for the <current> data, the data stored at address A_9 is selected with a 1/2 probability.
また、残りの１／２の重みを、ブロックＡ内の残りの９データ（アドレスＡ０～Ａ８）と、ブロックＢ＋Ｃとに均等に割り当てる。つまり、ブロックＡ内の＜現在＞のデータ以外が選択される確率を１／２とする。そのため、ブロックＡ内のアドレスＡ０～Ａ８のデータの重みは１／２＊１／１０＝１／２０となる。また、ブロックＢおよびブロックＣの重みも１／２０とする。 The remaining 1/2 of the weight is then evenly allocated to the remaining 9 data in block A (addresses A0 to A8) and blocks B+C. In other words, the probability that data other than the <current> data in block A will be selected is set to 1/2. Therefore, the weight of the data at addresses A0 to A8 in block A is 1/2 * 1/10 = 1/20. The weights of blocks B and C are also set to 1/20.
この場合、ブロックＢ内の各データ及びブロックＣの重みは１／２０＊１／１１＝１／２２０となり、ブロックＣ内の各データの重みは１／２２０＊１／１１＝１／２４２０となる。 In this case, the weight of each data in block B and block C is 1/20 * 1/11 = 1/220, and the weight of each data in block C is 1/220 * 1/11 = 1/2420.
データ送信部４０３は、上記の各実施形態で説明した重み付けに基づいて送信するデータを選択する。これにより、重みづけに基づいてランダムに選択されたデータが送信される。
また、データ送信部４０３は、例えば、図１３（Ａ）に示すように、選択したデータ１３１１と対応する付加情報１３１２とを含む送信データ１３１０を、受信装置１０２などの送信先に送信する。
The
Furthermore, the
別の一例として、データ送信部４０３は、図１３（Ｂ）に示すように、選択したデータ１３１１と対応する付加情報１３１２に加えて、最新データ１３２１と、最新データ１３２１のタイムスタンプ１３２２を送信しても良い。
As another example, the
［第４の実施形態］
図１４は、第４の実施形態に係る記録ブロック及びデータの重み付けを示す図である。図１４の例では、ブロックＡ～Ｃとは別の記憶領域（例えば、アドレスＸ＿０）にデータ取得部４０１が取得した最新データを一時的に記憶し、その重みを「１」としている。また、ブロックＡの各アドレスのデータの重みを「１／１１」とし、ブロックＢの各アドレスのデータの重みを「１／１１＊１／１１＝１／１２１」としている。さらに、ブロックＣの各アドレスのデータの重みを「１／１２１＊１／１１」としている。
[Fourth embodiment]
Fig. 14 is a diagram showing recording blocks and data weighting according to the fourth embodiment. In the example of Fig. 14, the latest data acquired by the
これにより、データ送信部４０３は、例えば図１３（Ｂ）に示すように、アドレスＸ＿０に格納された最新データ１３２１、最新データのタイムスタンプ１３２２、ブロックＡ～ブロックＣから選択したデータ１３１１、及びデータ１３１１に対応する付加情報１３１２を含む送信データ１３２０を送信する。これにより、データ送信部４０３は、最新の計測データを毎回送信しつつ、重み付けに基づいて選択した過去のデータを送信することができる。この場合、データ送信部４０３は、最新データ１３２１を送信した後に、当該最新データ１３２１をブロックＡの次の書き込み先に記録する。
As a result, the
さらに、データ送信部４０３は、図１３（Ｃ）に示すように、最新データ１３２１と最新データ１３２１のタイムスタンプ１３２２とともに、複数のデータ及び付加情報１３３１を含む送信データ１３３０を送信しても良い。
Furthermore, the
なお、上記の各実施形態では、例えば、ブロックＢの各データ、ブロックＣ内の各データの重みがそれぞれ均等になっているが、ブロックＢ、ブロックＣにおいても最新のデータの重みを高く設定しても良い。例えば、ブロックＢにおいても、ブロックＡと同様に最新データを別の記憶領域に格納し、当該記憶領域の重みをブロックＢより高く設定しても良い。これにより、データ送信部４０３は、ブロックＡの代表値が更新され、ブロックＢに記録されたときに、更新された代表値を優先的に送信することができる。同様に、ブロックＣにおいても、最新データを別の記憶領域に格納し、当該記憶領域の重みをブロックＣより高く設定しても良い。
In the above embodiments, for example, the weights of each data in block B and each data in block C are equal, but the weights of the most recent data in blocks B and C may also be set higher. For example, the most recent data in block B may be stored in a separate memory area, as in block A, and the weight of that memory area may be set higher than that of block B. This allows the
＜受信装置の処理＞
図１５は、一実施形態に係るデータ受信処理を示すフローチャートである。この処理は、受信装置１０２が、送信装置１０１が送信した送信データを受信したときに実行する処理の一例を示している。
<Processing of Receiving Device>
15 is a flowchart showing a data reception process according to an embodiment. This process shows an example of a process that the receiving
Ｓ１５０１において、データ受信部５０１は、図１３（Ａ）に示すように、データ１３１１と、データ１３１１に対応する付加情報１３１２とを含む送信データ１３１０を受信するものとする。
In S1501, the
なお、データ１３１１がブロックＡ２０１に記録された計測データである場合、付加情報１３１２には、データ１３１１を取得した日時を示す取得時間（タイムスタンプ）の情報が含まれる。また、データ１３１１が、ブロックＢ２０２等に記録された平均値である場合、付加情報１３１２には、平均化した複数の計測データを取得した期間を示す取得期間の情報が含まれる。
When the
Ｓ１５０２において、データ処理部５０２は、受信した送信データ１３１０に含まれるデータ１３１１が、平均値であるか、計測データであるかを判断する。データ処理部５０２は、送信データ１３１０に含まれる付加情報１３１２に取得期間が含まれる場合、データ１３１１が平均値であると判断する。一方、データ処理部５０２は、付加情報１３１２に取得時間が含まれる場合、データ１３１１が計測データであると判断する。
In S1502, the
データ１３１１が平均値でない場合（計測データである場合）、データ処理部５０２は処理をＳ１５０３に移行させる。一方、データ１３１１が平均値である場合、データ処理部５０２は処理をＳ１５０５に移行させる。
If the
Ｓ１５０３に移行すると、第１処理部５０２ａは、ログデータを記憶する記憶領域（ｄａｔａ＿ｌｏｇ）内の取得時間に対応するインデックス（書き込み位置）に、データ１３１１（ｒｃｖ＿ｄａｔａ）を記憶する。これにより、ログデータを記憶する記憶領域に、データ１３１１が当該データ１３１１を取得した取得時間と対応付けて記憶される。
When the process proceeds to S1503, the
Ｓ１５０４において、表示制御部５０３は、一例として、最も古いデータから現在のデータまでの計測データの推移を示すグラフを作成し、表示装置３１５に表示する。
In S1504, the
一方、Ｓ１５０２からＳ１５０５に移行すると、ログデータを記憶する記憶領域内の書き込み位置をカウントするカウンタｉを０に初期化して、Ｓ１５０６以降の処理を実行する。 On the other hand, when the process moves from S1502 to S1505, the counter i that counts the write positions in the memory area that stores the log data is initialized to 0, and the process from S1506 onwards is executed.
Ｓ１５０６において、第２処理部５０２ｂは、ｄａｔａ＿ｌｏｇ［平均期間内の最も古いインデックス＋ｉ］に、より低レベルブロックのデータが記憶されているか否かを判断する。例えば、データ受信部５０１が受信した送信データ１３１０に含まれるデータ１３１１が、取得時間ｔ０、ｔ１、ｔ２、・・・、ｔ９に測定した１０個の計測データの平均値であるものとする。この場合、送信データ１３１０に含まれる付加情報１３１２には、取得期間として、例えば開始日時ｔ０、データ取得間隔Δｔ、及びデータ数ｎ等の情報が含まれる。従って、ステップＳ１５０１で受信した送信データを平均した平均期間は、「ｔ０」～「ｔ０＋Δｔ×ｎ」で表すことができる。
In S1506, the
ここで、「平均期間内の最も古いインデックス＋ｉ」は、ログデータを記憶するｄａｔａ＿ｌｏｇ内の取得時間「ｔ０＋Δｔ×ｉ」に対応するインデックスを示す。また、低レベルブロックのデータとは、平均化していない計測データ、又はステップＳ１５０１で受信した送信データを平均した平均期間より短い平均期間で平均化されたデータを表す。 Here, "oldest index in the averaging period + i" indicates the index corresponding to the acquisition time "t0 + Δt × i" in data_log that stores the log data. Also, the data in the low-level block represents measurement data that has not been averaged, or data that has been averaged over an averaging period that is shorter than the averaging period for averaging the transmission data received in step S1501.
第２処理部５０２ｂは、Ｓ１５０６において、ログデータを記憶するｄａｔａ＿ｌｏｇ内の取得時間「ｔ０＋Δｔ×ｉ」に対応するインデックスに、計測データ（低レベルブロックのデータ）が記憶されているか否かを判断する。
In S1506, the
低レベルブロックのデータがない場合（Ｓ１５０６ＮＯ）、第２処理部５０２ｂは処理をＳ１５０７に移行させる。一方、低レベルブロックのデータがある場合（Ｓ１５０６ＹＥＳ）、第２処理部５０２ｂは処理をＳ１５０８に移行させる。
If there is no low-level block data (S1506 NO), the
Ｓ１５０７において、第２処理部５０２ｂは、ｄａｔａ＿ｌｏｇ［平均期間内の最も古いインデックス＋ｉ］に、データ受信部５０１が受信した送信データ１３１０に含まれるデータ１３１１（ｒｃｖ＿ｄａｔａ）を記憶する。
In S1507, the
上記の処理によりｄａｔａ＿ｌｏｇ内の取得時間「ｔ０＋Δｔ×ｉ」に対応するインデックスに計測データが記憶されていない場合、平均値であるデータ１３１１が記憶される。一方、ｄａｔａ＿ｌｏｇ内の取得時間「ｔ０＋Δｔ×ｉ」に対応するインデックスに計測データが記憶されている場合、平均値であるデータ１３１１を記憶せず、記憶されている計測データを維持する。
When no measurement data is stored in the index corresponding to the acquisition time "t0+Δt×i" in data_log by the above process, the
Ｓ１５０８において、第２処理部５０２ｂは、ｉの値が平均化したデータの数（ある取得期間に含まれるデータ数）より小さいか否かを判断する。ｉの値が平均化したデータの数より小さい場合、第２処理部５０２ｂは、処理をＳ１５０９に移行させる。一方、ｉの値が平均化したデータの数以上である場合、第２処理部５０２ｂは、処理をＳ１５０４に移行させる。
In S1508, the
Ｓ１５０９に移行すると、第２処理部５０２ｂは、ｉをインクリメントして、処理をＳ１５０６に戻す。
When processing proceeds to S1509, the
上記の処理により、受信装置１０２は、データ受信部５０１が受信した送信データ１３１０に計測データが含まれている場合、当該計測データを、付加情報１３１２に含まれる取得時間に基づいてログデータを記憶する記憶領域に記憶する。
By the above processing, when measurement data is included in the
また、受信装置１０２は、データ受信部５０１が受信した送信データに平均値が含まれており、付加情報１３１２に含まれる取得期間に計測データが記憶されていない場合、ステップＳ１５０５～Ｓ１６０９の処理により、当該平均値を用いて、ログデータが補完される。
In addition, if the transmission data received by the
なお、図１５に示す処理は一例である。例えば、受信装置１０２は、データ受信部５０１が受信した送信データ１３１０に平均値が含まれている場合、当該平均値と、当該平均値の取得期間の情報とを対応付けて、記憶部５０５に記憶しても良い。
The process shown in FIG. 15 is an example. For example, when an average value is included in the
この場合、受信装置１０２の表示制御部５０３に直近の計測データの推移と、過去の平均値とを表示画面に表示しても良いし、平均値を展開して、過去からの計測データの推移を表示画面に表示しても良い。
In this case, the
以上、本発明の各実施形態によれば、取得した複数データを記録しつつ、送信先に送信する送信装置１０１において、最新の計測データだけではなく、過去のデータも容易に取得できるようになる。
As described above, according to each embodiment of the present invention, the transmitting
また、本実施形態に係る送信装置１０１によれば、比較的最近のデータをより多いデータ量で記録し、古いデータをより少ないデータ量で記録することができるので、記録効率を向上させることができる。
In addition, according to the transmitting
また、送信時においても、モニタリングやデモンストレーション等の用途で比較的重要度の高い直近のデータを高頻度で、比較的注目度や緊急度が低いものの一定の需要のある古いデータを低頻度で受信装置１０２に送信することができる。
In addition, when transmitting, the most recent data that is relatively important for applications such as monitoring and demonstrations can be transmitted frequently to the receiving
従って、受信装置１０２は、比較的遠い過去から現在に至るまでの計測データの推移、アウトライン等を比較的短期間で取得可能となり、しかも計測データ取得におけるリアルタイム性もさほど損なわないという効果が期待できる。
Therefore, the receiving
以上の実施の形態に示した構成は、本発明の内容の一例を示すものであり、本発明の要旨を逸脱しない範囲で、構成の一部を省略、変更することも可能である。 The configurations shown in the above embodiments are merely examples of the contents of the present invention, and it is possible to omit or modify parts of the configurations without departing from the gist of the present invention.
１００ データ通信システム、１０１ 送信装置、１０２ 受信装置、
１１１ ゲートウェイ、１１２ 情報端末、２０１ ブロックＡ、２０２ ブロックＢ、２０３ ブロックＣ、４０２ データ管理部、４０３ データ送信部、
５０１ データ受信部、５０２ａ 第１処理部、５０２ｂ 第２処理部、
５０５ 記憶部、１３１２ 付加情報
100 Data communication system, 101 Transmitting device, 102 Receiving device,
111 Gateway, 112 Information terminal, 201 Block A, 202 Block B, 203 Block C, 402 Data management unit, 403 Data transmission unit,
501 data receiving unit, 502a first processing unit, 502b second processing unit,
505 storage unit, 1312 additional information
Claims (4)
環状バッファで構成されるデータ記録用の複数の記録ブロックと、
前記記録ブロックにおける記録が一巡するタイミングで、当該記録ブロックに記録されているデータの代表値を、当該記録ブロックとは異なる他の記録ブロックに記録するデータ管理部と、
前記複数の記録ブロックに重み付けし、前記重み付けに基づいて前記複数の記録ブロックに記録されているデータを送信するデータ送信部と、
を有し、
前記データ送信部は、前記送信するデータを、前記重み付けに基づいてランダムに決定する、送信装置。 A transmitting device that records and transmits acquired data,
a plurality of recording blocks for recording data, each of which is formed of a circular buffer;
a data management unit that records a representative value of data recorded in the recording block in another recording block different from the recording block when recording in the recording block is completed;
a data transmission unit that weights the plurality of recording blocks and transmits data recorded in the plurality of recording blocks based on the weighting;
having
A transmitting device , wherein the data transmitting unit randomly determines the data to be transmitted based on the weighting .
Ｎは１以上の整数であり、Ｘは１未満の有理数である、請求項１又は２に記載の送信装置。 The plurality of recording blocks are set such that a weight of an (N+1)th recording block is X times a weight of an Nth recording block,
3. The transmitting device according to claim 1, wherein N is an integer equal to or greater than 1, and X is a rational number less than 1.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2021016242A JP7597290B2 (en) | 2021-02-04 | 2021-02-04 | Transmitting Device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2021016242A JP7597290B2 (en) | 2021-02-04 | 2021-02-04 | Transmitting Device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2022119261A JP2022119261A (en) | 2022-08-17 |
| JP7597290B2 true JP7597290B2 (en) | 2024-12-10 |
Family
ID=82848436
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2021016242A Active JP7597290B2 (en) | 2021-02-04 | 2021-02-04 | Transmitting Device |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP7597290B2 (en) |
Families Citing this family (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP7503166B1 (en) | 2023-03-16 | 2024-06-19 | 新コスモス電機株式会社 | COMMUNICATION DEVICE, GAS DETECTION SYSTEM, GAS DETECTOR, COMMUNICATION METHOD, AND CONTROL METHOD |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2006323440A (en) | 2005-05-17 | 2006-11-30 | Mitsubishi Electric Corp | Information collection system |
| JP2010271190A (en) | 2009-05-21 | 2010-12-02 | Mitsubishi Electric Corp | Recording device |
| JP7128084B2 (en) | 2018-10-24 | 2022-08-30 | 積水化学工業株式会社 | roof unit |
-
2021
- 2021-02-04 JP JP2021016242A patent/JP7597290B2/en active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2006323440A (en) | 2005-05-17 | 2006-11-30 | Mitsubishi Electric Corp | Information collection system |
| JP2010271190A (en) | 2009-05-21 | 2010-12-02 | Mitsubishi Electric Corp | Recording device |
| JP7128084B2 (en) | 2018-10-24 | 2022-08-30 | 積水化学工業株式会社 | roof unit |
Also Published As
| Publication number | Publication date |
|---|---|
| JP2022119261A (en) | 2022-08-17 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN107102936B (en) | Fluency evaluation method, mobile terminal and storage medium | |
| CN106161628B (en) | Shooting file uploading method and device | |
| CN108073437B (en) | Application recommendation method and mobile terminal | |
| CN109189300B (en) | View circulation display method and device | |
| JP6701622B2 (en) | Synchronous measurement system | |
| WO2017152355A1 (en) | Display method and terminal device | |
| CN108984066B (en) | Application icon display method and mobile terminal | |
| CN104112156B (en) | System and method for updating electronic shelf label and updating device and method thereof | |
| JP6020092B2 (en) | Data processing apparatus, data processing method, and program | |
| CN110874128B (en) | Visualized data processing method and electronic equipment | |
| CN110377235B (en) | Data processing method and device, mobile terminal and computer readable storage medium | |
| JP7597290B2 (en) | Transmitting Device | |
| US20190243411A1 (en) | Methods for data synchronization between a sensor hub and an application processor and apparatuses using the same | |
| CN107196980B (en) | Method, system and device for controlling page display flow | |
| CN115017003A (en) | Load prediction method and load prediction device | |
| CN105392170A (en) | Information processing method and electronic device | |
| US20150301618A1 (en) | Sub-frame accumulation method and apparatus for keeping reporting errors of an optical navigation sensor consistent across all frame rates | |
| WO2019072179A1 (en) | Application running control method and apparatus | |
| CN110378798B (en) | Heterogeneous social network construction method, group recommendation method, device and equipment | |
| CN110753914A (en) | Information processing method, storage medium and mobile terminal | |
| CN109765850B (en) | Control system | |
| CN113784197B (en) | Video display method, video frame caching method and device | |
| JP2020052441A (en) | Master device, control method, information processing program, and recording medium of master device | |
| WO2017088180A1 (en) | Method, apparatus and device for storing data in queue | |
| CN112418631A (en) | Resource allocation method and device, electronic equipment and storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20240109 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20240523 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20240611 |
|
| A521 | Request for written amendment filed |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20240813 |
|
| TRDD | Decision of grant or rejection written | ||
| A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 Effective date: 20241029 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20241114 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 7597290 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |