(57)【要約】  本発明は、情報技術の分野に関し、データ集約および統計の精度が比較的低いという技術的問題とデータ集約操作が比較的高い遅延を有するという別の技術的問題とを解決するためのデータ集約方法および装置を開示し、したがってデータ集約の効率が改善され得、データ集約のリアルタイム実行が保証され得る。本発明の主な技術的解決策は以下のとおりである。クラウド環境内に格納された大量のサービスデータが集約される必要がある場合に、データ集約サーバは最初に、サービスデータサーバにより送信されたサービスデータを受信し、次に、サービスデータに含まれたタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかがリアルタイムで検出され、イエスである場合、データ集約は、タイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプと同じであるサービスデータに対し行われる。本発明はクラウド環境内に格納された大量のサービスデータを集約するために主として使用される。
2019510305.tif 000002
【特許請求の範囲】
【請求項１】
サービスデータサーバにより送信されたサービスデータをデータ集約サーバにより受信することであって、前記サービスデータはタイムスタンプを含み、前記タイムスタンプは前記サービスサーバが前記サービスデータを受信した時刻を識別するために使用される、受信することと、
前記タイムスタンプが標的タイムスタンプより大きいかどうかを検出することであって、前記標的タイムスタンプは、前記サービスデータサーバにより送信され前記データ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプである、検出することと、
前記タイムスタンプが前記標的タイムスタンプより大きい場合、タイムスタンプが前記標的タイムスタンプであるサービスデータに対しデータ集約を行うことであって、前記サービスデータは事前設定格納場所に格納されている前記標的タイムスタンプに対応する、データ集約を行うこととを含む、データ集約方法。
【請求項２】
タイムスタンプが前記標的タイムスタンプであるサービスデータに対しデータ集約を行う前記工程前に、タイムスタンプが前記標的タイムスタンプであるサービスデータが、現在受信されているサービスデータの受信後の第１の事前設定期間内に受信されるかどうかを判断することをさらに含む請求項１に記載のデータ集約方法であって、タイムスタンプが前記標的タイムスタンプであるサービスデータに対してデータ集約を行う前記工程は、
タイムスタンプが前記標的タイムスタンプであるいかなるサービスデータも前記第１の事前設定期間内に受信されない場合、タイムスタンプが前記標的タイムスタンプであるサービスデータに対しデータ集約を行うことと、
タイムスタンプが前記標的タイムスタンプであるサービスデータが前記第１の事前設定期間内に受信される場合、前記第１の事前設定期間内に受信された前記サービスデータおよびタイムスタンプが前記標的タイムスタンプであるサービスデータに対しデータ集約を行うこととを含む、データ集約方法。
【請求項３】
前記タイムスタンプが前記標的タイムスタンプより大きい場合、タイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行う前記工程後に、
前記サービスデータサーバが、タイプが前記現在受信されているサービスデータのものと同じであるサービスデータの受信を終了するかどうかを判断することと、
前記サービスデータサーバが、タイプが前記サービスデータのものと同じであるサービスデータの受信を終了する場合、前記現在受信されているサービスデータに対しデータ集約を行うことと、をさらに含む、請求項１に記載のデータ集約方法。
【請求項４】
前記サービスデータサーバが、タイプが前記現在受信されているサービスデータのものと同じであるサービスデータの受信を終了するかどうかを判断する前記工程は、
タイプが前記サービスデータのものと同じであるサービスデータが、前記現在受信されているサービスデータの受信後の第２の事前設定期間内に受信されるかどうかを判断することと、
タイプが前記サービスデータのものと同じであるいかなるサービスデータも前記第２の事前設定期間内に受信されない場合、前記サービスデータサーバは、タイプが前記サービスデータのものと同じであるサービスデータの受信を終了するということを確認することとを含む、請求項３に記載のデータ集約方法。
【請求項５】
前記サービスデータサーバが、タイプが前記サービスデータのものと同じであるサービスデータの受信を終了する場合、前記現在受信されているサービスデータに対しデータ集約を行う前記工程は、
前記サービスデータサーバが、タイプが前記サービスデータのものと同じであるサービスデータの受信を終了する場合、前記現在タイムスタンプとは異なる次の隣のタイムスタンプに対応する集約コンピュータサーバのローカル時刻を取得することであって、それぞれの異なるタイムスタンプは、前記集約コンピュータサーバの１つのローカル時刻にそれぞれ対応する前記サービスデータサーバにより構成される、取得することと、
前記集約コンピュータサーバの前記ローカル時刻に従って、前記現在受信されているサービスデータに対しデータ集約を行うこととを含む、請求項３または４に記載のデータ集約方法。
【請求項６】
前記タイムスタンプが標的タイムスタンプより大きいかどうかを検出する前記工程後に、
前記タイムスタンプが前記標的タイムスタンプと同じである場合、前記現在受信されているサービスデータを前記標的タイムスタンプに対応する事前設定キュー内にバッファすることであって、タイムスタンプが前記標的タイムスタンプであるすべてのサービスデータは前記事前設定キュー内にバッファされる、バッファすることと、
前記タイムスタンプが前記標的タイムスタンプより小さい場合、前記現在受信されているサービスデータを削除することと、をさらに含む、請求項１に記載のデータ集約方法。
【請求項７】
前記タイムスタンプが前記標的タイムスタンプより大きい場合、タイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行う前記工程後に、
現在受信されているサービスデータのタイムスタンプに対応するキューを設定することと、
前記サービスデータを前記キュー内にバッファすることと、をさらに含む、請求項１に記載のデータ集約方法。
【請求項８】
サービスデータサーバにより送信されたサービスデータを受信するように構成された受信ユニットであって、前記サービスデータはタイムスタンプを含み、前記タイムスタンプは前記サービスサーバが前記サービスデータを受信した時刻を識別するために使用される、受信ユニットと、
前記受信ユニットにより受信された前記タイムスタンプが標的タイムスタンプより大きいかどうかを検出するように構成された検出ユニットであって、前記標的タイムスタンプは、前記サービスデータサーバにより送信され前回受信されたサービスデータに含まれたタイムスタンプである、検出ユニットと、
前記検出ユニットにより検出された前記タイムスタンプが前記標的タイムスタンプより大きい場合、タイムスタンプが前記標的タイムスタンプであるサービスデータに対しデータ集約を行うように構成された集約ユニットであって、前記サービスデータは事前設定格納場所に格納されている前記標的タイムスタンプに対応する、集約ユニットとを含む、データ集約装置。
【請求項９】
判断ユニットをさらに含む請求項８に記載のデータ集約装置であって、
前記判断ユニットは、タイムスタンプが前記標的タイムスタンプであるサービスデータが、現在受信されているサービスデータの受信後の第１の事前設定期間内に受信されるかどうかを判断するように構成され、
前記集約ユニットは特に、タイムスタンプが前記標的タイムスタンプであるいかなるサービスデータも、現在受信されているサービスデータの受信後の前記第１の事前設定期間内に受信されない場合、タイムスタンプが前記標的タイムスタンプであるサービスデータに対しデータ集約を行うとともに、
タイムスタンプが前記標的タイムスタンプであるサービスデータが、現在受信されているサービスデータの受信後の前記第１の事前設定期間内に受信される場合、前記第１の事前設定期間内に受信された前記サービスデータおよびタイムスタンプが前記標的タイムスタンプであるサービスデータに対しデータ集約を行うように構成される、データ集約装置。
【請求項１０】
前記判断ユニットはさらに、前記サービスデータサーバが、タイプが前記現在受信されているサービスデータのものと同じであるサービスデータの受信を終了するかどうかを判断するように構成され、
前記集約ユニットはさらに、前記サービスデータサーバが、タイプが前記サービスデータのものと同じであるサービスデータの受信を終了する場合、前記現在受信されているサービスデータに対しデータ集約を行うように構成される、請求項９に記載のデータ集約装置。
【請求項１１】
確認ユニットをさらに含む請求項１０に記載のデータ集約装置であって、
前記判断ユニットは特に、タイプが前記サービスデータのものと同じであるサービスデータが、前記現在受信されているサービスデータの受信後の第２の事前設定期間内に受信されるかどうか判断するように構成され、
前記確認ユニットは、タイプが前記サービスデータのものと同じであるサービスデータが前記第２の事前設定期間内に受信されない場合に前記サービスデータサーバはタイプが前記サービスデータのものと同じであるサービスデータの受信を終了する、ということを確認するように構成される、データ集約装置。
【請求項１２】
前記集約ユニットは、
前記サービスデータサーバが、タイプが前記サービスデータのものと同じであるサービスデータの受信を終了する場合、前記現在タイムスタンプとは異なる次の隣のタイムスタンプに対応する集約コンピュータサーバのローカル時刻を取得するように構成された取得モジュールであって、それぞれの異なるタイムスタンプは前記集約コンピュータサーバの１つのローカル時刻にそれぞれ対応する前記サービスデータサーバにより構成される、取得モジュールと、
前記集約コンピュータサーバの前記ローカル時刻に従って、前記現在受信されているサービスデータに対しデータ集約を行うように構成された集約モジュールとを含む、請求項１０または１１に記載のデータ集約装置。
【請求項１３】
前記タイムスタンプが前記標的タイムスタンプと同じである場合、前記現在受信されているサービスデータを、前記標的タイムスタンプに対応する事前設定キュー内にバッファするように構成されるバッファユニットであって、タイムスタンプが前記標的タイムスタンプであるすべてのサービスデータは前記事前設定キュー内にバッファされる、バッファユニットと、
前記タイムスタンプが前記標的タイムスタンプより小さい場合、前記現在受信されているサービスデータを削除するように構成された削除ユニットと、をさらに含む、請求項８に記載のデータ集約装置。
【請求項１４】
設定ユニットをさらに含む請求項１３に記載のデータ集約装置であって、
前記設定ユニットは、現在受信されているサービスデータのタイムスタンプに対応するキューを設定するように構成され、
前記バッファユニットはさらに、前記サービスデータを前記キュー内にバッファするように構成される、データ集約装置。
【発明の詳細な説明】
【技術分野】
【０００１】
技術分野
本発明は情報技術の分野に関し、特にデータ集約方法および装置に関する。
【背景技術】
【０００２】
背景技術
インターネットが発展し続けるにつれて、サービスデータの統計をクラウド環境内に格納および収集する（例えば、毎秒クエリー数（ＱＰＳ：queries per second）データおよびページビュー（ＰＶ：page view）データなど様々なタイプのサービスデータの統計を格納および収集する）ことがますます普及してきた。膨大なデータがクラウド環境内に格納される。したがって、クラウド環境内に格納される大量のサービスデータは、大量のサービスデータの統計が収集される前に、集約される必要がある。
【０００３】
現在、クラウド環境内に格納される大量のサービスデータの集約中、様々な期間内に受信される様々なタイプのサービスデータが最初にファイル内に書き込まれ、次に、集約される必要のあるタイプを有するすべてのサービスデータがファイルから読み出され、読み出されたサービスデータは、最終的に時刻順にソートされ、データ集約のためにコンピュータサーバへ送信される。例えば、サービスデータはデータ集約のためにマップ削減サーバへ送信される。詳細は図５に示され得る。しかし、読み出し操作／書き込み操作はデータ集約中にファイルに対して行われる必要がある。ファイルに対する読み出し操作／書き込み操作中に存在するファイルロック競合問題を解決するために、データ集約中、集約対象データを保存するファイルコピー処理が一回行われる。その結果、データ計算は比較的大きい遅延を有する。さらに、読み出されたサービスデータはさらに、時刻順に一回ソートされる必要がある。結局、データ集約の処理は比較的複雑であり、データ集約操作は比較的低い効率を有し、データ集約操作は比較的高い遅延を有する。さらに、サービスデータがファイルから読み出され、集約操作が完了した後、その時刻が集約操作が行われたサービスデータと同じまたはそれより早いサービスデータが再び受信される場合、再び受信されたサービスデータの一部は廃棄されることになる。その結果、データ集約および統計の精度は比較的低い。
【発明の概要】
【課題を解決するための手段】
【０００４】
発明の概要
この観点で、本発明はデータ集約方法および装置を提供する。主目的は「データ集約操作は、クラウド環境内に格納された大量のサービスデータの集約中に比較的高い遅延を有する」という技術的問題を解決することである。
【０００５】
さらに、本発明はさらに、データ集約方法および装置を提供する。主目的は、データ集約および統計の精度が比較的低いという技術的問題を解決することである。
【０００６】
これまで述べた目的を達成するために、本発明は以下の技術的解決策を提供する。
【０００７】
一態様では、本発明は、サービスデータサーバにより送信されたサービスデータをデータ集約サーバにより受信することであって、サービスデータはタイムスタンプを含み、タイムスタンプはサービスサーバがサービスデータを受信した時刻を識別するために使用される、受信することと、タイムスタンプが標的タイムスタンプより大きいかどうかを検出することであって、標的タイムスタンプは、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプである、検出することと、タイムスタンプが標的タイムスタンプより大きい場合、タイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行うことであって、サービスデータは事前設定格納場所に格納されている標的タイムスタンプに対応する、データ集約を行うこととを含むデータ集約方法を提供する。
【０００８】
別の態様では、本発明は、サービスデータサーバにより送信されたサービスデータを受信するように構成された受信ユニットであって、サービスデータはタイムスタンプを含み、タイムスタンプはサービスサーバがサービスデータを受信した時刻を識別するために使用される、受信ユニットと、受信ユニットにより受信されたタイムスタンプが標的タイムスタンプより大きいかどうかを検出するように構成された検出ユニットであって、標的タイムスタンプは、サービスデータサーバにより送信され前回受信されたサービスデータに含まれたタイムスタンプである、検出ユニットと、検出ユニットにより受信されたタイムスタンプが標的タイムスタンプより大きい場合、タイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行うように構成された集約ユニットであって、サービスデータは事前設定格納場所に格納されている標的タイムスタンプに対応する、集約ユニットと、を含むデータ集約装置を提供する。
【０００９】
これまで述べた技術的解決策を使用することにより、本発明の実施形態において提供される技術的解決策は、少なくとも以下の利点を有する。
【００１０】
本発明において提供されるデータ集約方法および装置では、クラウド環境内に格納された大量のサービスデータが集約される必要がある場合、データ集約サーバは最初に、サービスデータサーバにより送信されたサービスデータを受信し、次に、サービスデータに含まれたタイムスタンプがサービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかがリアルタイムで検出され、イエスである場合、データ集約は、タイムスタンプがサービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプと同じであるサービスデータに対し行われる。現在、クラウド環境内に格納された大量のサービスデータの集約中、読み出し操作／書き込み操作はサービスデータを格納するためのファイルに対し行われる必要があり、読み出されたサービスデータはさらに、時刻順に一回ソートされる必要がある。一方、集約操作が行われたサービスデータと時刻が同じかまたはそれより早いサービスデータが再び受信される場合、このサービスデータの一部は廃棄されることになる。相対的に、本発明では、様々な期間内のサービスデータを集約するために、現在のサービスデータのタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかだけを検出する必要があり、したがってデータ集約の効率が改善され得る。検出操作はリアルタイムで行われるので、データ集約操作の遅延は低減され得、データ集約のリアルタイム性能が改善され得る。さらに、時間許容期間が本発明では設定されるので、集約操作は、時刻が比較的早い現在受信されているサービスデータに対し行われ得、したがってデータ集約および統計の精度が改善され得る。
【００１１】
これまでの説明は、本発明の技術的解決策の概要にすぎない。本発明の技術的措置をより明確に理解するとともに本明細書に従って内容を実施するために、そして本発明のこれまで述べたおよび他の目的、特徴、および利点をより理解可能にするために本発明の特定実施方法が以下に説明される。
【００１２】
図面の簡単な説明
様々な他の利点および恩恵は好適な実施方法の以下の詳細説明を読むことにより当業者に明確かつ明瞭になる。添付図面は、好適な実施方法を示す目的のためだけに使用され、本発明を限定するように意図されていない。同じ参照符号が添付図面を通じて同じ部品を表すために使用される。
【図面の簡単な説明】
【００１３】
【図１】図１は、本発明の一実施形態によるデータ集約方法のフローチャートである。
【図２】図２は、本発明の一実施形態による別のデータ集約方法のフローチャートである。
【図３】図３は、本発明の一実施形態によるデータ集約装置の概略構造図である。
【図４】図４は、本発明の一実施形態による別のデータ集約装置の概略構造図である。
【図５】図５は、本発明による既存データ集約手順の概略図である。
【図６】図６は、本発明の一実施形態による様々なサービスデータサーバのサービスデータのタイムスタンプの概略図である。
【図７】図７は、本発明の一実施形態による様々なデータ集約サーバのローカル時刻の概略図である。
【図８】図８は、本発明の一実施形態によるデータ集約サーバの様々なサービスデータのタイムスタンプの概略図である。
【図９】図９は、本発明の一実施形態によるサービスデータサーバの時刻とデータ集約サーバの時刻とのマッピング法の概略図である。
【発明を実施するための形態】
【００１４】
詳細な説明
本開示の例示的実施形態は、添付図面を参照してさらに詳細に以下に説明される。本開示の例示的実施形態は添付図面内に示されるが、本開示は様々な形式で実施され、本明細書で説明された実施形態により限定されるべきでないということを理解すべきである。その代りに、これらの実施形態は、本開示のより完全な理解と、本開示の範囲の当業者への完全な伝達とのために提供される。
【００１５】
本発明の一実施形態はデータ集約方法を提供する。図１に示すように、本方法は以下の工程を含む。
【００１６】
１０１：データ集約サーバが、サービスデータサーバにより送信されたサービスデータを受信する。
【００１７】
サービスデータはタイムスタンプを含み、タイムスタンプは、サービスサーバがサービスデータを受信する時刻を識別するために使用される。例えば、サービスデータサーバがサービスデータを受信する時刻が１０：０１である場合、データ集約サーバにより受信されるサービスデータに含まれたタイムスタンプは１０：０１である。データ集約サーバはサービスデータサーバにより送信されたサービスデータに対し集約処理を行うように構成される。サービスデータは、ＱＰＳデータおよびＰＶデータなど様々なタイプのサービスデータであってもよいし、様々なアプリケーションの同じタイプのサービスデータ（例えば、アプリケーションＡおよびアプリケーションＢのＰＶデータ）であってもよい。これは、本発明のこの実施形態では限定されない。
【００１８】
１０２．タイムスタンプが標的タイムスタンプより大きいかどうかが検出される。
【００１９】
標的タイムスタンプは、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプである。様々なタイムスタンプが一覧表および時間軸などのやり方で時刻順に提示され得る。これは、本発明のこの実施形態では限定されない。例えば、様々なタイムスタンプが時間軸などのやり方で時刻順に提示されるとき、時間軸上の時刻は、時間軸上の時刻が現在時刻であるということを保証するために経過し続ける。本発明のこの実施形態では、タイムスタンプが標的タイムスタンプより大きいかどうかが検出される、すなわち、サービスデータ集約操作をトリガすべきかどうかを判断するために、サービスデータを受信する時刻が現在のところ、サービスデータを前回受信した時刻と異なるかどうかが検出され、したがってサービスデータ集約操作のリアルタイム性能が保証され得る。
【００２０】
本発明のこの実施形態では、タイムスタンプは、単位として秒を使用することによりまたは単位として分を使用することにより構成され得る。これは、本発明のこの実施形態では限定されない。タイムスタンプが単位として秒を使用することにより構成される場合、異なるタイムスタンプは秒（例えば１０：０１：０１、１０：０１：０２、１０：０１：０３）により識別される。タイムスタンプが単位として分を使用することにより構成される場合、異なるタイムスタンプは分（例えば１０：０１、１０：０２、１０：０３）により識別される。ここで、１０：０１：０１〜１０：０１：５９はすべて１０：０１に含まれる。残りは類推により導出され得る。
【００２１】
例えば、サービスデータサーバは単位として分を使用することによりタイムスタンプを構成する。サービスデータサーバにより送信されデータ集約サーバにより現在受信されているサービスデータに含まれたタイムスタンプが１０：０１であり、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプもまた１０：０１である場合、サービスデータ集約操作をトリガしないことが判断される。サービスデータサーバにより送信されデータ集約サーバにより現在受信されているサービスデータに含まれたタイムスタンプが１０：０２であり、このタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプ１０：０１より大きい場合、サービスデータ集約操作をトリガすることが判断される。
【００２２】
１０３．タイムスタンプが標的タイムスタンプより大きい場合、データ集約は、タイムスタンプが標的タイムスタンプであるサービスデータに対し行われる。
【００２３】
標的タイムスタンプに対応するサービスデータは事前設定格納場所に格納される。事前設定格納場所は事前設定マッピング関係表、事前設定キューなどであり得る。これは、本発明のこの実施形態では限定されない。本発明のこの実施形態では、タイムスタンプが標的タイムスタンプより大きい場合、例えば１０：０１から１０：０２へ変化すれば、または１０：０１：０１から１０：０１：０２へ変化すれば、現在のサービスデータに含まれたタイムスタンプが進んだということを示し、以前のタイムスタンプを有するすべてのサービスデータに対し集約操作を行うことがリアルタイムでトリガされ、したがってサービスデータ集約操作のリアルタイム性能が保証され得、サービスデータ集約操作の効率が改善され得る。
【００２４】
本発明のこの実施形態において提供されるデータ集約方法では、クラウド環境内に格納された大量のサービスデータが集約される必要がある場合、データ集約サーバはサービスデータサーバにより送信されたサービスデータを最初に受信し、次に、サービスデータに含まれたタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかがリアルタイムで検出され、イエスである場合、データ集約は、タイムスタンプがサービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプと同じであるサービスデータに対し行われる。現在、クラウド環境内に格納された大量のサービスデータの集約中、読み出し操作／書き込み操作はサービスデータを格納するためのファイルに対し行われる必要があり、読み出されたサービスデータはさらに、時刻順に一回ソートされる必要がある。相対的に、本発明では、様々な期間内のサービスデータを集約するために、現在のサービスデータのタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかだけを検出する必要があり、したがってデータ集約の効率が改善され得る。検出操作はリアルタイムで行われるので、データ集約操作の遅延は低減され得、同時に、データ集約のリアルタイム性能が改善され得る。
【００２５】
さらに、本発明の一実施形態は別のデータ集約方法を提供する。図２に示すように、本方法は以下の工程を含む。
【００２６】
２０１：データ集約サーバが、サービスデータサーバにより送信されたサービスデータを受信する。
【００２７】
サービスデータはタイムスタンプを含み、タイムスタンプは、サービスサーバがサービスデータを受信する時刻を識別するために使用される。データ集約サーバおよびサービスデータの対応説明のために、図１の実施形態の対応説明を参照し得る。これはここでは最早詳述されない。
【００２８】
２０２：タイムスタンプが標的タイムスタンプより大きいかどうかが検出される。
【００２９】
標的タイムスタンプは、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプである。タイムスタンプを構成するやり方の特定説明のために、図１の実施形態の対応説明を参照し得る。これはここでは最早詳述されない。
【００３０】
本発明のこの実施形態では、タイムスタンプが標的タイムスタンプより大きいかどうかが検出される、すなわち、サービスデータ集約操作をトリガすべきかどうかを判断するために、サービスデータを受信する時刻が現在のところ、サービスデータを前回受信した時刻から進んだかどうかが検出され、したがってサービスデータ集約操作のリアルタイム性能が保証され得る。
【００３１】
さらに、工程２０２後、本方法はさらに、タイムスタンプが標的タイムスタンプと同じである場合、現在受信されているサービスデータを標的タイムスタンプに対応する事前設定キュー内にバッファすることを含み得る。タイムスタンプが標的タイムスタンプであるすべてのサービスデータは事前設定キュー内にバッファされる。異なるタイムスタンプを有するサービスデータはそれぞれ異なる事前設定キュー内にバッファにされる。キューに対するバッファおよび読み出し操作は比較的低い遅延を有するので、データ集約操作の遅延はキュー内のサービスデータをバッファすることによりさらに低減され、したがってデータ集約操作のリアルタイム性能が改善され得る。タイムスタンプが標的タイムスタンプより小さい場合、現在受信されているサービスデータは削除される。例えば、タイムスタンプが１０：０１から０９：５０へ変化し、タイムスタンプが０９：５０である現在受信されているサービスデータは削除され、したがってデータ集約の精度が保証され得る。
【００３２】
２０３：タイムスタンプが標的タイムスタンプより大きい場合、データ集約が、タイムスタンプが標的タイムスタンプであるサービスデータに対し行われる。
【００３３】
標的タイムスタンプに対応するサービスデータは事前設定格納場所に格納される。事前設定格納場所は事前設定マッピング関係表、事前設定キューなどであり得る。これは、本発明のこの実施形態では限定されない。
【００３４】
本発明のこの実施形態では、工程２０３の前に、本方法はさらに、タイムスタンプが標的タイムスタンプであるサービスデータが、現在受信されているサービスデータの受信後の第１の事前設定期間内に受信されるかどうかを判断することを含み得る。あるタイムスタンプを有するサービスデータが集約された後、データ送信の遅延などの理由のために、サービスデータサーバは同タイムスタンプを有するサービスデータを再び受信し得る。この場合、遅延後に受信されたサービスデータが処理されなければ、サービスデータの損失が引き起こされ得、その結果、サービスデータ集約の精度は比較的低い。したがって、データ集約が行われる前に、時間許容期間（すなたち、第１の事前設定期間）を構成することにより、遅延後に受信されたサービスデータの損失が回避され得、サービスデータ集約および統計の精度は改善され得る。
【００３５】
第１の事前設定期間はタイムスタンプの構成単位に従って構成され得る。例えば、タイムスタンプの構成単位が秒である場合、第１の事前設定期間は１秒、２秒などであり得る。タイムスタンプの構成単位が分である場合、第１の事前設定期間は１分、２分などであり得る。第１の事前設定期間はタイムスタンプの構成単位に従って構成され、したがって時間許容期間を構成する精度はさらに改善され得、サービスデータ集約の精度はさらに改善され得る。
【００３６】
この場合、工程２０３は特に、タイムスタンプが標的タイムスタンプであるいかなるサービスデータも第１の事前設定期間内に受信されない場合、タイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行うことと、タイムスタンプが標的タイムスタンプであるサービスデータが第１の事前設定期間内に受信される場合、第１の事前設定期間内に受信されたサービスデータおよびタイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行うこととを含み得る。
【００３７】
例えば、サービスデータサーバは単位として分を使用することによりタイムスタンプを構成する。この場合、第１の事前設定期間は５分であるように構成される。サービスデータサーバにより送信されデータ集約サーバにより現在受信されているサービスデータに含まれたタイムスタンプが１０：０２であり、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプが１０：０１である場合、タイムスタンプが１０：０１であるサービスデータが集約される前に、タイムスタンプ１０：０１を含むサービスデータが現在時刻から始まる５分以内に受信されるかどうかが判断される。このようなサービスデータが５分以内に受信される場合、データ集約は、５分以内に受信されタイムスタンプ１０：０１を有するサービスデータ、および以前に受信されタイムスタンプ１０：０１を有するサービスデータに対し行われる。いかなるこのようなサービスデータも５分以内に受信されない場合、いかなる遅延サービスデータもこの時存在しないということを示し、データ集約は、タイムスタンプが１０：０１であるサービスデータに対し行われ、したがってデータ集約の精度が保証され得る。
【００３８】
さらに、工程２０３後、本方法はさらに、現在受信されているサービスデータのタイムスタンプに対応するキューを設定することと、サービスデータをキュー内にバッファすることとを含み得る。異なるタイムスタンプは異なるキューに対応するので、現在受信されているサービスデータを格納するために新しいキューが生成される。
【００３９】
２０４：タイプが現在受信されているサービスデータのものと同じであるサービスデータの受信を、サービスデータサーバが終了するかどうかが判断される。
【００４０】
同じタイプを有するサービスデータは特に、同じサービスデータタイプを有するサービスデータであり得る。例えば、ＱＰＳタイプを有するサービスデータの受信を終了すべきかどうかが判断される。同じタイプを有するサービスデータはさらに、特に同じアプリケーションのサービスデータであり得る。例えば、アプリケーションＡのサービスデータの受信を終了すべきかどうかが判断される。
【００４１】
本発明のこの実施形態では、工程２０４は特に、現在受信されているサービスデータの受信後の第２の事前設定期間内に、タイプが当該サービスデータのものと同じであるサービスデータが受信されるかどうかを判断することと、タイプが当該サービスデータのものと同じであるいかなるサービスデータも第２の事前設定期間内に受信されない場合、サービスデータサーバは、タイプが当該サービスデータのものと同じであるサービスデータの受信を終了するということを確認することとを含み得る。現在受信されているサービスデータの受信後の特定の期間内に、タイプが当該サービスデータのものと同じであるいかなるサービスデータも受信されない場合、サービスデータサーバは、タイプが現在受信されているサービスデータのものと同じであるサービスデータの受信を終了するということが判断され得るということに注意すべきである。
【００４２】
第２の事前設定期間は特に、タイムスタンプの構成単位に従って構成され得る。例えば、タイムスタンプの構成単位が秒である場合、第２の事前設定期間は１秒、２秒などであり得る。タイムスタンプの構成単位が１分である場合、第２の事前設定期間は１分、２分などであり得る。第２の事前設定期間はタイムスタンプの構成単位に従って構成され、したがってサービスデータ受信の終了を判断する精度はさらに改善され得、サービスデータ集約操作の精度が改善され得る。
【００４３】
２０５：サービスデータサーバが、タイプが当該サービスデータのものと同じであるサービスデータの受信を終了する場合、データ集約が現在受信されているサービスデータに対し行われる。
【００４４】
本発明のこの実施形態では、サービスデータサーバが、タイプが当該サービスデータのものと同じであるサービスデータの受信を終了する場合、データ集約サーバは当該タイプを有するサービスデータを最早受信しないということを示す。すなわち、この場合、このタイプを有するサービスデータが再び受信されるかどうかを使用することにより、同タイプを有するサービスデータのタイムスタンプが変更されるかどうかを判断することは、最早行われ得ない。したがって、この場合、データ集約は現在受信されているサービスデータに対し直接行われ得、その結果、サービスデータサーバが、タイプが当該サービスデータのものと同じであるサービスデータの受信を終了する場合、現在受信されているサービスデータに関するデータ集約は完了され得る、ということが保証され得る。
【００４５】
本発明のこの実施形態では、工程２０５は特に、サービスデータサーバが、タイプが当該サービスデータのものと同じであるサービスデータの受信を終了する場合、現在タイムスタンプとは異なる次の隣のタイムスタンプに対応する集約コンピュータサーバのローカル時刻を取得することを含み得、それぞれの異なるタイムスタンプは、集約コンピュータサーバの１つのローカル時刻にそれぞれ対応するサービスデータサーバにより構成される。詳細は図９に示され得る。データ集約は、集約コンピュータサーバのローカル時刻に従って、現在受信されているサービスデータに対し行われる。データ集約サーバのローカル時刻は、一覧表および時間軸などのやり方で時刻順に提示され得る。これは、本発明のこの実施形態では限定されない。
【００４６】
ネットワーク条件および異なるサーバ間の時間差などの問題のために、データ集約サーバのローカル時刻は、サービスデータサーバにより構成されたタイムスタンプとは異なり得るということに注意すべきである。例えば、図６と７に示すように、サービスデータサーバ１のサービスデータはデータ集約サーバ１により処理される。サービスデータサーバ１により構成されたタイムスタンプは１０：０１：０１であるということがわかる。この場合、データ集約サーバ１の対応ローカル時刻は１０：０３：０１である。データ集約サーバのローカル時刻はサービスデータサーバにより構成された対応タイムスタンプとは異なるということがわかる。データ集約サーバでは、同じ監視アイテムの異なるサービスデータの、データ集約サーバに同時に到着するタイムスタンプは異なり得、異なる監視アイテムは、異なるタイムスタンプを有し得る。例えば、図８に示すように、同じ監視アイテムのサービスデータＰＶについては、同時に、アプリケーションＡにおけるサービスデータのタイムスタンプ１０：００：００は、アプリケーションＢにおけるサービスデータのタイムスタンプ１０：０１：１０とは異なる。異なる監視アイテムのサービスデータＰＶおよびＲＴについては、サービスデータのタイムスタンプは異なり得る。加えて、サービスデータ収集の方法に起因して、サービスデータがデータ集約サーバに到着する時刻は、サービスデータがサービスデータサーバに到着する時刻とは異なる。例えば、図９に示すように、サービスデータがサービスデータサーバに到着する時刻は１０：０１であり、サービスデータがデータ集約サーバに到着する時刻が１０：０３である。したがって、リアルタイムデータ集約中、サービスデータサーバにより構成されたタイムスタンプはトリガ時刻として使用され、データ集約サーバのローカル時刻は同時にトリガ時刻として使用されず、したがってデータ集約の精度が保証され得る。さらに、サービスデータサーバにより構成された各異なるタイムスタンプと、データ集約サーバのローカル時刻との１対１対応が時刻順に設定され、したがって時刻の一貫性が保証され得る。サービスデータサーバがあるタイプを有するサービスデータの受信を終了すると、データ集約サーバのローカル時刻を使用することにより、集約操作が同タイプを有するサービスデータに対し精密に行われるということが依然として保証され得る。
【００４７】
本発明のこの実施形態では、特定アプリケーションシナリオが以下のように示され得るがこれに限定されなく、次のものを含む。図９に示すように、時間軸上の点ＳＢにおいて、データ集約サーバは、サービスデータサーバにより送信されたサービスデータを受信する。サービスデータに含まれたタイムスタンプが１１：０２であるということが取得され、タイムスタンプが、サービスデータサーバにより送信され時間軸上の点ＳＡにおいて前回受信されたサービスデータに含まれたタイムスタンプ１１：０１より大きいということが検出される。この場合、データ集約は、タイムスタンプが１１：０１であるサービスデータに対し行われる。さらに、タイムスタンプが１１：０２であるサービスデータのものとタイプが同じであるいかなるサービスデータも現在時刻から始まる５分内に受信されないということが判断される。「サービスデータサーバは、タイムスタンプが１１：０２であるサービスデータのものとタイプが同じであるサービスデータの受信を終了する」ということが判断され得る。この場合、データ集約サーバのローカル時刻が１１：０７（サービスデータサーバの１１：０３に対応）に達すると、データ集約が、タイムスタンプが１１：０２であるサービスデータに対し行われ、その結果、タイムスタンプが１１：０２であるサービスデータに対しデータ集約が行われる、ということが保証され得る。
【００４８】
本発明のこの実施形態において提供される別のデータ集約方法では、クラウド環境内に格納された大量のサービスデータが集約される必要がある場合、データ集約サーバはサービスデータサーバにより送信されたサービスデータを最初に受信し、次に、サービスデータに含まれたタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかがリアルタイムで検出され、イエスである場合、タイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプと同じであるサービスデータに対し、データ集約が行われる。現在、クラウド環境内に格納された大量のサービスデータの集約中、読み出し操作／書き込み操作はサービスデータを格納するためのファイルに対し行われる必要があり、読み出されたサービスデータはさらに、時刻順に一回ソートされる必要がある。一方、集約操作が行われたサービスデータと時刻が同じまたはそれより早いサービスデータが再び受信される場合、このサービスデータの一部は廃棄されることになる。相対的に、本発明のこの実施形態では、様々な期間内のサービスデータを集約するために、現在のサービスデータのタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかだけを検出する必要があり、したがってデータ集約の効率が改善され得る。検出操作がリアルタイムで行われるので、データ集約操作の遅延は低減され得、データ集約のリアルタイム性能が改善され得る。さらに、時間許容期間が本発明のこの実施形態では設定されるので、集約操作は、時刻が比較的早い現在受信されているサービスデータに対し行われ得、したがってデータ集約および統計の精度が改善され得る。
【００４９】
さらに、図１に示す方法の特定実装形態として、本発明の一実施形態はデータ集約装置を提供する。図３に示すように、本装置は受信ユニット３１、検出ユニット３２および集約ユニット３３を含み得る。
【００５０】
受信ユニット３１は、サービスデータサーバにより送信されたサービスデータを受信するように構成され、サービスデータはタイムスタンプを含み、タイムスタンプはサービスサーバがサービスデータを受信した時刻を識別するために使用される。
【００５１】
検出ユニット３２は、受信ユニット３１により受信されたタイムスタンプが標的タイムスタンプより大きいかどうかを検出するように構成され、標的タイムスタンプは、サービスデータサーバにより送信され前回受信されたサービスデータに含まれたタイムスタンプである。
【００５２】
集約ユニット３３は、検出ユニット３２により検出されたタイムスタンプが標的タイムスタンプより大きい場合、タイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行うように構成され、サービスデータは事前設定格納場所に格納されている標的タイムスタンプに対応する。
【００５３】
本装置実施形態はこれまで述べた方法実施形態に対応するということに注意すべきである。読み易くするために、これまで述べた方法実施形態における詳細内容は本装置実施形態においては一つ一つ最早説明されない。しかし、この実施形態における装置はこれまで述べた方法実施形態におけるすべての内容をそれに応じて実施し得るということを理解すべきである。
【００５４】
本発明のこの実施形態において提供されるデータ集約装置では、クラウド環境内に格納された大量のサービスデータが集約される必要がある場合、データ集約サーバは最初に、サービスデータサーバにより送信されたサービスデータを受信し、次に、サービスデータに含まれたタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかがリアルタイムで検出され、イエスである場合、タイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプと同じであるサービスデータに対し、データ集約が行われる。現在、クラウド環境内に格納された大量のサービスデータの集約中、読み出し操作／書き込み操作はサービスデータを格納するためのファイルに対し行われる必要があり、読み出されたサービスデータはさらに、時刻順に一回ソートされる必要がある。相対的に、本発明では、様々な期間内のサービスデータを集約するために、現在のサービスデータのタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかだけを検出する必要があり、したがってデータ集約の効率が改善され得る。検出操作がリアルタイムで行われるので、データ集約操作の遅延は低減され得、同時に、データ集約のリアルタイム性能が改善され得る。
【００５５】
さらに、図２に示す方法の特定実装形態として、本発明の一実施形態はデータ集約装置を提供する。図４に示すように、本装置は受信ユニット４１、検出ユニット４２および集約ユニット４３を含み得る。
【００５６】
受信ユニット４１は、サービスデータサーバにより送信されたサービスデータを受信するように構成され、サービスデータはタイムスタンプを含み、タイムスタンプはサービスサーバがサービスデータを受信した時刻を識別するために使用される。
【００５７】
検出ユニット４２は、受信ユニット４１により受信されたタイムスタンプが標的タイムスタンプより大きいかどうかを検出するように構成され、標的タイムスタンプは、サービスデータサーバにより送信され前回受信されたサービスデータに含まれたタイムスタンプである。
【００５８】
集約ユニット４３は、検出ユニット４２により検出されたタイムスタンプが標的タイムスタンプより大きい場合、タイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行うように構成され、サービスデータは事前設定格納場所に格納されている標的タイムスタンプに対応する。
【００５９】
さらに、本装置はさらに判断ユニット４４を含む。
【００６０】
判断ユニット４４は、タイムスタンプが標的タイムスタンプであるサービスデータが、現在受信されているサービスデータの受信後の第１の事前設定期間内に受信されるかどうかを判断するように構成される。
【００６１】
集約ユニット４３は特に、タイムスタンプが標的タイムスタンプであるいかなるサービスデータも、現在受信されているサービスデータの受信後の第１の事前設定期間内に受信されない場合、タイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行い、またタイムスタンプが標的タイムスタンプであるサービスデータが現在受信されているサービスデータの受信後の第１の事前設定期間内に受信される場合、第１の事前設定期間内に受信されたサービスデータおよびタイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行うように構成される。
【００６２】
さらに、判断ユニット４４はさらに、「サービスデータサーバが、タイプが現在受信されているサービスデータのものと同じであるサービスデータの受信を終了するかどうか」を判断するように構成される。
【００６３】
集約ユニット４３はさらに、タイプが現在受信されているサービスデータのものと同じであるサービスデータの受信をサービスデータサーバが終了する場合、現在受信されているサービスデータに対しデータ集約を行うように構成される。
【００６４】
さらに、本装置はさらに確認ユニット４５を含む。
【００６５】
判断ユニット４４は特に、「現在受信されているサービスデータの受信後の第２の事前設定期間内に、タイプが当該サービスデータのものと同じであるサービスデータが受信されるかどうか」を判断するように構成される。
【００６６】
確認ユニット４５は、タイプが当該サービスデータのものと同じであるサービスデータが第１の事前設定期間内に受信されない場合、サービスデータサーバはタイプが当該サービスデータのものと同じであるサービスデータの受信を終了する、ということを確認するように構成される。
【００６７】
さらに、集約ユニット４３は特に、取得モジュール４３０１および集約モジュール４３０２を含み得る。
【００６８】
取得モジュール４３０１は、タイプがサービスデータのものと同じであるサービスデータの受信をサービスデータサーバが終了する場合、現在タイムスタンプとは異なる次の隣のタイムスタンプに対応する集約コンピュータサーバのローカル時刻を取得するように構成され、それぞれの異なるタイムスタンプは、集約コンピュータサーバの１つのローカル時刻にそれぞれ対応するサービスデータサーバにより構成される。
【００６９】
集約モジュール４３０２は、集約コンピュータサーバのローカル時刻に従って、現在受信されているサービスデータに対しデータ集約を行うように構成される。
【００７０】
さらに、本装置はバッファユニット４６および削除ユニット４７をさらに含む。
【００７１】
バッファユニット４６は、タイムスタンプが標的タイムスタンプと同じである場合、現在受信されているサービスデータを、標的タイムスタンプに対応する事前設定キュー内にバッファするように構成され、タイムスタンプが標的タイムスタンプであるすべてのサービスデータは事前設定キュー内にバッファされる。
【００７２】
削除ユニット４７は、タイムスタンプが標的タイムスタンプより小さい場合、現在受信されているサービスデータを削除するように構成される。
【００７３】
さらに、本装置は設定ユニット４８をさらに含む。
【００７４】
設定ユニット４８は、現在受信されているサービスデータのタイムスタンプに対応するキューを設定するように構成される。
【００７５】
バッファユニット４６はさらに、サービスデータをキュー内にバッファするように構成される。
【００７６】
本装置実施形態はこれまで述べた方法実施形態に対応するということに注意すべきである。読み易くするために、これまで述べた方法実施形態における詳細内容は、本装置実施形態においては一つ一つ最早説明されない。しかし、この実施形態における装置はこれまで述べた方法実施形態におけるすべての内容をそれに応じて実施し得るということを理解すべきである。
【００７７】
本発明のこの実施形態において提供される別のデータ集約装置では、クラウド環境内に格納された大量のサービスデータが集約される必要がある場合、データ集約サーバは最初に、サービスデータサーバにより送信されたサービスデータを受信し、次に、サービスデータに含まれたタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかがリアルタイムで検出され、イエスである場合、タイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプと同じであるサービスデータに対し、データ集約行われる。現在、クラウド環境内に格納された大量のサービスデータの集約中、読み出し操作／書き込み操作はサービスデータを格納するためのファイルに対し行われる必要があり、読み出されたサービスデータはさらに、時刻順に一回ソートされる必要がある。一方、集約操作が行われたサービスデータと時刻が同じまたはそれより早いサービスデータが再び受信される場合、このサービスデータの一部は廃棄されることになる。相対的に、本発明のこの実施形態では、様々な期間内のサービスデータを集約するために、現在のサービスデータのタイムスタンプが、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプより大きいかどうかだけを検出する必要があり、したがってデータ集約の効率が改善され得る。検出操作がリアルタイムで行われるので、データ集約操作の遅延は低減され得、データ集約のリアルタイム性能が改善され得る。さらに、時間許容期間が本発明のこの実施形態では設定されるので、集約操作は、時刻が比較的早い現在受信されているサービスデータに対し行われ得、したがってデータ集約および統計の精度が改善され得る。
【００７８】
データ集約装置はプロセッサおよびメモリを含む。これまで述べた受信ユニット、検出ユニット、集約ユニット、判断ユニット、確認ユニット、バッファユニット、削除ユニットおよび設定ユニットはすべてプログラムユニットとしてメモリ内に格納される。プロセッサは、対応機能を実現するために、メモリ内に格納されたこれまで述べたプログラムユニットを実行する。
【００７９】
プロセッサはカーネルを含む。カーネルはメモリから対応プログラムユニットを呼び出す。１つまたは複数のカーネルが配置され得る。カーネルパラメータは、グラフから選択されたグラフィックの表示中に断続的な表示停止があるという問題を解決するように調整される。
【００８０】
メモリは、コンピュータ可読媒体内の、揮発性メモリ、ランダムアクセスメモリ（ＲＡＭ）および／または不揮発性メモリ（例えば読み出し専用メモリ（ＲＯＭ）またはフラッシュＲＡＭ）などの形式を含み得る。メモリは少なくとも１つの記憶チップを含む。
【００８１】
本出願はさらにコンピュータプログラム製品を提供する。データ処理装置上で実行されると、コンピュータプログラム製品は、以下の方法工程により初期化されたプログラムコードを実行するように適用可能である：サービスデータサーバにより送信されたサービスデータをデータ集約サーバにより受信することであって、サービスデータはタイムスタンプを含み、タイムスタンプはサービスサーバがサービスデータを受信した時刻を識別するために使用される、受信することと、タイムスタンプが標的タイムスタンプより大きいかどうかを検出することであって、標的タイムスタンプは、サービスデータサーバにより送信されデータ集約サーバにより前回受信されたサービスデータに含まれたタイムスタンプである、検出することと、タイムスタンプが標的タイムスタンプより大きい場合、タイムスタンプが標的タイムスタンプであるサービスデータに対しデータ集約を行うことであって、サービスデータは事前設定格納場所に格納されている標的タイムスタンプに対応する、データ集約を行うこと。
【００８２】
当業者は、本出願の実施形態が方法、システムまたはコンピュータプログラム製品として提供され得るということを理解すべきである。したがって、本出願は、ハードウェアだけの実施形態、ソフトウェアだけの実施形態、またはソフトウェアおよびハードウェアの組み合わせを有する実施形態の形式を使用し得る。さらに、本出願は、コンピュータ使用可能プログラムコードを含む１つまたは複数のコンピュータ使用可能記憶媒体（限定しないが、ディスクメモリ、ＣＤ−ＲＯＭ、光学メモリなどを含む）上で実施されるコンピュータプログラム製品の形式を使用し得る。
【００８３】
本出願は、本出願の実施形態によるデータ集約方法および装置とコンピュータプログラム製品のフローチャートおよび／またはブロック図を参照して説明される。コンピュータプログラム命令は、フローチャートおよび／またはブロック図内の各処理および／または各ブロックと、フローチャートおよび／またはブロック図内の処理および／またはブロックの組み合わせとを実施するために使用され得るということを理解すべきである。これらのコンピュータプログラム命令は、機械を生成するために汎用コンピュータ、専用コンピュータ、埋め込み型プロセッサまたは別のプログラマブルデータ処理装置のプロセッサ用に提供され得、したがってコンピュータまたは別のプログラマブルデータ処理装置のプロセッサにより実行される命令は、フローチャート内の１つまたは複数の処理内の特定機能および／またはブロック図内の１つまたは複数のブロック内の特定機能を実施するための装置を生成する。
【００８４】
コンピュータまたは別のプログラマブルデータ処理装置に特定のやり方で働くように指示し得るこれらのコンピュータプログラム命令はコンピュータ可読メモリ内に格納され得、したがってコンピュータ可読メモリ内に格納された命令は、命令装置を含むアーティファクトを生成する。命令装置は、フローチャート内の１つまたは複数の処理内の特定機能および／またはブロック図内の１つまたは複数のブロック内の特定機能を実施する。
【００８５】
これらのコンピュータプログラム命令はコンピュータまたは別のプログラマブルデータ処理装置上にロードされ得、したがって一連の操作および工程はコンピュータまたは別のプログラマブル装置上で行われ、これによりコンピュータ実施処理を生成する。したがって、コンピュータまたは別のプログラマブル装置上で実行される命令は、フローチャート内の１つまたは複数の処理内の特定機能および／またはブロック図内の１つまたは複数のブロック内の特定機能を実施するための工程を提供する。
【００８６】
典型的構成では、コンピュータ装置は１つまたは複数のプロセッサ（ＣＰＵ）、入出力インターフェース、ネットワークインターフェースおよびメモリを含む。
【００８７】
メモリは、コンピュータ可読媒体内の揮発性メモリ（ＲＡＭ）および／または不揮発性メモリ（例えばＲＯＭ、フラッシュＲＡＭ）などの形式を含み得る。メモリはコンピュータ可読媒体の例である。
【００８８】
コンピュータ可読媒体は、不揮発性、揮発性、着脱可能、または着脱不能媒体を含み、任意の方法または技術を使用することにより情報の格納を実施し得る。情報は、コンピュータ可読命令、データ構造、プログラムモジュールまたは他のデータであり得る。コンピュータ記憶媒体の例は、限定しないが、相変化ＲＡＭ（ＰＲＡＭ：phase-change ＲＡＭ）、スタティックＲＡＭ（ＳＲＡＭ）、ダイナミックＲＡＭ（ＤＲＡＭ）、別のタイプのＲＡＭ、ＲＯＭ、電気的消去可能プログラマブルＲＯＭ（ＥＥＰＲＯＭ：electrically erasable programmable ＲＯＭ）、フラッシュメモリまたは別のメモリ技術、コンパクトディスクＲＯＭ（ＣＤ−ＲＯＭ）、デジタルバーサタイルディスク（ＤＶＤ）または別の光記憶装置、カセットテープ、磁気テープ、磁気ディスク記憶装置または別の磁気的格納装置または任意の他の送信不能媒体を含み、コンピュータ装置によりアクセスされ得る情報を格納するために使用され得る。本明細書の定義によると、コンピュータ可読媒体は、変調データ信号および搬送波などの過渡的コンピュータ可能媒体を含まない。
【００８９】
これまでの説明は、本出願の単に実施形態であり、本出願を限定するように使用されない。当業者は、様々な変更および変形を本出願に対しなし得る。本出願の趣旨および原理内でなされるいかなる修正、等価置換、および改善はすべて本出願の特許請求の範囲に入るものとする。
【図１】
2019510305.tif 000003
【図２】
2019510305.tif 000004
【図３】
2019510305.tif 000005
【図４】
2019510305.tif 000006
【図５】
2019510305.tif 000007
【図６】
2019510305.tif 000008
【図７】
2019510305.tif 000009
【図８】
2019510305.tif 000010
【図９】
2019510305.tif 000011
【国際調査報告】
2019510305.tif 000012
2019510305.tif 000013
2019510305.tif 000014
2019510305.tif 000015