(57)【要約】  逐次発生データ解析装置は、解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御手段を備えたことを特徴とする。逐次発生データ解析システムは、逐次発生するデータである逐次発生データを発生するデータ発生装置と、前記データ発生手段が発生する前記逐次発生データの解析処理を実行する逐次発生データ解析装置と、前記逐次発生データ解析装置の解析結果に基づいて、データ解析サービスを提供する処理を実行するサービス提供装置とを備え、前記逐次発生データ解析装置は、解析要求よりも前に、前記逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御手段を含むことを特徴とする。
2010131425.tif 000002
【特許請求の範囲】
【請求項１】
解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御手段を備えた
ことを特徴とする逐次発生データ解析装置。
【請求項２】
解析要求が発生したときに、解析対象の逐次発生データが既に事前解析制御手段による制御によって事前解析されているか否かを判定する解析方法判定手段を備え、
前記解析方法判定手段は、
事前解析されていないと判定すると、前記解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力し、
既に事前解析されていると判定すると、前記既に事前解析されている解析結果を出力する
請求項１記載の逐次発生データ解析装置。
【請求項３】
事前解析制御手段による制御によって事前解析された事前解析結果を記憶する事前解析結果記憶手段を備え、
解析方法判定手段は、解析要求が発生したときに、解析対象の逐次発生データに対応する事前解析結果が前記事前解析結果記憶手段に記憶されているか否かを判定することによって、前記解析対象の逐次発生データが既に事前解析されているか否かを判定する
請求項２記載の逐次発生データ解析装置。
【請求項４】
事前解析制御手段は、予め設定された、事前解析する対象とする条件を示す前記事前解析条件に基づいて、事前解析対象とする逐次発生データを判断し、当該逐次発生データを事前解析する処理を実行させる制御を行う
請求項１から請求項３のうちのいずれか１項に記載の逐次発生データ解析装置。
【請求項５】
事前解析制御手段は、
逐次発生データの発生状況を監視する逐次発生データ監視手段と、
前記逐次発生データ監視手段の監視結果と、事前解析条件設定手段によって設定された事前解析条件とに基づいて、優先して事前解析の対象とすべき逐次発生データを特定する事前解析対象特定手段と、
前記事前解析対象特定手段が特定した事前解析対象の逐次発生データの解析を実行させる制御を行う事前解析実行制御手段と、
前記事前解析実行制御手段の制御により実行された事前解析の解析結果を、事前解析結果を記憶する事前解析結果記憶手段に記憶させる事前解析結果登録手段とを含む
請求項１から請求項４のうちのいずれか１項に記載の逐次発生データ解析装置。
【請求項６】
解析要求の履歴情報を記憶する解析要求履歴記憶手段を備え、
事前解析制御手段は、前記解析要求履歴記憶手段が記憶する履歴情報に基づいて、出現頻度が高い解析要求に対応する逐次発生データを優先して事前解析対象とするように、事前解析対象とする逐次発生データの優先度を判定する出現頻度優先事前解析判定手段を含む
請求項１から請求項５のうちのいずれか１項に記載の逐次発生データ解析装置。
【請求項７】
逐次発生データの解析にかかった解析コストを監視する解析コスト監視手段を備え、
事前解析制御手段は、前記解析コスト監視手段の監視結果に基づいて、事前解析対象とする逐次発生データの優先度を判定する解析コスト優先事前解析判定手段を含む
請求項１から請求項６のうちのいずれか１項に記載の逐次発生データ解析装置。
【請求項８】
解析コスト監視手段は、
逐次発生データの解析を開始した時間である開始時間を一時記憶し、前記逐次発生データの解析を終了したときに、当該解析を終了した時間である終了時間と、一時記憶した前記開始時間とに基づいて、解析コストを算出する解析コスト算出手段と、
前記解析コスト算出手段の算出結果を記憶する解析コスト記憶手段とを含む
請求項７記載の逐次発生データ解析装置。
【請求項９】
逐次発生データの解析処理に用いる情報処理装置のリソースの空き容量を監視するリソース監視手段を備え、
事前解析制御手段は、前記リソース監視手段の監視結果に基づいて、事前解析する対象とする逐次発生データを絞り込む
請求項１から請求項８のうちのいずれか１項に記載の逐次発生データ解析装置。
【請求項１０】
逐次発生するデータである逐次発生データを発生するデータ発生装置と、
前記データ発生手段が発生する前記逐次発生データの解析処理を実行する逐次発生データ解析装置と、
前記逐次発生データ解析装置の解析結果に基づいて、データ解析サービスを提供する処理を実行するサービス提供装置とを備え、
前記逐次発生データ解析装置は、解析要求よりも前に、前記逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御手段を含む
ことを特徴とする逐次発生データ解析システム。
【請求項１１】
逐次発生データ解析装置は、解析要求が発生したときに、解析対象の逐次発生データが既に事前解析制御手段による制御によって事前解析されているか否かを判定する解析方法判定手段を含み、
前記解析方法判定手段は、
事前解析されていないと判定すると、前記解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力し、
既に事前解析されていると判定すると、前記既に事前解析されている解析結果を出力する
請求項１０記載の逐次発生データ解析システム。
【請求項１２】
解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御ステップを含む
ことを特徴とする逐次発生データ解析方法。
【請求項１３】
解析要求が発生したときに、解析対象の逐次発生データが既に事前解析されているか否かを判定する解析方法判定ステップを含み、
前記解析方法判定ステップにおいて、
事前解析されていないと判定すると、前記解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力し、
既に事前解析されていると判定すると、前記既に事前解析されている解析結果を出力する
請求項１２記載の逐次発生データ解析方法。
【請求項１４】
コンピュータに、
解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御処理を
実行させるための逐次発生データ解析プログラム。
【請求項１５】
コンピュータに、
解析要求が発生したときに、解析対象の逐次発生データが既に事前解析されているか否かを判定する解析方法判定処理を実行させ、
前記解析方法判定処理において、
事前解析されていないと判定すると、前記解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力する処理と、
既に事前解析されていると判定すると、前記既に事前解析されている解析結果を出力する処理とを実行させる
請求項１４記載の逐次発生データ解析プログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、逐次的に発生するデータを収集して解析する逐次発生データ解析装置、逐次発生データ解析システム、逐次発生データ解析方法、及び逐次発生データ解析プログラムに関する。
【背景技術】
【０００２】
高速にデータを解析する関連技術として、例えば、特許文献１には、キャッシュサーバを用いてデータ解析を行うキャッシュ制御装置が記載されている。図３１は、特許文献１に記載されたキャッシュ制御装置の構成を示すブロック図である。図３１に示すように、特許文献１に記載されたキャッシュ制御装置は、データを解析する解析サーバを備えるとともに、解析結果を利用するサービス提供端末との間に、解析結果を記憶しておき２次利用するキャッシュサーバを備える。そのような構成を備えることによって、サービス提供端末が同じクエリを発行した場合、２回目以降に発行されるクエリに対しては、キャッシュサーバが記憶する以前の解析結果を利用することにより、解析サーバが毎回解析を行う必要をなくすことができ、ある程度データ解析の高速化を期待できる。
【先行技術文献】
【特許文献】
【０００３】
【特許文献１】特開２００８−２１００９４号公報
【発明の概要】
【発明が解決しようとする課題】
【０００４】
しかし、特許文献１に記載された関連技術では、１度目のクエリは高速化されないという問題がある。従って、キャッシュサーバは、同じクエリを何度も発行するようなアプリケーションでしかデータ解析の高速化を行うことはできない。例えば、キャッシュを利用したＷｅｂページの閲覧を例に考えると、まだ誰も見ていないＷｅｂページへのアクセスを高速化することはできない。つまり、多くのユーザが同じクエリを何度も発行するといった利用環境においてのみ、データ解析の高速化を期待できる。【０００５】
一方、例えば、サーバが蓄積するログデータやセンサが検出するデータ等逐次的に発生するデータを解析対象とする場合には、最新のデータを１度だけ解析することが多い。従って、特許文献１に記載された関連技術を用いたとしても、データ解析の高速化の効果が低い。【０００６】
また、特許文献１に記載された関連技術では、解析対象のデータに変化がないことが前提である。そのため、新たなデータが追加された場合、同じクエリに対してデータ解析を行った場合であっても解析結果が変化する可能性があり、キャッシュサーバのデータを二次利用することはできない。【０００７】
一方、例えば、サーバが蓄積するログデータやセンサが検出するデータ等の逐次的に発生するデータを対象とする場合には、解析対象のデータが常に変化している。従って、特許文献１に記載された関連技術を用いたとしても、キャッシュサーバで記憶した解析結果を２次利用する機会はなく、毎回、解析サーバが解析処理を実行する必要がある。そのため、データ解析の高速化を図ることはできない。【０００８】
以上のように、サーバが蓄積するログデータやセンサが検出するデータ等、逐次的に発生するデータを収集して解析する状況においてデータ解析を行う場合には、特許文献１に記載された関連技術を用いたとしても、解析対象のデータを高速に解析することはできない。【０００９】
そこで、本発明は、逐次的に発生するデータを収集して解析する場合であっても、サービス毎のレスポンスタイムの要望に応じた解析を行うことができる逐次発生データ解析装置、逐次発生データ解析システム、逐次発生データ解析方法、及び逐次発生データ解析プログラムを提供することを目的とする。
【課題を解決するための手段】
【００１０】
本発明による逐次発生データ解析装置は、解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御手段を備えたことを特徴とする。【００１１】
本発明による逐次発生データ解析システムは、逐次発生するデータである逐次発生データを発生するデータ発生装置と、データ発生手段が発生する逐次発生データの解析処理を実行する逐次発生データ解析装置と、逐次発生データ解析装置の解析結果に基づいて、データ解析サービスを提供する処理を実行するサービス提供装置とを備え、逐次発生データ解析装置は、解析要求よりも前に、逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御手段を含むことを特徴とする。【００１２】
本発明による逐次発生データ解析方法は、解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御ステップを含むことを特徴とする。【００１３】
本発明による逐次発生データ解析プログラムは、コンピュータに、解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御処理を実行させるためのものである。
【発明の効果】
【００１４】
本発明によれば、逐次的に発生するデータを収集して解析する場合であっても、サービス毎のレスポンスタイムの要望に応じた解析を行うことができる。
【図面の簡単な説明】
【００１５】
【図１】本発明による逐次発生データ解析システムの構成の一例を示すブロック図である。
【図２】逐次発生データ解析システムの物理的なサーバ構成の例を示すブロック図である。
【図３】Ｗｅｂアクセスの動線分析サービスの入力画面例を示す説明図である。
【図４】サービス要件設定手段が設定するサービス要件の例を示す説明図である。
【図５】解析データの例を示す説明図である。
【図６】解析データ記憶手段が記憶するテーブルの例を示す説明図である。
【図７】解析結果記憶手段が記憶するテーブルの例を示す説明図である。
【図８】事前解析制御手段のより詳細な構成例を示すブロック図である。
【図９】逐次発生データ解析システムが逐次発生データの解析を行う処理の一例を示す流れ図である。
【図１０】事前解析処理の一例を示す流れ図である。
【図１１】解析命令受付手段が実行する解析命令（解析要求）の受付処理の一例を示す流れ図である。
【図１２】第２の実施形態における逐次発生データ解析システムの構成の一例を示すブロック図である。
【図１３】第２の実施形態における事前解析制御手段のより詳細な構成例を示すブロック図である。
【図１４】第２の実施形態における逐次発生データ解析システムの物理的なサーバ構成の例を示すブロック図である。
【図１５】解析命令履歴手段が記憶する解析命令履歴情報の例を示す説明図である。
【図１６】第２の実施形態における逐次発生データ解析システムが逐次発生データの解析を行う処理の一例を示す流れ図である。
【図１７】第２の実施形態における事前解析処理の一例を示す流れ図である。
【図１８】第３の実施形態における逐次発生データ解析システムの構成の一例を示すブロック図である。
【図１９】第３の実施形態における事前解析制御手段のより詳細な構成例を示すブロック図である。
【図２０】第３の実施形態における解析コスト監視手段のより詳細な構成例を示すブロック図である。
【図２１】第３の実施形態における逐次発生データ解析システムの物理的なサーバ構成の例を示すブロック図である。
【図２２】解析コスト算出手段が記憶するテーブルの例を示す説明図である。
【図２３】解析コスト監視手段が記憶するテーブルの例を示す説明図である。
【図２４】第３の実施形態における逐次発生データ解析システムが逐次発生データの解析を行う処理の一例を示す流れ図である。
【図２５】第３の実施形態における事前解析処理の一例を示す流れ図である。
【図２６】第４の実施形態における事前解析制御手段のより詳細な構成例を示すブロック図である。
【図２７】空き容量記憶監視手段が予め設定するテーブルの例を示す説明図である。
【図２８】第４の実施形態における逐次発生データ解析システムが逐次発生データの解析を行う処理の一例を示す流れ図である。
【図２９】第４の実施形態における事前解析処理の一例を示す流れ図である。
【図３０】逐次発生データ解析装置の最小の構成例を示すブロック図である。
【図３１】特許文献１に記載されたキャッシュ制御装置の構成を示すブロック図である。
【発明を実施するための形態】
【００１６】
実施形態１．
以下、本発明の第１の実施形態について図面を参照して説明する。図１は、本発明による逐次発生データ解析システムの構成の一例を示すブロック図である。図１に示すように、逐次発生データ解析システムは、サービス提供手段１、サービス要件設定手段２、解析データ発生手段３、解析データ記憶手段４、解析手段５、解析命令受付手段６、解析結果記憶手段７、及び事前解析制御手段８を含む。なお、本実施形態において、逐次発生データ解析システムは、プログラムに従って動作するパーソナルコンピュータ等の複数の情報処理装置を用いて実現される。
【００１７】
なお、本実施形態において、逐次発生データ解析システムは、例えば、Ｗｅｂデータが発生するログデータに基づいて、Ｗｅｂアクセスの動線解析を行う用途に適用できる。また、逐次発生データ解析システムは、例えば、交通情報（例えば、道路上の自動車の位置情報）を収集し、道路上の渋滞箇所を検出して提供する渋滞情報提供システムの用途に適用できる。また、例えば、逐次発生データ解析システムは、株価の変動を監視し、株価の変動と事前入力した売買ルールとをマッチングして、株式の自動売買を行うアルゴリズムトレードの用途に適用できる。すなわち、逐次発生データ解析システムは、大量のデータが逐次的に発生し、最新のデータをリアルタイムに反映しながら解析を行うあらゆるシステムに適用可能である。
【００１８】
サービス提供手段１は、具体的には、プログラムに従って動作する情報処理装置のＣＰＵ及びネットワークインタフェース部によって実現される。サービス提供手段１は、サーバが出力するログデータやセンサ（例えば、温度センサや湿度センサ）が出力するデータ等、逐次的に発生するデータを収集して解析する機能を備える。また、サービス提供手段１は、様々なサービスを一般ユーザに提供する装置（例えば、Ｗｅｂサーバ）を運営する事業者ユーザ（例えば、Ｗｅｂサイトのオーナ）に対して、データの解析結果を用いてデータ解析サービス（例えば、解析結果の配信サービス）を提供する機能を備える。
【００１９】
サービス要件設定手段２は、具体的には、プログラムに従って動作する情報処理装置のＣＰＵによって実現される。サービス要件設定手段２は、サービス提供手段１が提供するサービス毎に、サービスのレスポンスタイムの要件（以下、サービス要件ともいう）を設定し、設定内容を記憶装置（例えば、情報処理装置が備える磁気ディスク装置や光ディスク装置）に記憶する機能を備える。なお、サービス要件とは、後述する事前解析対象のデータとするか否かを示す要件や、事前解析を行う優先度を示す要件のことである。サービス要件設定手段２は、例えば、Ｗｅｂサーバを運営する事業者ユーザの設定要求に従って、サービス要件を設定し、設定内容を記憶装置に記憶する。
【００２０】
解析データ発生手段３は、具体的には、プログラムに従って動作する情報処理装置のＣＰＵによって実現される。解析データ発生手段３は、サーバが出力するログデータやセンサが出力するデータ等、解析対象のデータを逐次的に発生させる機能を備える。なお、本実施形態では、時系列に逐次的に発生するデータを解析する場合を示しているが、何らかの順序性をもつデータであれば、例えば、距離が近い順や遠い順等の位置的な順序性をもったデータを逐次的に入力して解析を行う場合にも適用できる。また、短い時間間隔（例えば、数秒間隔）で連続して発生されるデータに限らず、逐次的に発生するデータであれば、例えば、数時間や数日等の長い時間間隔で発生するデータや、発生間隔が一定しないようなデータを入力して解析を行う場合にも適用できる。
【００２１】
解析データ記憶手段４は、具体的には、情報処理装置が備えるメモリ等の一時記憶装置によって実現される。解析データ記憶手段４は、解析データ発生手段３が発生するデータを記憶する。このように、本実施形態では、逐次発生データ解析システムは、解析データ発生手段３が発生するデータを磁気ディスク装置や光ディスク装置等のデータベース装置に蓄積してから解析するのではなく、メモリ等の一時記憶装置等に一旦記憶するのみでリアルタイムに高速解析を行う。
【００２２】
解析手段５は、具体的には、プログラムに従って動作する情報処理装置のＣＰＵによって実現される。解析手段５は、解析データ記憶手段４に記憶されたデータを解析する機能を備える。
【００２３】
事前解析制御手段８は、具体的には、プログラムに従って動作する情報処理装置のＣＰＵによって実現される。事前解析制御手段８は、サービス要件設定手段２によって設定されたサービス要件に従って、解析データ記憶手段４が記憶するデータの中から事前解析対象のデータを選択し、サービス提供手段１から解析要求のクエリを入力する前に事前解析を実行する制御（解析手段５に解析処理を実行させる）を行う機能を備える。なお、本実施形態において、「事前解析」とは、解析要求がされるよりも前に予めデータを解析しておくことをいう。
【００２４】
解析結果記憶手段７は、具体的には、情報処理装置が備えるメモリ等の一時記憶装置によって実現される。解析結果記憶手段７は、事前解析制御手段８が求めた事前解析結果を記憶する。
【００２５】
解析命令受付手段６は、具体的には、プログラムに従って動作する情報処理装置のＣＰＵ及びネットワークインタフェース部によって実現される。解析命令受付手段６は、サービス提供手段１から解析要求のクエリを受け取る（入力又は受信する）機能を備える。また、解析命令受付手段６は、この解析要求のクエリに対する回答情報（解析結果）の作成するために、解析結果記憶手段７が記憶する事前解析結果を用いるのか、解析手段５に解析処理を実行させるのかを判断する機能を備える。また、解析命令受付手段６は、解析結果記憶手段７が記憶する事前解析結果、又は解析手段５が実行した解析結果のいずれかを、解析要求のクエリに対する回答情報として、サービス提供手段１に出力（又は送信）する機能を備える。
【００２６】
次に、逐次発生データ解析システムの物理的なサーバ構成について説明する。図２は、逐次発生データ解析システムの物理的なサーバ構成の例を示すブロック図である。図２に示すように、逐次発生データ解析システムは、例えば、アプリケーションサーバ１０１、解析サーバ１０２、データ解析サービスサーバ１０３、データ解析受付サーバ１０４、及びデータ高速解析サーバ１０５を含む。
【００２７】
アプリケーションサーバ１０１は、例えば、不特定多数の一般ユーザに対して各種Ｗｅｂサービスを提供する事業者ユーザが運営するサーバ（例えば、Ｗｅｂサーバ）であり、解析データ発生手段３及び解析データ記憶手段４を含む。アプリケーションサーバ１０１は、解析データ発生手段３と解析データ記憶手段４とを用いて動作することによって、解析対象のログデータを発生し解析データ記憶手段４に一時蓄積する。
【００２８】
解析サーバ１０２は、例えば、逐次発生データの解析サービスを提供する事業者が運営するサーバであり、解析手段５を含む。解析サーバ１０２は、解析手段５を用いて動作することによって、アプリケーションサーバ１１が発生したデータ（例えば、ログデータ）を解析する。
【００２９】
データ解析サービスサーバ１０３は、例えば、逐次発生データの解析サービスを提供する事業者が運営するサーバであり、サービス提供手段１及びサービス要件設定手段２を含む。データ解析サービスサーバ１０３は、サービス提供手段１とサービス要件設定手段２とを用いて動作することによって、データ解析結果を、アプリケーションサーバ１０１を運営する事業者ユーザに提供する処理を行う。
【００３０】
データ解析受付サーバ１０４は、例えば、逐次発生データの解析サービスを提供する事業者が運営するサーバであり、解析命令受付手段６を含む。データ解析受付サーバ１０４は、解析命令受付手段６を用いて動作することによって、データ解析サービスサーバ１０３から解析要求のクエリを受け付ける（受信する）処理を行う。
【００３１】
データ高速解析サーバ１０５は、例えば、逐次発生データの解析サービスを提供する事業者が運営するサーバであり、解析結果記憶手段７及び事前解析制御手段８を含む。データ高速解析サーバ１０５は、解析結果記憶手段７と事前解析制御手段８とを用いて動作することによって、データ解析サービスサーバ１０３からサービス要件を受け取る（入力する）。また、データ高速解析サーバ１０５は、入力したサービス要件に応じて、解析要求のクエリが発行される前に、アプリケーションサーバ１０１が発生するデータを事前に解析するために解析サーバ１０２を制御する。
【００３２】
なお、図２に示した各サーバ１０１〜１０５は、必ずしもそれぞれ別の情報処理装置を用いて実現される必要はなく、サーバの能力に応じて、図２に示した各サーバ１０１〜１０５のうちのいずれか複数を１つの情報処理装置を用いて実現してもよい。例えば、多くの場合、解析サーバ１０２、データ解析受付サーバ１０４、及びデータ高速解析サーバ１０５を、同じ１つの情報処理装置によって実現することができる。
【００３３】
また、図２に示した各サーバ１０１〜１０５や各手段１〜８の間では、通信が必要なネットワークやポート番号等の設定が事前に共有されているものとし、互いに通信できるものとする。
【００３４】
また、図２に示す例において、逐次発生データ解析装置は、例えば、データ高速解析サーバ１０５によって実現される。また、例えば、逐次発生データ解析装置は、解析サーバ１０２、データ解析受付サーバ１０４、及びデータ高速解析サーバ１０５を実現する情報処理装置によって実現される。
【００３５】
以下、図１及び図２に示した手段毎の実現方法を説明する。
【００３６】
サービス提供手段１は、データの解析結果を、アプリケーションサーバ１０１を運営する事業者ユーザに提供する手段である。例えば、サービス提供手段１は、Ｗｅｂアクセスの動線分析等の解析結果を、ネットワークを介して、事業者ユーザの端末に配信する。以下、Ｗｅｂアクセスの動線分析を行う場合を例に説明する。
【００３７】
図３は、Ｗｅｂアクセスの動線分析サービスの入力画面例を示す説明図である。なお、具体的には、サービス提供手段１は、例えば、事業者ユーザの端末からの要求に応じて、図３に示す入力画面の画面情報（例えば、Ｗｅｂページの情報）を送信する。次いで、事業者ユーザの端末は、サービス提供手段１から受信した画面情報に基づいて、図３に示す入力画面を表示する。そして、事業者ユーザは、端末に表示された入力画面を見ながら操作を行うことによって、Ｗｅｂアクセスの動線分析サービスの要求操作を行う。図３に示す画面例では、Ｗｅｂページ毎に、「どのページからのアクセスが多いか」を示している。ただし、図３に示す画面例は一例であり、解析サービスの提供に用いる画面例は、本実施形態で示したものに限られない。
【００３８】
図３において、ＵＲＬ入力フィールド（Ｕ０１）は、解析対象のＷｅｂページのＵＲＬの入力部である。具体的には、解析サービスを利用する事業者ユーザがＵＲＬ入力部Ｕ０１にＵＲＬを入力操作すると、事業者ユーザの端末は、事業者ユーザの操作に従って、解析対象のＷｅｂページのＵＲＬを入力する。
【００３９】
解析ボタン（Ｕ０２）は、入力したＵＲＬで特定されるＷｅｂページの動線解析の要求操作を行うためのボタン（入力部）である。具体的には解析サービスを利用する事業者ユーザが解析ボタンＵ０２をマウス等でクリック操作すると、事業者ユーザの端末は、入力したＵＲＬで示されるＷｅｂページの解析要求を、ネットワークを介してサービス提供手段１に送信する。
【００４０】
ランキング（Ｕ０３）は、アクセスが多かった順にＷｅｂページのランキングを表示する表示領域である。また、アクセス元のＵＲＬ（Ｕ０４）は、どのＷｅｂページから移ってきたを表示する表示領域である。また、アクセス数（Ｕ０５）は、アクセス数を表示する表示領域である。
【００４１】
サービス提供手段１は、事業者ユーザの端末から、解析対象のＷｅｂページのＵＲＬの入力情報を受ける（受信する）。また、解析ボタンＵ０２が押されると、サービス提供手段１は、解析要求を受信し、解析命令受付手段６に解析要求のクエリを発行（出力）する。以下、解析要求のクエリのフォーマットの例を示す。ただし、この解析要求のクエリのフォーマットの例は、本実施形態で示したものに限られない。
【００４２】
解析要求のクエリのフォーマット：（GetReferrerRanking、ＵＲＬ）
例：（GetReferrerRanking、”http://bar.co.jp/~foo/Page-001”）
【００４３】
なお、”GetReferrerRanking”は、動線分析を指定するコマンド名であり、固定値である。また、コマンド名は、上記に示した例に限られない。
ＵＲＬは、解析対象のデータ（Ｗｅｂページのデータ）を表すＵＲＬであり、ＵＲＬ入力フィールド（Ｕ０１）からの入力値である。
【００４４】
上記に示した解析要求のクエリに対して、解析命令受付手段６は、以下に示すフォーマットで解析結果をサービス提供手段１に対して返答（出力又は送信）する。
【００４５】
解析結果のフォーマット：（（ランキング，アクセス元ＵＲＬ，アクセス数），（ランキング，アクセス元ＵＲＬ，アクセス数））
例：（（１，http://bar.co.jp/~foo/Page-999，1230），（２，http://aaa.co.jp/~bbb/Page-123，881 ）．．．）
【００４６】
ただし、上記に示した返答結果のフォーマットは一例であり、本実施形態で示したものに限られない。
【００４７】
サービス提供手段１は、解析要求のクエリ対する回答（解析結果）を受け取ると（入力又は受信すると）、図３に示すように、ランキング（Ｕ０３）や、アクセス元のＵＲＬ（Ｕ０４）、アクセス数（Ｕ０５）のフィールドに解析結果を表示した表示画面の情報を生成する。また、サービス提供手段１は、事業者ユーザの端末に対して、ネットワークを介して、生成した表示画面の情報を送信し、事業者ユーザの端末で解析結果が表示される。
【００４８】
サービス要件設定手段２は、事業者ユーザが提供するサービス毎に（例えば、Ｗｅｂページ毎に）、サービスのレスポンスタイムの要件（サービス要件）を設定し記憶する手段である。
【００４９】
図４は、Ｗｅｂページ毎にレスポンスタイムの要件（サービス要件）を設定した場合の例を示す説明図である。図４において、ＵＲＬ（Ｔ０２−０１）は、サービス要件の設定対象のＷｅｂページのＵＲＬである。また、レスポンスタイムの要件（Ｔ０２−０２）は、レスポンスタイムの要件（サービス要件）の設定値である。図４に示す例では、早いレスポンスが必要であり、優先的に事前解析対象としたいデータに対しては、サービス要件としてＨｉｇｈが設定される。一方、レスポンスが遅くてもかまわず、それ程優先的に事前解析対象とする必要がないデータに対しては、サービス要件としてＬｏｗが設定される。
【００５０】
解析サービスを受けるために、事業者ユーザは、事前にこのサービス要件の設定を入力操作しておく。また、サービス要件設定手段２は、事業者ユーザの端末から受信した設定指示情報に基づいて、データ毎にサービス要件を設定し予め記憶装置に記憶している。そして、サービス要件設定手段２は、事前解析制御手段８の要求に応じて、事前解析制御手段８から入力（又は受信）したＵＲＬをキーに、このＵＲＬに対応したレスポンスタイムの要件（サービス要件）の値を検索して抽出し、事前解析制御手段８に対して出力（又は送信）する。
【００５１】
また、本実施形態では、事業者ユーザの設定操作に従ってサービス要件を設定する場合を示したが、サービス要件設定手段２は、所定のルールに従ってサービス要件を自動設定するようにしてもよい。例えば、サービス要件設定手段２は、Ｗｅｂアクセスの動線分析サービスを行う場合には、新サービスのプロモーション等を紹介しているサイトを検出して、事前解析の対象として自動設定するようにしてもよい。
【００５２】
また、サービス要件設定手段２は、例えば、内容が変動するデータを自動的に検出して事前解析対象として自動設定するようにしてもよい。この場合、例えば、Ｗｅｂサイトのトップページは一般に内容が頻繁に変動している点に着目し、サービス要件設定手段２は、Ｗｅｂサイトのトップケージの情報に対して、事前解析対象とするようにサービス要件を自動設定するようにしてもよい。なお、サービス要件設定手段２は、Ｗｅｂサイトのトップページであるか否かを、例えば、ＵＲＬに「index.html」等のファイル名が含まれるか否かを判断することによって判定することができる。
【００５３】
また、例えば、交通情報提供システムに適用する場合には、サービス要件設定手段２は、国道に関係する交通情報を事前解析対象として自動設定したり、駅前に関係する交通情報を事前解析対象として自動設定したりしてもよい。
【００５４】
解析データ発生手段３は、解析対象のデータを発生させる手段である。本実施形態では、解析データ発生手段３がＷｅｂサーバによって実現され、アクセスログのデータを発生する場合を例に説明する。解析データ発生手段３は、Ｗｅｂサーバのアクセスログのデータとして、図５に示すように、日時（Ｔ０３−０１）、ＵＲＬ（Ｔ０３−０２）、及びReferrer（Ｔ０３−０３）ののフィールドをもつデータを発生するものとする。なお、日時（Ｔ０３−０１）は、Ｗｅｂページにアクセスがあった日時である。また、ＵＲＬ（Ｔ０３−０２）は、アクセス先のＷｅｂページのＵＲＬである。また、Referrer（Ｔ０３−０３）は、アクセス元のＷｅｂページのＵＲＬである。
【００５５】
図５に示す例では、例えば、日時「2008/12/16 10:00:00 」に、Ｗｅｂページ”http://bar.co.jp/~foo/Page-001”へ、Ｗｅｂページ”http://bar.co.jp/~foo/Page-002”から移動するアクセスがあったことが分かる。
【００５６】
なお、図５に示す例では、Ｗｅｂページのアクセスログのデータを、ＣＳＶ形式とテキストデータとで記載する場合を示したが、アクセスログのデータの形式は、本実施形態で示したものに限られない。さらに、解析データ発生手段３は、Ｗｅｂページのアクセスログのデータとして、図５に示した日時（Ｔ０３−０１）やＵＲＬ（Ｔ０３−０２）、Referrer（Ｔ０３−０３）以外のフィールドをもつデータを発生してもよい。なお、本実施形態では、説明を簡単にするために、図５に示すフィールドのみをもつアクセスログのデータを説明に用いる。
【００５７】
解析データ発生手段３は、発生したデータを、解析データ記憶手段４に転送（出力）し、一時記憶させる。例えば、解析データ発生手段３は、以下に示すフォーマットでデータを解析データ記憶手段４に転送（出力）すればよい。
【００５８】
データのフォーマット：（日時、ＵＲＬ、Referrer）
例：（2008/12/16 10:00:00 、http://bar.co.jp/~foo/Page-001、http://bar.co.jp/~foo/Page-002）
【００５９】
ただし、上記に示したデータのフォーマットは一例であり、本実施形態で示したものに限られない。
【００６０】
解析データ記憶手段４は、解析データ発生手段３が発生したデータを一時記憶する手段である。解析データ記憶手段４が記憶しているデータは、解析手段５と事前解析制御手段８とによって検索され抽出される。なお、解析データ記憶手段４は、リレーショナルデータベースを用いて実現してもよい。
【００６１】
解析データ記憶手段４は、少なくとも、解析データ発生手段３が発生するデータと同じフィールドを最低限もつデータを記憶する。例えば、解析データ記憶手段４は、図６に示すように、日時（Ｔ０４−０１）、ＵＲＬ（Ｔ０４−０２）、及びReferrer（Ｔ０４−０３）を含むデータを記憶する。なお、日時（Ｔ０４−０１）は、Ｗｅｂページにアクセスがあった日時である。また、ＵＲＬ（Ｔ０４−０２）は、アクセス先のＷｅｂページのＵＲＬである。また、Referrer（Ｔ０４−０３）は、アクセス元のＷｅｂページのＵＲＬである。
【００６２】
なお、実際にシステムを運用する際には、解析データ記憶手段４から古いデータを随時削除する等の処理が必要であるが、本発明とは直接的には無関係であるので、以下、説明を分かりやすくするために、基本的に解析データ記憶手段４にデータが追加され続けるものとして説明を行う。
【００６３】
解析手段５は、データを解析する手段であり、本実施形態では、解析手段５は、Ｗｅｂアクセスログのデータの動線分析を行う。解析手段５は、解析命令受付手段６又は事前解析制御手段８から、解析要求のクエリを受けると（入力すると）、解析対象のデータ（本例では、Ｗｅｂアクセスログデータ）を解析データ記憶手段７から読み込む。そして、解析手段５は、読み込んだデータにもとづいて解析処理を実行し、要求を受けた手段（解析命令受付手段６又は事前解析制御手段８）に解析結果を回答（出力）する。
【００６４】
なお、解析命令受付手段６又は事前解析制御手段８から出力される解析要求のクエリは、サービス提供手段１が解析命令受付手段６に出力するクエリと同じフォーマットのクエリを用いればよい。また、解析手段５は、解析結果の回答として、解析命令受付手段６がサービス提供手段１に出力する回答と同じ形式のデータを出力すればよい。
【００６５】
解析手段５は、以下のような動線解析方法に従って解析処理を実行する。ただし、本実施形態で示す解析処理のアルゴリズムは一例であり、解析手段５は、他の解析方法に従って解析処理を実行してもよい。
【００６６】
ステップ１：
まず、解析手段５は、解析要求のクエリで指定されたＵＲＬのデータを、解析データ記憶手段４が記憶する各データＵＲＬフィールド（Ｔ０４−０２）に基づいて検索し、ＵＲＬが合致するデータを抽出する。
ステップ２：
次いで、解析手段５は、この抽出したデータセットに対して、Referrerの値毎に出現数をカウントする。
ステップ３：
そして、解析手段５は、出現数の多い順にデータを並び替え、データに順位をつける。
【００６７】
解析結果記憶手段７は、事前解析した結果を記憶する手段である。解析結果記憶手段７は、事前解析制御手０８から事前に実行した解析処理の解析結果を受け取り（書き込まれ）、入力した事前解析結果を随時記憶する。また、解析命令受付手段６は、解析結果記憶手段７が記憶する事前解析結果を必要に応じて検索し抽出する。解析結果記憶手段７は、図７に示すように、解析結果管理テーブルと解析結果詳細テーブルとの２種類のテーブルを記憶すればよい。
【００６８】
解析結果管理テーブルは、解析したデータのＵＲＬとそのデータの事前解析結果との対応関係を含むテーブルである。図７に示すように、解析結果記憶手段７は、１つの解析結果管理テーブルを記憶する。また、解析結果記憶手段７は、ＵＲＬ（Ｔ０７−０１）及び解析結果（Ｔ０７−０２）のフィールドを含む解析結果管理テーブルを記憶する。なお、ＵＲＬ（Ｔ０７−０１）は、解析対象のデータのＵＲＬを含むフィールドである。また、解析結果（Ｔ０７−０２）は、事前解析結果へのリンクを示す情報を含むフィールドである。
【００６９】
解析結果詳細テーブルは、解析結果管理テーブルでリンクされた解析結果の詳細な解析内容を示すテーブルである。解析結果詳細テーブルに含まれる各解析内容の情報は、解析結果管理テーブルの解析結果からリンクされている。また、図７に示すように、解析結果記憶手段７は、ランキング（Ｔ０７−０３）、アクセス元のＵＲＬ（Ｔ０７−０４）、及びアクセス数（Ｔ０７−０５）のフィールドを含む解析結果詳細テーブルを記憶する。なお、ランキング（Ｔ０７−０３）は、アクセスが多かった順のランキングを示す情報を含むフィールドである。また、アクセス元のＵＲＬ（Ｔ０７−０４）は、どのＷｅｂページから移ってきたかを示す情報（具体的には、アクセス元のＷｅｂページのＵＲＬ）を含むフィールドである。また、アクセス（Ｔ０７−０５）は、アクセス数のカウント値を示す情報を含むフィールドである。
【００７０】
事前解析制御手段８は、事前解析処理の制御を行うメイン制御部である。事前解析制御手段８は、以下に示す要件に従って、いずれのＵＲＬのデータを事前解析すべきか判断する。例えば、事前解析制御手段８は、サービス要件設定手段２によってＵＲＬ毎に設定されたサービス要件に従って、そのＵＲＬのデータを事前解析すべきか否かを判断する。また、例えば、事前解析制御手段８は、解析データの変化を検出して、データを事前解析すべきか否かを判断する。そして、事前解析制御手段８は、事前解析対象であると判断したデータを解析手段５に事前解析させる。
【００７１】
図８は、事前解析制御手段８のより詳細な構成例を示すブロック図である。図８に示すように、事前解析制御手段８は、解析対象監視手段８０１、事前解析対象生成手段８０２、事前解析依頼手段８０３、及び事前解析結果登録手段８０４を含む。
【００７２】
解析対象監視手段８０１は、解析データ記憶手段４に記憶されているデータの追加状況を監視する機能を備える。また、事前解析対象生成手段８０２は、解析対象監視手段８０１の監視結果と、サービス要件設定手段２が記憶しているサービス要件の情報とに基づいて、優先的に事前解析すべきデータの一覧情報を作成する機能を備える。また、事前解析依頼手段８０３は、事前解析対象生成手段８０２が生成した事前解析対象の一覧情報に示されるデータの事前解析を、解析手段５に依頼する機能を備える。また、事前解析結果登録手段８０４は、解析手段５が事前解析処理を行った解析結果を解析結果記憶手段７に記憶させる機能を備える。
【００７３】
解析対象監視手段８０１は、定期的に（例えば、５分単位に）、解析データ記憶手段４が記憶する情報を監視する処理を繰り返し実行する。解析対象監視手段８０１は、解析データ記憶手段４が記憶しているデータのうち、前回の監視処理を実行した後に追加されたデータが存在するか否かを検出する。解析対象監視手段８０１は、追加データを検出する場合、例えば、監視処理を毎回実行する度に、追加されたデータの中で最も日時が新しい日時の値を記憶しておく。そして、解析対象監視手段８０１は、次回の監視処理を実行する時に、この記憶する日時よりも新しい日時のデータを新たに追加されたデータと判断すればよい。ただし、この検出方法は一例であり、解析データ記憶手段４が記憶する情報に検出用のフィールドを追加し、解析対象監視手段８０１は、既に処理済みのフィールドには処理済みの情報を書き込む等の処理を行うことによって、データの追加を検出できるようにしてもよい。
【００７４】
事前解析対象生成手段８０２は、解析対象監視手段８０１が検出した追加データに含まれるＵＲＬの集合を抽出する。具体的には、事前解析対象生成手段８０２は、抽出した各追加データのＵＲＬのうち、重複するＵＲＬを除くようにすればよく、全ての追加されたデータのＵＲＬを順にハッシュテーブルに登録する。そして、このハッシュテーブルのキーの一覧が事前解析対象の候補となるデータのＵＲＬの集合になる。以下、このハッシュテーブルに含まれるＵＲＬの集合を、追加ＵＲＬという。
【００７５】
また、事前解析対象生成手段８０２は、追加ＵＲＬそれぞれに対応するサービス要件を、サービス要件設定手段２から得る（入力する）。そして、事前解析対象生成手段８０２は、追加ＵＲＬの中から、対応するサービス要件の値がＨｉｇｈであるものを、事前解析を実行する対象として特定する。一方、もし、サービス要件の値がＨｉｇｈであるものがなければ、事前解析対象生成手段８０２は、サービス要件の値がＬｏｗのものを事前解析の対象として特定する。そのようにすることによって、高速処理が要件となっているＵＲＬのデータを優先的に事前解析対象とすることができる。なお、本実施形態では、説明を簡単にするために、サービス要件をＨｉｇｈとＬｏｗとの２段階に設定する場合を示したが、より細かく段階分けして（例えば、３段階以上に設定するようにして）、この事前解析対象とするか否かの判定処理をより複数段階に行ってもよい。
【００７６】
事前解析依頼手段８０３は、事前解析対象生成手段８０２によって特定された事前解析の対象となるデータについて、解析手段５に対して解析依頼を出力する。事前解析依頼手段８０３は、例えば、以下に示すフォーマットの解析依頼を出力するようにすればよい。
【００７７】
フォーマット：（Analyze ＜｛ＵＲＬの集合｝）
例：（Analyze ，｛”http://bar.co.jp/~foo/Page-999”，”http://hml.co.jp/~xyz/Page-777”｝）
【００７８】
なお、上記に示す例において、Analyze は、コマンド名である。なお、事前解析依頼手段８０３が出力する解析依頼のフォーマット例は、本実施形態で示したものに限られない。
【００７９】
解析手段５は、上記のコマンドを含む解析要求を受け取る（入力する）と、解析要求にパラメータとして含まれるＵＲＬのデータを順に解析し、事前解析依頼手段８０３に解析結果を回答（出力）する。この場合、解析手段５は、例えば、以下に示す回答フォーマットの解析結果を出力する。
【００８０】
解析結果のフォーマット：｛解析結果の集合｝
解析結果：（解析対象のＵＲＬ，｛動線情報の集合｝）
【００８１】
ここで、動線情報とは、（ランキング、アクセス元のＵＲＬ、アクセス数）である。以下、上記のフォーマットで出力される解析結果の例を示す。
【００８２】
例：｛
（http://bar.co.jp/~foo/Page-001，｛（１，http://bar.co.jp/~foo/Page-999，1230），
（２，http://aaa.co.jp/~bbb/Page-123，881 ），（３，．．．）｝），
（http://bar.co.jp/~foo/Page-002，｛（１，http://bar.co.jp/~foo/Page-111，1357），
（２，http://aaa.co.jp/~bbb/Page-654，881 ），（３，．．．）｝），．．．
｝
【００８３】
事前解析結果登録手段８０４は、以下に示す方法で、解析結果記憶手段７に事前解析結果を登録する。まず、事前解析結果登録手段８０４は、新たな事前解析結果が、解析結果記憶手段７に既に登録されているか否かを検索して判定する。具体的には、事前解析結果登録手段８０４は、検索対象の事前解析結果のデータのＵＲＬをキーとして、解析結果記憶手段７が記憶する解析結果管理テーブルに含まれるＵＲＬフィールド（Ｔ０６−０１）を検索する。そして、事前解析結果登録手段８０４は、合致するＵＲＬが見つかれば既に登録済みであると判定し、見つからなければ未登録であると判断できる。
【００８４】
事前解析結果登録手段８０４は、登録済みであると判定した場合には、その登録済みのレコードに新たな事前解析結果を上書きする。すなわち、事前解析結果登録手段８０４は、解析結果フィールドのリンク先の解析結果詳細テーブルのレコードを新たな動線情報で上書きする。
【００８５】
また、事前解析結果登録手段８０４は、未登録あると判定した場合には、解析結果管理テーブルに新たなレコードを追加し、その追加したレコードに事前解析結果を登録する。すなわち、事前解析結果登録手段８０４は、解析結果管理テーブルに新たなレコードを追加し、この解析結果管理テーブルの新たなレコードのＵＲＬフィールドに解析対象のデータのＵＲＬを登録する。また、事前解析結果登録手段８０４は、新たなレコードの解析結果のフィールドには、新たな解析結果詳細テーブルを追加して、この追加した解析結果詳細テーブルへのリンク情報を登録する。さらに、事前解析結果登録手段８０４は、新たに追加した解析結果詳細テーブルには、新たな事前解析結果である動線情報を登録する。
【００８６】
解析命令受付手段６は、サービス提供手段１から受け取った（入力した）解析要求のクエリに対して、解析結果を高速に回答するために、解析要求のクエリの処理を分岐する手段である。解析命令受付手段６は、サービス提供手段１からの解析要求のクエリに対して、事前解析結果を利用可能であると判断した場合には、事前解析結果記憶手段７から事前解析結果をロードして、その事前解析結果をサービス提供手段１に対して出力（又は送信）する。そのようにすることによって、高速に解析要求のクエリに対する回答を行うことができる。また、解析命令受付手段６は、事前解析結果を利用できないと判断した場合には、解析手段５に解析要求のクエリを転送して、通常通りの時間をかけた解析処理を行って、その解析結果をサービス提供手段１に対して回答（出力又は送信）する。なお、解析処理の分岐方法については後述する。
【００８７】
なお、本実施形態において、逐次発生データ解析システムを実現する情報処理装置の記憶装置は、逐次発生データを高速に解析するための各種プログラムを記憶している。例えば、逐次発生データ解析システムを実現する情報処理装置の記憶装置は、コンピュータに、解析要求よりも前に、逐次発生するデータである逐次発生データを事前に解析する処理を実行させる制御を行う事前解析制御処理を実行させるための逐次発生データ解析プログラムを記憶している。
【００８８】
次に、動作について説明する。図９は、逐次発生データ解析システムが逐次発生データの解析を行う処理の一例を示す流れ図である。図９に示すように、本実施形態では、サーバが出力するログデータやセンサが出力するデータ等、逐次的に発生するデータを収集して解析することにより、様々なサービスをユーザに提供する装置（システム）に関して、以下の処理を実行する。
【００８９】
図９に示すように、逐次発生データ解析システムの動作ステップは、解析対象のデータが逐次発生する解析対象データ発生ステップ（ステップＳ１）を含む。また、解析対象データ発生ステップＳ１で蓄積した解析対象データを解析する解析ステップ（ステップＳ２）を含む。また、事業者ユーザの操作に従って入力されたデータ解析依頼の要求に従い、解析を開始し事業者ユーザに対して解析結果を提供する解析サービス利用ステップ（ステップＳ３）を含む。また、解析サービス利用ステップＳ３における具体的な解析の依頼を受ける前に、事前に解析を実行する事前解析ステップ（ステップＳ４）を含む。また、解析サービス利用ステップＳ３における解析の依頼を受けたときに、既に事前解析ステップＳ４で解析済みのデータである場合には、この事前解析結果を回答として出力し、まだ事前解析が行われていないデータである場合には、解析ステップＳ２の処理を実行するように解析を依頼し、この解析結果を回答として出力する解析サービス制御ステップＳ５を含む。
【００９０】
なお、実際には、解析データ発生手段３は、データを逐次的に随時発生して出力している。そのため、実際には、逐次発生データ解析システムは、図９に示す各ステップＳ１〜Ｓ５の処理を並列的に実行しており、適宜通信しあいながら処理を進める。以下、まず、各ステップで実行される処理について説明する。
【００９１】
解析対象データ発生ステップ（ステップＳ１）では、解析データ発生手段３は、アプリケーションやサーバ等を利用する際に、解析対象のデータを発生させるアプリケーション利用ステップ（ステップＳ１０１）の処理と、アプリケーション利用ステップＳ１０１の処理で発生した解析対象のデータを解析データ記憶手段４に蓄積させる解析データ記憶ステップ（ステップＳ１０２）の処理とを実行する。
【００９２】
解析サービス利用ステップ（ステップＳ３）では、サービス要件設定手段２は、事業者ユーザの設定操作に従って、解析サービスを受ける前に、解析サービス毎に、解析のレスポンスタイム等の解析の要件（サービス要件）を設定する解析サービス要件設定ステップ（ステップＳ３０１）の処理を実行する。また、サービス提供手段１は、事業者ユーザの要求操作に従って、解析サービスの要求を受け付け（入力して）解析命令受付手段６に対して要求する解析サービス要求ステップ（ステップＳ３０２）の処理と、解析命令受付手段６から解析結果を受け取り（入力して）、事業者ユーザに対して解析結果を提供する解析サービス提供ステップ（ステップＳ３０３）の処理とを実行する。
【００９３】
解析サービス制御ステップ（ステップＳ５）では、解析命令受付手段６は、サービス提供手段１から解析依頼を受け付ける（入力する）解析命令受付ステップ（ステップＳ５０１）の処理を実行する。また、解析命令受付手段６は、この命令（解析依頼）で解析を要求されているデータが既に事前解析され解析済みであるか否かを調査する事前解析利用可能性チェックステップ（ステップＳ５０２）の処理を実行する。また、解析命令受付手段６は、事前解析結果を利用可能であると判定した場合に、その事前解析結果を解析結果記憶手段７から得る（抽出する）事前解析結果利用ステップ（ステップＳ５０３）の処理を実行する。また、解析命令受付手段６は、事前解析結果を利用不可能であると判定した場合に、解析手段５に対して解析処理の実行を依頼する解析依頼ステップ（ステップＳ０５０４）の処理を実行する。また、解析命令受付手段６は、事前解析結果利用ステップ（ステップＳ５０３）又は解析結果依頼ステップ（ステップＳ５０４）で得た解析結果を、サービス提供手段１に対して回答（出力）する解析命令回答ステップ（ステップＳ５０５）の処理を実行する。
【００９４】
また、図１０は、事前解析ステップ（ステップＳ４）における事前解析処理の一例を示す流れ図である。図１０に示すように、事前解析ステップ（ステップＳ４）では、事前解析制御手段８は、解析サービス利用ステップ（ステップＳ３）において事業者ユーザの入力操作に従って設定された解析の要件（サービス要件）を読み込む解析サービス要件読込ステップ（ステップＳ４０１）の処理を実行する。また、事前解析制御手段８は、解析対象データ発生ステップ（ステップＳ１）で蓄積した解析データに関して、前回の監視処理を実行した後に追加されたデータを検出する解析対象変化検出ステップ（ステップＳ４０２）の処理を実行する。
【００９５】
また、事前解析制御手段８は、解析対象変化検出ステップ（ステップＳ４０２）で検出した追加データの中から、解析サービス要件読込ステップ（ステップＳ４０１）で読み込んだサービス要件を満たすか否かを判断することによって、事前解析を行うデータを選別する事前解析対象決定ステップ（ステップＳ４０３）の処理を実行する。また、事前解析制御手段８は、事前解析決定ステップ（ステップＳ４０３）で選別した事前解析データについて、解析手段５に対して解析処理の実行を依頼する事前解析依頼ステップ（ステップＳ４０４）の処理を実行する。また、事前解析制御手段８は、事前解析依頼ステップ（ステップＳ４０４）で解析手段５から得られた回答を事前解析結果として解析結果記憶手段７に記憶させる事前解析結果登録ステップ（ステップＳ４０５）の処理を実行する。
【００９６】
また、事前解析制御手段８は、解析命令受付手段６からの事前解析データの抽出要求に対して、解析結果記憶手段７に記憶している事前解析結果を抽出して回答（出力）する事前解析結果回答ステップ（ステップＳ４０６）の処理を実行する。
【００９７】
なお、データは逐次的に随時発生しているのであり、解析要求も随時発生するものであることから、事前解析制御手段８は、解析サービス要件読込ステップ（ステップＳ４０１）から事前解析結果登録ステップ（ステップＳ４０５）までの処理を、事前解析結果回答ステップ（ステップＳ４０６）の処理とは独立に一定間隔で繰り返し実行している。
【００９８】
また、事前解析制御手段８は、事前解析結果回答ステップ（ステップＳ４０６）の処理を、解析命令受付手段６から要求があったタイミングで起動して実行し、処理が終了すると要求待ち状態に戻るように制御する。
【００９９】
また、事前解析制御手段８は、解析サービス要件読込ステップ（ステップＳ４０１）から事前解析結果登録ステップ（ステップＳ４０５）までの処理と、事前解析結果回答ステップ（ステップＳ４０６）の処理とを、事前解析結果登録ステップ（ステップＳ４０５）の処理で登録した事前解析結果のデータを共有することによって、非同期にコミュニケーションをとるように実行する。
【０１００】
以下、上記に示した各ステップの処理の実現方法を、各手段と対応させながら説明する。
【０１０１】
本実施形態では、例えば、解析対象データ発生ステップ（ステップＳ１）の処理を、アプリケーションサーバ１０１が動作することによって実行する。具体的には、アプリケーション利用ステップ（ステップＳ１０１）の処理は、解析データ発生手段３によって実行される。また、解析データ記憶ステップ（ステップＳ１０２）の処理は、解析データ発生手段３によって逐次発生データを解析データ記憶手段４に記憶させることによって実行される。
【０１０２】
また、本実施形態では、例えば、解析サービス利用ステップ（ステップＳ３）の処理を、データ解析サービスサーバ１０３が動作することによって実行する。具体的には、解析サービス要件設定ステップ（ステップＳ３０１）の処理は、サービス要件設定手段２によって実行される。また、解析サービス要求ステップ（ステップＳ３０２）及び解析サービス提供ステップ（ステップＳ３０３）の処理は、サービス提供手段１によって実行される。
【０１０３】
また、本実施形態では、例えば、解析ステップ（ステップＳ２）の処理は、解析サーバ１０２の解析手段５によって実行される。
【０１０４】
また、本実施形態では、例えば、解析サービス制御ステップ（ステップＳ５）の処理は、データ解析受付サーバ１０４の解析命令受付手段６によって実行される。
【０１０５】
図１１は、解析命令受付手段６が実行する解析命令（解析要求）の受付処理の一例を示す流れ図である。
【０１０６】
まず、解析命令受付手段６は、解析要求のクエリを、サービス提供手段１から受け取る（入力する）処理を行う（受付ステップＳ５０１）。なお、解析命令受付手段６は、前述したようなコマンドGetReferrerRankingを含むクエリを入力するものとし、そのクエリにはパラメータとして解析対象のデータのＵＲＬが含まれているものとする。以下、このクエリに含まれるＵＲＬを解析対象ＵＲＬという。
【０１０７】
次いで、解析命令受付手段６は、解析対象ＵＲＬで特定されるデータについて、事前解析結果が利用できるか否かを判断するために、解析結果記憶手段７が記憶するデータを検索する（事前解析利用可能性チェックステップＳ５０２）。この場合、解析命令受付手段６は、例えば、解析結果記憶手段７が記憶する解析結果管理テーブルのＵＲＬフィールド（Ｔ０７−０１）の各ＵＲＬの中に、解析対象ＵＲＬに合致するものがあるか否かを検索する。
【０１０８】
検索に成功した場合（合致するＵＲＬが存在した場合）には、解析命令受付手段６は、解析結果記憶手段７が記憶する解析結果管理テーブルから、ＵＲＬが合致した１つのレコードを検索結果として抽出する。検索に失敗した場合（合致するＵＲＬが存在しなかった場合）には、解析命令受付手段６は、検索に失敗こと（利用可能な事前解析結果が存在しないこと）を示す値（例えばＮＵＬＬ）を返す（検索結果として求める）。
【０１０９】
次いで、もし、検索結果があれば（すなわち、ステップＳ５０２において、検索結果としてレコードを抽出した場合には）、解析命令受付手段６は、事前解析結果を利用できると判定して、事前解析結果利用ステップ（ステップＳ５０４）の処理に進む。検索結果がなければ（すなわち、ステップＳ５０２において、ＮＵＬＬの値を求めた場合には）、解析命令受付手段６は、事前解析結果を利用できないと判定して、ステップ（ステップＳ５０５）の処理に進む（分岐ステップＳ５０３）。
【０１１０】
事前解析結果利用ステップＳ５０４では、解析命令受付手段６は、検索結果のレコードの解析結果フィールドに示されるリンク先の解析結果詳細テーブルを解析結果記憶手段７から抽出する。そして、解析命令受付手段６は、この抽出した解析結果詳細テーブルを、解析要求のクエリに対する回答（事前解析結果）として求める。
【０１１１】
解析依頼ステップステップＳ５０５では、解析命令受付手段６は、解析要求のクエリで指定されたデータの解析処理を実行するために、解析手段５に、その解析要求のクエリを転送する。この場合、例えば、解析命令受付手段６は、サービス提供手段１からの解析要求のクエリをそのまま解析手段５に転送すればよい。そして、解析命令受付手段６は、解析手段５から解析結果を受け取る（入力する）まで処理を待機する。
【０１１２】
次いで、解析命令受付手段６は、解析結果として、解析結果記憶手段７が記憶する解析結果詳細テーブルと同じ形式の情報を解析手段５から得る（入力する）。そして、解析命令受付手段６は、この解析手段５から入力した解析結果を、解析要求のクエリに対する回答（解析結果）として求める。
【０１１３】
次いで、解析命令受付手段６は、ステップＳ５０４で求めた事前解析結果、又はステップＳ５０５で求めた解析結果を、サービス提供手段１に対して回答（出力）する（解析命令回答ステップＳ５０６）。
【０１１４】
また、本実施形態では、例えば、事前解析ステップ（ステップＳ４）の処理は、データ高速解析サーバ１０５によって実行される。具体的には、解析サービス要件読込ステップ（ステップＳ４０１）の処理は、事前解析対象生成手段８０２によって実行され、事前解析対象生成手段８０２は、サービス要件設定手段２からデータ（サービス要件）を読み込む。また、解析対象変化検知ステップ（ステップＳ４０２）の処理は、解析対象監視手段８０１によって実行される。また、事前解析対象決定ステップ（ステップＳ４０３）の処理は、事前解析対象生成手段８０２によって実行される。また、事前解析依頼ステップ（ステップＳ４０４）の処理は、事前解析依頼手段８０３によって実行される。また、事前解析結果登録ステップ（ステップＳ４０５）の処理は、事前解析結果登録手段８０４によって実行される。また、事前解析結果回答ステップ（ステップＳ４０６）の処理は、解析命令受付手段６によって実行される。
【０１１５】
以上のように、本実施形態によれば、事前解析制御手段８により、事業者ユーザからデータ解析のサービスを要求される前に、事前に解析を実行しておく。そして、実際にデータ解析の要求があった場合に、この事前解析結果を用いて解析サービスを事業者ユーザに対して提供する。そのようにすることによって、事業者ユーザが解析要求の操作を行ってから解析結果を得られるまでの時間を大きく短縮することができ、高速な解析サービスの提供の処理を可能とすることができる。従って、逐次的に発生するデータを収集して解析する場合であっても、サービス毎のレスポンスタイムの要望に応じた解析を行うことができる。
【０１１６】
なお、本実施形態では、データ毎に（例えば、ＷｅｂページのＵＲＬ毎に）、サービス要件を設定し、事前解析対象とするか否かを設定する場合を示しているが、サービス要件の設定の仕方は、本実施形態で示したものに限られない。例えば、複数種類の解析処理を実行可能である場合に、解析処理の種類毎にサービス要件を設定し、事前解析対象とするか否かを設定するようにしてもよい。以下、解析処理の種類毎にサービス要件を設定する場合の変形例について説明する。
【０１１７】
解析処理の種類（解析方法）毎にサービス要件を設定する場合、解析対象のデータ毎に解析方法が異なる場合でも動作するように、逐次発生データ解析システムは、図１に示した各手段の機能を拡張した以下の構成要素を含む。
【０１１８】
サービス提供手段１は、解析対象のデータとその解析方法とを入力する機能を備える。また、サービス要件設定手段２は、解析対象のデータと解析方法との組に対して、レスポンスタイムの要件（サービス要件）を設定する機能を備える。
【０１１９】
また、解析手段５は、複数種類の解析を受け付け、複数種類の解析処理を実行する機能を備える。また、事前解析制御手段８は、サービス要件設定手段２が設定した設定情報に基づいて、事前に解析すべき対象データと、事前に解析すべき対象とする解析方法とを決定する機能を備える。また、事前解析制御手段８は、解析手段５に対して解析対象と解析方法とを指定して事前解析処理を指示する機能を備える。また、解析結果記憶手段７は、事前解析結果として、解析対象と解析方法との組に対して、事前解析処理を行った事前解析結果を記憶する。
【０１２０】
また、解析命令受付手段６は、解析対象と解析方法との組に対して、解析結果記憶手段７に記憶している事前解析結果を利用するか、解析手段５に新たに解析処理を実行させるかを判断する機能を備える。
【０１２１】
具体的には、サービス提供手段１は、例えば、図３に示した入力画面の解析ボタンＵ０２を解析処理の種類を選択可能に構成し、事業者ユーザの操作に従って、解析処理の種類（解析方法）を入力可能にすればよい。例えば、サービス提供手段１は、プルダウンメニューで解析方法の一覧を表示するようにすればよい。
【０１２２】
また、サービス要件設定手段２は、例えば、図４に示すサービス要件の設定テーブルにおいて、解析方法の設定内容を含むフィールドＴ０２−０３を追加したテーブルを用いて、サービス要件を設定し記憶するようにすればよい。なお、サービス提供手段１とサービス要件設定手段２とは、例えば、解析方法を解析名で指定して処理を行ってもよいし、内部的に解析方法を特定可能なＩＤ（解析ＩＤ）を指定して管理し処理を実行してもよい。
【０１２３】
また、解析手段５は、複数種類の解析方法で解析処理を実行可能である。この場合、例えば、解析命令受付手段６や事前解析制御手段８は、パラメータとして、解析対象のＵＲＬに加えて、解析名又は解析ＩＤを含む解析依頼を、解析手段５に対して出力するようにすればよい。そして、解析手段５は、入力した解析依頼に含まれる解析名又は解析ＩＤに従って、指定された種類の解析処理を実行するようにすればよい。
【０１２４】
また、事前解析制御手段８は、解析対象のＵＲＬのみに基づいて事前解析対象のデータを判断するのではなく、解析対象のＵＲＬと解析方法との組に基づいて、事前解析対象のデータ及び解析方法を判断し、事前解析処理の制御を行うようにすればよい。例えば、事前解析制御手段８は、サービス要件設定手段２が設定したサービス要件を検索する場合において、ＵＲＬのフィールドＴ０２−０１と解析方法のフィールドＴ０２ー０３との組を検索キーとして、事前解析対象のデータ及び解析方法を検索するようにすればよい。また、事前解析制御手段８は、解析手段５に対して事前解析処理の実行を依頼する場合に、解析対象のデータのＵＲＬに加えて、解析方法もパラメータとして含む解析依頼を出力するようにすればよい。
【０１２５】
また、解析結果記憶手段７は、例えば、図７に示した解析結果管理テーブルにおいて、解析方法を含むフィールドＴ０７−０３を追加したテーブルを記憶するようにすればよい。
【０１２６】
また、解析命令受付手段６は、サービス提供手段１から、解析対象のＵＲＬと解析方法とを指定する情報を受け取る（入力する）。そして、解析命令受付手段６は、入力した解析対象のＵＲＬと解析方法との組に基づいて、事前解析結果を利用可能であるか否かをチェック（判断）する。この場合、例えば、解析命令受付手段６は、入力した解析対象のＵＲＬと解析方法との組を検索キーとして、解析結果記憶手段７が記憶する解析結果管理テーブルのＵＲＬフィールドＴ０７−０１と解析方法フィールドＴ０７−０３とを検索するようにすればよい。また、解析命令受付手段６は、解析手段５に解析処理の実行を依頼する際には、解析対象のデータのＵＲＬに加えて、解析方法もパラメータとして指定した解析依頼を出力するようにすればよい。
【０１２７】
以上のように構成することによって、解析対象のデータ毎に解析方法が異なる場合であっても、事前解析を行うことができ、高速な解析サービスの提供の処理を可能とすることができる。
【０１２８】
実施形態２．
次に、本発明の第２の実施形態を図面を参照して説明する。図１２は、第２の実施形態における逐次発生データ解析システムの構成の一例を示すブロック図である。また、図１３は、第２の実施形態における事前解析制御手段８のより詳細な構成例を示すブロック図である。
【０１２９】
図１２に示すように、本実施形態では、逐次発生データ解析システムが、図１に示した構成要素に加えて、解析命令履歴手段９を含む点で、第１の実施形態と異なる。
【０１３０】
解析命令履歴手段９は、具体的には、情報処理装置が備えるメモリや磁気ディスク装置、光ディスク装置等の記憶装置によって実現される。解析命令履歴手段９は、解析命令受付手段６で受け付けた解析要求のクエリの履歴を示す解析命令履歴情報を記憶する。
【０１３１】
また、図１３に示すように、本実施形態では、事前解析制御手段８が、図８に示した構成要素に加えて、優先事前解析判定手段８０５を含む点で、第１の実施形態と異なる。
【０１３２】
優先事前解析判定手段８０５は、解析命令履歴手段９が記憶する解析命令履歴情報のうち多く出現する命令ほど優先的に事前解析するように、解析履歴数をカウントし、優先度を判定する機能を備える。
【０１３３】
図１４は、第２の実施形態における逐次発生データ解析システムの物理的なサーバ構成の例を示すブロック図である。図１４に示すように、本実施形態における逐次発生データ解析システムを構成する場合、解析命令履歴手段９を、例えば、データ解析受付サーバ１０４が備えるように構成すればよい。ただし、図１４に示す例は一例であり、例えば、解析命令履歴手段９をデータ高速解析サーバ１０５が備えるようにしてもよく、解析命令受付手段６と通信を行うことによって解析命令の履歴情報を受け取る（入力する）ようにしてもよい。
【０１３４】
解析命令履歴手段９は、サービス提供手段１が要求した解析要求のクエリの履歴情報を記憶する。この場合、解析命令履歴手段９は、解析命令受付手段６を経由して入力する解析要求のクエリに従って、解析命令履歴情報を記憶する。すなわち、解析命令受付手段６は、解析要求のクエリを受け付ける（入力する）度に、解析命令履歴手段９に履歴情報を登録する。
【０１３５】
図１５は、解析命令履歴手段９が記憶する解析命令履歴情報の例を示す説明図である。図１５に示すように、解析命令履歴手段９は、日時（Ｔ０９−０１）と、ＵＲＬ（Ｔ０９−０２）とを対応付けて記憶する。なお、日時（Ｔ０９−０１）は、解析命令受付手段６が解析要求のクエリを受け付けた日時である。また、ＵＲＬ（Ｔ０９−０２）は、コマンドGetReferrerRankingを含むクエリで指定されているＵＲＬパラメータの値である。
【０１３６】
優先事前解析判定手段８０５は、事前解析対象生成手段８０２から解析対象のデータの追加ＵＲＬを受け取り（入力し）、それぞれの追加ＵＲＬの出現頻度を、解析命令履歴手段９が記憶するＵＲＬ（Ｔ０９−０２）に基づいてカウントする。また、優先事前解析判定手段８０５は、このカウントした数に応じて追加ＵＲＬを降順にソートして、そのソート結果を事前解析対象生成手段８０２に返す（出力する）。
【０１３７】
なお、優先事前解析判定手段８０５は、出現頻度のカウントを行う場合、例えば、追加ＵＲＬ毎に、解析命令履歴手段９が記憶するＵＲＬフィールド（Ｔ０９−０２）のＵＲＬをマッチング（照合）してレコード数をカウントすればよい。
【０１３８】
また、事前解析対象生成手段８０２は、ソート済みの追加ＵＲＬを受け取ると（入力すると）、ソートされた追加ＵＲＬのうち、先頭から順に解析手段５に１つずつ解析処理を依頼する制御を行う。
【０１３９】
一般的に、解析手段５が実行する解析処理にかかる解析時間は、数分から数時間かかる重い処理である。そのため、第１の実施形態で示した逐次発生データ解析システムのように、解析対象として求めた追加ＵＲＬのデータを一括して一気に解析すると、膨大な解析時間がかかることがあり、しばらく解析結果が返ってこない。この場合、解析処理を実行している間、解析結果記憶手段７が記憶する事前解析を更新できないことになってしまい改善の余地がある。
【０１４０】
例えば、実際の解析サービスの利用態様を考慮すると、事前解析の処理が行われ解析結果記憶手段７に記憶される情報の中には、事業者ユーザによって提供を要求されるものもあれば、実際には全く要求されないものもありうる。このような場合に、事前解析処理を一括して行うようにしてしまうと、全ての解析処理が終了するまでは、事前解析結果を利用することができず、却って利用頻度の高い解析結果の提供を高速に受けられなくなってしまう可能がある。また、実際には事業者ユーザに利用されないにもかかわらず、長時間にわたって無駄な事前解析処理を行うような事態が生じてしまう可能性もありうる。
【０１４１】
そこで、本実施形態では、事前解析対象のデータを一括して処理するのではなく、より出現頻度の高い解析要求のクエリに対するデータを優先的に事前解析することによって、事前解析処理を優先順位に従って時間分散して実行することにより、優先度の高いデータの解析結果を高速に得られなくなる事態を防止している。
【０１４２】
なお、本実施形態では、出現頻度に応じて事前解析処理の優先度を決める場合を示したが、事前解析処理の優先度の決め方は、本実施形態で示したものに限られず、例えば、解析時間の短い順に優先度を決定して事前解析処理を実行するようにしてもよい。
【０１４３】
次に、動作について説明する。図１６は、第２の実施形態における逐次発生データ解析システムが逐次発生データの解析を行う処理の一例を示す流れ図である。図１６に示すように、本実施形態では、解析命令受付手段６は、解析命令受付ステップ（ステップＳ５０１）の処理を実行した後に、解析命令受付ステップ（ステップＳ５０１）で受け付けた解析要求のクエリの履歴を示す解析命令履歴情報を蓄積する解析命令履歴ステップ（ステップＳ５０６）の処理を実行する。そして、解析命令受付手段６は、解析命令履歴ステップ（ステップＳ５０６）の処理を実行した後に、事前解析利用可能性チェックステップ（ステップＳ５０２）の処理を実行する。
【０１４４】
また、図１７は、第２の実施形態における事前解析処理の一例を示す流れ図である。図１７に示すように、本実施形態では、事前解析制御手段８は、事前解析ステップ（ステップＳ４）の解析対象変化検出ステップ（ステップＳ４０２）の処理を実行した後に、解析命令履歴情報の中に多く出現する命令ほど優先的に事前解析するように解析履歴数をカウントし、優先度を判定する優先時全解析判定ステップ（ステップＳ４０２）の処理を実行する。そして、事前解析制御手段８は、優先時全解析判定ステップ（ステップＳ４０２）の処理を実行した後に、事前解析対象決定ステップ（ステップＳ４０３）の処理を実行する。
【０１４５】
なお、本実施形態では、例えば、解析命令履歴ステップ（ステップＳ５０６）の処理は、解析命令受付手段６が履歴情報を解析命令履歴手段９に記憶させることによって実行される。また、優先事前解析判定ステップ（ステップＳ４０７）の処理は、優先事前解析判定手段８０５によって実行される。
【０１４６】
以上のように、本実施形態によれば、解析命令履歴手段９と優先事前解析判定手段８０５とにより、事業者ユーザからの解析要求を受けた頻度を考慮して、事前解析を実行する優先度を判定し、判定した優先度に従って事前解析を時間分散して実行する。そのため、より効果的に高速な解析処理を実行することを可能とすることができる。
【０１４７】
実施形態３．
次に、本発明の第３の実施形態を図面を参照して説明する。図１８は、第３の実施形態における逐次発生データ解析システムの構成の一例を示すブロック図である。また、図１９は、第３の実施形態における事前解析制御手段８のより詳細な構成例を示すブロック図である。
【０１４８】
図１８に示すように、本実施形態では、逐次発生データ解析システムが、図１に示した構成要素に加えて、解析コスト監視手段１０を含む点で、第１の実施形態と異なる。なお、逐次発生データ解析システムは、第２の実施形態で示した構成要素に加えて解析コスト監視手段１０を含むように構成されてもよい。
【０１４９】
解析コスト監視手段１０は、具体的には、プログラムに従って動作する情報処理装置のＣＰＵ、及びメモリ等の記憶装置によって実現される。解析コスト監視手段１０は、解析手段５が実行する各解析処理にかかった時間を監視する機能を備える。
【０１５０】
また、図１９に示すように、本実施形態では、事前解析制御手段８が、図８に示した構成要素に加えて、優先事前解析判定手段８０５Ａを含む点で、第１の実施形態と異なる。
【０１５１】
優先事前解析判定手段８０５Ａは、解析コスト監視手段１０の監視結果に基づいて、事前解析制御手段８によって解析コストが高い命令を優先的に事前解析する制御がされるように、優先度を判定する機能を備える。なお、優先事前解析判定手段８０５Ａは、第２の実施形態で示した優先事前解析判定手段８０５と同様の優先度判定機能も備えていてもよい。
【０１５２】
図２０は、第３の実施形態における解析コスト監視手段１０のより詳細な構成例を示すブロック図である。図２０に示すように、解析コスト監視手段１０は、解析コスト算出手段１００１及び解析コスト記憶手段１００２を含む。
【０１５３】
解析コスト算出手段１００１は、解析開始の時間を一時的にメモリ等の記憶装置に記憶しておき、解析終了の時間を解析手段５から受け取った（入力した）タイミングで、例えば、解析にかかった時間を算出することによって、解析のコストを算出する機能を備える。また、解析コスト記憶手段１００２は、解析コスト算出手段１００１の算出結果（解析処理毎の解析コスト）を記憶する。
【０１５４】
図２１は、第３の実施形態における逐次発生データ解析システムの物理的なサーバ構成の例を示すブロック図である。図２１に示すように、本実施形態における逐次発生データ解析システムを構成する場合、の解析コスト監視手段１０を、例えば、解析サーバ１０２が備えるように構成すればよい。ただし、図２１に示す例は一例であり、例えば、解析コスト監視手段１０をデータ高速解析サーバ１０５が備えるようにしてもよく、解析手段５と通信を行うことによって解析状況を受け取る（入力する）ようにしてもよい。
【０１５５】
解析手段５は、解析処理を実行する際に、解析開始と解析終了とのタイミングで、それぞれ開始命令と終了命令とを解析コスト監視手段１０に出力する。例えば、解析手段５は、以下に示すフォーマットで開始命令や終了命令を出力する。
【０１５６】
解析開始：
開始命令のフォーマット：（StartAnalysis ，解析対象のデータのＵＲＬ）
例：（StartAnalysis ，”http://bar.co.jp/~foo/Page-001”）
【０１５７】
解析終了：
終了命令のフォーマット：（EndAnalysis ，解析対象のデータのＵＲＬ）
例：（EndAnalysis ，”http://bar.co.jp/~foo/Page-001”）
【０１５８】
ここで、StartAnalysis とEndAnalysis とは、コマンド名である。なお、開始命令や終了命令に含まれるコマンド名は、上記に示した表現のものに限られない。また、開始命令や終了命令のフォーマット自体も一例であり、上記に示した表現のものに限られない。
【０１５９】
解析コスト算出手段１００１は、解析手段から、StartAnalysis のコマンドを含む開始命令と、EndAnalysis のコマンドを含む終了命令とを受け取る（入力する）。そして、解析コスト算出手段１００１は、開始命令と終了命令とを入力した時間差を求めることによって、各解析処理にかかるコスト（時間）を算出する。
【０１６０】
図２２は、解析コスト算出手段１００１が記憶する情報の例を示す説明図である。図２２に示すように、解析コスト算出手段１００１は、StartAnalysis のコマンドを含む開始命令を受けた際に、開始時間をＵＲＬ毎に対応付けてテーブルとして記憶する。なお、図２２において、ＵＲＬ（Ｔ１０−０１）は、解析を開始したデータのＵＲＬである。また、解析開始時間（Ｔ１０−０２）は、解析を開始した時間である。
【０１６１】
解析コスト算出手段１００１は、EndAnalysis のコマンドを含む終了命令を受けた（入力した）際には、この終了命令に含まれるＵＲＬの値と、記憶するＵＲＬ（Ｔ１０−０１）とをマッチイング（照合）する。次いで、解析コスト算出手段１００１は、合致したＵＲＬに対応する解析開始時間（Ｔ１０−０２）を抽出する。そして、解析コスト算出手段１００１は、抽出した解析開始時間（Ｔ１０−０２）の値と現在時刻との差を求めることによって、この解析処理にかかったコストを算出する。
【０１６２】
解析コスト記憶手段１００２は、解析コスト算出手段１００１から解析処理のコストの算出結果を受け取り（入力し）記憶する。この場合、解析コスト算出手段１００１は、例えば、以下に示すフォーマットで解析コストの算出結果を出力する。
【０１６３】
解析コストの算出結果のフォーマット：（SetCost 、解析のＵＲＬ、解析コスト）
例：（SetCost ，”http://bar.co.jp/~foo/Page-001，10）
【０１６４】
また、解析コスト記憶手段１００２は、解析コストの算出結果を、図２３に示すフォーマットのテーブルとして記憶する。なお、図２３において、ＵＲＬ（Ｔ１０−０３）は、解析対象データのＵＲＬである。また、解析コスト（Ｔ１０−０４）は、解析コスト算出手段１００１が求めた解析にかかった時間の合計である。
【０１６５】
解析コスト算出手段１００１は、SetCost 命令を出力し、この命令のＵＲＬの値をキーとして、解析コスト記憶手段１００２が記憶するテーブルのＵＲＬフィールド（Ｔ１０−０３）を検索する。そして、解析コスト算出手段１００１は、この検索して特定したレコードの解析コストフィールド（Ｔ１０−０４）の値と、SetCost 命令に含まれる解析コストとの合計を、解析コスト記憶手段１００２が記憶する解析コストフィールド（Ｔ１０−０４）の値に上書きさせる。
【０１６６】
なお、本実施形態で示した解析処理のコスト計算方法は一例であり、解析コスト算出手段１００１は、例えば、合計値ではなく、平均値等を解析コストとして求めてもよい。また、解析コスト算出手段１００１が出力する命令のフォーマット等も一例であり、本実施形態で示したものに限られない。
【０１６７】
事前解析制御手段８は、第２の実施形態では、解析命令履歴情報のデータ数に従って事前解析対象のデータの追加ＵＲＬをソートする処理を実行していたが、本実施形態では、解析コスト記憶手段１００２が記憶する解析コスト（Ｔ１０−０４）の値に従ってソートするようにすればよい。そして、事前解析制御手段８は、事前解析対象のデータを一括して処理するのではなく、例えば、解析コストが小さい順に優先処理することによって、時間的に分散処理するようにすればよい。
【０１６８】
なお、解析コスト記憶手段１００２には、解析手段５でまだ一度も解析処理が実行されていない場合には、まだエントリがない。この場合には、解析コスト記憶手段１００２に、予め固定値（デフォルト値）を計算コストとして記憶させておく等、運用でカバーするようにすればよい。
【０１６９】
また、第２の実施形態で示した優先度の判定処理と、第３の実施形態で示した優先度の判定処理とを組み合わせて用いるようにしてもよい。この場合には、優先事前解析判定手段８０５は、カウントの値と解析コストの値とを適当なウエイトで合計したスコアを求めて、その求めたスコアに従って解析対象のデータの追加ＵＲＬをソートすればよい。なお、このソート方法は一例であり、優先事前解析判定手段８０５が、カウントの値と解析コストの値とに基づいて、解析対象のデータの追加ＵＲＬをソートする方法は、本実施形態で示した方法に限られない。
【０１７０】
次に、動作について説明する。図２４は、第３の実施形態における逐次発生データ解析システムが逐次発生データの解析を行う処理の一例を示す流れ図である。図２４に示すように、本実施形態では、第１の実施形態や第２の実施形態で示した処理に加えて、解析コスト監視手段１０は、解析コスト監視ステップ（ステップＳ６）の処理を実行する。
【０１７１】
また、図２５は、第３の実施形態における事前解析処理の一例を示す流れ図である。図２５に示すように、本実施形態では、事前解析制御手段８は、解析対象変化検出ステップ（ステップＳ４０２）の処理を実行した後に、解析コスト監視ステップ（ステップＳ６）で算出した各解析処理のコストを用いて事前解析すべきデータの優先度付けを判定する優先事前解析判定ステップ（ステップＳ４０７）の処理を実行する。また、事前解析制御手段８は、優先事前解析判定ステップ（ステップＳ４０７）の処理を実行した後に、事前解析対象決定ステップ（ステップＳ４０３）の処理を実行する。
【０１７２】
なお、本実施形態では、例えば、解析コスト監視ステップ（ステップＳ６）の処理は、解析コスト監視手段１０によって実行される。また、優先事前解析判定ステップ（ステップＳ４０７）の処理は、優先事前解析判定手段８０５によって実行される。
【０１７３】
以上のように、本実施形態によれば、解析コスト監視手段１０により、解析処理にかかる時間を考慮して、事前解析を実行する優先度を判定し、判定した優先度に従って事前解析を時間分散して実行する。そのため、より効果的に高速な解析処理を実行することを可能とすることができる。
【０１７４】
なお、本実施形態において、さらに、第２の実施形態と同様に、解析命令履歴手段９も備えるように構成するようにしてもよい。そのように構成すれば、解析処理にかかる時間に加えて、さらに事業者ユーザからの解析要求を受けた頻度も考慮して、事前解析を実行する優先度を判定し、判定した優先度に従って事前解析を時間分散して実行することができる。そのため、さらに、より効果的に高速な解析処理を実行することを可能とすることができる。
【０１７５】
実施形態４．
次に、本発明の第４の実施形態を図面を参照して説明する。図２６は、第４の実施形態における事前解析制御手段８のより詳細な構成例を示すブロック図である。図２６に示すように、本実施形態では、事前解析制御手段８が、図８に示した構成要素に加えて、空き記憶容量監視手段８０６を含む点で、第１の実施形態と異なる。なお、事前解析制御手段８は、第２の実施形態又は第３の実施形態で示した構成要素に加えて空き記憶容量監視手段８０６を含むように構成されていてもよい。
【０１７６】
空き記憶容量監視手段８０６は、事前に解析する対象とするデータを絞り込むために、事前解析制御手段８が動作する情報処理装置（ＰＣ）のメモリ等のリソースの空き容量を監視する機能を備える。
【０１７７】
空き記憶容量監視手段８０６は、リソースの空き容量と事前解析可能なデータ数との関係を設定したテーブルに事前にセットしている。そして、空き記憶容量監視手段８０６は、予めセットしたテーブルに従って、事前解析可能なデータ数を求める。
【０１７８】
図２７は、空き記憶容量監視手段８０６が予め設定するテーブルの例を示す説明図である。図２７に示すように、空き記憶容量監視手段８０６は、予め空き記憶容量（Ｔ０８０６−０１）と事前解析可能数（Ｔ０８０６−０２）とを対応付けたテーブルをセットする。なお、空き記憶容量（Ｔ０８０６−０１）は、事前解析制御手段８が動作する情報処理装置が備えるメモリ等のリソースの全容量のうち、利用可能な空き記憶容量である。また、事前解析可能数（Ｔ０８０６−０２）は、その空き記憶容量に対する事前解析可能なデータの最大数である。
【０１７９】
空き記憶容量監視手段８０６は、事前解析対象生成手段８０２から事前解析可能なデータ数の問い合わせを受けると（算出要求を入力すると）、事前解析制御手段８が動作する情報処理装置（ＰＣ）のシステムコールからメモリ等のリソースの空き記憶容量を取得（抽出）する。そして、空き記憶容量監視手段８０６は、抽出した空き記憶容量に基づいて、図２７に示すテーブルから、対応する事前解析可能数を抽出する。そのように処理することによって、空き記憶容量監視手段８０６は、事前解析可能な数を算出し、事前解析対象生成手段８０２に対して算出結果を返答（出力）する。例えば、図２７に示す例の場合、空き記憶容量監視手段８０６は、空き容量を７００Ｋｂｙｔｅと抽出したときには、事前解析可能なデータ数を５０と算出して回答（出力）する。
【０１８０】
なお、事前解析制御手段８が動作する情報処理装置において複数のアプリケーションが動作している場合には、空き記憶容量監視手段８０６は、同じ情報処理装置上で動作する他のアプリケーションで使用されるメモリ容量も考量して監視するようにしてもよい。
【０１８１】
事前解析対象生成手段８０２は、事前解析対象を決定する際に、空き記憶容量監視手段８０６に事前解析可能数を問い合わせて、事前解析可能なデータ数を取得（算出結果を入力）する。そして、事前解析対象生成手段８０２は、事前解析可能なデータ数よりも、事前解析対象のデータ数の方が多い場合には、解析対象のデータを絞り込む処理を行う。
【０１８２】
なお、事前解析対象生成手段８０２は、事前解析対象のデータの絞り込みを行う場合、例えば、第２の実施形態や第３の実施形態のように、事前解析対象のデータの追加ＵＲＬが優先度に従ってソートされている場合には、優先度の低いものから順に、事前解析の候補から削除すればよい。また、第１の実施形態のように追加ＵＲＬのソートを行っていない場合には、事前解析対象生成手段８０２は、事前解析対象のデータをランダムに削除するようにすればよい。
【０１８３】
次に、動作について説明する。図２８は、第４の実施形態における逐次発生データ解析システムが逐次発生データの解析を行う処理の一例を示す流れ図である。図２８に示すように、本実施形態では、第１の実施形態や第２の実施形態、第３の実施形態で示した処理に加えて、事前解析制御手段８は、情報処理装置（ＰＣ）のメモリ等のリソースの空き容量に基づいて、事前に解析可能なデータ数を見積る空き記憶容量監視ステップ（ステップＳ７）の処理を実行する。
【０１８４】
また、図２９は、第４の実施形態における事前解析処理の一例を示す流れ図である。図２９に示すように、本実施形態では、事前解析制御手段８は、解析対象変化検出ステップ（ステップＳ４０２）の処理を実行した後に、空き記憶容量監視ステップ（ステップＳ７）の処理で算出した解析可能なデータ数に基づいて、事前解析の対象データを絞り込む事前解析対象絞り込みステップ（ステップＳ４０８）の処理を実行する。また、事前解析制御手段８は、事前解析対象絞り込みステップ（ステップＳ４０８）の処理を実行した後に、事前解析対象決定ステップ（ステップＳ４０３）の処理を実行する。
【０１８５】
なお、本実施形態では、例えば、空き記憶容量監視ステップ（ステップＳ７）の処理は、空き記憶容量監視手段８０６によって実行される。また、事前解析対象絞り込みステップ（ステップＳ４０８）の処理は、優先事前解析判定手段８０２によって実行される。
【０１８６】
以上のように、本実施形態によれば、空き記憶容量監視手段８０６により、解析処理を実行する情報処理装置（ＰＣ）の空きリソース等を考慮して、事前解析を実行する優先度を判定し、事前解析対象とするデータを絞り込む。そのため、解析処理を実行する情報処理装置のリソース不足により事前解析を行えなくなる事態を防止することができ、より効果的に高速な解析処理を実行することを可能とすることができる。
【０１８７】
次に、本発明による逐次発生データ解析装置の最小構成について説明する。図３０は、逐次発生データ解析装置の最小の構成例を示すブロック図である。図３０に示すように、逐次発生データ解析装置は、最小の構成要素として、事前解析制御手段８を含む。図３０において、事前解析制御手段８は、解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う機能を備える。
【０１８８】
図３０に示す最小構成の逐次発生データ解析装置によれば、逐次的に発生するデータを収集して解析する場合であっても、サービス毎のレスポンスタイムの要望に応じた解析を行うことができる。
【０１８９】
なお、上記に示した各実施形態では、以下の（１）〜（１８）に示すような逐次発生データ解析装置の特徴的構成が示されている。
【０１９０】
（１）逐次発生データ解析装置（例えば、データ高速解析サーバ１０５。例えば、解析サーバ１０２、データ解析受付サーバ１０４、及びデータ高速解析サーバ１０５を実現する情報処理装置。）は、解析要求よりも前に、逐次発生するデータである逐次発生データ（例えば、Ｗｅｂサーバが出力するログデータ、温度センサや湿度センサが出力するデータ）を事前解析する処理を実行させる制御を行う事前解析制御手段（例えば、事前解析制御手段８によって実現される）を備えたことを特徴とする。
【０１９１】
（２）また、逐次発生データ解析装置は、解析要求が発生したときに、解析対象の逐次発生データが既に事前解析制御手段による制御によって事前解析されているか否かを判定する解析方法判定手段（例えば、解析命令受付手段６によって実現される）を備え、解析方法判定手段は、事前解析されていないと判定すると、解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力し、既に事前解析されていると判定すると、既に事前解析されている解析結果を出力するように構成されていてもよい。
【０１９２】
（３）また、逐次発生データ解析装置は、事前解析制御手段による制御によって事前解析された事前解析結果を記憶する事前解析結果記憶手段（例えば、解析結果記憶手段７によって実現される）を備え、解析方法判定手段は、解析要求が発生したときに、解析対象の逐次発生データに対応する事前解析結果が事前解析結果記憶手段に記憶されているか否かを判定することによって、解析対象の逐次発生データが既に事前解析されているか否かを判定するように構成されていてもよい。
【０１９３】
（４）また、逐次発生データ解析装置において、事前解析制御手段は、予め設定された、事前解析する対象とする条件を示す事前解析条件（例えば、サービス要件）に基づいて、事前解析対象とする逐次発生データを判断し、当該逐次発生データを事前解析する処理を実行させる制御を行うように構成されていてもよい。
【０１９４】
（５）また、逐次発生データ解析装置において、事前解析制御手段は、逐次発生データの発生状況を監視する逐次発生データ監視手段（例えば、解析対象監視手段８０１によって実現される）と、逐次発生データ監視手段の監視結果と、事前解析条件設定手段によって設定された事前解析条件とに基づいて、優先して事前解析の対象とすべき逐次発生データを特定する事前解析対象特定手段（例えば、事前解析対象生成手段８０２によって実現される）と、事前解析対象特定手段が特定した事前解析対象の逐次発生データの解析を実行させる制御を行う事前解析実行制御手段（例えば、事前解析依頼手段８０３によって実現される）と、事前解析実行制御手段の制御により実行された事前解析の解析結果を、事前解析結果を記憶する事前解析結果記憶手段に記憶させる事前解析結果登録手段（例えば、事前解析結果登録手段８０４によって実現される）とを含むように構成されていてもよい。
【０１９５】
（６）また、逐次発生データ解析装置は、解析要求の履歴情報を記憶する解析要求履歴記憶手段（例えば、解析命令履歴手段９によって実現される）を備え、事前解析制御手段は、解析要求履歴記憶手段が記憶する履歴情報に基づいて、出現頻度が高い解析要求に対応する逐次発生データを優先して事前解析対象とするように、事前解析対象とする逐次発生データの優先度を判定する出現頻度優先事前解析判定手段（例えば、優先事前解析判定手段８０５によって実現される）を含むように構成されていてもよい。
【０１９６】
（７）また、逐次発生データ解析装置は、逐次発生データの解析にかかった解析コストを監視する解析コスト監視手段（例えば、解析コスト監視手段１０によって実現される）を備え、事前解析制御手段は、解析コスト監視手段の監視結果に基づいて、事前解析対象とする逐次発生データの優先度を判定する解析コスト優先事前解析判定手段（例えば、優先事前解析判定手段８０５Ａによって実現される）を含むように構成されていてもよい。
【０１９７】
（８）また、逐次発生データ解析装置において、解析コスト監視手段は、逐次発生データの解析を開始した時間である開始時間を一時記憶し、逐次発生データの解析を終了したときに、当該解析を終了した時間である終了時間と、一時記憶した開始時間とに基づいて、解析コストを算出する解析コスト算出手段（例えば、解析コスト算出手段１００１によって実現される）と、解析コスト算出手段の算出結果を記憶する解析コスト記憶手段（例えば、解析コスト記憶手段１００２によって実現される）とを含むように構成されていてもよい。
【０１９８】
（９）また、逐次発生データ解析装置は、逐次発生データの解析処理に用いる情報処理装置のリソースの空き容量を監視するリソース監視手段（例えば、空き記憶容量監視手段８０６によって実現される）を備え、事前解析制御手段は、リソース監視手段の監視結果に基づいて、事前解析する対象とする逐次発生データを絞り込むように構成されていてもよい。
【０１９９】
（１０）逐次発生データ解析装置は、解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御部を備えるように構成されていてもよい。
【０２００】
（１１）また、逐次発生データ解析装置は、解析要求が発生したときに、解析対象の逐次発生データが既に事前解析制御部による制御によって事前解析されているか否かを判定する解析方法判定部を備え、解析方法判定部は、事前解析されていないと判定すると、解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力し、既に事前解析されていると判定すると、既に事前解析されている解析結果を出力するように構成されていてもよい。
【０２０１】
（１２）また、逐次発生データ解析装置は、事前解析制御部による制御によって事前解析された事前解析結果を記憶する事前解析結果記憶部を備え、解析方法判定部は、解析要求が発生したときに、解析対象の逐次発生データに対応する事前解析結果が事前解析結果記憶部に記憶されているか否かを判定することによって、解析対象の逐次発生データが既に事前解析されているか否かを判定するように構成されていてもよい。
【０２０２】
（１３）また、逐次発生データ解析装置において、事前解析制御部は、予め設定された、事前解析する対象とする条件を示す事前解析条件に基づいて、事前解析対象とする逐次発生データを判断し、当該逐次発生データを事前解析する処理を実行させる制御を行うように構成されていてもよい。
【０２０３】
（１４）また、逐次発生データ解析装置において、事前解析制御部は、逐次発生データの発生状況を監視する逐次発生データ監視部と、逐次発生データ監視部の監視結果と、事前解析条件設定部によって設定された事前解析条件とに基づいて、優先して事前解析の対象とすべき逐次発生データを特定する事前解析対象特定部と、事前解析対象特定部が特定した事前解析対象の逐次発生データの解析を実行させる制御を行う事前解析実行制御部と、事前解析実行制御部の制御により実行された事前解析の解析結果を、事前解析結果を記憶する事前解析結果記憶部に記憶させる事前解析結果登録部とを含むように構成されていてもよい。
【０２０４】
（１５）また、逐次発生データ解析装置は、解析要求の履歴情報を記憶する解析要求履歴記憶部を備え、事前解析制御部は、解析要求履歴記憶部が記憶する履歴情報に基づいて、出現頻度が高い解析要求に対応する逐次発生データを優先して事前解析対象とするように、事前解析対象とする逐次発生データの優先度を判定する出現頻度優先事前解析判定部を含むように構成されていてもよい。
【０２０５】
（１６）また、逐次発生データ解析装置は、逐次発生データの解析にかかった解析コストを監視する解析コスト監視部を備え、事前解析制御部は、解析コスト監視部の監視結果に基づいて、事前解析対象とする逐次発生データの優先度を判定する解析コスト優先事前解析判定部を含むように構成されていてもよい。
【０２０６】
（１７）また、逐次発生データ解析装置において、解析コスト監視部は、逐次発生データの解析を開始した時間である開始時間を一時記憶し、逐次発生データの解析を終了したときに、当該解析を終了した時間である終了時間と、一時記憶した開始時間とに基づいて、解析コストを算出する解析コスト算出部と、解析コスト算出部の算出結果を記憶する解析コスト記憶部とを含むように構成されていてもよい。
【０２０７】
（１８）また、逐次発生データ解析装置は、逐次発生データの解析処理に用いる情報処理装置のリソースの空き容量を監視するリソース監視部を備え、事前解析制御部は、リソース監視部の監視結果に基づいて、事前解析する対象とする逐次発生データを絞り込むように構成されていてもよい。
【０２０８】
また、上記に示した各実施形態では、以下の（１９）〜（３６）に示すような逐次発生データ解析システムの特徴的構成が示されている。
【０２０９】
（１９）逐次発生データ解析システムは、逐次発生するデータである逐次発生データを発生するデータ発生装置（例えば、アプリケーションサーバ１０１）と、データ発生手段が発生する逐次発生データの解析処理を実行する逐次発生データ解析装置（例えば、データ高速解析サーバ１０５。例えば、解析サーバ１０２、データ解析受付サーバ１０４、及びデータ高速解析サーバ１０５を実現する情報処理装置。）と、逐次発生データ解析装置の解析結果に基づいて、データ解析サービスを提供する処理を実行するサービス提供装置（例えば、データ解析サービスサーバ１０３）とを備え、逐次発生データ解析装置は、解析要求よりも前に、逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御手段を含むことを特徴とする。
【０２１０】
（２０）逐次発生データ解析システムにおいて、逐次発生データ解析装置は、解析要求が発生したときに、解析対象の逐次発生データが既に事前解析制御手段による制御によって事前解析されているか否かを判定する解析方法判定手段を含み、解析方法判定手段は、事前解析されていないと判定すると、解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力し、既に事前解析されていると判定すると、既に事前解析されている解析結果を出力するように構成されていてもよい。
【０２１１】
（２１）また、逐次発生データ解析システムにおいて、逐次発生データ解析装置は、事前解析制御手段による制御によって事前解析された事前解析結果を記憶する事前解析結果記憶手段を含み、解析方法判定手段は、解析要求が発生したときに、解析対象の逐次発生データに対応する事前解析結果が事前解析結果記憶手段に記憶されているか否かを判定することによって、解析対象の逐次発生データが既に事前解析されているか否かを判定するように構成されていてもよい。
【０２１２】
（２２）また、逐次発生データ解析システムにおいて、サービス提供装置は、事前解析する対象とする条件を示す事前解析条件を設定する事前解析条件設定手段（例えば、サービス要件設定手段２によって実現される）を含み、事前解析制御手段は、事前解析条件設定手段によって設定された事前解析条件に基づいて、事前解析対象とする逐次発生データを判断し、当該逐次発生データを事前解析する処理を実行させる制御を行うように構成されていてもよい。
【０２１３】
（２３）また、逐次発生データ解析システムにおいて、事前解析制御手段は、逐次発生データの発生状況を監視する逐次発生データ監視手段と、逐次発生データ監視手段の監視結果と、事前解析条件設定手段によって設定された事前解析条件とに基づいて、優先して事前解析の対象とすべき逐次発生データを特定する事前解析対象特定手段と、事前解析対象特定手段が特定した事前解析対象の逐次発生データの解析を実行させる制御を行う事前解析実行制御手段と、事前解析実行制御手段の制御により実行された事前解析の解析結果を、事前解析結果を記憶する事前解析結果記憶手段に記憶させる事前解析結果登録手段とを含むように構成されていてもよい。
【０２１４】
（２４）また、逐次発生データ解析システムにおいて、逐次発生データ解析装置は、解析要求の履歴情報を記憶する解析要求履歴記憶手段を含み、事前解析制御手段は、解析要求履歴記憶手段が記憶する履歴情報に基づいて、出現頻度が高い解析要求に対応する逐次発生データを優先して事前解析対象とするように、事前解析対象とする逐次発生データの優先度を判定する出現頻度優先事前解析判定手段を含むように構成されていてもよい。
【０２１５】
（２５）また、逐次発生データ解析システムにおいて、逐次発生データ解析装置は、逐次発生データの解析にかかった解析コストを監視する解析コスト監視手段を含み、事前解析制御手段は、解析コスト監視手段の監視結果に基づいて、事前解析対象とする逐次発生データの優先度を判定する解析コスト優先事前解析判定手段を含むように構成されていてもよい。
【０２１６】
（２６）また、逐次発生データ解析システムにおいて、解析コスト監視手段は、逐次発生データの解析を開始した時間である開始時間を一時記憶し、逐次発生データの解析を終了したときに、当該解析を終了した時間である終了時間と、一時記憶した開始時間とに基づいて、解析コストを算出する解析コスト算出手段と、解析コスト算出手段の算出結果を記憶する解析コスト記憶手段とを含むように構成されていてもよい。
【０２１７】
（２７）また、逐次発生データ解析システムにおいて、逐次発生データ解析装置は、逐次発生データの解析処理に用いる情報処理装置のリソースの空き容量を監視するリソース監視手段を含み、事前解析制御手段は、リソース監視手段の監視結果に基づいて、事前解析する対象とする逐次発生データを絞り込むように構成されていてもよい。
【０２１８】
（２８）逐次発生データ解析システムは、逐次発生するデータである逐次発生データを発生するデータ発生装置と、データ発生部が発生する逐次発生データの解析処理を実行する逐次発生データ解析装置と、逐次発生データ解析装置の解析結果に基づいて、データ解析サービスを提供する処理を実行するサービス提供装置とを備え、逐次発生データ解析装置は、解析要求よりも前に、逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御部を含むように構成されていてもよい。
【０２１９】
（２９）逐次発生データ解析システムにおいて、逐次発生データ解析装置は、解析要求が発生したときに、解析対象の逐次発生データが既に事前解析制御部による制御によって事前解析されているか否かを判定する解析方法判定部を含み、解析方法判定部は、事前解析されていないと判定すると、解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力し、既に事前解析されていると判定すると、既に事前解析されている解析結果を出力するように構成されていてもよい。
【０２２０】
（３０）また、逐次発生データ解析システムにおいて、逐次発生データ解析装置は、事前解析制御部による制御によって事前解析された事前解析結果を記憶する事前解析結果記憶部を含み、解析方法判定部は、解析要求が発生したときに、解析対象の逐次発生データに対応する事前解析結果が事前解析結果記憶部に記憶されているか否かを判定することによって、解析対象の逐次発生データが既に事前解析されているか否かを判定するように構成されていてもよい。
【０２２１】
（３１）また、逐次発生データ解析システムにおいて、サービス提供装置は、事前解析する対象とする条件を示す事前解析条件を設定する事前解析条件設定部を含み、事前解析制御部は、事前解析条件設定部によって設定された事前解析条件に基づいて、事前解析対象とする逐次発生データを判断し、当該逐次発生データを事前解析する処理を実行させる制御を行うように構成されていてもよい。
【０２２２】
（３２）また、逐次発生データ解析システムにおいて、事前解析制御部は、逐次発生データの発生状況を監視する逐次発生データ監視部と、逐次発生データ監視部の監視結果と、事前解析条件設定部によって設定された事前解析条件とに基づいて、優先して事前解析の対象とすべき逐次発生データを特定する事前解析対象特定部と、事前解析対象特定部が特定した事前解析対象の逐次発生データの解析を実行させる制御を行う事前解析実行制御部と、事前解析実行制御部の制御により実行された事前解析の解析結果を、事前解析結果を記憶する事前解析結果記憶部に記憶させる事前解析結果登録部とを含むように構成されていてもよい。
【０２２３】
（３３）また、逐次発生データ解析システムにおいて、逐次発生データ解析装置は、解析要求の履歴情報を記憶する解析要求履歴記憶部を含み、事前解析制御部は、解析要求履歴記憶部が記憶する履歴情報に基づいて、出現頻度が高い解析要求に対応する逐次発生データを優先して事前解析対象とするように、事前解析対象とする逐次発生データの優先度を判定する出現頻度優先事前解析判定部を含むように構成されていてもよい。
【０２２４】
（３４）また、逐次発生データ解析システムにおいて、逐次発生データ解析装置は、逐次発生データの解析にかかった解析コストを監視する解析コスト監視部を含み、事前解析制御部は、解析コスト監視部の監視結果に基づいて、事前解析対象とする逐次発生データの優先度を判定する解析コスト優先事前解析判定部を含むように構成されていてもよい。
【０２２５】
（３５）また、逐次発生データ解析システムにおいて、解析コスト監視部は、逐次発生データの解析を開始した時間である開始時間を一時記憶し、逐次発生データの解析を終了したときに、当該解析を終了した時間である終了時間と、一時記憶した開始時間とに基づいて、解析コストを算出する解析コスト算出部と、解析コスト算出部の算出結果を記憶する解析コスト記憶部とを含むように構成されていてもよい。
【０２２６】
（３６）また、逐次発生データ解析システムにおいて、逐次発生データ解析装置は、逐次発生データの解析処理に用いる情報処理装置のリソースの空き容量を監視するリソース監視部を含み、事前解析制御部は、リソース監視部の監視結果に基づいて、事前解析する対象とする逐次発生データを絞り込むように構成されていてもよい。
【０２２７】
また、上記に示した各実施形態では、以下の（３７）〜（４５）に示すような逐次発生データ解析方法の特徴的構成が示されている。
【０２２８】
（３７）逐次発生データ解析方法は、解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御ステップを含むことを特徴とする。
【０２２９】
（３８）また、逐次発生データ解析方法は、解析要求が発生したときに、解析対象の逐次発生データが既に事前解析されているか否かを判定する解析方法判定ステップを含み、解析方法判定ステップにおいて、事前解析されていないと判定すると、解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力し、既に事前解析されていると判定すると、既に事前解析されている解析結果を出力するように構成されていてもよい。
【０２３０】
（３９）また、逐次発生データ解析方法は、事前解析された事前解析結果を事前解析結果記憶手段に記憶する事前解析結果記憶ステップを含み、解析方法判定ステップにおいて、解析要求が発生したときに、解析対象の逐次発生データに対応する事前解析結果が事前解析結果記憶手段に記憶されているか否かを判定することによって、解析対象の逐次発生データが既に事前解析されているか否かを判定するように構成されていてもよい。
【０２３１】
（４０）また、逐次発生データ解析方法は、事前解析する対象とする条件を示す事前解析条件を設定する事前解析条件設定ステップを含み、事前解析制御ステップにおいて、設定された事前解析条件に基づいて、事前解析対象とする逐次発生データを判断し、当該逐次発生データを事前解析する処理を実行させる制御を行うように構成されていてもよい。
【０２３２】
（４１）また、逐次発生データ解析方法は、事前解析制御ステップにおいて、逐次発生データの発生状況を監視し、逐次発生データの発生状況の監視結果と、設定された事前解析条件とに基づいて、優先して事前解析の対象とすべき逐次発生データを特定し、特定した事前解析対象の逐次発生データの解析を実行させる制御を行い、事前解析の解析結果を、事前解析結果を記憶する事前解析結果記憶手段に記憶させるように構成されていてもよい。
【０２３３】
（４２）また、逐次発生データ解析方法は、解析要求の履歴情報を解析要求履歴記憶手段に記憶する解析要求履歴記憶ステップを含み、事前解析制御ステップにおいて、解析要求履歴記憶手段が記憶する履歴情報に基づいて、出現頻度が高い解析要求に対応する逐次発生データを優先して事前解析対象とするように、事前解析対象とする逐次発生データの優先度を判定するように構成されていてもよい。
【０２３４】
（４３）また、逐次発生データ解析方法は、逐次発生データの解析にかかった解析コストを監視する解析コスト監視ステップを含み、事前解析制御ステップにおいて、解析コストの監視結果に基づいて、事前解析対象とする逐次発生データの優先度を判定するように構成されていてもよい。
【０２３５】
（４４）また、逐次発生データ解析方法は、解析コスト監視ステップにおいて、逐次発生データの解析を開始した時間である開始時間を一時記憶し、逐次発生データの解析を終了したときに、当該解析を終了した時間である終了時間と、一時記憶した開始時間とに基づいて、解析コストを算出し、解析コストの算出結果を解析コスト記憶手段に記憶するように構成されていてもよい。
【０２３６】
（４５）また、逐次発生データ解析方法は、逐次発生データの解析処理に用いる情報処理装置のリソースの空き容量を監視するリソース監視ステップを含み、事前解析制御ステップにおいて、リソースの監視結果に基づいて、事前解析する対象とする逐次発生データを絞り込むように構成されていてもよい。
【０２３７】
さらに、上記に示した各実施形態では、以下の（４６）〜（５４）に示すような逐次発生データ解析プログラムの特徴的構成が示されている。
【０２３８】
（４６）逐次発生データ解析プログラムは、コンピュータに、解析要求よりも前に、逐次発生するデータである逐次発生データを事前解析する処理を実行させる制御を行う事前解析制御処理を実行させるためのものである。
【０２３９】
（４７）また、逐次発生データ解析プログラムは、コンピュータに、解析要求が発生したときに、解析対象の逐次発生データが既に事前解析されているか否かを判定する解析方法判定処理を実行させ、解析方法判定処理において、事前解析されていないと判定すると、解析対象の逐次発生データを解析する処理を実行する制御を行い、当該解析結果を出力する処理と、既に事前解析されていると判定すると、既に事前解析されている解析結果を出力する処理とを実行させるものであってもよい。
【０２４０】
（４８）また、逐次発生データ解析プログラムは、コンピュータに、事前解析された事前解析結果を事前解析結果記憶手段に記憶させる事前解析結果記憶処理を実行させ、解析方法判定処理において、解析要求が発生したときに、解析対象の逐次発生データに対応する事前解析結果が事前解析結果記憶手段に記憶されているか否かを判定することによって、解析対象の逐次発生データが既に事前解析されているか否かを判定する処理を実行させるものであってもよい。
【０２４１】
（４９）また、逐次発生データ解析プログラムは、コンピュータに、事前解析制御処理において、予め設定された、事前解析する対象とする条件を示す事前解析条件に基づいて、事前解析対象とする逐次発生データを判断し、当該逐次発生データを事前解析する処理を実行させる制御を行う処理を実行させるものであってもよい。
【０２４２】
（５０）また、逐次発生データ解析プログラムは、コンピュータに、事前解析制御処理において、逐次発生データの発生状況を監視する処理と、逐次発生データの発生状況の監視結果と、設定された事前解析条件とに基づいて、優先して事前解析の対象とすべき逐次発生データを特定する処理と、特定した事前解析対象の逐次発生データの解析を実行させる制御を行う処理と、事前解析の解析結果を、事前解析結果を記憶する事前解析結果記憶手段に記憶させる処理とを実行させるものであってもよい。
【０２４３】
（５１）また、逐次発生データ解析プログラムは、コンピュータに、解析要求の履歴情報を解析要求履歴記憶手段に記憶させる解析要求履歴記憶処理を実行させ、事前解析制御処理において、解析要求履歴記憶手段が記憶する履歴情報に基づいて、出現頻度が高い解析要求に対応する逐次発生データを優先して事前解析対象とするように、事前解析対象とする逐次発生データの優先度を判定する処理を実行させるものであってもよい。
【０２４４】
（５２）また、逐次発生データ解析プログラムは、コンピュータに、逐次発生データの解析にかかった解析コストを監視する解析コスト監視処理を実行させ、事前解析制御処理において、解析コストの監視結果に基づいて、事前解析対象とする逐次発生データの優先度を判定する処理を実行させるものであってもよい。
【０２４５】
（５３）また、逐次発生データ解析プログラムは、コンピュータに、解析コスト監視処理において、逐次発生データの解析を開始した時間である開始時間を一時記憶し、逐次発生データの解析を終了したときに、当該解析を終了した時間である終了時間と、一時記憶した開始時間とに基づいて、解析コストを算出する処理と、解析コストの算出結果を解析コスト記憶手段に記憶させる処理とを実行させるものであってもよい。
【０２４６】
（５４）また、逐次発生データ解析プログラムは、コンピュータに、逐次発生データの解析処理に用いる情報処理装置のリソースの空き容量を監視するリソース監視処理を実行させ、事前解析制御処理において、リソースの監視結果に基づいて、事前解析する対象とする逐次発生データを絞り込む処理を実行させるものであってもよい。
【０２４７】
以上、実施形態を参照して本願発明を説明したが、本願発明は上記実施形態に限定されるものではない。本願発明の構成や詳細には、本願発明のスコープ内で当業者が理解し得る様々な変更をすることができる。
【０２４８】
この出願は、２００９年５月１４日に出願された日本特許出願２００９−１１８０３１を基礎とする優先権を主張し、その開示の全てをここに取り込む。
【産業上の利用可能性】
【０２４９】
本発明は、サーバが出力するログデータやセンサが出力するデータ等、逐次的に発生するデータを収集して解析することにより、様々なサービスをユーザに提供する装置に適用できる。例えば、本発明は、サービス毎のレスポンスタイムの要望に応じて解析処理を行う逐次発生データ高速解析装置や、方法、プログラムに適用できる。また、本発明は、特に、発生したデータがタイムラグなく解析結果に反映される高速性を要求されるサービスを提供する装置や、方法、プログラムに適用できる。
【符号の説明】
【０２５０】
１  サービス提供手段
２  サービス要件設定手段
３  解析データ発生手段
４  解析データ記憶手段
５  解析手段
６  解析命令受付手段
７  解析結果記憶手段
８  事前解析制御手段
８０１  解析対象監視手段
８０２  事前解析対象生成手段
８０３  事前解析依頼手段
８０４  事前解析結果登録手段
８０５  優先事前解析判定手段
８０６  空き記憶容量監視手段
９  解析命令履歴手段
１０  解析コスト監視手段
１００１  解析コスト算出手段
１００２  解析コスト記憶手段
１０１  アプリケーションサーバ
１０２  解析サーバ
１０３  データ解析サービスサーバ
１０４  データ解析受付サーバ
１０５  データ高速解析サーバ
【図１】
2010131425.tif 000003
【図２】
2010131425.tif 000004
【図３】
2010131425.tif 000005
【図４】
2010131425.tif 000006
【図５】
2010131425.tif 000007
【図６】
2010131425.tif 000008
【図７】
2010131425.tif 000009
【図８】
2010131425.tif 000010
【図９】
2010131425.tif 000011
【図１０】
2010131425.tif 000012
【図１１】
2010131425.tif 000013
【図１２】
2010131425.tif 000014
【図１３】
2010131425.tif 000015
【図１４】
2010131425.tif 000016
【図１５】
2010131425.tif 000017
【図１６】
2010131425.tif 000018
【図１７】
2010131425.tif 000019
【図１８】
2010131425.tif 000020
【図１９】
2010131425.tif 000021
【図２０】
2010131425.tif 000022
【図２１】
2010131425.tif 000023
【図２２】
2010131425.tif 000024
【図２３】
2010131425.tif 000025
【図２４】
2010131425.tif 000026
【図２５】
2010131425.tif 000027
【図２６】
2010131425.tif 000028
【図２７】
2010131425.tif 000029
【図２８】
2010131425.tif 000030
【図２９】
2010131425.tif 000031
【図３０】
2010131425.tif 000032
【図３１】
2010131425.tif 000033
【国際調査報告】
2010131425.tif 000034
2010131425.tif 000035
2010131425.tif 000036
2010131425.tif 000037