(57)【要約】【課題】システム毎にデータフォーマットが異なるデータを一つのサーバ内に取り込んで効率良く活用するデータ活用装置を提供する。【解決手段】複数のデータ発生装置から受信したデータに時間情報を付けて時系列データを生成し、データ発生装置毎に異なるデータフォーマットの時系列データを、参照可能な参照用データに変換するとともに、参照目的に応じた仕分けをして登録先を決定するし、仕分けされた参照用データを登録先に蓄積し、クライアントの要求に応じて蓄積された参照用データの中から要求に合った参照用データを参照し、表示画面を生成して提供する構成とする。【選択図】図１
2015158757.tif 000002
【特許請求の範囲】
【請求項１】
複数のデータ発生装置から受信したデータに時間情報を付けて時系列データを生成する時系列データ生成部、上記データ発生装置毎に異なるデータフォーマットの上記時系列データを、参照可能な参照用データに変換するとともに、参照目的に応じた仕分けをして登録先を決定する時系列データ変換部、仕分けされた上記参照用データを上記登録先に蓄積する参照用データ蓄積部を備えたことを特徴とするデータ活用装置。
【請求項２】
上記参照用データ蓄積部からクライアントの要求に応じた上記参照用データを参照し、表示画面を生成する画面生成部を備えた請求項１記載のデータ活用装置。
【請求項３】
仕分けされた上記参照用データを複数組み合わせて画面表示可能とする参照用データ合成部を備えた請求項２記載のデータ活用装置。
【請求項４】
上記時系列データを蓄積する時系列データ蓄積部を備えた請求項１記載のデータ活用装置。
【請求項５】
上記時系列データ変換部は、上記時系列データの変更に必要となる情報をデータベースに保管したことを特徴とする請求項１記載のデータ活用装置。
【請求項６】
上記参照用データ合成部において生成された、複数の上記参照用データを合成処理して得られた合成データを、データベースへ保管するデータベースエクスポート部を備えたことを特徴とする請求項３記載のデータ活用装置。
【請求項７】
上記参照用データ合成部において生成された、複数の上記参照用データを合成処理して得られた合成データを、ファイルとして出力するファイルエクスポート部と、上記ファイルをクライアントにダウンロードするファイルダウンロード部を備えたことを特徴とする請求項３記載のデータ活用装置。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、ビッグデータを活用するためのデータ活用装置に関するものである。
【背景技術】
【０００２】
近年、ビッグデータと呼ばれる多種多量なデータが世の中にあふれており、それらを有効活用するための開発が行われている。
例えば、大量データの検索時間を短縮するための技術がある（例えば、特許文献１参照）。
【先行技術文献】
【特許文献】
【０００３】
【特許文献１】特開平１１−６６１０２号公報
【発明の概要】
【発明が解決しようとする課題】
【０００４】
しかしながら、特許文献１で処理対象となっているのは、一つのシステム内のデータベースに保管されたデータであり、ビッグデータと呼ばれるような多種多量なデータを対象としたものではなかった。
ビッグデータは、発生するシステム毎にデータフォーマットが異なるなどの問題があるため、一つのサーバ内にビッグデータを取り込み、そのデータを効率良く活用することが難しかった。
【０００５】
本発明は、かかる問題を解決するためになされたものであり、システム毎にデータフォーマットが異なるデータを一つのサーバ内に取り込んで効率良く活用し、クライアントが要求する参照画面を出力するための応答時間短縮が可能となるデータ活用装置を提供することを目的とする。
【課題を解決するための手段】
【０００６】
この発明に係わるデータ活用装置は、複数のデータ発生装置から受信したデータに時間情報を付けて時系列データを生成する時系列データ生成部、上記データ発生装置毎に異なるデータフォーマットの上記時系列データを、参照可能な参照用データに変換するとともに、参照目的に応じた仕分けをして登録先を決定する時系列データ変換部、仕分けされた上記参照用データを上記登録先に蓄積する参照用データ蓄積部を備えたものである。
【発明の効果】
【０００７】
この発明のデータ活用装置によれば、データ発生装置毎に異なるデータフォーマットの時系列データを、参照可能な参照用データに変換するとともに、参照目的に応じて仕分けをして登録するため、参照目的に合った登録先にアクセスすることで、クライアントが要求する画面の出力を短い応答時間で実施することが可能となる。
【図面の簡単な説明】
【０００８】
【図１】本発明の実施の形態１のデータ活用装置の構成図である。
【図２】実施の形態１におけるデータ活用のフローチャートを示す図である。
【図３】実施の形態１のデータ活用装置の詳細な構成図である。
【図４】実施の形態１におけるデータ活用の詳細なフローチャートを示す図である。
【図５】本発明の実施の形態２のデータ活用装置の構成図である。
【図６】実施の形態２におけるデータ活用のフローチャートを示す図である。
【図７】実施の形態２のデータ活用装置の詳細な構成図である。
【図８】実施の形態２におけるデータ活用の詳細なフローチャートを示す図である。
【図９】本発明の実施の形態３のデータ活用装置の詳細な構成図である。
【図１０】本発明の実施の形態４のデータ活用装置の詳細な構成図である。
【図１１】実施の形態４におけるデータ活用のフローチャートを示す図である。
【図１２】本発明の実施の形態５のデータ活用装置の詳細な構成図である。
【図１３】実施の形態５におけるデータ活用のフローチャートを示す図である。
【発明を実施するための形態】
【０００９】
実施の形態１．
従来、システム毎にデータが処理される構成であったため、複数のシステムから異なるデータフォーマットのデータが一つのサーバに蓄積されることはなかった。本発明のデータ活用装置は、複数のシステムから受信した多種多量なデータ（ビッグデータ）を蓄積し、活用するための装置である。このデータ活用装置では、各システムから吸い上げたデータに時間情報を付けて時系列データとし、時間の要素をデータ処理に活かせる構成としている。
【００１０】
そして、このデータ活用装置では、画面表示要求が来る前に、蓄積された大量の時系列データを画面からの参照用データ（参照用時系列データ）に事前に変換しておくことで、画面応答性能を向上させる構成である。また、時系列データに関する情報（データフォーマット等）を定義ファイルとしてプログラムから分離することで、データ種類の増加等のデータ変更に伴うシステムメンテナンスのコストを削減できる構成としている。
【００１１】
以下、本発明の実施の形態１のデータ活用装置について図１から図４を参照して説明する。
図１は、本発明のデータ活用装置のシステム構成を示す図である。データ活用装置の主構成部となるサーバ１０１には、時系列データの発生元となるデータ発生装置１００からデータフォーマットが異なるデータが送られてくる。そして、サーバ１０１では、受信したデータに時間情報を付け、その時系列データを蓄積・活用し、時系列データの画面表示を要求するクライアント１０２に参照画面を提供する構成である。
【００１２】
このサーバ１０１内には、データ発生装置１００からのデータを受信し、そのデータに時間情報を付けて時系列データを生成する時系列データ生成部１０３、時系列データを蓄積する時系列データ蓄積部１０４、時系列データを時系列データ蓄積部１０４から参照し、時系列データを参照用データに変換するとともに参照目的に応じた仕分けをする時系列データ変換部１０５、仕分けされた参照用データを蓄積（登録）する参照用データ蓄積部１０６、参照用データ蓄積部１０６からデータを参照し、クライアント１０２が要求する参照画面を生成する画面生成部１０７が構成要素として含まれている。
【００１３】
なお、データ発生元であるデータ発生装置１００としては、例えば、図１に示すように、車、ＥＴＣ装置、気象サービス、事故管理システム等のシステムがある。上述の例は、交通情報に関するものであったが、他の分野の情報を一つのサーバ１０１に取り込むことが可能であることは言うまでもない。
【００１４】
次に、図２に本発明の実施の形態１によるデータ活用のフローチャートを示し、本発明のデータ活用装置の動作について説明する。大きな動作としては、図２（ａ）に示す時系列データの蓄積、図２（ｂ）に示す時系列データの変換、図２（ｃ）に示す時系列データの参照があり、それぞれは非同期に動作する。
図２（ａ）のフローチャートに示すように、時系列データの蓄積動作では、データ発生装置１００より時系列データが送られて来ると（Ｓ２００（ステップ２００）：時系列データ発生）、サーバ１０１にて、そのデータを受信するとともに、時系列データ生成部１０３にて時間情報を付けて時系列データを生成し、生成された時系列データを時系列データ蓄積部１０４に登録する（Ｓ２０１：時系列データ登録）。
【００１５】
図２（ｂ）のフローチャートに示すように、時系列データの変換動作では、時系列データ蓄積部１０４に登録されたデータを、時系列データ変換部１０５にて参照し（Ｓ２０２：時系列データ参照）、時系列データの変換を行い、参照可能な参照用データとする。その変換後、参照用データを参照目的に応じて仕分けし（Ｓ２０３：時系列データ変換）、参照用データ蓄積部１０６の各登録先に登録する（Ｓ２０４：時系列データ登録）。
【００１６】
図２（ｃ）のフローチャートに示すように、時系列データの参照動作では、クライアント１０２からの画面表示の要求を受け（画面表示要求２０５）、画面生成部１０７にて参照用データ蓄積部１０６に登録された仕分け済みの参照用データを参照し、画面を生成する（画面生成２０６）。その後、生成された参照画面がクライアント１０２に提供され、参照画面が表示される（画面表示２０７）。
【００１７】
次に、図３を用いて時系列データ変換部１０５の内部構成について詳細に説明する。
時系列データ変換部１０５は、図３に示すように、時系列データ参照部１０５ａ、時系列データ解析変換部１０５ｂ、参照用データ登録部１０５ｃの三つの構成に分かれている。
時系列データ蓄積部１０４よりデータ参照する時系列データ参照部１０５ａは、データを参照するデータ参照部３０１と、データ参照部３０１をスケジュール（定周期、時刻指定等）に従って実行するスケジューラ３０２で構成される。
【００１８】
時系列データ参照部１０５ａが取得したデータを参照用データに変換する時系列データ解析変換部１０５ｂは、データを解析するデータ解析部３０３、データを変換するデータ変換部３０５、及び、データ解析に利用するデータフォーマット定義ファイル３０４、データ変換に利用するデータ変換定義ファイル３０６で構成される。
【００１９】
時系列データ解析変換部１０５ｂが変換したデータを参照用データ蓄積部１０６に登録する参照用データ登録部１０５ｃは、データを仕分け（データの登録先決定）した後に登録を行うデータ仕分け登録部３０７、データ仕分けに利用するデータ仕分け定義ファイル３０８で構成される。
【００２０】
以下に、図３を用いて、車のプローブ情報等を用いたモビリティシステムにおけるデータ変換例について説明する。時系列データ蓄積部１０４は、時刻と値の列で構成されており、時刻をキーに様々な値が格納できるデータベースとなっている。ここに、車通過情報（車ID、緯度、経度）、ETC情報（ETC車載器ID、インターチェンジ名、入口／出口区分）、気象情報（地名、気温、降雨量）のような多種多量なデータが一括で保管される。ただし、このままでは、値の意味づけを持っていないために、このデータを検索しても、目的に応じて有効に利用することができない。データ変換においては、データフォーマット定義ファイル３０４とデータ変換定義ファイル３０６の情報によって、データの意味づけが行われ、その結果が参照用データ蓄積部１０６に登録される。
【００２１】
参照用データ蓄積部１０６では、データの意味づけによって、テーブルが分散される。例えば、車通過情報が時系列に集約されたCARテーブル３０９、ETC装置（ETC車載器）毎のインターチェンジ入出情報が時系列に集約されたETCテーブル３１０、気象情報が時系列に集約されたWEATHERテーブル３１１等である。これにより、参照目的に合わせてデータ処理対象をテーブル単位に絞り込むことができ、データの参照が容易となる。
【００２２】
次に、図４にデータ活用の詳細なフローチャートを示し、時系列データ変換部１０５によるデータ変換の動作について説明する。まず、定周期や時刻指定等のスケジュールに従って動作が実行され（Ｓ４００：スケジュール実行）、データの読み込み処理がなされる（Ｓ４０１：データ読み込み）。このデータ読み込みステップ（Ｓ４０１）では、以前に読み込みを終えた分を記憶しており、まだ読み込みを終えていないデータを読み込む。データフォーマット定義ファイル３０４、データ変換定義ファイル３０６、データ仕分け定義ファイル３０８を読み込み、メモリ上に記憶する（Ｓ４０２：定義情報読み込み）。次に、未処理データの有無を判断し（Ｓ４０３：未処理データ）、読み込んだデータを処理し終え未処理データ無しであればこの動作は終了となる。
【００２３】
未処理データ有無判定のステップ（Ｓ４０３）において、未処理データ有りと判定された場合は、次の動作が繰り返される。まず、データフォーマット定義ファイル３０４の情報を元に、データ解析が行われる（Ｓ４０４：データ解析）。このデータ解析のステップ（Ｓ４０４）では、時系列データの値とデータフォーマット定義ファイル３０４の情報を比較し、情報種類を判定する。次にデータの変換が行われ（Ｓ４０５：データ変換）、このデータ変換のステップ（Ｓ４０５）では、先に判定した情報種類とデータ変換定義ファイル３０６の情報を比較し、時系列データの値の意味づけを行う。最後に、データ仕分け定義ファイル３０８の情報を元に、先の情報種類を用いて、データ登録先を決定（仕分け）し、参照用データ蓄積部１０６に登録をする（Ｓ４０６：データ仕分け登録）。
【００２４】
このように、発明のデータ活用装置によれば、データ発生装置１００毎に異なるデータフォーマットのデータを時系列データとした上で、参照可能な参照用データに変換するとともに、参照目的に応じた仕分けをして登録する構成である。
エンドユーザにとっては、データの検索時間だけでなく、実際に画面に表示されるまでの応答時間短縮が重要であるが、本発明のデータ活用装置では、参照目的に応じて仕分けされた参照用データにアクセスする構成であり、クライアント１０２からの画面表示要求があった場合、参照目的に合った登録先（テーブル）にアクセスすることで、クライアント１０２が要求する画面の出力を短い応答時間で実施することが可能となる。従って、サーバ１０１内に蓄積された全てのデータにアクセスする必要がないため、エンドユーザへの画面応答性能を向上させることが可能である。
また、システム開発者にとっては、データフォーマット等のデータに関する情報を定義ファイルとしてプログラムから分離できるため、データ種類の増加に伴うシステムメンテナンスを容易とすることが可能である。
【００２５】
実施の形態２．
以下、本発明の実施の形態２のデータ活用装置について図５から図８を参照して説明する。本発明の実施の形態２では、参照用データを画面に表示する際に、複数のデータを合成することにより、データ間の相対関係や傾向の比較を容易とする構成について説明する。図５は実施の形態２のデータ活用装置の構成図であり、上述の実施の形態１の図１で示した構成に、参照用データ合成部５００が加わった構成であり、参照用データ蓄積部１０６と画面生成部１０７の間に参照用データ合成部５００が追加されている。
【００２６】
図６に実施の形態２の時系列データのデータ活用（参照動作）のフローチャートを示し、その動作について説明する。なお、時系列データの蓄積動作、時系列データの変換動作は、上述の実施の形態１と同様である。時系列データの参照動作では、図６に示すように、クライアント１０２からの画面表示要求があると（Ｓ２０５：画面表示要求）、どの時系列データを合成したいかという要求内容が分かる。その要求に従い、参照用データ蓄積部１０６より、複数の時系列データを参照し、参照用データの合成が行われる（Ｓ６０１：参照用データ合成）。合成したデータを、画面部品に組み込んで画面を生成し（Ｓ６０２：画面生成）、クライアント１０２に合成画面を提供し、画面表示がなされる（Ｓ２０７：画面表示）。
【００２７】
図７にて、実施の形態２によるデータ活用装置の内部構成について詳細に説明する。参照用データ合成部５００は、参照用データ蓄積部１０６にある仕分けされた複数の時系列データ（CARテーブル３０９、ETCテーブル３１０、WEATHERテーブル３１１）から、複数のデータを取得し、同一時刻のデータを合わせるように合成して合成ファイル５０１を生成し、合成データを画面部品７０３に組み込み、クライアント１０２に提供する合成画面７０４を生成する画面部品組み込み部７０２で構成する。
【００２８】
なお、同一時刻によるデータの合成においては、時間に幅（合成用時間幅）をもたせる。例えば、”２０１３年１１月１０日１２時０１分”、”２０１３年１１月１０日１２時０３分”、”２０１３年１１月１０日１２時０８分”のデータが存在し、合成用時間幅を５分と設定した場合、最初の２つのデータは”２０１３年１１月１０日１２時００分”、３つ目のデータは”２０１３年１１月１０日１２時０５分”のデータと認識される。これにより、最初の２つのデータを同一時刻のデータとして合成でき、時刻がずれている場合でも、ユーザが分析したい時間単位でのデータ比較が可能となる。
【００２９】
以下に、図７を用いて車のプローブ情報等を用いたモビリティシステムにおけるデータ合成例を説明する。参照用データ蓄積部１０６には、車通過情報（CARテーブル３０９）、ETC情報（ETCテーブル３１０）、天気情報（WEATHERテーブル３１１）が蓄積されている。クライアント１０２からの情報合成要求によって、合成対象を決定するが、例えば、車通過情報と天気情報の合成要求がきた場合、車の列と地名の列を同じ時刻で合成した情報を生成する。これによって、車の台数（車交通量）と、車の通過した地点の天気情報が合成された情報（合成ファイル５０１）を得ることが可能となる。この合成情報を画面部品７０３の折れ線グラフによって表示することで、クライアント１０２は合成画面７０４上にて合成ファイル５０１の情報を確認することができる。
【００３０】
次に、図８に実施の形態２におけるデータ活用の詳細なフローチャートを示して説明する。まず、クライアント１０２から表示期間、合成対象情報、グラフ（画面部品）種別の要求が来（Ｓ８００：画面表示要求）、この要求を解析する（Ｓ８０１：要求解析８０１）。図６のＳ２０５に相当。
次に、合成対象となる時系列データを参照用データ蓄積部１０６から取得する（Ｓ８０２：参照用データ読み込み）。その後、同じ時刻で合わせるようにデータ合成を行う（Ｓ８０３：データ合成）。図６のＳ６０１に相当。
データ合成が完了したら、画面表示要求８００からきた画面部品種別に従い、画面部品を読み込み（Ｓ８０４：画面部品読み込み）、画面部品に合成データを組み込む（Ｓ８０５：データ組み込み）。図６のＳ６０２に相当。
次に、完成した合成画面７０４をクライアント１０２に提供する（Ｓ８０６：画面表示）。
このように、時系列データよりなる複数の参照用データを一つのグラフに合成して表示することで、複数のデータの相対関係や傾向の比較がしやすくなるという効果が得られる。
【００３１】
実施の形態３．
本発明の実施の形態３によるデータ活用装置は、図９にその構成図を示すように、上述の実施の形態１とは、時系列データ変換部１０５を構成する時系列データ解析変換部１０５ｂの内部構成が異なっている。実施の形態１では、図３に示したように、時系列データ解析変換部１０５ｂのデータフォーマットやデータ変換定義等の各種定義情報をファイルに保管していたが、この実施の形態３によるデータ活用装置では、図９に示すように、ファイルではなく、データベースにて保管している。
【００３２】
時系列データ解析変換部１０５ｂが、データフォーマット定義ＤＢ（データベース）９００、データ変換定義ＤＢ９０１、データ仕分け定義ＤＢ９０２を備えることによって、定義情報のメンテナンス（追加、変更、削除）時におけるデータ整合性確保をデータベース機能に任せることができ、メンテナンス用のアプリケーション開発が容易となる。
【００３３】
実施の形態４．
図１０は、本発明の実施の形態４のデータ活用装置の詳細な構成図であり、図１１はデータ活用のフローチャートを示す図である。上述した実施の形態２では、図７に示したように、合成したデータを合成ファイル５０１としてメモリ上に記憶していたが、この実施の形態４では、合成したデータを、合成情報ＤＢ１００１（データベース）に保管することで、合成した情報を他システム等で利用可能としたことを特徴としている。
【００３４】
図１０に示すように、この実施の形態４のサーバ１０１内の構成は、実施の形態２で示した構成に加え、参照用データ合成部５００の合成データをエクスポートするデータベースエクスポート部１０００と、エクスポートされた合成データを格納する合成情報ＤＢ１００１を備えている。
【００３５】
次に、図１１に実施の形態４におけるデータ活用のフローチャートを示し、データエクスポートの動作について説明する。実施の形態２の図８で示した動作に加え、データ合成のステップ（Ｓ８０３）の後に、合成情報ＤＢ１００１へのエクスポート（登録）処理が行われる（Ｓ１１００：データエクスポート）。
このように、合成した情報をデータベースへ保管する構成とすることで、他システムでの情報利用が可能となり、データを有効利用することができる。
【００３６】
実施の形態５．
図１２は、本発明の実施の形態５のデータ活用装置の詳細な構成図であり、図１３はデータ活用のフローチャートを示す図である。実施の形態５のデータ活用装置は、実施の形態４と異なり、合成したデータをデータベースに保管するのではなく、クライアント１０２側にファイル出力できる構成である。システム利用者であるクライアント１０２は、ファイル出力された情報をダウンロードして利用することが可能である。
【００３７】
図１２に示すように、この実施の形態５のサーバ１０１内の構成は、実施の形態２で示した構成に加え、参照用データ合成部５００の合成データをエクスポートするファイルエクスポート部１２００と、ファイルエクスポート部１２００から出力された合成データを保管する合成情報ファイル１２０１と、合成情報ファイル１２０１内の合成データをクライアント１０２側にダウンロードするファイルダウンロード部１２０２を備えたものである。
【００３８】
次に、図１３に実施の形態５におけるデータ活用のフローチャートを示し、ファイルエクスポートの動作について説明する。実施の形態２の図８で示した動作と共通のステップが多いが、画面表示要求（Ｓ１３００）には、ファイルエクスポート要求が含まれており、また、その要求を解析するステップ（Ｓ１３０１：要求解析）が加えられており、データ合成のステップ（Ｓ８０３）の後に、合成データのファイルへのエクスポート処理のステップ（Ｓ１３０２：ファイルエクスポート）、クライアント１０２へのダウンロード処理のステップ（Ｓ１３０３：ファイルダウンロード）が加えられている。
このように、合成した情報をクライアント１０２がダウンロードできる構成としたことで、システム利用者によるデータ利用が可能となり、データを有効利用することができ、エンドユーザへのサービス向上が可能となる。
【００３９】
なお、本発明は、その発明の範囲内において、各実施の形態を自由に組み合わせたり、各実施の形態を適宜、変形、省略することが可能である。
【符号の説明】
【００４０】
１００  データ発生装置、１０１  サーバ、１０２  クライアント、１０３  時系列データ生成部、１０４  時系列データ蓄積部、１０５  時系列データ変換部、１０５ａ  時系列データ参照部、１０５ｂ  時系列データ解析変換部、１０５ｃ  参照用データ登録部、１０６  参照用データ蓄積部、１０７  画面生成部、３０１  データ参照部、３０２  スケジューラ、３０３  データ解析部、３０４  データフォーマット定義ファイル、３０５  データ変換部、３０６  データ変換定義ファイル、３０７  データ仕分け登録部、３０８  データ仕分け定義ファイル、３０９  CARテーブル、３１０  ETCテーブル、３１１  WEATHERテーブル、５００  参照用データ合成部、５０１  合成ファイル、７０２  画面部品組み込み部、７０３  画面部品、７０４  合成画面、９００  データフォーマット定義ＤＢ、９０１  データ変換定義ＤＢ、９０２  データ仕分け定義ＤＢ、１０００  データベースエクスポート部、１００１  合成情報ＤＢ、１２００  ファイルエクスポート部、１２０１  合成情報ファイル、１２０２  ファイルダウンロード部。    
【図１】
2015158757.tif 000003
【図２】
2015158757.tif 000004
【図３】
2015158757.tif 000005
【図４】
2015158757.tif 000006
【図５】
2015158757.tif 000007
【図６】
2015158757.tif 000008
【図７】
2015158757.tif 000009
【図８】
2015158757.tif 000010
【図９】
2015158757.tif 000011
【図１０】
2015158757.tif 000012
【図１１】
2015158757.tif 000013
【図１２】
2015158757.tif 000014
【図１３】
2015158757.tif 000015