(57)【要約】  複数の計算機、及び管理計算機を備える計算機システムであって、計算機システムには、複数のデータストアが構成され、複数のデータストアの各々は、データソースから取得され、かつ、属性が異なるデータを格納し、管理計算機は、データ取得リクエストを受け付け、データ取得リクエストを解析することによって要求データを取得するデータストアを決定するリクエスト振り分け部と、複数のデータストアの各々に格納されるデータの時間属性を含むメタデータ管理情報と、を有し、リクエスト振り分け部は、データ取得リクエストの解析結果に基づいてメタデータ管理情報を参照して、候補データストアを選択し、候補データストアから要求データを取得できるか否かを判定し、判定の結果に基づいて、要求データを取得するためのリクエストを発行するデータストアを決定する。
2015193988.tif 000002
【特許請求の範囲】
【請求項１】
複数の計算機、及び管理計算機を備える計算機システムであって、
前記複数の計算機の各々は、第１のプロセッサ、前記第１のプロセッサに接続される第１のメモリ、前記第１のプロセッサに接続される第１のネットワークインタフェースを有し、
前記管理計算機は、第２のプロセッサ、前記第２のプロセッサに接続される第２のメモリ、前記第２のプロセッサに接続される第２のネットワークインタフェースを有し、
前記計算機システムには、前記複数の計算機を用いて複数のデータストアが構成され、
前記複数のデータストアの各々は、データソースから取得され、かつ、属性が異なるデータを格納し、
前記管理計算機は、
前記複数のデータストアから要求データを取得するためのデータ取得リクエストを受け付け、前記データ取得リクエストを解析することによって前記要求データを取得するデータストアを決定するリクエスト振り分け部と、
前記複数のデータストアの各々に格納されるデータの時間属性を含むメタデータ管理情報と、を有し、
前記リクエスト振り分け部は、
前記要求データの時間属性を含む前記データ取得リクエストを受け付けた場合、前記データ取得リクエストの解析結果に基づいて前記メタデータ管理情報を参照して、候補データストアを選択し、
前記候補データストアから前記要求データを取得できるか否かを判定し、
前記判定の結果に基づいて、前記要求データを取得するためのリクエストを発行するデータストアを決定し、
前記決定されたデータストアに前記リクエストを発行することを特徴とする計算機システム。
【請求項２】
請求項１に記載の計算機システムであって、
前記複数のデータストアは、
前記データソースからリアルタイムデータを取得し、所定の集計単位時間分のリアルタイムデータを集計することによって算出されたリアルタイム統計データを格納する第１のデータストアと、
前記リアルタイム統計データの履歴である履歴統計データを格納する第２のデータストアと、を含み、
前記第１のデータストアは、現在の時刻から保持時間だけさかのぼった時刻までの時間範囲の前記リアルタイム統計データを格納し、
前記メタデータ管理情報は、前記第１のデータストアに格納される前記リアルタイム統計データに関する前記保持時間を管理する第１のメタデータ情報を含み、
前記データ取得リクエストに含まれる前記要求データの時間属性は、取得するデータの時間範囲を示す指定時間を含み、
前記リクエスト振り分け部は、
前記第１のメタデータ情報に含まれる前記保持時間、及び前記データ取得リクエストに含まれる前記指定時間に基づいて、前記第１のデータストアから前記要求データを取得できる可能性があるか否かを判定し、
前記第１のデータストアから前記要求データを取得できると判定された場合、前記第１のデータストアを前記候補データストアとして選択し、
前記第１のデータストアから前記要求データを取得できないと判定された場合、前記第２のデータストアを前記候補データストアとして選択することを特徴とする計算機システム。
【請求項３】
請求項２に記載の計算機システムであって、
前記データ取得リクエストに含まれる前記指定時間は、開始時刻と終了時刻とを含み、
前記リクエスト振り分け部は、
現在の時刻を取得し、
前記現在の時刻から前記第１のメタデータ情報に含まれる前記保持時間を減算することによって第１の時刻を算出し、
前記第１の時刻が前記終了時刻以前の時刻であるか否かを判定し、
前記第１の時刻が前記終了時刻以後の時刻であると判定された場合、前記第２のデータストアを前記候補データストアとして選択し、
前記第１の時刻が前記終了時刻以前の時刻であると判定された場合、前記第１の時刻が前記開始時刻以後の時刻であるか否かを判定し、
前記第１の時刻が前記開始時刻以前の時刻であると判定された場合、前記第１のデータストアを前記候補データストアとして選択し、
前記第１の時刻が前記開始時刻以後の時刻であると判定された場合、前記開始時刻から前記第１の時刻までの前記要求データを取得する前記候補データストアとして前記第２のデータストアを選択し、前記第１の時刻から前記終了時刻までの前記要求データを取得する前記候補データストアとして前記第１のデータストアを選択することを特徴とする計算機システム。
【請求項４】
請求項３に記載の計算機システムであって、
前記複数のデータストアは、前記データソースから取得された前記リアルタイムデータの履歴を格納する第３のデータストアを含み、
前記第１のメタデータ情報は、前記リアルタイム統計データの算出時に集計されるデータの種別及び集計単位時間を第１の集計情報として含み、
前記メタデータ管理情報は、前記履歴統計データに対応する前記リアルタイム統計データの算出時に集計されるデータの種別、及び集計単位時間を第２の集計情報として含む第２のメタデータ情報を含み、
前記データ取得リクエストは、前記要求データを特定するためのデータの種別及び集計単位時間を第３の集計情報として含み、
前記リクエスト振り分け部は、
前記候補データストアとして前記第１のデータストアが選択された場合、前記第３の集計情報のデータの種別が前記第１の集計情報のデータの種別と一致し、かつ、前記第３の集計情報の集計単位時間が前記第１の集計情報の集計単位時間と一致する第１の判定条件を満たすか否かを判定し、
前記第１の判定条件を満たすと判定された場合、前記第１のデータストアを前記リクエストを発行するデータストアに決定し、
前記第１の判定条件を満たさないと判定された場合、前記第３のデータストアを前記リクエストを発行するデータストアに決定し、
前記候補データストアとして前記第２のデータストアが選択された場合、前記第３の集計情報のデータの種別が前記第２の集計情報のデータの種別と一致し、かつ、前記第３の集計情報の集計単位時間が前記第２の集計情報の集計単位時間と一致する第２の判定条件を満たすか否かを判定し、
前記第２の判定条件を満たすと判定された場合、前記第２のデータストアを前記リクエストを発行するデータストアに決定し、
前記第２の判定条件を満たさないと場合、前記第３のデータストアを前記リクエストを発行するデータストアに決定することを特徴とする計算機システム。
【請求項５】
請求項４に記載の計算機システムであって、
前記管理計算機は、前記複数のデータストアから取得されたデータを用いて前記データ取得リクエストに対する応答として応答情報を生成する出力処理部を有し、
前記リクエスト振り分け部は、
前記候補データストアとして前記第１のデータストアが選択された場合、前記第３の集計情報のデータの種別が前記第１の集計情報のデータの種別と一致し、かつ、前記第３の集計情報の集計単位時間が前記第１の集計情報の集計単位時間の約数である第３の判定条件を満たすか否かを判定し、
前記第３の判定条件を満たすと判定された場合、前記第１のデータストアを前記リクエストを発行するデータストアに決定し、
前記第３の判定条件を満たさないと判定された場合、前記第３のデータストアを前記リクエストを発行するデータストアに決定し、
前記候補データストアとして前記第２のデータストアが選択された場合、前記第３の集計情報のデータの種別が前記第２の集計情報のデータの種別と一致し、かつ、前記第３の集計情報の集計単位時間が前記第２の集計情報の集計単位時間の約数である第４の判定条件を満たすか否かを判定し、
前記第４の判定条件を満たすと判定された場合、前記第２のデータストアを前記リクエストを発行するデータストアに決定し、
前記第４の判定条件を満たさないと判定された場合、前記第３のデータストアを前記リクエストを発行するデータストアに決定し、
前記出力処理部は、
前記第１のデータストアからデータが取得された場合、前記第１のメタデータ情報を参照し、
前記第１のデータストアから取得されたデータの集計単位時間が、前記第３の集計情報の集計単位時間より小さいか否かを判定し、
前記第１のデータストアから取得されたデータの集計単位時間が、前記第３の集計情報の集計単位時間より小さいと判定された場合、前記第１のデータストアから取得されたデータを集計することによって、前記要求データを生成し、
前記第２のデータストアからデータが取得された場合、前記第２のメタデータ情報を参照し、
前記第２のデータストアから取得されたデータの集計単位時間が、前記第３の集計情報の集計単位時間より小さいか否かを判定し、
前記第２のデータストアから取得されたデータの集計単位時間が、前記第３の集計情報の集計単位時間より小さいと判定された場合、前記第２のデータストアから取得されたデータを集計することによって、前記要求データを生成し、
前記要求データを用いて、前記データ取得リクエストに対する応答として応答情報を生成することを特徴とする計算機システム。
【請求項６】
データを格納する複数の計算機、及び管理計算機を備える計算機システムにおけるデータアクセス管理方法であって、
前記複数の計算機の各々は、第１のプロセッサ、前記第１のプロセッサに接続される第１のメモリ、前記第１のプロセッサに接続される第１のネットワークインタフェースを有し、
前記管理計算機は、第２のプロセッサ、前記第２のプロセッサに接続される第２のメモリ、前記第２のプロセッサに接続される第２のネットワークインタフェースを有し、
前記計算機システムには、前記複数の計算機を用いて複数のデータストアが構成され、
前記複数のデータストアの各々は、データソースから取得され、かつ、属性が異なるデータを格納し、
前記管理計算機は、
前記複数のデータストアから要求データを取得するためのデータ取得リクエストを受け付け、前記データ取得リクエストを解析することによって前記要求データを取得するデータストアを決定するリクエスト振り分け部と、
前記複数のデータストアの各々に格納されるデータの時間属性を含むメタデータ管理情報と、を有し、
前記データアクセス管理方法は、
前記リクエスト振り分け部が、前記要求データの時間属性を含む前記データ取得リクエストを受け付けた場合、前記データ取得リクエストの解析結果に基づいて前記メタデータ管理情報を参照して、候補データストアを選択する第１のステップと、
前記リクエスト振り分け部が、前記候補データストアから前記要求データを取得できるか否かを判定し、前記判定の結果に基づいて前記要求データを取得するためのリクエストを発行するデータストアを決定する第２のステップと、
前記リクエスト振り分け部が、前記決定されたデータストアに前記リクエストを発行する第３のステップと、を含むことを特徴とするデータアクセス管理方法。
【請求項７】
請求項６に記載のデータアクセス管理方法であって、
前記複数のデータストアは、
前記データソースからリアルタイムデータを取得し、所定の集計単位時間分のリアルタイムデータを集計することによって算出されたリアルタイム統計データを格納する第１のデータストアと、
前記リアルタイム統計データの履歴である履歴統計データを格納する第２のデータストアと、を含み、
前記第１のデータストアは、現在の時刻から保持時間だけさかのぼった時刻までの時間範囲の前記リアルタイム統計データを格納し、
前記メタデータ管理情報は、前記第１のデータストアに格納される前記リアルタイム統計データに関する前記保持時間を管理する第１のメタデータ情報を含み、
前記データ取得リクエストに含まれる前記要求データの時間属性は、取得するデータの時間範囲を示す指定時間を含み、
前記第１のステップは、
前記第１のメタデータ情報に含まれる前記保持時間、及び前記データ取得リクエストに含まれる前記指定時間に基づいて、前記第１のデータストアから前記要求データを取得できる可能性があるか否かを判定するステップと、
前記第１のデータストアから前記要求データを取得できると判定された場合、前記第１のデータストアを前記候補データストアとして選択するステップと、
前記第１のデータストアから前記要求データを取得できないと判定された場合、前記第２のデータストアを前記候補データストアとして選択するステップと、を含むことを特徴とするデータアクセス管理方法。
【請求項８】
請求項７に記載のデータアクセス管理方法であって、
前記データ取得リクエストに含まれる前記指定時間は、開始時刻と終了時刻とを含み、
前記第１のステップは、
現在の時刻を取得するステップと、
前記現在の時刻から前記第１のメタデータ情報に含まれる前記保持時間を減算することによって第１の時刻を算出するステップと、
前記第１の時刻が前記終了時刻以前の時刻であるか否かを判定するステップと、
前記第１の時刻が前記終了時刻以後の時刻であると判定された場合、前記第２のデータストアを前記候補データストアとして選択するステップと、
前記第１の時刻が前記終了時刻以前の時刻であると判定された場合、前記第１の時刻が前記開始時刻以後の時刻であるか否かを判定するステップと、
前記第１の時刻が前記開始時刻以前の時刻であると判定された場合、前記第１のデータストアを前記候補データストアとして選択するステップと、
前記第１の時刻が前記開始時刻以後の時刻であると判定された場合、前記開始時刻から前記第１の時刻までの前記要求データを取得する前記候補データストアとして前記第２のデータストアを選択し、前記第１の時刻から前記終了時刻までの前記要求データを取得する前記候補データストアとして前記第１のデータストアを選択するステップと、を含むことを特徴とするデータアクセス管理方法。
【請求項９】
請求項８に記載のデータアクセス管理方法であって、
前記複数のデータストアは、前記データソースから取得された前記リアルタイムデータの履歴を格納する第３のデータストアを含み、
前記第１のメタデータ情報は、前記リアルタイム統計データの算出時に集計されるデータの種別及び集計単位時間を第１の集計情報として含み、
前記メタデータ管理情報は、前記履歴統計データに対応する前記リアルタイム統計データの算出時に集計されるデータの種別、及び集計単位時間を第２の集計情報として含む第２のメタデータ情報を含み、
前記データ取得リクエストは、前記要求データを特定するためのデータの種別及び集計単位時間を第３の集計情報として含み、
前記第２のステップは、
前記候補データストアとして前記第１のデータストアが選択された場合、前記第３の集計情報のデータの種別が前記第１の集計情報のデータの種別と一致し、かつ、前記第３の集計情報の集計単位時間が前記第１の集計情報の集計単位時間と一致する第１の判定条件を満たすか否かを判定するステップと、
前記第１の判定条件を満たすと判定された場合、前記第１のデータストアを前記リクエストを発行するデータストアに決定するステップと、
前記第１の判定条件を満たさないと判定された場合、前記第３のデータストアを前記リクエストを発行するデータストアに決定するステップと、
前記候補データストアとして前記第２のデータストアが選択された場合、前記第３の集計情報のデータの種別が前記第２の集計情報のデータの種別と一致し、かつ、前記第３の集計情報の集計単位時間が前記第２の集計情報の集計単位時間と一致する第２の判定条件を満たすか否かを判定するステップと、
前記第２の判定条件を満たすと判定された場合、前記第２のデータストアを前記リクエストを発行するデータストアに決定するステップと、
前記第２の判定条件を満たさないと場合、前記第３のデータストアを前記リクエストを発行するデータストアに決定するステップと、を含むことを特徴とするデータアクセス管理方法。
【請求項１０】
請求項９に記載のデータアクセス管理方法であって、
前記管理計算機は、前記複数のデータストアから取得されたデータを用いて前記データ取得リクエストに対する応答として応答情報を生成する出力処理部を有し、
前記第２のステップは、
前記候補データストアとして前記第１のデータストアが選択された場合、前記第３の集計情報のデータの種別が前記第１の集計情報のデータの種別と一致し、かつ、前記第３の集計情報の集計単位時間が前記第１の集計情報の集計単位時間の約数である第３の判定条件を満たすか否かを判定するステップと、
前記第３の判定条件を満たすと判定された場合、前記第１のデータストアを前記リクエストを発行するデータストアに決定するステップと、
前記第３の判定条件を満たさないと判定された場合、前記第３のデータストアを前記リクエストを発行するデータストアに決定するステップと、
前記候補データストアとして前記第２のデータストアが選択された場合、前記第３の集計情報のデータの種別が前記第２の集計情報のデータの種別と一致し、かつ、前記第３の集計情報の集計単位時間が前記第２の集計情報の集計単位時間の約数である第４の判定条件を満たすか否かを判定するステップと、
前記第４の判定条件を満たすと判定された場合、前記第２のデータストアを前記リクエストを発行するデータストアに決定するステップと、
前記第４の判定条件を満たさないと判定された場合、前記第３のデータストアを前記リクエストを発行するデータストアに決定するステップと、を含み、
前記データアクセス管理方法は、
前記出力処理部が、前記第１のデータストアからデータが取得された場合、前記第１のメタデータ情報を参照し、
前記出力処理部が、前記第１のデータストアから取得されたデータの集計単位時間が、前記第３の集計情報の集計単位時間より小さいか否かを判定するステップと、
前記出力処理部が、前記第１のデータストアから取得されたデータの集計単位時間が、前記第３の集計情報の集計単位時間より小さいと判定された場合、前記第１のデータストアから取得されたデータを集計することによって、前記要求データを生成するステップと、
前記出力処理部が、前記第２のデータストアからデータが取得された場合、前記第２のメタデータ情報を参照するステップと、
前記出力処理部が、前記第２のデータストアから取得されたデータの集計単位時間が、前記第３の集計情報の集計単位時間より小さいか否かを判定するステップと、
前記出力処理部が、前記第２のデータストアから取得されたデータの集計単位時間が、前記第３の集計情報の集計単位時間より小さいと判定された場合、前記第２のデータストアから取得されたデータを集計することによって、前記要求データを生成するステップと、
前記出力処理部が、前記要求データを用いて、前記データ取得リクエストに対する応答として応答情報を生成するステップと、を含むことを特徴とするデータアクセス管理方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、システムの監視に必要な複数種類のデータへのアクセスを管理する計算機システム及び管理方法に関する。
【背景技術】
【０００２】
ネットワークにおいても仮想化技術が普及し、ネットワークの監視が複雑化している。そのため、ネットワーク監視システムでは、ネットワークの監視処理及び障害の解析処理のために、様々な種類の詳細なデータを把握したいという要求がある。より具体的には、リアルタイムに集計されたデータ及び履歴データを把握したいという要求がある。【０００３】
そのため、ネットワーク監視システムでは、様々な種類のデータがデータストアに格納される。ユーザは、監視処理の内容に応じて、当該データストアからデータを取得することができる。【０００４】
複数種類のデータを取得する方法として、例えば、特許文献１のような技術が知られている。特許文献１には、「クライアント計算機１０−１からデータベース言語による問い合わせを行う問い合わせ発行部１１ａと、サーバ計算機１３で複数異種のデータベースを管理するＤＢＭＳサーバ群２３と、複数異種のデータを管理する非ＤＢＭＳサーバ群２４と、問い合わせ発行部１１ａからの問い合わせを対応するＤＢＭＳに固有のデータベース言語に変換し、あるいは固有のアクセス方法に変換し、ＤＢＭＳサーバ群２３あるいは非ＤＢＭＳサーバ群２４にアクセス要求を発行し、このアクセス結果をクライアント計算機１０−１に返却するマルチメディアデータベースアクセス部１４とを具備し、複数異種のＤＢＭＳ及び非ＤＢＭＳからなるマルチメディアデータベース１５を、データベース言語により統一的にアクセスする」ことが記載されている。これによって、複数異種のデータベースを含むマルチメディアデータをクライアント計算機上のアプリケーションから統一的にアクセスできる。
【先行技術文献】
【特許文献】
【０００５】
【特許文献１】特開平８−８３２０６号公報
【発明の概要】
【発明が解決しようとする課題】
【０００６】
従来の一般的なシステムでは、ログをそのままデータストアに格納していた。そのため、集計されたデータが必要な場合、リクエストを受け付けた計算機は、検索処理及び集計処理の二つの処理を実行する必要がある。そのため、効率よくデータを取得できない。【０００７】
前述の課題を解決するために、集計処理毎にデータストアを構築する方法が考えられる。しかし、集計処理毎にデータストアを構築した場合、データストアの管理が複雑化する。そのため、ユーザはどのデータストアからデータを取得すればよい判断できない。【０００８】
特許文献１に記載の技術は、種類の異なるデータを管理する複数データベース又は非データベースからデータを取得することはできるが、複雑なデータ管理が必要となる計算機システムでは効率的にデータを取得できない。また、ユーザは予めデータストアに格納されるデータの属性を把握する必要があるが、動的に更新され、かつ、複数の集計処理毎のデータを管理するデータストアを複数有する計算機システムでは、データストアに格納されるデータの属性を把握することが困難である。【０００９】
本発明は、ユーザにデータストアに格納されるデータの属性、特に時間の属性を意識させることなく、適切なデータストアを特定し、当該データストアからデータを取得することができるシステム及び方法を提供することを目的とする。
【課題を解決するための手段】
【００１０】
本願において開示される発明の代表的な一例を示せば以下の通りである。すなわち、複数の計算機、及び管理計算機を備える計算機システムであって、前記複数の計算機の各々は、第１のプロセッサ、前記第１のプロセッサに接続される第１のメモリ、前記第１のプロセッサに接続される第１のネットワークインタフェースを有し、前記管理計算機は、第２のプロセッサ、前記第２のプロセッサに接続される第２のメモリ、前記第２のプロセッサに接続される第２のネットワークインタフェースを有し、前記計算機システムには、前記複数の計算機を用いて複数のデータストアが構成され、前記複数のデータストアの各々は、データソースから取得され、かつ、属性が異なるデータを格納し、管理計算機は、前記複数のデータストアから要求データを取得するためのデータ取得リクエストを受け付け、前記データ取得リクエストを解析することによって前記要求データを取得するデータストアを決定するリクエスト振り分け部と、前記複数のデータストアの各々に格納されるデータの時間属性を含むメタデータ管理情報とを有し、前記リクエスト振り分け部は、前記要求データの時間属性を含む前記データ取得リクエストを受け付けた場合、前記データ取得リクエストの解析結果に基づいて前記メタデータ管理情報を参照して、候補データストアを選択し、前記候補データストアから前記要求データを取得できるか否かを判定し、前記判定の結果に基づいて、前記要求データを取得するためのリクエストを発行するデータストアを決定し、前記決定されたデータストアに前記リクエストを発行することを特徴とする。
【発明の効果】
【００１１】
本発明の一形態によれば、属性が異なるデータを格納する複数のデータストアを有する計算機システムにおいて、管理計算機は、任意のデータ取得リクエストに基づいて、複数のデータストアの中から要求データを取得するデータストアを決定できる。【００１２】
前述した以外の課題、構成及び効果は、以下の実施例の説明によって明らかにされる。
【図面の簡単な説明】
【００１３】
【図１】本実施例１の計算機システムの構成例を説明するブロック図である。
【図２】実施例１の計算機のハードウェア構成及びソフトウェア構成の一例を説明するブロック図である。
【図３】実施例１の計算機システムにおける処理の流れを説明するブロック図である。
【図４】実施例１のリアルタイム統計データ＿メタデータの一例を示す説明図である。
【図５】実施例１の履歴統計データ＿メタデータの一例を示す説明図である。
【図６】実施例１の生データ＿メタデータの一例を示す説明図である。
【図７】実施例１のメタデータ設定部が実行する処理の一例を説明するフローチャートである。
【図８】実施例１のメタデータ＿データベースにメタデータを設定するための設定ファイルの一例を示す説明図である。
【図９】実施例１のメタデータ＿データベースにメタデータを設定するための設定コマンドの一例を示す説明図である。
【図１０】実施例１のリクエスト振り分け部が実行する処理の概要を説明するフローチャートである。
【図１１Ａ】実施例１のデータストア判定処理の一例を説明するフローチャートである。
【図１１Ｂ】実施例１のデータストア判定処理の一例を説明するフローチャートである。
【図１２】実施例１のリクエスト決定処理の一例を説明するフローチャートである。
【図１３Ａ】実施例１のデータ取得リクエストの一例を示す説明図である。
【図１３Ｂ】実施例１のデータ取得リクエストの一例を示す説明図である。
【図１３Ｃ】実施例１のデータ取得リクエストの一例を示す説明図である。
【図１３Ｄ】実施例１のデータ取得リクエストの一例を示す説明図である。
【図１３Ｅ】実施例１のデータ取得リクエストの一例を示す説明図である。
【図１３Ｆ】実施例１のデータ取得リクエストの一例を示す説明図である。
【図１３Ｇ】実施例１のデータ取得リクエストの一例を示す説明図である。
【図１４】実施例１の出力処理部が実行する処理の一例を説明するフローチャートである。
【図１５】実施例２の計算機システムにおける処理の流れを説明するブロック図である。
【図１６】実施例２のデータストア管理部が実行する処理の一例を説明するフローチャートである。
【発明を実施するための形態】
【００１４】
以下、本発明の実施例について、図面を参照して説明する。
［実施例１］
【００１５】
図１は、実施例１の計算機システムの構成例を説明するブロック図である。
【００１６】
計算機システムは、複数の計算機１００、１１０、１２０、１３０、及び複数のクライアント端末１４０から構成される。
【００１７】
計算機１００、複数の計算機１１０、複数の計算機１２０、複数の計算機１３０、及び複数のクライアント端末１４０は、ネットワーク１６０を介して互いに接続される。ネットワーク１６０は、計算機１００、複数の計算機１１０、１２０、１３０、及び複数のクライアント端末１４０が互いに通信できるものであればどのようなものであってもよい。例えば、ネットワークの種類はＷＡＮ及びＬＡＮなどのいずれでもよく、また、ネットワークの接続方式は無線及び有線のいずれでもよい。
【００１８】
クライアント端末１４０は、ユーザが使用する計算機であり、プロセッサ（図示省略）、メモリ（図示省略）、ネットワークインタフェース（図示省略）等のハードウェアを有する。クライアント端末１４０には、各種データを参照し、データ等を表示するための表示部１４１が稼動する。ユーザは、表示部１４１を使用して計算機１００にデータ取得リクエストを送信し、また各種情報を入力する。
【００１９】
複数の計算機１１０、１２０、１３０の各々は、様々な種類のデータを格納するデータストアを構成する計算機である。本実施例では、複数の計算機１１０を用いて一つ以上のデータストア、複数の計算機１２０を用いて一つ以上のデータストア、複数の計算機１３０を用いて一つの以上のデータストアを構成するものとする。また、本実施例では、複数のデータストアが一つのデータストア群として管理される。
【００２０】
データストアには、データソース１５０から取得されるデータが管理される。ここで、データソース１５０は、データストア群において管理されるデータの取得元を示す。例えば、データセンタにおけるサーバの稼働ログを管理するデータストア群の場合、データセンタがデータソース１５０に対応する。また、センサの計測値を管理するデータストア群の場合、センサがデータソース１５０に対応する。また、ネットワークの状態を管理するデータストア群の場合、ネットワークを構成するスイッチ等がデータソース１５０に対応する。
【００２１】
複数の計算機１１０の各々は、データソース１５０からリアルタイムデータを取得し、取得されたリアルタイムデータを用いて算出されたリアルタイム統計データを管理する計算機である。すなわち、各計算機１１０は、リアルタイム統計データを格納するデータストアを実現する計算機である。各計算機１１０は、リアルタイムデータ集計部１１１を有する。
【００２２】
リアルタイムデータ集計部１１１は、リアルタイム統計データを格納するデータストアを管理する。具体的には、リアルタイムデータ集計部１１１は、予め指定された集計処理に従って、データソース１５０から取得されたリアルタイムデータを所定の集計単位時間毎に集計することによってリアルタイム統計データを算出し、バッファ１１２にリアルタイム統計データを格納する。リアルタイムデータ集計部１１１には、バッファ１１２に格納されるリアルタイム統計データの時間範囲を決定するパラメタとして保持時間が設定される。バッファ１１２には、現在の時刻から保持時間さかのぼった時刻までのリアルタイム統計データが格納される。
【００２３】
リアルタイムデータ集計部１１１は、リアルタイムデータを用いてリアルタイム統計データを生成し、生成されたリアルタイム統計データを計算機１２０に格納する。また、リアルタイムデータ集計部１１１は、計算機１００からリクエストを受信した場合、当該リクエストに従ってバッファ１１２に格納されるリアルタイム統計データを読み出し、読み出されたリアルタイム統計データを応答として計算機１００に送信する。
【００２４】
複数の計算機１２０の各々は、リアルタイム統計データの履歴を管理する計算機である。すなわち、各計算機１２０は、リアルタイム統計データの履歴を格納するデータストアを実現する計算機である。各計算機１２０は、データベース管理部１２１及び履歴統計データ＿データベース１２２を有する。以下の説明では、リアルタイム統計データの履歴を履歴統計データとも記載する。
【００２５】
履歴統計データ＿データベース１２２は、履歴統計データを格納する。データベース管理部１２１は、履歴統計データを格納するデータストアを管理する。
【００２６】
具体的には、データベース管理部１２１は、リアルタイムデータ集計部１１１から受信したリアルタイム統計データを履歴統計データ＿データベース１２２に格納する。また、データベース管理部１２１は、計算機１００からリクエストを受信した場合、当該リクエストに従って履歴統計データ＿データベース１２２から履歴統計データを読み出し、読み出された履歴統計データを応答として計算機１００に送信する。
【００２７】
なお、履歴統計データは、リアルタイム統計データ以外のデータの履歴であってもよい。例えば、データベース管理部１２１は、データソース１５０からデータを取得し、所定の統計処理を実行することによって算出された統計データを履歴統計データとして格納してもよい。また、データベース管理部１２１は、後述する計算機１３０から生データを取得し、所定の統計処理を実行することによって算出された統計データを履歴統計データとして格納してもよい。
【００２８】
複数の計算機１３０の各々は、データソース１５０から取得された生データを管理する計算機である。ここで、生データとは、データソース１５０から取得されたリアルタイムデータそのものを示す。すなわち、各計算機１３０は、生データを格納するデータストアを実現する計算機である。各計算機１３０は、データベース管理部１３１及び生データ＿データベース１３２を有する。
【００２９】
生データ＿データベース１３２は、現在から過去までの生データを格納する。データベース管理部１３１は、生データを格納するデータストアを管理する。
【００３０】
具体的には、データベース管理部１３１は、データソース１５０から生データを取得し、取得された生データを生データ＿データベース１３２に格納する。また、データベース管理部１３１は、計算機１００からリクエストを受信した場合、当該リクエストに従って生データ＿データベース１３２から生データを読み出し、読み出された生データを応答として計算機１００に送信する。
【００３１】
前述したように、実施例１のデータストア群を構成する各データストアでは、集計内容、集計単位時間、保持時間等のデータの属性が異なるデータが管理される。
【００３２】
計算機１００は、表示部１４１から送信されたデータ取得リクエストに基づいてデータの取得先となる候補のデータストアを特定する。以下の説明では、特定された候補のデータストアを候補データストアとも記載する。計算機１００は、候補データストアからデータを取得できるか否かを判定し、判定結果に基づいてデータを取得するデータストアを決定する。計算機１００は、データストア管理部１０１を有する。
【００３３】
データストア管理部１０１は、データストア群に含まれるデータストアに対するアクセス処理を管理する。データストア管理部１０１は、メタデータ設定部１０２、リクエスト振り分け部１０３、出力処理部１０４、及びメタデータ＿データベース１０５を有する。
【００３４】
メタデータ設定部１０２は、データストアに格納されるデータの属性を示すメタデータを設定する。リクエスト振り分け部１０３は、表示部１４１からデータ取得リクエストを受信した場合、当該リクエストの対象となるデータを取得するデータストアを特定し、特定されたデータストアに対してリクエストを発行する。出力処理部１０４は、データストアから取得されたデータを用いて応答情報を生成し、表示部１４１に生成された応答情報を送信する。
【００３５】
メタデータ＿データベース１０５は、データストアに格納されるデータの属性を管理するためのメタデータを格納する。
【００３６】
図２は、実施例１の計算機１００のハードウェア構成及びソフトウェア構成の一例を説明するブロック図である。
【００３７】
計算機１００は、プロセッサ２０１、メモリ２０２、記憶装置２０３、及びネットワークインタフェース２０４を有する。
【００３８】
プロセッサ２０１は、メモリ２０２に格納されるプログラムを実行する。プロセッサ２０１がプログラムを実行することによって計算機１００が有する機能を実現できる。以下の説明ではプログラムを主体に処理の説明をする場合、当該プログラムがプロセッサ２０１によって実行されていることを示す。
【００３９】
メモリ２０２は、プロセッサ２０１によって実行されるプログラム及び当該プログラムの実行に必要な各種情報を格納する。メモリ２０２は、メタデータ設定部１０２、リクエスト振り分け部１０３、及び出力処理部１０４を実現するプログラムを格納する。また、メモリ２０２は、メタデータ＿データベース１０５を格納する。
【００４０】
記憶装置２０３は、計算機１００が使用する各種プログラム及び各種情報を格納する。メモリ２０２に格納されるプログラム及び情報は記憶装置２０３に格納されてもよい。この場合、プロセッサ２０１は、記憶装置２０３からプログラム及び情報を読み出し、メモリ２０２にロードし、メモリ２０２上にロードされたプログラムを実行する。ネットワークインタフェース２０４は、ネットワークと接続するためのインタフェースである。
【００４１】
計算機１１０、１２０、１３０も、計算機１００と同一のハードウェア構成である。ただし、メモリ２０２及び記憶装置２０３に格納されるプログラム及び情報が異なる。具体的には、計算機１１０のメモリ２０２にはリアルタイムデータ集計部１１１を実現するプログラムが格納される。計算機１２０のメモリ２０２にはデータベース管理部１２１を実現するプログラムが格納され、記憶装置２０３には履歴統計データ＿データベース１２２が格納される。計算機１３０のメモリ２０２にはデータベース管理部１３１を実現するプログラムが格納され、記憶装置２０３には生データ＿データベース１３２が格納される。
【００４２】
本実施例では、記憶装置２０３の記憶領域を用いたディスクストアとしてデータストアを実現しているが、メモリ２０２の記憶領域を用いたメモリストアとしてデータストアを実現してもよい。
【００４３】
図３は、実施例１の計算機システムにおける処理の流れを説明するブロック図である。
【００４４】
図３に示すように、データストア管理部１０１は、各データストアにアクセスするための専用のアダプタ３０４を複数有する。データストア管理部１０１は、各アダプタ３０４を用いて各データストアにリクエストを送信し、各データストアからデータを受信する。
【００４５】
実施例１のデータストア管理部１０１は、三つのアダプタ３０４−１、３０４−２、３０４−３を有する。アダプタ３０４−１は、リアルタイムデータ集計部１１１が管理するリアルタイム統計データ３１０を取得するためのアダプタである。アダプタ３０４−２は、データベース管理部１２１が管理する履歴統計データ３２０を取得するためのアダプタである。アダプタ３０４−３は、データベース管理部１３１が管理する生データ３３０を取得するためのアダプタである。
【００４６】
データストア管理部１０１には予めメタデータ設定情報３５０が入力される。メタデータ設定部１０２は、入力されたメタデータ設定情報３５０に基づいて、データストア群において管理されるデータの属性を示すメタデータをメタデータ＿データベース１０５に設定する。
【００４７】
実施例１では、メタデータ設定部１０２は、リアルタイム統計データ＿メタデータ３０１、履歴統計データ＿メタデータ３０２、及び生データ＿メタデータ３０３をメタデータ＿データベース１０５に設定する。
【００４８】
リアルタイム統計データ＿メタデータ３０１は、計算機１１０が管理するリアルタイム統計データのメタデータである。履歴統計データ＿メタデータ３０２は、計算機１２０が管理する履歴統計データのメタデータである。生データ＿メタデータ３０３は、計算機１３０が管理する生データのメタデータである。
【００４９】
リアルタイム統計データ＿メタデータ３０１、履歴統計データ＿メタデータ３０２、及び生データ＿メタデータ３０３をメタデータ＿データベース１０５の詳細は、図４、図５、及び図６を用いて後述する。
【００５０】
データストア管理部１０１は、表示部１４１からデータ取得リクエストを受信した場合、以下のようなに動作する。
【００５１】
まず、リクエスト振り分け部１０３はデータ取得リクエストを解析する。リクエスト振り分け部１０３は、解析結果に基づいてメタデータ＿データベース１０５を参照し、データを取得するデータストアを決定する。リクエスト振り分け部１０３は、決定されたデータストアにアクセスするためのアダプタ３０４に対してリクエストの発行指示を出力する。
【００５２】
アダプタ３０４は、リクエストの発行指示を受け付けると、当該指示に基づいてデータストアに対するリクエストを発行し、データストアからデータを取得する。アダプタ３０４は、取得されたデータを出力処理部１０４に出力する。
【００５３】
出力処理部１０４は、データ取得リクエストの解析結果、及び各アダプタから入力されたデータを用いて応答情報を生成する。このとき、出力処理部１０４は、必要がある場合、データストアから取得されたデータを処理することによって、データ取得リクエストによって要求されたデータを生成する。出力処理部１０４は、表示部１４１に生成された応答情報を送信する。
【００５４】
実施例１では、リクエスト振り分け部１０３が、データ取得リクエストの解析結果及びメタデータ＿データベース１０５に基づいて、データを取得するデータストアを決定することに特徴がある。また、リクエスト振り分け部１０３は、データストアに格納されるデータを用いて、データ取得リクエストによって要求されるデータを生成することに特徴がある。
【００５５】
図４は、実施例１のリアルタイム統計データ＿メタデータ３０１の一例を示す説明図である。
【００５６】
実施例１のリアルタイム統計データ＿メタデータ３０１は、テーブル形式のデータであり、プロセス名４０１、カラム名４０２、集計内容４０３、集計単位時間４０４、及び保持時間４０５を含む。なお、リアルタイム統計データ＿メタデータ３０１は前述したカラム以外のカラムが含まれてもよい。
【００５７】
プロセス名４０１は、リアルタイムデータ集計部１１１が実行する集計処理の名称である。カラム名４０２は、リアルタイムデータ集計部１１１によって集計されるリアルタイム統計データ３１０の内容である。集計内容４０３は、リアルタイムデータ集計部１１１が実行する集計処理の内容である。集計内容４０３には、例えば、集計処理の関数が格納される。集計単位時間４０４は、集計処理における集計時間の間隔である。保持時間４０５は、リアルタイムデータ集計部１１１のバッファ１１２に保持するリアルタイム統計データ３１０の時間幅である。
【００５８】
図４の一番目のエントリに対応するメタデータは、１秒単位にパケットのサイズを合計することによって算出される利用率を、リアルタイム統計データ３１０として管理するデータストアであることを示す。また、当該データストアは現在の時刻から一分間過去にさかのぼった時刻までの利用率が格納されることが分かる。
【００５９】
図４の二番目のエントリに対応するメタデータは、１秒単位にパケットの数を計測することによって算出されるパケット数を、リアルタイム統計データ３１０として管理するデータストアであることを示す。また、当該データストアは現在の時刻から一分間過去にさかのぼった時刻までのパケット数が格納されることが分かる。
【００６０】
図５は、実施例１の履歴統計データ＿メタデータ３０２の一例を示す説明図である。
【００６１】
実施例１の履歴統計データ＿メタデータ３０２は、テーブル形式のデータであり、テーブル名５０１、カラム名５０２、集計内容５０３、時間間隔５０４、及び集計単位時間５０５を含む。履歴統計データ＿メタデータ３０２は前述したカラム以外のカラムが含まれてもよい。
【００６２】
カラム名５０２、集計内容５０３、及び集計単位時間５０５は、カラム名４０２、集計内容４０３、及び集計単位時間４０４と同一のものである。テーブル名５０１は、履歴統計データ３２０として格納されたリアルタイム統計データ３１０を集計するための集計処理の名称であり、プロセス名４０１に対応する。時間間隔５０４は、履歴統計データ３２０の履歴の期間である。
【００６３】
計算機１２０の履歴統計データ＿データベース１２２には、履歴統計データ３２０が追加される。そのため、データベース管理部１２１は、新たな履歴統計データ３２０が追加されると、更新後の時間間隔を計算機１００に通知する。これによって時間間隔５０４が更新される。なお、計算機１００が、データベース管理部１２１に問い合わせることによって時間間隔５０４を更新してもよい。
【００６４】
図６は、実施例１の生データ＿メタデータ３０３の一例を示す説明図である。
【００６５】
実施例１の生データ＿メタデータ３０３は、ファイル形式のデータである。生データ＿メタデータ３０３には、計算機１３０が取得する生データ３３０のスキーマの定義情報が格納される。生データ＿メタデータ３０３は前述した定義情報以外の情報が格納されてもよい。
【００６６】
なお、本実施例は、リアルタイム統計データ＿メタデータ３０１、履歴統計データ＿メタデータ３０２、及び生データ＿メタデータ３０３のデータ形式に限定されない。例えば、リアルタイム統計データ＿メタデータ３０１及び履歴統計データ＿メタデータ３０２はファイル形式のデータであってもよい。また、メタデータとして登録するカラムは、メタデータ設定情報３５０を用いて任意に設定できる。
【００６７】
図７は、実施例１のメタデータ設定部１０２が実行する処理の一例を説明するフローチャートである。図８は、実施例１のメタデータ＿データベース１０５にメタデータを設定するための設定ファイルの一例を示す説明図である。図９は、実施例１のメタデータ＿データベース１０５にメタデータを設定するための設定コマンドの一例を示す説明図である。
【００６８】
メタデータ設定部１０２は、メタデータ設定指示を受信すると処理を開始する（ステップＳ７０１）。メタデータ設定指示は、計算機１００を操作する管理者、又はクライアント端末１４０を操作するユーザ等によって入力される。
【００６９】
メタデータ設定指示には、各データストアのデータに関する設定ファイル又は設定コマンド等がメタデータ設定情報３５０として含まれる。例えば、図８に示すような設定ファイル、又は、図９に示すような設定コマンドがメタデータ設定情報３５０として含まれる。
【００７０】
メタデータ設定部１０２は、データストアのループ処理を開始する（ステップＳ７０２）。具体的には、メタデータ設定部１０２は、メタデータ設定指示に含まれるメタデータ設定情報３５０を参照し、処理対象のデータストアを一つ選択する。
【００７１】
メタデータ設定部１０２は、メタデータ設定情報３５０に基づいて、メタデータ＿データベース１０５に選択されたデータストアのメタデータを設定する（ステップＳ７０３）。
【００７２】
例えば、メタデータ設定情報３５０が図８に示す設定ファイルであり、リアルタイム統計データ３１０を管理するデータストアが選択されている場合、メタデータ設定部１０２は、設定ファイルからカラムを抽出する。メタデータ設定部１０２は、抽出されたカラムが設定されたリアルタイム統計データ＿メタデータ３０１をメタデータ＿データベース１０５に生成する。さらに、メタデータ設定部１０２は、設定ファイルに基づいて、各カラムに値を設定する。
【００７３】
メタデータ設定部１０２は、メタデータ設定情報３５０に含まれるすべてのデータストアについてメタデータの設定が完了したか否かを判定する（ステップＳ７０４）。
【００７４】
メタデータ設定情報３５０に含まれるすべてのデータストアについてメタデータの設定が完了していないと判定された場合、メタデータ設定部１０２は、ステップＳ７０２に戻り、次の処理対象のデータストアを一つ選択し、同様の処理を実行する。
【００７５】
メタデータ設定情報３５０に含まれるすべてのデータストアについてメタデータの設定が完了したと判定された場合、メタデータ設定部１０２は、処理を終了する。
【００７６】
図１０は、実施例１のリクエスト振り分け部１０３が実行する処理の概要を説明するフローチャートである。
【００７７】
リクエスト振り分け部１０３は、表示部１４１からデータ取得リクエストを受信すると処理を開始する。データ取得リクエストは、要求するデータの時間範囲を指定する指定時間と、データの属性情報（集計情報）とを含む。指定時間は、開始時刻（ｔｓ）及び終了時刻（ｔｅ）を含み、また、データの属性情報は、プロセス名、集計単位時間、及び集計内容、又は、生データのスキーマの少なくともいずれかを含む。以下の説明では、データ取得リクエストによって要求されたデータを要求データとも記載する。
【００７８】
本実施例では、指定時間は任意に設定できる。指定時間は絶対時間又は相対時間のいずれかで指定される。例えば、絶対時間の場合、開時時刻「２０１４／０２／０１  １９：００」及び終了時刻「２０１４／０３／０１  １１：００」が指定時間として含まれ、相対時間の場合、開始時刻「ｎｏｗ−１ｍｉｎ」及び終了時刻「ｎｏｗ」が指定時間として含まれる。「ｎｏｗ」は現在の時刻を示し、本実施例では、現在の時刻とは、リクエスト振り分け部１０３が処理を開始した時刻を表すものとする。
【００７９】
リクエスト振り分け部１０３は、データ取得リクエストを解析し、要求データを取得するデータストアを特定するための情報を取得する（ステップＳ１００１）。具体的には、リクエスト振り分け部１０３は、指定時間及びデータの属性情報を取得する。また、リクエスト振り分け部１０３は、指定時間が相対時間又は絶対時間のいずれであるかを判定する。
【００８０】
リクエスト振り分け部１０３は、取得された指定時間に基づいて、データを取得するデータストアを特定するためのデータストア判定処理を実行する（ステップＳ１００２）。データストア判定処理では、リクエスト振り分け部１０３は、メタデータ＿データベース１０５に格納される各メタデータに含まれる時間の属性に基づいて、候補データストアを決定する。なお、データストア判定処理の詳細は、図１１Ａ及び図１１Ｂを用いて後述する。
【００８１】
リクエスト振り分け部１０３は、実際にリクエストを発行するデータストアを決定するためのリクエスト決定処理を実行し（ステップＳ１００３）、処理を終了する。
【００８２】
これは、候補データストアからは要求データを取得できない可能性があるためである。そのため、リクエスト振り分け部１０３は、メタデータに基づいて、候補データストアから要求データを取得できるか否かを判定し、当該判定結果に基づいて実際にリクエストを発行するデータストアを決定する。なお、リクエスト決定処理の詳細は、図１２を用いて後述する。
【００８３】
図１１Ａ及び図１１Ｂは、実施例１のデータストア判定処理の一例を説明するフローチャートである。
【００８４】
リクエスト振り分け部１０３は、データ取得リクエストの解析結果に基づいて、指定時間が相対時間であるか否かを判定する（ステップＳ１１０１）。
【００８５】
指定時間が相対時間であると判定された場合、リクエスト振り分け部１０３は、リアルタイムデータ集計部１１１から要求データを取得できる可能性があるか否かを判定する（ステップＳ１１０２）。具体的には、以下のような処理が実行される。
【００８６】
リクエスト振り分け部１０３は、現在の時刻を取得する。また、リアルタイム統計データ＿メタデータ３０１を参照し、保持時間４０５の値を取得する。リクエスト振り分け部１０３は、保持時間４０５の値を一つ選択し、下式（１）を満たすか否かを判定する。
【００８７】
【数１】
2015193988.tif 000003
【００８８】
ここで、「ｎｏｗ」は、現在の時刻を示す変数であり、「ｒｔ＿ｒａｎｇｅ」は選択された保持時間４０５を示す変数であり、ｔｅは終了時刻を示す変数である。式（１）を満たす保持時間４０５が少なくとも一つでも存在する場合、リクエスト振り分け部１０３は、リアルタイムデータ集計部１１１から取得可能なデータが存在すると判定する。なぜならば、式（１）を満たす場合、リアルタイムデータ集計部１１１のバッファ１１２には指定時間によって指定された要求データが格納されている可能性があるためである。
【００８９】
このとき、リクエスト振り分け部１０３は、リアルタイム統計データ＿メタデータ３０１にフラグを付与する。以上がステップＳ１１０２の処理の説明である。なお、リクエスト振り分け部１０３は、式（１）を満たすエントリにのみフラグを付与してもよい。これによって、後述するリクエスト決定処理では、フラグが付与されたエントリのみを対象に処理を実行すればよいため処理負荷を低減できる。以上がステップＳ１１０２の処理の説明である。なお、式（１）を用いた判定方法は一例であって、同様の判定ができればどのような条件を用いてもよい。
【００９０】
リアルタイムデータ集計部１１１から要求データを取得できる可能性がないと判定された場合、リクエスト振り分け部１０３は、履歴統計データ３２０を管理するデータストアを候補データストアに決定し（ステップＳ１１０３）、その後、リクエスト決定処理を開始する（ステップＳ１１０４）。
【００９１】
リアルタイムデータ集計部１１１から要求データを取得できる可能性があると判定された場合、リクエスト振り分け部１０３は、ステップＳ１１０６に進む。
【００９２】
ステップＳ１１０１において、指定時間が絶対時間であると判定された場合、リクエスト振り分け部１０３は、現在の時刻を取得し、現在の時刻が指定時間に含まれるか否かを判定する（ステップＳ１１０５）。
【００９３】
現在の時刻が指定時間に含まれないと判定された場合、リクエスト振り分け部１０３は、履歴統計データ３２０を管理するデータストアを候補データストアに決定し（ステップＳ１１０３）、その後、リクエスト決定処理を開始する（ステップＳ１１０４）。
【００９４】
現在の時刻が指定時間に含まれると判定された場合、リクエスト振り分け部１０３は、ステップＳ１１０６に進む。
【００９５】
ステップＳ１１０２の判定結果が「Ｙｅｓ」、又はステップＳ１１０５の判定結果が「Ｙｅｓ」の場合、リクエスト振り分け部１０３は、履歴統計データ３２０を取得する必要があるか否かを判定する（ステップＳ１１０６）。具体的には、以下のような処理が実行される。
【００９６】
リクエスト振り分け部は、現在の時刻、及び保持時間４０５の値を取得する。リクエスト振り分け部１０３は、保持時間４０５の値を一つ選択し、下式（２）を満たすか否かを判定する。
【００９７】
【数２】
2015193988.tif 000004
【００９８】
ここで、ｔｓは開始時刻を示す変数である。式（２）を満たす保持時間４０５が少なくとも一つでも存在する場合、リクエスト振り分け部１０３は、履歴統計データを取得する必要があると判定する。なぜならば、式（２）を満たす場合、リアルタイムデータ集計部１１１のバッファ１１２には、すべての要求データが格納されていないためである。なお、式（２）を用いた判定方法は一例であって、同様の判定ができればどのような条件を用いてもよい。
【００９９】
履歴統計データ３２０を取得する必要があると判定された場合、リクエスト振り分け部１０３は、リアルタイム統計データ３１０を管理するデータストア及び履歴統計データ３２０を管理するデータストアを候補データストアに決定し（ステップＳ１１０７）、その後、リクエスト決定処理を開始する（ステップＳ１１０４）。具体的には、以下のような処理が実行される。
【０１００】
リクエスト振り分け部１０３は、下式（３）を満たす時刻ｔ０を特定する。リクエスト振り分け部１０３は、ｔｓからｔ０までの要求データについては履歴統計データ３２０を管理するデータストアを候補データストアとして決定し、また、ｔ０からｔｅまでの要求データについてはリアルタイム統計データ３１０を管理するデータストアを候補データストアとして決定する。
【０１０１】
【数３】
2015193988.tif 000005
【０１０２】
このとき、リクエスト振り分け部１０３は、履歴統計データ＿メタデータ３０２にフラグを付与する。以上がステップＳ１１０７の処理の説明である。なお、式（３）を用いた判定方法は一例であって、同様の判定ができればどのような条件を用いてもよい。
【０１０３】
履歴統計データ３２０を取得する必要がないと判定された場合、リクエスト振り分け部１０３は、リアルタイム統計データ３１０を管理するデータストアを候補データストアに決定し（ステップＳ１１０８）、その後、リクエスト決定処理を開始する（ステップＳ１１０４）。
【０１０４】
前述したように、データストア判定処理では、データ取得リクエストに含まれる指定時間に基づいてメタデータ＿データベース１０５を参照することによって、リクエストを発行する候補データストアを決定できる。これによって、ユーザがデータストアに格納されるデータの属性、特に、時間の属性を意識することなく、適切なデータストアを選択できる。
【０１０５】
図１２は、実施例１のリクエスト決定処理の一例を説明するフローチャートである。
【０１０６】
リクエスト振り分け部１０３は、リアルタイム統計データ３１０を管理するデータストアが候補データストアであるか否かを判定する（ステップＳ１２０１）。
【０１０７】
具体的には、リクエスト振り分け部１０３は、リアルタイム統計データ＿メタデータ３０１にフラグが付与されているか否かを判定する。
【０１０８】
リアルタイム統計データ３１０を管理するデータストアが候補データストアでないと判定された場合、リクエスト振り分け部１０３は、ステップＳ１２０４に進む。
【０１０９】
リアルタイム統計データ３１０を管理するデータストアが候補データストアであると判定された場合、リクエスト振り分け部１０３は、リアルタイム統計データ＿メタデータ３０１を参照して、データ取得リクエストに含まれるデータの属性情報に一致するリアルタイム統計データ３１０が存在するか否かを判定する（ステップＳ１２０２）。具体的には、以下のような処理が実行される。
【０１１０】
まず、リクエスト振り分け部１０３は、データの属性情報として、プロセス名、集計内容、及び集計単位時間が取得されたか否かを判定する。プロセス名、集計内容、及び集計単位時間が取得されていない場合、リクエスト振り分け部１０３は、データ取得リクエストのデータの属性情報に一致するリアルタイム統計データ３１０が存在しないと判定する。
【０１１１】
プロセス名、集計内容、及び集計単位時間が取得されたと判定された場合、リクエスト振り分け部１０３は、リアルタイム統計データ＿メタデータ３０１のプロセス名４０１及び集計内容４０３が取得されたプロセス名及び集計内容と一致するエントリを検索する。一致するエントリが存在しない場合、リクエスト振り分け部１０３は、データ取得リクエストのデータの属性情報に一致するリアルタイム統計データ３１０が存在しないと判定する。
【０１１２】
リクエスト振り分け部１０３は、検索されたエントリの集計単位時間４０４の値が、取得された集計単位時間以下、かつ、集約可能な時間であるか否かを判定する。以下の説明では、前述の判定条件を第１の判定条件とも記載する。ここで、取得された集計単位時間が「１ｍｉｎ」の場合を例に前述した処理を説明する。
【０１１３】
検索されたエントリの集計単位時間４０４の値が「１ｍｉｎ」の場合、リクエスト振り分け部１０３は、第１の判定条件を満たすと判定する。
【０１１４】
検索されたエントリの集計単位時間４０４の値が「３０ｓｅｃ」の場合、リクエスト振り分け部１０３は、第１の判定条件を満たすと判定する。これは、リクエスト振り分け部１０３は、集計単位時間が「３０ｓｅｃ」のリアルタイム統計データ３１０を二つ取得し、当該二つのリアルタイム統計データ３１０を集計することによって「１ｍｉｎ」のリアルタイム統計データ３１０を生成できるためである。
【０１１５】
検索されたエントリの集計単位時間４０４の値が「５０ｓｅｃ」の場合、リクエスト振り分け部１０３は、第１の判定条件を満たさないと判定する。これは、集計単位時間が「５０ｓｅｃ」のリアルタイム統計データ３１０から「１ｍｉｎ」のリアルタイム統計データ３１０を生成できないためである。
【０１１６】
すなわち、集計単位時間４０４の値が取得された集計単位時間の約数である場合、リクエスト振り分け部１０３は、第１の判定条件を満たすと判定する。以上がステップＳ１２０２の処理の説明である。
【０１１７】
データ取得リクエストに含まれるデータの属性情報に一致するリアルタイム統計データ３１０が存在すると判定された場合、リクエスト振り分け部１０３は、リアルタイムデータ集計部１１１へリクエストを発行し（ステップＳ１２０３）、その後、ステップＳ１２０４に進む。
【０１１８】
具体的には、リクエスト振り分け部１０３は、検索されたエントリの情報を含むリクエスト発行指示をアダプタ３０４−１に出力する。アダプタ３０４−１は、当該指示が入力されると、所定のリアルタイムデータ集計部１１１に対してリクエストを発行する。
【０１１９】
データ取得リクエストに含まれるデータの属性情報に一致するリアルタイム統計データ３１０が存在しないと判定された場合、リクエスト振り分け部１０３は、生データを管理するデータベース管理部１３１へリクエストを発行し（ステップＳ１２０７）、その後、ステップＳ１２０４に進む。具体的には、以下のような処理が実行される。
【０１２０】
リクエスト振り分け部１０３は、生データ＿メタデータ３０３を参照し、要求されたデータを取得できる生データ＿データベース１３２を特定する。このとき、第１の判定条件を適用してもよい。リクエスト振り分け部１０３は、特定された生データ＿データベース１３２を管理する計算機１３０の識別子を含むリクエスト発行指示をアダプタ３０４−３に出力する。アダプタ３０４−３は、当該指示が入力されると、所定の計算機１３０のデータベース管理部１３１に対してリクエストを発行する。以上がステップＳ１２０７の処理の説明である。
【０１２１】
ステップＳ１２０４では、リクエスト振り分け部１０３は、履歴統計データ３２０を管理するデータストアが候補データストアであるか否かを判定する（ステップＳ１２０４）。
【０１２２】
具体的には、リクエスト振り分け部１０３は、履歴統計データ＿メタデータ３０２にフラグが付与されているか否かを判定する。
【０１２３】
履歴統計データ３２０を管理するデータストアが候補データストアでないと判定された場合、リクエスト振り分け部１０３は、処理を終了する。
【０１２４】
履歴統計データ３２０を管理するデータストアが候補データストアであると判定された場合、リクエスト振り分け部１０３は、履歴統計データ＿メタデータ３０２を参照して、データ取得リクエストに含まれるデータの属性情報に一致する履歴統計データ３２０が存在するか否かを判定する（ステップＳ１２０５）。ステップＳ１２０５の処理は、ステップＳ１２０２の処理と同一の処理である。
【０１２５】
データ取得リクエストに含まれるデータの属性情報に一致する履歴統計データ３２０が存在すると判定された場合、リクエスト振り分け部１０３は、データベース管理部１２１へリクエストを発行し（ステップＳ１２０６）、その後、処理を終了する。
【０１２６】
具体的には、リクエスト振り分け部１０３は、検索されたエントリの情報を含むリクエスト発行指示をアダプタ３０４−２に出力する。アダプタ３０４−２は、当該指示が入力されると、所定のデータベース管理部１２１に対してリクエストを発行する。
【０１２７】
データ取得リクエストに含まれるデータの属性情報に一致するリアルタイム統計データ３１０が存在しないと判定された場合、リクエスト振り分け部１０３は、生データを管理するデータベース管理部１３１へリクエストを発行し（ステップＳ１２０８）、その後、処理を終了する。ステップＳ１２０８の処理は、ステップＳ１２０７の処理と同一の処理である。
【０１２８】
本実施例では、データストア判定処理及びリクエスト決定処理を別々に実行しているが、二つの処理を同時に実行してもよい。例えば、リクエスト振り分け部１０３は、ステップＳ１１０３の処理の後にステップＳ１２０５の処理を実行し、ステップＳ１１０７の処理の後にステップＳ１２０２及びステップＳ１２０５の処理を実行し、ステップＳ１１０８の処理の実行後にステップＳ１２０２の処理を実行する。
【０１２９】
ここで、具体的なデータ取得リクエストを用いて、データストア判定処理及びリクエスト決定処理の具体的な処理内容を説明する。図４、図５及び図６に示す各メタデータを想定する。
【０１３０】
図１３Ａ、図１３Ｂ、図１３Ｃ、図１３Ｄ、図１３Ｅ、図１３Ｆ、及び図１３Ｇは、実施例１のデータ取得リクエストの一例を示す説明図である。
【０１３１】
（図１３Ａのデータ取得リクエスト）
開時時刻及び終了時刻が「ｎｏｗ」になり、指定時間は相対時間である。したがって、ステップＳ１１０１の判定結果はＹｅｓとなる。また、式（１）を満たすエントリが存在するため、ステップＳ１１０２の判定結果はＹｅｓとなる。また、式（２）を満たさないため、ステップＳ１１０６の判定結果はＮｏとなる。したがって、候補データストアは、リアルタイム統計データ３１０を管理するデータストアとなる。
【０１３２】
候補データストアはリアルタイム統計データ３１０を管理するデータストアであるため、ステップＳ１２０１の判定結果はＹｅｓとなる。ステップＳ１２０２では、プロセス名、集計内容、及び集計単位時間が、リアルタイム統計データ＿メタデータ３０１の一番上のエントリと一致するため、判定結果はＹｅｓとなる。また、候補データストアはリアルタイム統計データ３１０を管理するデータストアのみであるため、ステップＳ１２０４の判定結果はＮｏとなる。
【０１３３】
以上の結果より、リクエスト振り分け部１０３は、リアルタイムデータ集計部１１１へリクエストを発行する。
【０１３４】
（図１３Ｂのデータ取得リクエスト）
開始時刻が「ｎｏｗ−１ｍｉｎ」、終了時刻が「ｎｏｗ」になり、指定時間は相対時間である。したがって、ステップＳ１１０１の判定結果はＹｅｓとなる。また、式（１）を満たすエントリが存在するため、ステップＳ１１０２の判定結果はＹｅｓとなる。また、式（２）を満たさないため、ステップＳ１１０６の判定結果はＮｏとなる。したがって、候補データストアは、リアルタイム統計データ３１０を管理するデータストアとなる。
【０１３５】
候補データストアはリアルタイム統計データ３１０を管理するデータストアであるため、ステップＳ１２０１の判定結果はＹｅｓとなる。ステップＳ１２０２では、プロセス名、集計内容、及び集計単位時間が、リアルタイム統計データ＿メタデータ３０１の一番上のエントリと一致するため、判定結果はＹｅｓとなる。また、候補データストアはリアルタイム統計データ３１０を管理するデータストアのみであるため、ステップＳ１２０４の判定結果はＮｏとなる。
【０１３６】
以上の結果より、リクエスト振り分け部１０３は、リアルタイムデータ集計部１１１へリクエストを発行する。
【０１３７】
（図１３Ｃのデータ取得リクエスト）
開始時刻が「２０１４／０２／０１  １９：００：００」、終了時刻が「２０１４／０２／０１  １９：０１：００」になり、指定時間は絶対時間である。したがって、ステップＳ１１０１の判定結果はＮｏとなる。
【０１３８】
現在の時刻が指定時間に含まれる場合、ステップＳ１１０５の判定結果はＹｅｓとなる。式（２）を満たさないため、ステップＳ１１０６の判定結果はＮｏとなる。したがって、候補データストアは、リアルタイム統計データ３１０を管理するデータストアとなる。
【０１３９】
一方、現在の時刻が指定時間に含まれない場合、ステップＳ１１０５の判定結果はＮｏとなる。したがって、候補データストアは、履歴統計データ３２０を管理するデータストアとなる。
【０１４０】
候補データストアがリアルタイム統計データ３１０を管理するデータストアの場合、ステップＳ１２０１の判定結果はＹｅｓとなる。ステップＳ１２０２では、プロセス名、集計内容、及び集計単位時間が、リアルタイム統計データ＿メタデータ３０１の一番上のエントリと一致するため、判定結果はＹｅｓとなる。また、候補データストアはリアルタイム統計データ３１０を管理するデータストアのみであるため、ステップＳ１２０４の判定結果はＮｏとなる。以上の結果より、リクエスト振り分け部１０３は、リアルタイムデータ集計部１１１へリクエストを発行する。
【０１４１】
候補データストアが履歴統計データ３２０を管理するデータストアの場合、ステップＳ１２０１の判定結果はＮｏとなり、また、ステップＳ１２０４の判定結果はＹｅｓとなる。ステップＳ１２０５では、プロセス名、集計内容、及び集計単位時間が、リアルタイム統計データ＿メタデータ３０１の一番上のエントリと一致するため、判定結果はＹｅｓとなる。以上の結果より、リクエスト振り分け部１０３は、データベース管理部１２１へリクエストを発行する。
【０１４２】
（図１３Ｄのデータ取得リクエスト）
開始時刻が「ｎｏｗ−１ｈｏｕｒ」、終了時刻が「ｎｏｗ」になり、指定時間は相対時間である。したがって、ステップＳ１１０１の判定結果はＹｅｓとなる。また、式（１）を満たすエントリが存在するため、ステップＳ１１０２の判定結果はＹｅｓとなる。式（２）を満たすため、ステップＳ１１０６の判定結果はＹｅｓとなる。したがって、候補データストアは、リアルタイム統計データ３１０を管理するデータストア及び履歴統計データ３２０を管理するデータストアとなる。なお、ｔ０は「ｎｏｗ−１ｍｉｎ」となる。
【０１４３】
候補データストアはリアルタイム統計データ３１０を管理するデータストアであるため、ステップＳ１２０１の判定結果はＹｅｓとなる。ステップＳ１２０２では、プロセス名、集計内容、及び集計単位時間が、リアルタイム統計データ＿メタデータ３０１の一番上のエントリと一致するため、判定結果はＹｅｓとなる。また、履歴統計データ３２０を管理するデータストアも候補データストアであるため、ステップＳ１２０４の判定結果はＹｅｓとなる。ステップＳ１２０５では、プロセス名、集計内容、及び集計単位時間が、リアルタイム統計データ＿メタデータ３０１の一番上のエントリと一致するため、判定結果はＹｅｓとなる。
【０１４４】
以上の結果より、リクエスト振り分け部１０３は、リアルタイムデータ集計部１１１へリクエストを発行し、「ｎｏｗ−１ｈｏｕｒ」から「ｎｏｗ−１ｍｉｎ」までの要求データについてはデータベース管理部１２１へリクエストを発行する。
【０１４５】
（図１３Ｅのデータ取得リクエスト）
開始時刻が「２０１４／０２／０１  １９：００：００」、終了時刻が「２０１４／０２／０１  １９：１０：００」になり、指定時間は絶対時間である。したがって、ステップＳ１１０１の判定結果はＮｏとなる。
【０１４６】
現在の時刻が指定時間に含まれる場合、ステップＳ１１０５の判定結果はＹｅｓとなる。式（２）を満たすため、ステップＳ１１０６の判定結果はＹｅｓとなる。したがって、候補データストアは、リアルタイム統計データ３１０を管理するデータストア及び履歴統計データ３２０を管理するデータストアとなる。
【０１４７】
一方、現在の時刻が指定時間に含まれない場合、ステップＳ１１０５の判定結果はＮｏとなる。したがって、候補データストアは、履歴統計データ３２０を管理するデータストアとなる。
【０１４８】
候補データストアがリアルタイム統計データ３１０を管理するデータストアの場合、ステップＳ１２０１の判定結果はＹｅｓとなる。ステップＳ１２０２では、プロセス名、集計内容、及び集計単位時間が、リアルタイム統計データ＿メタデータ３０１の一番上のエントリと一致するため、判定結果はＹｅｓとなる。また、履歴統計データ３２０を管理するデータストアも候補データストアの場合、ステップＳ１２０５の判定結果はＹｅｓとなる。以上の結果より、リクエスト振り分け部１０３は、リアルタイムデータ集計部１１１へリクエストを発行し、「２０１４／０２／０１  １９：００：００」から「２０１４／０２／０１  １９：０９：００」までの要求データについてはデータベース管理部１２１へリクエストを発行する。
【０１４９】
候補データストアが履歴統計データ３２０を管理するデータストアの場合、ステップＳ１２０１の判定結果はＮｏとなり、また、ステップＳ１２０４の判定結果はＹｅｓとなる。ステップＳ１２０５では、プロセス名、集計内容、及び集計単位時間が、リアルタイム統計データ＿メタデータ３０１の一番上のエントリと一致するため、判定結果はＹｅｓとなる。以上の結果より、リクエスト振り分け部１０３は、データベース管理部１２１へリクエストを発行する。
【０１５０】
（図１３Ｆのデータ取得リクエスト）
開始時刻が「２０１４／０２／０１  １９：００：００」、終了時刻が「２０１４／０２／０１  １９：１０：００」になり、指定時間は絶対時間である。したがって、ステップＳ１１０１の判定結果はＮｏとなる。
【０１５１】
現在の時刻が指定時間に含まれる場合、ステップＳ１１０５の判定結果はＹｅｓとなる。式（２）を満たすため、ステップＳ１１０６の判定結果はＹｅｓとなる。したがって、候補データストアは、リアルタイム統計データ３１０を管理するデータストア及び履歴統計データ３２０を管理するデータストアとなる。
【０１５２】
一方、現在の時刻が指定時間に含まれない場合、ステップＳ１１０５の判定結果はＮｏとなる。したがって、候補データストアは、履歴統計データ３２０を管理するデータストアとなる。
【０１５３】
候補データストアがリアルタイム統計データ３１０を管理するデータストアの場合、ステップＳ１２０１の判定結果はＹｅｓとなる。ステップＳ１２０２では、集計単位時間と一致するエントリが存在しないため、判定結果はＮｏとなる。また、履歴統計データ３２０を管理するデータストアも候補データストアの場合、ステップＳ１２０５の判定結果はＮｏとなる。以上の結果より、リクエスト振り分け部１０３は、データベース管理部１３１へリクエストを発行する。
【０１５４】
候補データストアが履歴統計データ３２０を管理するデータストアの場合、ステップＳ１２０１の判定結果はＮｏとなり、また、ステップＳ１２０４の判定結果はＹｅｓとなる。ステップＳ１２０５では、集計単位時間と一致するエントリが存在しないため判定結果はＮｏとなる。以上の結果より、リクエスト振り分け部１０３は、データベース管理部１３１へリクエストを発行する。
【０１５５】
（図１３Ｇのデータ取得リクエスト）
開始時刻が「２０１４／０２／０１  １９：００：００」、終了時刻が「２０１４／０２／０１  １９：１０：００」になり、指定時間は絶対時間である。したがって、ステップＳ１１０１の判定結果はＮｏとなる。
【０１５６】
現在の時刻が指定時間に含まれる場合、ステップＳ１１０５の判定結果はＹｅｓとなる。式（２）を満たすため、ステップＳ１１０６の判定結果はＹｅｓとなる。したがって、候補データストアは、リアルタイム統計データ３１０を管理するデータストア及び履歴統計データ３２０を管理するデータストアとなる。
【０１５７】
一方、現在の時刻が指定時間に含まれない場合、ステップＳ１１０５の判定結果はＮｏとなる。したがって、候補データストアは、履歴統計データ３２０を管理するデータストアとなる。
【０１５８】
候補データストアがリアルタイム統計データ３１０を管理するデータストアの場合、ステップＳ１２０１の判定結果はＹｅｓとなる。ステップＳ１２０２では、プロセス名、集計内容及び集計単位時間が取得されていないため、判定結果はＮｏとなる。また、履歴統計データ３２０を管理するデータストアも候補データストアの場合、ステップＳ１２０５の判定結果はＮｏとなる。以上の結果より、リクエスト振り分け部１０３は、データベース管理部１３１へリクエストを発行する。
【０１５９】
候補データストアが履歴統計データ３２０を管理するデータストアの場合、ステップＳ１２０１の判定結果はＮｏとなり、また、ステップＳ１２０４の判定結果はＹｅｓとなる。ステップＳ１２０５では、プロセス名、集計内容及び集計単位時間が取得されていないため、判定結果はＮｏとなる。以上の結果より、リクエスト振り分け部１０３は、データベース管理部１３１へリクエストを発行する。
【０１６０】
以上で説明したように、ユーザは指定時間のみを行うことによって、適切なデータストアから要求データを取得できる。
【０１６１】
次に、出力処理部１０４が実行する処理について説明する。図１４は、実施例１の出力処理部１０４が実行する処理の一例を説明するフローチャートである。
【０１６２】
出力処理部１０４は、データストアからすべてのデータが取得された後、以下で説明する処理を実行する。例えば、リクエスト振り分け部１０３が、発行されたリクエストの応答を監視し、発行されたすべてのリクエストの応答を受信したことを検知した場合、出力処理部１０４に処理の開始を指示する。
【０１６３】
出力処理部１０４は、データストアのループ処理を開始する（ステップＳ１４０１）。出力処理部１０４は、対象のデータストアから取得されたデータを集計する必要があるか否かを判定する（ステップＳ１４０２）。具体的には、以下のような処理が実行される。
【０１６４】
出力処理部１０４は、対象のデータストアがリアルタイム統計データ３１０又は履歴統計データ３２０を管理するデータストアであるか否かを判定する。対象のデータストアが生データ３３０を管理するデータストアである場合、出力処理部１０４は、データを集計する必要がないと判定する。
【０１６５】
対象のデータストアがリアルタイム統計データ３１０又は履歴統計データ３２０を管理するデータストアであると判定された場合、出力処理部１０４は、対象のデータストアに対応するメタデータ、すなわち、リアルタイム統計データ＿メタデータ３０１又は履歴統計データ＿メタデータ３０２を参照し、集計単位時間４０４の値又は集計単位時間５０５の値を取得する。
【０１６６】
出力処理部１０４は、集計単位時間４０４の値又は集計単位時間５０５の値が、データ取得リクエストに含まれるデータの属性情報の集計単位時間より小さいか否かを判定する。
【０１６７】
集計単位時間４０４の値又は集計単位時間５０５の値が、データ取得リクエストに含まれるデータの属性情報の集計単位時間より小さい場合、出力処理部１０４は、データを集計する必要があると判定する。以上がステップＳ１４０２の処理の説明である。
【０１６８】
対象のデータストアから取得されたデータを集計する必要がないと判定された場合、出力処理部１０４は、ステップＳ１４０４に進む。
【０１６９】
対象のデータストアから取得されたデータを集計する必要があると判定された場合、出力処理部１０４は、取得されたデータを用いて、要求されたデータを生成する（ステップＳ１４０３）。
【０１７０】
例えば、要求データの集計時間単位が「１ｍｉｎ」であり、データストアから取得されたデータの集計時間単位が「２０ｓｅｃ」である場合、出力処理部１０４は、取得されたデータを三つマージすることによって一つの要求データを生成する。さらに、出力処理部１０４は、生成された要求データを時間順に並び替える。なお、予め収集処理の内容が指定されてもよい。
【０１７１】
出力処理部１０４は、データが取得されたすべてのデータストアについて処理が完了したか否かを判定する（ステップＳ１４０４）。
【０１７２】
データが取得されたすべてのデータストアについて処理が完了していないと判定された場合、出力処理部１０４は、新たなデータストアを選択し（ステップＳ１４０１）、同様の処理を実行する。
【０１７３】
データが取得されたすべてのデータストアについて処理が完了したと判定された場合、出力処理部１０４は、応答情報を生成し（ステップＳ１４０５）、生成された応答情報を表示部１４１に送信する（ステップＳ１４０６）。その後、出力処理部１０４は処理を終了する。
【０１７４】
出力処理部１０４は、表示部１４１からの要求に基づいて、応答情報を生成する。例えば、出力処理部１０４は、グラフデータ、タイムチャート、及びＣＳＶ形式のファイルデータを応答情報として生成する。本実施例では、生成される応答情報の内容に限定されない。
【０１７５】
実施例１では、出力処理部１０４が、ステップＳ１４０３において要求されたデータを生成しているが、データベース管理部１２１及びデータベース管理部１３１が要求されたデータを生成してもよい。
【０１７６】
例えば、リクエスト振り分け部１０３が、データの集計方法を決定し、アダプタ３０４に決定された集計方法を含むリクエストの発行を指示する。この場合、アダプタ３０４は、ＳＱＬ等の所定のリクエストをデータベース管理部１２１又はデータベース管理部１３１に発行する。データベース管理部１２１又はデータベース管理部１３１は、受信したリクエストに従って、データベースからデータを取得し、取得されたデータを所定の集計方法に基づいて集計し、集計されたデータをデータストア管理部１０１に送信する。
【０１７７】
データベース管理部１２１又はデータベース管理部１３１が、データを集計する場合、ステップＳ１４０１からステップＳ１４０４の処理を省略できる。
【０１７８】
以上で説明したように、実施例１によれば、データストア管理部１０１は、データ取得リクエストを解析し、当該解析の結果とデータストアに格納されるデータの属性とを比較することによって、データを取得するデータストアを適切に決定できる。
【０１７９】
ユーザは、データ取得リクエストに、詳細なデータの属性を設定する必要がないため、容易に要求データを取得できる。また、データストアに格納されるデータの属性を把握する必要がないため、ユーザの管理負担を低減できる。
【０１８０】
また、データストアに要求されたデータが存在しない場合であっても、データストア管理部１０１は、生データ等のデータを用いて、要求データを生成できる。
【０１８１】
［実施例２］
実施例２では、新たにリアルタイム集計処理を追加された場合のデータストア管理部１０１の処理について説明する。以下、実施例１との差異を中心に実施例２について説明する。
【０１８２】
実施例２の計算機システムの構成、計算機１００のハードウェア構成及びソフトウェア構成は実施例１のものと同一であるため説明を省略する。実施例２のリアルタイム統計データ＿メタデータ３０１、履歴統計データ＿メタデータ３０２、及び生データ＿メタデータ３０３は実施例１のものと同一であるため説明を省略する。また、実施例２のデータストア判定処理及びリクエスト決定処理は実施例１の処理と同一であるため説明を省略する。
【０１８３】
図１５は、実施例２の計算機システムにおける処理の流れを説明するブロック図である。図１６は、実施例２のデータストア管理部１０１が実行する処理の一例を説明するフローチャートである。
【０１８４】
実施例２では、一時的に集計処理が追加される点が実施例１と異なる。このとき、リアルタイムデータ集計部１１１のバッファ１１２には、既存のリアルタイム統計データ３１０、及び新規のリアルタイム統計データ１５１０が格納される。新規のリアルタイム統計データ１５１０は、履歴統計データ３２０に格納されず、一定時間経過した後にバッファ１１２から破棄される。
【０１８５】
一時的に集計処理を追加する方法としては、表示部１４１がデータ取得リクエストを用いてリアルタイム集計処理を追加する方法が考えられる。例えば、現在参照しているデータのドリルダウンを行う時に一時的にリアルタイム集計処理を追加することが考えられる。ここで、図１６を用いて、実施例２のデータストア管理部１０１が実行する処理について説明する。
【０１８６】
データストア管理部１０１は、表示部１４１からデータ取得リクエストを受信すると処理を開始する。まず、データストア管理部１０１のリクエスト振り分け部１０３は、受信したデータ取得リクエストを解析する（ステップＳ１６０１）。受信したデータ取得リクエストが図１３Ａに示すようなリクエストの場合、リクエスト振り分け部１０３が実施例１に示した処理を実行する。
【０１８７】
ここでは、新規集計処理の追加を指示するデータ取得リクエストを受信したものとする。当該データ取得リクエストには、プロセス名、リアルタイム統計データ３１０の内容、集計内容、集計単位時間、及び保持時間が含まれる。また、リクエスト振り分け部１０３は、データ取得リクエストの解析結果を含む更新指示をメタデータ設定部１０２に出力する。
【０１８８】
データストア管理部１０１は、データ取得リクエストの解析結果に基づいて、所定のリアルタイムデータ集計部１１１に新たなリアルタイム集計処理の追加、及び当該リアルタイム集計処理の開始を指示する（ステップＳ１６０２）。
【０１８９】
データストア管理部１０１のメタデータ設定部１０２は、更新指示に含まれるデータ取得リクエストの解析結果に基づいて、リアルタイム統計データ＿メタデータ３０１を更新する（ステップＳ１６０３）。データストア管理部１０１は、その後、処理を終了する。
【０１９０】
具体的には、メタデータ設定部１０２は、リアルタイム統計データ＿メタデータ３０１に新たにエントリを追加し、データ取得リクエストの解析結果に基づいて、追加されたエントリのプロセス名４０１、カラム名４０２、集計内容４０３、集計単位時間４０４、及び保持時間４０５のそれぞれに値を設定する。
【０１９１】
なお、追加されたリアルタイム集計処理が終了した後、データストア管理部１０１のメタデータ設定部１０２は、リアルタイム統計データ＿メタデータ３０１から追加されたエントリを削除する。
【０１９２】
実施例１及び実施例２では、データストア管理部１０１、リアルタイムデータ集計部１１１、履歴統計データ＿データベース１２２、及び生データ＿データベース１３２を別々の計算機を用いて実現していたがこれに限定されない。
【０１９３】
計算機１００、１１０、１２０、１３０は、仮想計算機であってもよい。また、一つの計算機が、データストア管理部１０１、リアルタイムデータ集計部１１１、履歴統計データ＿データベース１２２、及び生データ＿データベース１３２を有してもよい。また、一つの計算機上に生成された仮想計算機を用いて、計算機１００、１１０、１２０、１３０を実現してもよい。また、計算機１００が表示部１４１を有してもよい。
【０１９４】
なお、本発明は上記した実施例に限定されるものではなく、様々な変形例が含まれる。また、例えば、上記した実施例は本発明を分かりやすく説明するために構成を詳細に説明したものであり、必ずしも説明した全ての構成を備えるものに限定されるものではない。また、各実施例の構成の一部について、他の構成に追加、削除、置換することが可能である。
【０１９５】
また、上記の各構成、機能、処理部、処理手段等は、それらの一部又は全部を、例えば集積回路で設計する等によりハードウェアで実現してもよい。また、本発明は、実施例の機能を実現するソフトウェアのプログラムコードによっても実現できる。この場合、プログラムコードを記録した記憶媒体をコンピュータに提供し、そのコンピュータが備えるプロセッサが記憶媒体に格納されたプログラムコードを読み出す。この場合、記憶媒体から読み出されたプログラムコード自体が前述した実施例の機能を実現することになり、そのプログラムコード自体、及びそれを記憶した記憶媒体は本発明を構成することになる。このようなプログラムコードを供給するための記憶媒体としては、例えば、フレキシブルディスク、ＣＤ−ＲＯＭ、ＤＶＤ−ＲＯＭ、ハードディスク、ＳＳＤ（Ｓｏｌｉｄ  Ｓｔａｔｅ  Ｄｒｉｖｅ）、光ディスク、光磁気ディスク、ＣＤ−Ｒ、磁気テープ、不揮発性のメモリカード、ＲＯＭなどが用いられる。
【０１９６】
また、本実施例に記載の機能を実現するプログラムコードは、例えば、アセンブラ、Ｃ／Ｃ＋＋、ｐｅｒｌ、Ｓｈｅｌｌ、ＰＨＰ、Ｊａｖａ等の広範囲のプログラム又はスクリプト言語で実装できる。
【０１９７】
さらに、実施例の機能を実現するソフトウェアのプログラムコードを、ネットワークを介して配信することによって、それをコンピュータのハードディスクやメモリ等の記憶手段又はＣＤ−ＲＷ、ＣＤ−Ｒ等の記憶媒体に格納し、コンピュータが備えるプロセッサが当該記憶手段や当該記憶媒体に格納されたプログラムコードを読み出して実行するようにしてもよい。
【０１９８】
上述の実施例において、制御線や情報線は、説明上必要と考えられるものを示しており、製品上必ずしも全ての制御線や情報線を示しているとは限らない。全ての構成が相互に接続されていてもよい。
【図１】
2015193988.tif 000006
【図２】
2015193988.tif 000007
【図３】
2015193988.tif 000008
【図４】
2015193988.tif 000009
【図５】
2015193988.tif 000010
【図６】
2015193988.tif 000011
【図７】
2015193988.tif 000012
【図８】
2015193988.tif 000013
【図９】
2015193988.tif 000014
【図１０】
2015193988.tif 000015
【図１１Ａ】
2015193988.tif 000016
【図１１Ｂ】
2015193988.tif 000017
【図１２】
2015193988.tif 000018
【図１３Ａ】
2015193988.tif 000019
【図１３Ｂ】
2015193988.tif 000020
【図１３Ｃ】
2015193988.tif 000021
【図１３Ｄ】
2015193988.tif 000022
【図１３Ｅ】
2015193988.tif 000023
【図１３Ｆ】
2015193988.tif 000024
【図１３Ｇ】
2015193988.tif 000025
【図１４】
2015193988.tif 000026
【図１５】
2015193988.tif 000027
【図１６】
2015193988.tif 000028
【国際調査報告】
2015193988.tif 000029
2015193988.tif 000030