(57)【特許請求の範囲】
【請求項１】
非同期多重のデータセットを受信して同期化し、データセットの受信から該データセットの統合までをリアルタイムで行うリアルタイムデータ多重受け付け装置であって、
データセットの受信状態と受信したデータセットの統合状態とを可視化してそれぞれ表示するインジケータと、
システムの運用を停止することなく、受信タイミングと統合タイミングとを自動及び手動で任意に調整できる調整手段と、
非同期で発生するデータセットを受信する複数のデータ受信手段と、
前記複数のデータ受信手段にデータセットが受信されたとき、タイムスタンプに着目して、各々のデータ受信手段に対応してデータセットを格納する複数の待ち合わせバッファと、該複数の待ち合わせバッファにデータセットが格納されたときにオン状態にして、データセットの受信状態を監視する複数のインジケータとを有するデータ待ち合わせ手続き手段と、
データセットを統合するとき、前記複数のデータ受信手段で受信されたデータセットに対応する全てのインジケータがオンのときのみオンして、データセットの受信状態と統合状態とを監視する統合インジケータと、データセットの受信から統合までの時間を動的に可変するタイマとを有するデータ統合手続き手段とを備えたことを特徴とするリアルタイムデータ多重受け付け装置。
【請求項２】
前記データ統合手続き手段から、前記タイマが所定時間をカウントする毎に、データセットを受信して業務処理を行う業務処理手段をさらに有することを特徴とする請求項１に記載のリアルタイムデータ多重受け付け装置。
【請求項３】
前記データ待ち合わせ手続き手段のインジケータの監視状況、及び前記データ統合手続き手段の統合インジケータの監視状況を、前記タイマが所定時間をカウントする毎に、サイクリックで再表示するインジケータ表示部と、前記複数のデータ受信部の何れかにデータセットの欠測があることを検出したとき、外部に警報通知を行うアラーム表示部とを有するオペレータ報知手段をさらに有することを特徴とする請求項１または２に記載のリアルタイムデータ多重受け付け装置。
【請求項４】
前記タイマは、
データセットの受信から統合までの時間をサイクリックでカウントする統合間隔タイマと、
現時点でのタイムスタンプの時刻とシステム時刻との時間差をカウントする待ち合わせ時間差タイマと、
前記時間差を変更する待ち合わせ時間差変更用タイマと、
前記待ち合わせ時間差タイマと前記待ち合わせ時間差変更用タイマとの間に所定の時間ずれが発生したとき、前記統合間隔タイマの時間を増減させるアジャスト用タイマとを有することを特徴とする請求項１ないし３のいずれかに記載のリアルタイムデータ多重受け付け装置。
【請求項５】
非同期多重のデータセットを受信して同期化し、データセットの受信から該データセットの統合までをリアルタイムで行うリアルタイムデータ多重受け付け方法であって、
データセットの受信状態と受信したデータセットの統合状態とを可視化してそれぞれを表示し、システムの運用を停止することなく、受信タイミングと統合タイミングとを自動及び手動で任意に調整する過程と、
非同期で発生するデータセットを複数のデータ受信手段によって受信する過程と、
前記複数のデータ受信手段にデータセットが受信されたとき、タイムスタンプに着目して、各々のデータ受信手段に対応してデータセットを複数の待ち合わせバッファに格納するとともに、バッファにデータセットが格納されたときにオン状態にして、データセットの受信状態を複数のインジケータによって監視するデータ待ち合わせ手続き過程と、
データセットを統合するとき、前記複数のデータ受信手段で受信されたデータセットに対応する全てのインジケータがオンのときのみオンして、データセットの受信状態と統合状態とを監視するとともに、データセットの受信から統合までの時間を動的に可変するデータ統合手続き過程とを備えたことを特徴とするリアルタイムデータ多重受け付け方法。
【請求項６】
前記データセットの受信から統合までの所定時間をカウントする毎に、データセットを受信して業務処理を行う業務処理過程と、
前記データ待ち合わせ手続き過程におけるインジケータの監視状況、及び前記データ統合手続き過程の監視状況を、前記所定時間をカウントする毎に、サイクリックで再表示するとともに、前記複数のデータ受信部の何れかにデータセットの欠測があることを検出したとき、外部に警報通知を行うアラーム表示するオペレータ報知過程とをさらに有することを特徴とする請求項５に記載のリアルタイムデータ多重受け付け方法。
【請求項７】
非同期多重のデータセットを受信して同期化し、データセットの受信から該データセットの統合までをリアルタイムで行うリアルタイムデータ多重受け付けプログラムであって、
データセットの受信状態と受信したデータセットの統合状態とを可視化してそれぞれを表示し、システムの運用を停止することなく、受信タイミングと統合タイミングとを自動及び手動で任意に調整可能とするステップと、
非同期で発生するデータセットを複数のデータ受信手段によって受信するステップと、
前記複数のデータ受信手段にデータセットが受信されたとき、タイムスタンプに着目して、各々のデータ受信手段に対応してデータセットを複数の待ち合わせバッファに格納するとともに、バッファにデータセットが格納されたときにオン状態にして、データセットの受信状態を複数のインジケータによって監視可能とするデータ待ち合わせ手続きステップと、
データセットを統合するとき、前記複数のデータ受信手段で受信されたデータセットに対応する全てのインジケータがオンのときのみオンして、データセットの受信状態と統合状態とを監視可能とするとともに、データセットの受信から統合までの時間を動的に可変するデータ統合手続きステップとを備えたことを特徴とするリアルタイムデータ多重受け付けプログラム。
【請求項８】
前記データセットの受信から統合までの所定時間をカウントする毎に、データセットを受信して業務処理を行う業務処理ステップと、
前記データ待ち合わせ手続きステップにおけるインジケータの監視状況、及び前記データ統合手続き過程の監視状況を、前記所定時間をカウントする毎に、サイクリックで再表示するとともに、前記複数のデータ受信部の何れかにデータセットの欠測があることを検出したとき、外部に警報通知を行うアラーム表示するオペレータ報知ステップとをさらに有することを特徴とする請求項７に記載のリアルタイムデータ多重受け付けプログラム。
【発明の詳細な説明】
【０００１】
【発明の属する技術分野】
本発明は、リアルタイムデータ受信システムに用いられるリアルタイムデータ多重受け付け装置、その方法、およびプログラムに関し、特に、非同期多重データストリームからのデータを、リアルタイム性よく、且つ効果的に受信してデータ統合を行うリアルタイムデータ多重受け付け装置、その方法、およびプログラムに関するものである。
【０００２】
【従来の技術】
従来、特開平11-168454号公報などに、非同期多重データストリームから受信したデータを同期化する技術が開示されている。この技術によれば、別々にクロック制御した複数の非同期ソースの間において、非同期多重データストリームから共通のデータ速度の出力ストリームを作成することにより、非同期多重データストリームから受信するデータをデジタル的に同期化させている。これによって、各入力ソースからの、適当な順序で並べられた非同期多重データを、同期データストリームとして出力することができる。
また、特開平10-283199号公報などには、複数のメディアストリームのサンプルがタイムスタンプを持ち、マスタクロックに対応するサンプルを処理することによって、複数のデータストリーム間の処理を同期化し、処理レートの調整を容易に行うようにした技術が開示されている。
【０００３】
【発明が解決しようとする課題】
しかしながら、上記従来の多重データ受信技術においては、データの受信状況やデータの統合状況が可視化されていないため、オペレータにおいて、現在のデータ受信からデータ統合までの時間が長すぎるのか、あるいは、ぎりぎりなのかがわからなかったり、または、どこからのデータが受信や統合のネックになっているのかなどがわからないことがある。また、データ受信からデータ統合までの時間を変更することが、リアルタイムデータ受信システム全体に影響を与えることになるため、データ受信からデータ統合までの時間の調整にも多大な作業工数が必要となるなどの使い勝手の悪さがある。
【０００４】
本発明はこのような事情に鑑みてなされたものであり、その目的は、データの受信からデータ統合までのデータの流れを可視化し、データ受信からデータ統合までの時間を、運用を停止することなく、容易且つ簡単に変更できるようにしたリアルタイムデータ多重受け付け装置を提供することにある。
【０００５】
【課題を解決するための手段】
上記の課題を解決するために、本発明のリアルタイムデータ多重受け付け装置は、非同期多重のデータセットを受信して同期化し、データセットの受信からこのデータセットの統合までをリアルタイムで行うリアルタイムデータ多重受け付け装置であって、データセットの受信状態と受信したデータセットの統合状態とを可視化し、システムの運用を停止することなく、受信タイミングと統合タイミングとを自動及び手動で任意に調整できるようにしたことを特徴とする。
【０００６】
すなわち、本発明のリアルタイムデータ多重受け付け装置よれば、非同期で受信したデータセットの到着状態をインジケータなどで示すことにより、より欠測が少なく、よりリアルタイム性を確保しながら、データを受信することができる。さらに、このリアルタイムデータを統合するまでの待ち合わせ時間を、リアルタイムに、且つ任意に変更することができるので、リアルタイムデータをより早く、より正確に統合することができる。
【０００７】
また、上記発明のリアルタイムデータ多重受け付け装置の具体的な構成は、非同期で発生するデータセットを受信する複数のデータ受信手段と、複数のデータ受信手段にデータセットが受信されたとき、タイムスタンプに着目して、各々のデータ受信手段に対応してデータセットを格納する複数の待ち合わせバッファ、及びこの複数の待ち合わせバッファにデータセットが格納されたときにオン状態にして、データセットの受信状態を監視する複数のインジケータを有するデータ待ち合わせ手続き手段と、データセットを統合するとき、複数のデータ受信手段で受信されたデータセットに対応する全てのインジケータがオンのときのみオンして、データセットの受信状態と統合状態とを監視する統合インジケータ、及びデータセットの受信から統合までの時間を動的に可変するタイマを有するデータ統合手続き手段と、データ統合手続き手段から、タイマが所定時間をカウントする毎に、データセットを受信して業務処理を行う業務処理手段と、データ待ち合わせ手続き手段のインジケータの監視状況、並びにデータ統合手続き手段の統合インジケータの監視状況を、タイマが所定時間をカウントする毎に、サイクリックに再表示するインジケータ表示部、及び複数のデータ受信部の何れかにデータセットの欠測があることを検出したとき、外部に警報通知を行うアラーム表示部を有するオペレータ報知手段とを備えたことを特徴とする。
【０００８】
さらに、本発明のリアルタイムデータ多重受け付け装置は、上記発明の構成において、前記タイマは、データセットの受信から統合までの時間をサイクリックでカウントする統合間隔タイマと、現時点でのタイムスタンプの時刻とシステム時刻との時間差をカウントする待ち合わせ時間差タイマと、前記時間差を変更する待ち合わせ時間差変更用タイマと、前記待ち合わせ時間差タイマと前記待ち合わせ時間差変更用タイマとの間に所定の時間ずれが発生したとき、前記統合間隔タイマの時間を増減させるアジャスト用タイマとを有することを特徴とする。
また本発明は、上記発明の装置にて実行されるリアルタイムデータ多重受け付け方法、および、リアルタイムデータ多重受け付け装置を実現すべくコンピュータにおいて実行される処理プログラムを特徴とする。
【０００９】
【発明の実施の形態】
以下、図面を用いて、本発明におけるリアルタイムデータ多重受け付け装置の実施の形態について説明する。図１は、本発明におけるリアルタイムデータ多重受け付け装置の一実施の形態を示す構成図である。
【００１０】
同図において、リアルタイムデータ多重受け付け装置は、複数のデータ受信部１，２，３と、データ待ち合わせ手続き部４と、データ統合手続き部７と、業務処理部１３と、オペレータ報知部１４とによって構成されている。データ受信部１、データ受信部２、及びデータ受信部３は、それぞれ、非同期で発生するデータセットが受信される受信口を表している。
【００１１】
また、データ待ち合わせ手続き部４は、待ち合わせバッファ５とインジケータ６とによって構成されている。待ち合わせバッファ５とインジケータ６はサイクリックで使用され、これらはデータ受信部１，２，３毎に個別に存在する。すなわち、データ受信部１，２，３にデータが受信されると、タイムスタンプに着目して、データセットが、それぞれのデータ受信部１，２，３に対応する待ち合わせバッファ５にセットされ、同時にインジケータ６がオンにされる。尚、インジケータ６の初期値はオフの状態である。
【００１２】
データ統合手続き部７は、統合インジケータ８と、待ち合わせ時間差タイマ９と、統合間隔タイマ１０と、アジャスト用タイマ１１と、待ち合わせ時間差変更用タイマ１２とによって構成されている。統合インジケータ８はサイクリックに使用され、データ統合時に、全てのデータ受信部１，２，３のインジケータ６がオンだった場合にオンし、それ以外はオフとする。したがって、この統合インジケータ８がオフであることは、どこかのデータ受信部でデータが欠測したことを表している。
【００１３】
タイマは、通常、統合間隔タイマ１０のみが使用される。この実施の形態では、このタイマ値は１であり、すなわち、１秒毎にデータの統合が行われる。
また、待ち合わせ時間差タイマ９は、現時点でのタイムスタンプの時刻とシステム時刻の時間差を示している。この時間差を変更する際には、待ち合わせ時間差変更用タイマ１２を変更する。待ち合わせ時間差タイマ９と待ち合わせ時間差変更用タイマ１２の間に、ある程度以上の時間ずれが発生すると、統合間隔タイマ１０はアジャスト用タイマ１１の範囲内で増減される。
【００１４】
業務処理部１３は、データ統合手続き部７から統合間隔タイマ１０毎にデータを受け取って業務処理を行う部分である。
また、オペレータ報知部１４は、インジケータ表示部１５とアラーム報知部１６とからなり、インジケータ表示部１５は、データ待ち合わせ手続き部４のインジケータ６と、データ統合手続き部７の統合インジケータ８とを、サイクリックに統合間隔タイマ１０毎に再表示する。また、アラーム報知部１６はデータ統合手続き部７において欠測を検出した時に起動される。
尚、図１のデータ受信部１〜３とインジケータ表示部１５とアラーム報知部１６は、当業者にとってよく知られており、また本発明とは直接関係しないので、その詳細な説明は省略する。
【００１５】
次に、図１に示すリアルタイムデータ多重受け付け装置の動作を説明する。先ず、リアルタイムデータがデータ受信部１，２，３に受信されると、受信されたデータはデータ待ち合わせ手続き部４に引き渡され、データ中のタイムスタンプとデータ受信部の番号とによって定められた待ち合わせバッファ５にセットされる。一方、データ統合手続き部７は、データ受信部１，２，３及びデータ待ち合わせ手続き部４とは非同期で動作し、起動毎に、待ち合わせバッファ５の同一タイムスタンプのデータを一組づつ統合して業務処理部１３に引き渡す。
【００１６】
次に、データの受信、統合の状況をインジケータ６により視覚化する機能は以下のように動作する。データ待ち合わせ手続き部４は、待ち合わせバッファ５へのデータセット時に、インジケータ６も合わせてONにする。尚、インジケータ６はリアルタイムデータの受信状況が把握できるインジケータである。
【００１７】
データ統合手続き部７は、サイクリック起動時に、リアルタイムデータが正しく統合できれば統合インジケータ８をオンにし、欠測があればオフにする。統合インジケータ８は、いま統合データが欠測したかどうかを把握できるインジケータである。尚、欠測が発生するとオペレータ報知部１４のアラーム報知部１６によってオペレータに通知される。
【００１８】
また、データの受信から統合までの時間を動的に変更する機能は以下のように動作する。先ず、データ統合手続き部７は、通常、統合間隔タイマ１０毎に動作する。例えば、この実施の形態においては、統合間隔タイマ１０のタイマ値は１秒になる。したがって、何も変化が無ければ、データ統合手続き部は１秒毎に起動されることになる。
【００１９】
待ち合わせ時間差タイマ９は、データのタイムスタンプと現在時刻との時間差の実測値を表示している。すなわち、この数値は、インジケータ６と統合インジケータ８の時間差を正確な数値で示すものである。また、待ち合わせ時間差変更用タイマ１２は、データのタイムスタンプと現在時刻との時間差の適正値を表している。すなわち、この数値のみが、唯一、オペレータによって変更される数値である。
【００２０】
また、待ち合わせ時間差タイマ９は、待ち合わせ時間差変更用タイマ１２と常に等しくなろうとする。具体的には、データ統合手続き部７の待ち合わせ時間差タイマ９と待ち合わせ時間差変更用タイマ１２の差の絶対値がアジャスト用タイマ１１を超えていることが検出されると、次回のデータ統合手続き部７の起動間隔をアジャスト用タイマ１１の分だけ増減させることにより、待ち合わせ時間差タイマ９と待ち合わせ時間差変更用タイマ１２の２つのタイマの差を一定に保とうとする。
【００２１】
以上述べた実施の形態は本発明を説明するための一例であり、本発明は、上記の実施の形態に限定されるものではなく、発明の要旨の範囲で種々の変形が可能である。例えば、上記の実施の形態では、データ受信部は３個設けてあるが、これに限ることはなく、複数であればよく、２個以上幾つであっても同じである。さらに、各データ受信部に受信されるデータセットは、この実施の形態では、１秒毎に受信される想定としたが、タイムスタンプさえ付与されていれば、例えば、１０秒おきであっても、全くの非同期であっても、その仕組みは上記の実施の形態と全く変わらない。
【００２２】
【発明の効果】
以上説明したように、本発明のリアルタイムデータ多重受け付け装置によれば、データの受信状況や統合状況をインジケータ表示しているので、データの取り込み状況や欠測の状況を、オペレータはリアルタイムで認識することができる。また、データ待ち合わせ手続き部のインジケータとデータ統合手続き部の統合インジケータの同時表示により、データ受信から統合までの時間の余裕度が目視できるため、データ受信からデータ統合までの時間をより正確に判定することができる。さらに、データ統合手続き部に設けられたタイマのコントロールにより、運用者が所望するデータ受信からデータ統合までの時間を、システムを停止することなく任意に変更することができる。
【００２３】
また、データ統合手続き部に設けられたタイマのコントロールにより、運用者が所望するデータ受信からデータ統合までの時間が、システムが長期運用を継続することにより発生する時刻的な誤差に影響されずに保たれる。さらに、データ受信からデータ統合までの時間の自由度が向上したことにより、システム評価時には余裕のある時間を設定し、運用開始に向けて設定を本番モードに上げていくことができ、システム構築の効率化が期待される。
【図面の簡単な説明】
【図１】  本発明におけるリアルタイムデータ多重受け付け装置の一実施の形態を示す構成図である。
【符号の説明】
１，２，３  データ受信部
４  データ待ち合わせ手続き部
５  待ち合わせバッファ
６  インジケータ
７  データ統合手続き部
８  統合インジケータ
９  待ち合わせ時間差タイマ
１０  統合間隔タイマ
１１  アジャスト用タイマ
１２  待ち合わせ時間差変更用タイマ
１３  業務処理部
１４  オペレータ報知部
１５  インジケータ表示部
１６  アラーム報知部
【図１】
0003654150.tif 000002