Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
JP3600985B2 - How to extract specific product data - Google Patents
[go: Go Back, main page]

JP3600985B2 - How to extract specific product data - Google Patents

How to extract specific product data Download PDF

Info

Publication number
JP3600985B2
JP3600985B2 JP2002128320A JP2002128320A JP3600985B2 JP 3600985 B2 JP3600985 B2 JP 3600985B2 JP 2002128320 A JP2002128320 A JP 2002128320A JP 2002128320 A JP2002128320 A JP 2002128320A JP 3600985 B2 JP3600985 B2 JP 3600985B2
Authority
JP
Japan
Prior art keywords
product data
threshold
save area
data
name
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Expired - Fee Related
Application number
JP2002128320A
Other languages
Japanese (ja)
Other versions
JP2003044480A (en
Inventor
宏彰 高橋
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Hitachi Software Engineering Co Ltd
Original Assignee
Hitachi Software Engineering Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Hitachi Software Engineering Co Ltd filed Critical Hitachi Software Engineering Co Ltd
Priority to JP2002128320A priority Critical patent/JP3600985B2/en
Publication of JP2003044480A publication Critical patent/JP2003044480A/en
Application granted granted Critical
Publication of JP3600985B2 publication Critical patent/JP3600985B2/en
Anticipated expiration legal-status Critical
Expired - Fee Related legal-status Critical Current

Links

Images

Landscapes

  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Description

【0001】
【発明の属する技術分野】
本発明は、データベースに格納された複数の商品データのうちアクセス回数や配信要求の多い特定の商品データまたは在庫量(残量)の少ない商品の商品データを抽出する特定商品データの抽出方法に関するものである。
【0002】
【従来の技術】
データベースに格納された複数の商品データのうちアクセス回数や配信要求の多い特定の商品データまたは在庫量(残量)の少ない商品の商品データを抽出する特定商品データの抽出方法については、ソート処理を使用するものが多いが、データベースのアクセス回数の多いデータを特定することについては、電話網の加入者情報のデータベースシステムが知られている。
電話網のような情報伝達網から高度通信サービス機能やそれに関連する通信網制御機能を階層的に分離し、サービス動作階層,サービス制御階層,サービス管理階層という3階層で構成されるインテリジェントネットワークでは、加入者がどのような条件でどのようなネットワークサービスを受けるかといったような加入者情報は、サービス制御階層のデータベースで管理され、それらのサービス制御階層のデータベースは分散データベースシステムとして構成されるのが一般的である。
【0003】
インテリジェントネットワークのサービス制御階層を構成する分散データベースシステムにおいて、分散配置されるそれぞれの加入者情報を、どのデータベースシステムに配置するかを決定するにあたっては、それぞれの加入者に提供されるネットワークサービスの利用状況を予想して、特定の分散データベースシステムに負荷が集中しないように負荷バランスを考慮したデータ配置がなされる。
【0004】
しかしながら、ネットワークサービスの利用状況を予想しての加入者情報配置では、当初予想されなかった利用状況が発生した時に、ある特定の分散データベースシステムに配置されている1つもしくは複数の特定加入者に対するサービス要求が同時期に集中してしまい、該特定の分散データベースシステムに負荷が集中して処理能力を圧迫してしまい、データ参照に遅延が生じて正常なネットワークサービスが受けられなくなるようなケースが発生する恐れがある。
【0005】
この問題に対し、特開平5−12338号公報では、運用中に各データベースに対するデータ参照回数及び平均参照時間を収集し、収集された情報からデータベースのデータ配置を変更する公知例が開示されている。
【0006】
また、特開平6−119383号公報には、使用頻度の高いデータを使用頻度の高い複数のデータベースに多重配置し、参照の遅延時間を極力抑える公知例が開示されている。
【0007】
これら公知例におけるデータ参照回数あるいは使用頻度といった、データに対するアクセス頻度に関し、アクセス頻度の高いデータを特定する方法の公知例として、特開平1−177673号公報に開示された方法がある。
【0008】
図19は、特開平1−177673号公報に開示された方法を実現するための頻度テーブルのレコード形式を示す図であり、第1フィールド1101がノードidであり、データベースのそれぞれのデータ名に相当し、第2フィールド1102、第3フィールド1103、第4フィールド1104、第5フィールド1105はそれぞれ、ある期間内のアクセス回数で、例えば1週間を単位とし、第2フィールドが今週、第3フィールドが先週・・・のように、週単位が古くなるように構成され、第6フィールド1106が第2〜第5フィールド1102〜1105のアクセス回数の合計を表している。
【0009】
このように構成された頻度テーブルからアクセス頻度の高いノードidを特定する方法として、頻度テーブルの各レコードをアクセス回数合計(第6フィールド1106)の順にソートし、ソートしたレコードに対して、ある閾値でアクセス頻度の高いノードidを選択する方法が開示されている。
【0010】
【発明が解決しようとする課題】
しかしながら、上記特開平1−177673号公報に開示されたアクセス頻度の高いノードidを特定する方法にあっては、頻度テーブルのレコードをアクセス回数合計1106の順にソートする必要があるため、ソート対象となるレコード件数、つまりノードid1101の数が多くなると、ソートに要する処理が増大する。
【0011】
インテリジェントネットワークを用いてネットワークサービスを受ける加入者の数は膨大であり、1つの分散データベースシステムに収容される加入者は数万〜数10万といった数にのぼる。
【0012】
このため、上記公知例をインテリジェントネットワークの分散データベースシステムに適用してアクセス頻度の高いデータの特定を行おうとすると、数万〜数10万のデータに対するソート処理を行う必要がある。この結果、分散データベースシステムの処理能力へ与える影響が大きくなり、本来のデータベースアクセス処理を圧迫してしまうという問題がある。
【0013】
この場合、ソートを行わずにアクセス頻度の高いデータを抽出する方法としては、アクセス回数がある閾値を超えたデータのみを登録するという方法があるが、閾値を小さく与えてしまうと登録用テーブルがすぐに満杯になってしまい、閾値を再設定する必要が生じたり、あるいは逆に閾値を大きく与えてしまうと閾値を超過するデータが発生するまでに時間がかかってしまい、ある特定の分散データベースシステムに負荷が集中している時に、負荷の集中要因となっているアクセス頻度の高いデータを負荷の少ない分散データベースシステムに再配置しようとしても、再配置対象とするアクセス頻度の高いデータを特定するのに時間がかかるという問題が生じる。
このような問題は、オンラインショッピングを実現するシステム等においても、どの商品へのアクセス頻度が多いか、または配信要求が多いのか、あるいはどの商品の在庫数が少なくなっているのかを特定する場合に同様に起こる。
【0014】
本発明の目的は、特に、オンラインショッピングシステム等の商品データを格納しているデータベースを備えたシステムにおいて、ソート処理を不要とし、しかも予め閾値を設定しなくてもアクセス頻度の高い特定商品データや配信要求の多い特定商品データまたは在庫数の少ない特定商品を迅速に抽出することができる特定商品データの抽出方法を提供することにある。
【0015】
【課題を解決するための手段】
上記目的を達成するために、本発明は、データベースに格納された複数の商品データのうちアクセス頻度の高い特定の商品データをデータベースシステムにより抽出する特定商品データの抽出方法であって、前記データベースシステムが、
所定周期毎に商品データへのアクセス回数を判定するための閾値“0”を閾値記憶部に設定する第1のステップと、前記所定周期内における前記データベースの商品データへのアクセス回数を商品データ名単位で測定する第2のステップと、測定したアクセス回数が前記閾値記憶部に設定された閾値を超過したか否かを判定する第3のステップと、第3のステップの結果、超過したならば該当商品データ名をセーブエリアに記憶した後、当該セーブエリアが満杯か否かを判定する第4のステップと、満杯ならば当該セーブエリアに登録されている任意の1つの閾値超過商品データ名の現在のアクセス回数を新しい閾値として前記閾値記憶部に設定し、かつ当該セーブエリアを商品データ名が記憶されていない状態にする第5のステップとを備え、前記第3のステップから第5のステップを前記所定周期内で商品データへのアクセス毎に繰り返し、前記セーブエリアに記憶されている商品データ名の商品データをアクセス頻度の高い特定の商品データとして抽出することを特徴とする。
また、前記セーブエリアに登録されている2つ以上の閾値超過商品データ名の中で現在のアクセス回数が最大の値を、前記新しい閾値として設定することを特徴とする。
【0016】
また、データベースに格納された複数の商品データで示される商品のうち残量の少ない特定の商品の商品データをデータベースシステムにより抽出する特定商品データの抽出方法であって、前記データベースシステムが、
所定周期毎に商品の受注に伴う残量を判定するための閾値として商品データの在庫数エリアで表現可能な最大の値を閾値記憶部に設定する第1のステップと、前記所定周期内における前記データベースの商品データで示される商品の受注に伴う残量を商品データ名単位で測定する第2のステップと、測定した残量が前記閾値記憶部に設定された閾値より少ないか否かを判定する第3のステップと、第3ステップの結果、少ないならば該当商品データ名をセーブエリアに記憶した後、当該セーブエリアが満杯か否かを判定する第4のステップと、満杯ならば当該セーブエリアに登録されている任意の1つの閾値降下商品データ名の商品残量を新しい閾値として前記閾値記憶部に設定し、かつ当該セーブエリアを商品データ名が記憶されていない状態にする第5のステップとを備え、前記第3のステップから第5のステップを前記所定周期内で商品データへの受注毎に繰り返し、前記セーブエリアに記憶されている商品データ名の商品データを残量の少ない特定の商品データとして抽出することを特徴とする。
また、前記セーブエリアに登録されている2つ以上の閾値降下商品データ名の中で現在の残量が最小の値を、前記新しい閾値として設定することを特徴とする。
【0017】
また、データベースに格納された複数の商品データのうち配信要求の多い特定の商品データをデータベースシステムにより抽出する特定商品データの抽出方法であって、
前記データベースシステムが、
所定周期毎に商品データへの配信要求回数を判定するための閾値“0”を閾値記憶部に設定する第1のステップと、前記所定周期内における前記データベースの商品データへの配信要求回数を商品データ名単位で測定する第2のステップと、測定した配信要求回数が前記閾値記憶部に設定された閾値を超過したか否かを判定する第3のステップと、第3のステップの結果、超過したならば該当商品データ名をセーブエリアに記憶した後、当該セーブエリアが満杯か否かを判定する第4のステップと、満杯ならば当該セーブエリアに登録されている任意の1つの閾値超過商品データ名の現在の配信要求回数を新しい閾値として前記閾値記憶部に設定し、かつ当該セーブエリアを商品データ名が記憶されていない状態にする第5のステップとを備え、前記第3のステップから第5のステップを前記所定周期内で商品データへの配信要求毎に繰り返し、前記セーブエリアに記憶されている商品データ名の商品データを配信要求頻度の高い特定の商品データとして抽出することを特徴とする。
また、前記セーブエリアに登録されている2つ以上の閾値超過商品データ名の中で現在の配信要求回数が最大の値を前記新しい閾値として設定することを特徴とする。
【0018】
上記手段によれば、閾値を動的に更新しながらアクセス頻度の高い商品データまたは配信要求の多い商品データあるいは在庫数の少ない商品データが時間の経過とともにセーブエリアに絞り込まれていく。
このため、アクセス頻度の高い商品データまたは配信要求の多い商品データあるいは在庫数の少ない商品データを抽出する際に、全ての商品データをサーチし、アクセス頻度等の順にソートするといった処理が不要となり、システムの処理能力へ与える影響を軽減することができる。
【0019】
【発明の実施の形態】
以下、本発明を図示する実施形態に基づき詳細に説明する。
【0020】
図1は、本発明をインテリジェントネットワークにおける分散データベースのアクセス頻度の高いデータを特定する場合に適用した実施形態のブロック図である。
【0021】
図1において、分散データベースシステム管理部101は、インテリジェントネットワークにおけるサービス管理階層190に該当し、複数の分散データベースシステム102と通信網103を介して接続される。
【0022】
分散データベースシステム102は、インテリジェントネットワークにおけるサービス制御階層191に該当し、自システムに収容されるデータベース106へのアクセスを制御するデータベースアクセス部105と、データベース106へのアクセス頻度を収集するアクセス頻度収集部108と、分散データベースシステム管理部101あるいは他の分散データベースシステム102とを通信網103で接続するための通信制御部104と、通信制御部104,データベースアクセス部105,アクセス頻度収集部108の処理を実行する中央演算処理装置(以下、CPUと略す)の使用率を収集するCPU使用率測定部107から構成される。
【0023】
ここで、CPUの使用率とは、単位時間当りの通信制御、データベースアクセス、アクセス頻度収集に割当てられるCPU時間の割合のことである。
【0024】
本実施形態の分散データベースシステム管理部101は、従来構成と同一であり、その詳細な構成および動作の記述は省略するが、基本的には、データ配置変更の基礎情報として、分散データベースシステム102のCPU使用率と、その時のアクセス頻度の高いデータ名とを各分散データベースシステム102から受信し、その情報をもとに、CPU使用率が低い分散データベースシステム102に対して、CPU使用率が高い他の分散データベースシステム102に配置されているアクセス頻度の高いデータの配置変更を行う方法をとっている。
【0025】
このために必要となるCPU使用率と、アクセス頻度の高いデータ名の収集とを、それぞれの分散データベースシステム102におけるアクセス頻度収集部108が行っている。
【0026】
アクセス頻度収集部108は、それぞれのデータへのアクセス回数をカウントするアクセス回数加算部109、動的閾値変更部111で設定された閾値を超過したデータを格納する閾値超過情報記憶部110、閾値超過データ名セーブエリアが満杯になった時に、閾値を変更し直し、再びアクセス頻度の高いデータを収集するための新しい閾値を決定する動的閾値変更部111、一定周期で分散データベースシステム管理部101に、CPU使用率とその時のアクセス頻度の高いデータ名とを通知し、通知終了後再びアクセス頻度の高いデータを収集するための処理を行う閾値超過情報定期送信部112とから構成される。
【0027】
閾値超過情報記憶部110は、時々刻々変化する閾値情報あるいは閾値超過データ名を記憶するために必要となる各種情報をセーブするエリアであり、ここに格納される閾値測定情報201は、図2に示すように、アクセス頻度収集識別子202、閾値203、閾値超過識別子204、セーブエリア識別子205とから構成されている。
【0028】
ここで、アクセス頻度収集識別子202は、一定時間のアクセス頻度収集が完了して、分散データベースシステム管理部101への通知が終わり、新たにアクセス頻度の収集を開始した際に、以前の収集と今回の収集とを区別するための情報である。
【0029】
閾値203は、図4の閾値超過データ名セーブエリア401が満杯になるたびに、動的閾値変更部111により更新されていく現在の閾値である。
【0030】
閾値超過識別子204は、各データのアクセス回数が閾値203を超過した時に、図4で示す閾値超過データ名セーブエリア401に既にセーブされているか否かを識別するための情報である。
【0031】
また、セーブエリア識別子205は、図4で示すA面とB面から成る閾値超過データ名セーブエリア401のどちらを現在使用しているかを識別するための情報である。
【0032】
図3は、データベース106に配置されるそれぞれのデータの構成を示しており、データ名301、閾値測定情報201のアクセス頻度収集識別子202をセーブするアクセス頻度収集識別子セーブ302、閾値測定情報201の閾値超過識別子204をセーブする閾値超過識別子セーブ303、アクセス回数をセーブするアクセス回数304、及び実データ305から構成される。
【0033】
図4は、アクセス回数304が閾値203を超過した時に、そのデータ名を記憶するためのエリアを示し、閾値超過データ名セーブエリア401は、A面及びB面の2面構成とし、それぞれ閾値測定情報201の閾値203をセーブする閾値セーブ402と、閾値超過データ名セーブエリア401に登録されている個数を示す登録個数403と、有限個(図4の場合はn個)のデータ名を格納する閾値超過データ名404とから構成される。
【0034】
アクセス頻度収集部108のアクセス回数加算部109の処理概要を図5を用いて説明する。
【0035】
データベース106へのアクセス要求発生時、データベースアクセス部105からアクセス回数加算部109へ制御を渡す。アクセス回数加算部109では、該当データのアクセス頻度収集識別子セーブ302をデータベース106から抽出する(ステップ501)。
【0036】
抽出したアクセス頻度収集識別子セーブ302の値と、閾値測定情報201のアクセス頻度収集識別子202とが一致するかを判定する(ステップ502)。不一致の場合、アクセス頻度収集を新たに開始してから初めてのデータベースアクセス要求であるため、該当データのアクセス頻度収集識別子セーブ302に、閾値測定情報201のアクセス頻度収集識別子202を設定し(ステップ504)、該当データのアクセス回数304に”0”を設定し(ステップ505)、該当データのアクセス回数304に”1”を加算する(ステップ506)。
【0037】
これにより、アクセス頻度収集を新たに開始してから初めてのデータベースアクセス要求として、アクセス回数304に”1”が設定される。
【0038】
一方、ステップ502において一致と判定されると、アクセス頻度の収集を新たに開始してから、既に少なくとも1回は該当データへのアクセスがあったため、該当データのアクセス回数304に”1”を加算(ステップ506)することで、最新のアクセス回数304を設定する。
【0039】
最後に、アクセス回数加算部109から、閾値超過情報記憶部110へ制御を渡す(ステップ508)。
【0040】
アクセス頻度収集部108の閾値超過情報記憶部110の処理概要を図6を用いて説明する。
【0041】
閾値超過情報記憶部110は、アクセス回数加算部109より制御が渡されると、アクセス回数加算部109で算出された該当データのアクセス回数304を抽出し(ステップ601)、抽出されたアクセス回数304と閾値測定情報201の閾値203とを比較する(ステップ602)。
【0042】
アクセス回数304が閾値203を超過している場合、既に現在の閾値超過により、閾値超過データ名セーブエリア401に登録済みか否かを判断するため、該当データの閾値超過識別子セーブ303を抽出し(ステップ604)、抽出された閾値超過識別子セーブ303と閾値測定情報201の閾値超過識別子204とが一致するか否かを判定する(ステップ605)。
【0043】
閾値超過識別子セーブ303と閾値測定情報201の閾値超過識別子204とが不一致の場合、新しい閾値に変更されてから初めてのデータベースアクセス要求であるため、セーブエリア識別子205に対応する閾値超過データ名セーブエリア401に、該当データのデータ名301を登録し、登録個数403を”1”加算し(ステップ607)、さらに該当データの閾値超過識別子セーブ304に、閾値測定情報201の閾値超過識別子204を設定する(ステップ608)。
【0044】
その後、動的閾値変更部111に制御を渡す(ステップ609)。
【0045】
一方、ステップ602で閾値非超過と判定された場合及びステップ605で既に閾値超過データ名セーブエリア401に登録済みであるとして一致と判定された場合は、アクセス頻度収集部108の処理を終了する(ステップ612)。
【0046】
アクセス頻度収集部108の動的閾値変更部111の処理概要を図7を用いて説明する。
【0047】
動的閾値変更部111は、閾値超過情報記憶部110より制御が渡されると、現在使用している閾値超過データ名セーブエリア401が登録エリア満杯となったか否かを判定する(ステップ701)。
【0048】
登録エリア満杯の時は、閾値超過データ名セーブエリア401に登録されている任意の1つの閾値超過データ名404を抽出し(ステップ703)、抽出されたデータ名の現在のアクセス回数304を、新しい閾値として閾値測定情報201の閾値203に設定する(ステップ704)。
【0049】
ステップ703で任意に選択する方法は、閾値超過データ名セーブエリア401の先頭に登録されている閾値超過データ名(1)404でも、i番目に登録されている閾値超過データ名(i)404であってもよい。
【0050】
任意に選択されたデータは、閾値超過データ名セーブエリア401が満杯になり、動的閾値変更部111で閾値が更新されるまでは、データへのアクセス要求が何回あっても再び登録されることはなく、アクセス回数304のみが更新されていく。このため、ステップ703で選択された時点での該当データのアクセス回数304は、現在の閾値よりも大きな値となっている。
【0051】
したがって、ステップ703で任意に選択されたデータが、アクセス頻度の高いデータであれば、更新される閾値は現在の閾値よりも大きな値が設定され、たとえアクセス頻度の低いデータであっても、少なくとも現在の閾値203より”1”大きい値が設定されることとなり、新しい閾値を使用してのアクセス頻度の高いデータの絞り込みが行われる。
【0052】
次に、閾値超過識別子204を更新し(ステップ705)、さらにセーブエリア識別子205を変更し(ステップ706)、最後に、変更されたセーブエリア識別子205に対応した閾値超過データ名セーブエリア401の閾値セーブ402に新しい閾値203を、登録個数403に”0”をそれぞれ設定する(ステップ707)。
【0053】
一方、ステップ701で登録エリアが満杯でない時は、閾値の変更は不要であるため、動的閾値変更処理を終了する。
【0054】
アクセス頻度収集部108の閾値超過情報定期送信部112は、閾値超過情報記憶部110で収集している閾値超過データ名セーブエリア401に登録されている閾値超過データ名404を、システムで任意に予め設定されている一定時間間隔で、分散データベースシステム管理部101に通知する機能を実現している。
【0055】
閾値超過情報定期送信部112の処理概要を図8と図9を用いて説明する。
【0056】
図8の閾値超過データ名送信情報801は、分散データベースシステム管理部101に送信する情報の構成を示しており、CPU使用率測定部107で従来技術を用いて測定されている一定時間内の平均CPU使用率を格納するエリアであるCPU使用率802と、閾値超過データ名804と、送信時点の該当データへのアクセス回数を格納するアクセス回数805とから構成される。
【0057】
閾値超過情報定期送信部112では、CPU使用率測定部107からCPU使用率を収集し、閾値超過データ名送信情報801のCPU使用率802に設定し(ステップ901)、閾値超過データ名セーブエリア(A面)401と、閾値超過データ名セーブエリア(B面)401に登録されているデータ名404の現在のアクセス回数304を収集し、データ名804とアクセス回数805と送信個数803とを設定する(ステップ902,903)。
【0058】
次に、閾値超過データ名セーブエリア401の両面の登録個数403に”0”を設定し(ステップ904)、閾値測定情報201のアクセス頻度収集識別子202を更新し(ステップ905)、さらに閾値測定情報201の閾値203を”0”に初期設定し(ステップ906)、処理を終了する。
【0059】
これにより、一定時間間隔でのアクセス頻度の高いデータの収集が再スタートされることになる。
【0060】
図10を用いて、閾値が動的に変更される具体例を説明する。
図10の具体例では、閾値超過データ名セーブエリア401に登録できるデータ数を5個とし、すでにセーブエリアへの登録が行われ、あと1個のデータで現在セーブエリアとして使用しているA面の登録エリア401が満杯となり、閾値が更新される場合を示している。
【0061】
データ名A5に対するデータベースアクセス要求が発生すると、アクセス回数加算部109の処理が実施される。
【0062】
すると、データ名A5のアクセス頻度収集識別子セーブ1004と閾値測定情報201のアクセス頻度収集識別子1001とが一致するため、図5のステップ506の処理によりデータ名A5のアクセス回数1006が加算される。
【0063】
閾値超過情報記憶部110では、データ名A5のアクセス回数1017が閾値測定情報201の閾値1002より大であるため、図6のステップ604の処理を実行する。また、データ名A5の閾値超過識別子セーブ1005が閾値測定情報201の閾値超過識別子1003と不一致であるため、図6のステップ607の処理を実行し、現在セーブエリアとして使用されているA面の閾値超過データ名セーブエリア401の閾値超過データ名(5)1012にデータ名A5を登録し、さらに登録個数1010を更新する。
【0064】
次に、該当データA5の閾値超過識別子セーブ1016に閾値測定情報201の閾値超過識別子1003が設定され、動的閾値変更部111へ制御が渡る。
【0065】
動的閾値変更部111では、登録エリアが満杯であるため図7のステップ703以降の処理を実行し、新しい閾値の設定を行う。図7のステップ703の任意の閾値超過データ名の抽出方法として、図10では登録エリアの先頭に登録されている閾値超過データ名を抽出する場合を例として示している。
【0066】
図10の例では、現在使用している閾値超過データ名セーブエリア401のA面の先頭1011には、データ名A1が登録されており、データA1の現在のアクセス回数1015を新しい閾値として閾値測定情報201の閾値1007に設定する。
【0067】
次に、閾値超過識別子1008を更新し、セーブエリア識別子1009をB面に変更する。
最後に、B面の閾値超過データ名セーブエリア401の閾値セーブ1013に新しい閾値1007を設定し、さらに登録個数1014を”0”に初期設定して動的閾値変更部111の処理を終了する。
【0068】
図7で示した動的閾値更新部111の処理例では、任意の1つの閾値超過データ名404を抽出し(ステップ703)、その時点での該当データのアクセス回数304を新しい閾値203とする方法を述べたが、任意の複数個の閾値超過データ名404の中からその時点のアクセス回数304が最大のものを新しい閾値203としても良い。この方法によると、アクセス頻度のより高いデータのアクセス回数をもとに新しい閾値が更新されていくため、アクセス頻度の高いデータの絞り込みをより迅速に行うことができ、アクセス頻度の高いデータの特定を急ぐ場合により有効なものとなる。
【0069】
また、図8および図9で示した閾値超過情報定期送信部112の処理例では、閾値超過データ名セーブエリア401に登録されている閾値超過データ名404の、その時点でのアクセス回数304を抽出して分散データベースシステム管理部101に送信する方法を述べたが、図4に示す2面の閾値超過データ名セーブエリア401をそのまま送信しても良い。
【0070】
また、閾値203の初期設定を行う際(ステップ906)、”0”ではなく、現在の閾値203の”2分の1”といった条件で初期値を設定すると、初回の定期送信以降に行われるアクセス頻度の高いデータの絞り込みがより一層迅速に行える。
【0071】
また、分散データベースシステム102で自律的にアクセス頻度の高いデータの特定を行い、その結果を定期的に送信するのではなく、分散データベースシステム管理部101からの指示でアクセス頻度の高いデータの特定を開始し、さらに分散データベースシステム管理部101からの指示でその結果を報告する方法をとっても良い。
【0072】
図11は、カタログ販売業者がオンラインのホーム・ショッピング・サービスいわゆる仮想ショッピングを実現するシステムの構成を示す図である。
カタログ販売業者1201は、ネットワーク1204を介して顧客1205の各々のクライアント1206から要求される、カタログに記載されている商品のより詳細な情報の請求、あるいは商品の発注をサーバ1202で処理し、データベース1203に記憶されている商品情報のクライアント1206への提供、あるいはクライアント1206からの発注に伴う在庫状況の更新を行う。
【0073】
仮想ショッピングでは、顧客がどの商品の詳細情報により多くアクセスしてくるかといった商品別のアクセス数、あるいは商品別の受注数を正確に予測することは困難である。このため、顧客からのアクセスが多い商品を特定し、アクセスが多い商品の情報をより詳細にしたり、あるいはそれら商品の価格を安くしたりといったように、提供情報を適宜変更することができれば受注をより一層増やすといったことも可能である。
【0074】
また、受注が集中して在庫が不足するといったケースをより早い段階で検出できれば、受注を断ったり、あるいは商品の発送が遅れたりといったことがなくなり、顧客に対するサービス性をより向上させることができる。
【0075】
しかしながら、対象商品が多くなればなるほど、アクセス頻度の高い商品,受注が多くなり、在庫が少ない商品をリアルタイムで特定しようとすると、サーバ1202の処理能力に与える影響が大きくなってしまい、顧客1205へのレスポンスが遅れるといった問題が発生する。
【0076】
そこで本発明を応用することにより、リアルタイムにアクセス頻度の高い商品を特定化し、さらに在庫が少ない商品を特定化するシステムを実現することができる。このようなシステムを実現する場合の閾値測定情報201の構成を図12に、データベース1203の構成を図13に、また、在庫が少ない商品をセーブするエリアの構成を図14に示す。
【0077】
図12において、202〜205は図2で説明したのと同様の情報である。本実施形態では、この他に、在庫閾値1301、在庫閾値降下識別子1302、在庫閾値降下セーブエリア識別子1303が新たに設けられており、これらの情報はそれぞれアクセス頻度の高いデータを特定する際に使用する閾値203、閾値超過識別子204、セーブエリア識別子205に対応する。
【0078】
図13において、在庫数1402はクライアント1206からの受注で随時減算されていくデータであり、在庫閾値降下識別子セーブ1401は、各商品の在庫数1402が在庫閾値1301より小さい時に、図14で示す在庫閾値降下データ名セーブエリア1501に既にセーブされているか否かを識別するための情報である。
【0079】
なお、アクセス頻度の高い商品の特定化は図5,図6,図7,図9で述べた処理により実現できる。ただし、図9で記述しているCPU使用率の情報は不要である。
【0080】
これに対し、在庫が少ない商品を特定するためには、在庫閾値を動的に小さくしていくことになるが、図14で示す在庫閾値降下データ名セーブエリア1501が満杯になったときに、図7で示した動的閾値変更部111の処理フローと同じ流れで、在庫閾値降下データ名セーブエリア1501から任意に選択されたデータの現在の在庫数をもとに新しい在庫閾値1301を動的に更新していく。
【0081】
すなわち、図1の実施例においては閾値をアクセス頻度に応じて増加させているが、在庫の少ない商品を特定する場合のように、特定対象の個数、回数、割合、所要時間などの測定可能な物理量が少ないものを特定する場合には、閾値を動的に小さい方向に更新する。
【0082】
また、在庫閾値1301の初期値はデータベース1203の在庫数1402のエリア(バイト長・ビット長)で表現できる最大の値を使用する。あるいは、各商品毎に適正在庫数が予め分かっていれば、在庫数の代わりに、在庫数が適正在庫数に占める割合(%)を在庫閾値として設定することも可能であり、この場合は在庫閾値1301の初期値として”100(%)”という値を使用すれば良い。
【0083】
図11のシステム構成において、図5,図6,図7,図9で述べた処理をサーバ1202で実行することにより、仮想ショッピングにおいて、サーバ1202に大きな負担をかけることなく、顧客がどの商品の詳細情報により多くアクセスしてくるかといった商品別のアクセス数、あるいは商品別の受注数を正確に測定することができる。この結果、アクセスが多い商品の情報をより詳細にしたり、あるいはそれら商品の価格を安くしたりすることにより、受注増に貢献することが可能になる。
【0084】
また、受注が集中して在庫が不足している商品を早い段階で特定し、受注を断ったり、あるいは商品の発送が遅れたりといったことがなくなり、顧客に対するサービス性をより向上させることができる。
【0085】
図15は、特定の映像ソフト(以下、ビデオ・ストリームと略称する)にアクセスが集中した場合の負荷分散機能を有する分散処理構成をとるビデオ・サーバを使用してビデオ・オン・デマンド・サービス(以下、VODサービスと略称する)を提供するシステムの構成を示す図である。
【0086】
VODサービス提供者1601は、顧客1609の各々のクライアント1610からの要求を、ネットワーク1608を介してビデオ・サーバ1602で受け付け、クライアントにビデオ・ストリームを配信する。ビデオ・サーバ1602は図15の例では、負荷分散された3台のビデオ・ストリーム送信部1604と、1台のVOD管理部1606とから構成され、それぞれビデオ・ストリーム記憶部1603と、アクセス頻度を収集するためのアクセス頻度データベース1605を有し、VOD管理部1606とビデオ・ストリーム送信部1604とはネットワーク1607により接続される。
【0087】
負荷分散構成をとるビデオ・サーバ1602では、特定のビデオ・ストリームに要求が集中するケースが発生すると、要求が集中しているビデオ・ストリームを一番負荷が軽いビデオ・ストリーム送信部1604のビデオ・ストリーム記憶部1603に多重配置して、ビデオ・ストリーム送信部1604の負荷を分散させ、クライアント1610からの要求に応じられなくなる事態を前もって回避する機能を有している。
【0088】
VODサービスの場合も、顧客からの需要分布は一様ではなく、時々刻々変化し、社会的要因によっても特定のビデオ・ストリームに特定の日時に集中するといったケースがあり、ビデオ・ストリームの数が多くなればなるほど、アクセス頻度の高いビデオ・ストリームをリアルタイムで特定するのが困難になってくる。
【0089】
そこで本発明を、この様な特性を有するビデオ・サーバに適用し、アクセス頻度の高いビデオ・ストリームを特定化する場合の閾値測定情報の構成を図16に、閾値超過データ名セーブエリアの構成を図17に、またアクセス頻度データべース1605の構成を図18に示す。
【0090】
図16の閾値測定情報1701は、3台のビデオ・ストリーム送信部1604のそれぞれに対して、閾値203,閾値超過識別子204,セーブエリア識別子205及びビデオ・ストリーム送信部1604が送信したビデオ・ストリームの総数を計数する送信ストリーム総数1703から構成する。
【0091】
A面・B面の2面から構成される閾値超過データ名セーブエリア1801もやはり3台のビデオ・ストリーム送信部1604それぞれに対応させた構成とする。
また、VOD管理部1606で管理するアクセス頻度データベース1605は、閾値超過識別子セーブ303とアクセス回数304とを、3台のビデオ・ストリーム送信部1604のそれぞれに対応させた構成とする。
【0092】
アクセス頻度の高いビデオ・ストリームの特定化は、図5・図6・図7・図9で述べた処理を、3台のビデオ・ストリーム送信部毎に実施することで実現される。
【0093】
ビデオ・ストリームの多重配置は、送信ストリーム総数1703が一番小さいビデオ・ストリーム送信部1604に対して、送信ストリーム総数1703が一番大きいビデオ・ストリーム送信部1604で特定された閾値超過データ名セーブエリア1801に登録されているアクセス頻度の一番高いビデオ・ストリームを多重配置することで実現できる。
【0094】
これにより、特定のビデオ・ストリームに対するアクセスが特定の日時に集中するケースに迅速に対処し、ユーザに対するサービスを向上させることが可能になる。
【0095】
なお、本発明は、上記実施例に限定されるものではなく、特定対象の個数、回数、割合、所要時間などの測定可能な物理量が少ないもの、あるいは多いものを特定する場合の全てに適用することができる。
【0096】
【発明の効果】
以上のように、本発明によれば、オンラインショッピングシステム等の商品データを格納しているデータベースを備えたシステムにおいて、ソート処理を不要とし、しかも予め閾値を設定しなくてもアクセス頻度の高い特定商品データや配信要求の多い特定商品データまたは在庫数の少ない特定商品を迅速に抽出することができ、システムの処理能力の負担を軽減することが出来る。そして、抽出した商品データを参考にして、商品データの拡充や再配置、在庫量の補填などに役立てることができる。
【図面の簡単な説明】
【図1】本発明の一実施形態を示す分散データベースシステムのブロック図である。
【図2】図1における閾値測定情報の構成を示す図である。
【図3】図1におけるデータベースの構成を示す図である。
【図4】図1における閾値超過データ名をセーブするエリアの構成を示す図である。
【図5】図1におけるアクセス回数加算部の処理手順を示すフローチャートである。
【図6】図1における閾値超過情報記憶部の処理手順を示すフローチャートである。
【図7】図1における動的閾値変更部の処理手順を示すフローチャートである。
【図8】図1における分散データベースシステム管理部に通知される情報の構成を示す図である。
【図9】図1における閾値超過情報定期送信部の処理手順を示すフローチャートである。
【図10】本発明による動的閾値変更の具体例を示す説明図である。
【図11】本発明を応用したオンラインショッピングサービスシステムの実施形態を示すブロック図である。
【図12】図11における閾値測定情報の構成を示す図である。
【図13】図11におけるデータベースの構成を示す図である。
【図14】図11における閾値超過データ名をセーブするエリアの構成を示す図である。
【図15】本発明を応用したビデオオンデマンドサービスシステムの実施形態を示すブロック図である。
【図16】図15における閾値測定情報の構成を示す図である。
【図17】図15における閾値超過データ名をセーブするエリアの構成を示す図である。
【図18】図15におけるアクセス頻度データベースの構成を示す図である。
【図19】従来のアクセス頻度テーブルの構成を示す図である。
【符号の説明】
108…アクセス頻度収集部、109…アクセス回数加算部、110…閾値超過情報記憶部、111…動的閾値変更部、112…閾値超過情報定期送信部、203…閾値、304…アクセス回数、401…閾値超過データ名セーブエリア。
[0001]
TECHNICAL FIELD OF THE INVENTION
The present invention relates to a method for extracting specific product data from among a plurality of product data stored in a database, which extracts specific product data having a high access count or distribution request or product data having low inventory (remaining amount). It is.
[0002]
[Prior art]
For the extraction method of specific product data that extracts specific product data with a high access count or distribution request or product data with a small inventory amount (remaining amount) from among a plurality of product data stored in the database, the sorting process is used. A database system for subscriber information of a telephone network is known for specifying data that is frequently used but frequently accessed in a database.
An intelligent network composed of three layers, a service operation layer, a service control layer, and a service management layer, separates an advanced communication service function and a related network control function hierarchically from an information transmission network such as a telephone network. Subscriber information, such as the conditions under which subscribers receive what network services, is managed in a service control layer database, and the service control layer database is configured as a distributed database system. General.
[0003]
In a distributed database system that constitutes a service control layer of an intelligent network, in deciding which database system to distribute subscriber information to be distributed, use of a network service provided to each subscriber. In anticipation of the situation, data is arranged in consideration of the load balance so that the load is not concentrated on a specific distributed database system.
[0004]
However, in the arrangement of subscriber information in anticipation of the usage status of the network service, when an unexpected usage status occurs, one or a plurality of specific subscribers located in a specific distributed database system may be allocated. In the case where service requests are concentrated at the same time, the load is concentrated on the specific distributed database system and the processing capacity is squeezed, so that data reference is delayed and normal network service cannot be received. May occur.
[0005]
To solve this problem, Japanese Patent Application Laid-Open No. Hei 5-12338 discloses a known example in which the number of data references and the average reference time for each database are collected during operation, and the data arrangement of the database is changed based on the collected information. .
[0006]
Japanese Patent Application Laid-Open No. 6-119383 discloses a known example in which frequently used data is multiplexed and arranged in a plurality of frequently used databases to minimize reference delay time.
[0007]
As a known example of a method of specifying data having a high access frequency, such as a data access frequency or a use frequency in these known examples, there is a method disclosed in Japanese Patent Application Laid-Open No. 1-177673.
[0008]
FIG. 19 is a diagram showing a record format of a frequency table for realizing the method disclosed in Japanese Patent Laid-Open No. 1-177673, in which a first field 1101 is a node id and corresponds to each data name of the database. Each of the second field 1102, the third field 1103, the fourth field 1104, and the fifth field 1105 is the number of accesses within a certain period, for example, in units of one week, the second field is this week, and the third field is last week. .., The week unit becomes older, and the sixth field 1106 indicates the total number of accesses in the second to fifth fields 1102 to 1105.
[0009]
As a method of specifying the node id having a high access frequency from the frequency table configured as described above, the records of the frequency table are sorted in the order of the total number of accesses (sixth field 1106), and a certain threshold is applied to the sorted records. Discloses a method of selecting a node id having a high access frequency in the above.
[0010]
[Problems to be solved by the invention]
However, according to the method of specifying a node id having a high access frequency disclosed in the above-mentioned Japanese Patent Application Laid-Open No. 1-177673, it is necessary to sort the records of the frequency table in the order of the total number of access times 1106. When the number of records becomes large, that is, the number of node ids 1101 increases, the processing required for sorting increases.
[0011]
The number of subscribers who receive network services using the intelligent network is enormous, and the number of subscribers accommodated in one distributed database system is tens of thousands to hundreds of thousands.
[0012]
For this reason, if the above-mentioned known example is applied to a distributed database system of an intelligent network to specify data having a high access frequency, it is necessary to perform sort processing on tens of thousands to hundreds of thousands of data. As a result, there is a problem that the influence on the processing capacity of the distributed database system is increased, and the original database access processing is squeezed.
[0013]
In this case, as a method of extracting data having a high access frequency without sorting, there is a method of registering only data in which the number of accesses exceeds a certain threshold. If it becomes full quickly and it is necessary to reset the threshold value, or if the threshold value is set too large, it takes time until data exceeding the threshold value is generated. When the data is frequently concentrated, the data that is frequently accessed, which is the cause of the load concentration, is to be relocated to a distributed database system with a small load. Takes a long time.
Such a problem arises in a system for realizing online shopping, for example, when specifying which product is accessed frequently, which distribution request is large, or which product inventory is low. Happens as well.
[0014]
An object of the present invention is to provide a system including a database that stores product data, such as an online shopping system, in which sorting processing is unnecessary, and specific product data that is frequently accessed without setting a threshold value in advance. It is an object of the present invention to provide a method for extracting specific product data that can quickly extract specific product data with a large distribution request or specific products with a small number of stocks.
[0015]
[Means for Solving the Problems]
In order to achieve the above object, the present invention provides a method for storing specific product data having a high access frequency among a plurality of product data stored in a database.Depending on the database systemA method for extracting specific product data to be extracted,The database system is
PredeterminedA first step of setting a threshold “0” for determining the number of accesses to the product data in each cycle in the threshold storage unit;Of the databaseeachMeasure the number of accesses to product data for each product data nameSecondSteps and the measured number of accessesSet in the threshold storage unitDetermine if a threshold has been exceededThirdSteps andThirdIf the result of the step is that the save area has been exceeded, the corresponding product data name is stored in the save area, and then it is determined whether or not the save area is full.4thAnd the current number of accesses of any one of the threshold-exceeding product data names registered in the save area if the storage area is full as a new thresholdSetting the save area to a state where the product data name is not stored in the threshold storage unit, and performing the third to fifth steps within the predetermined period. Repeat for each access to theIt is characterized in that the product data of the product data name stored in the save area is extracted as specific product data having a high access frequency.
In addition, the value of the current number of times of access is the maximum value among two or more threshold-exceeding product data names registered in the save area,SaidTo set a new thresholdFeatures.
[0016]
In addition, product data of a specific product having a small remaining amount among the products represented by a plurality of product data stored in the database is stored.Depending on the database systemA method for extracting specific product data to be extracted,The database system is
A first step of setting, in a threshold value storage unit, a maximum value that can be expressed in a stock quantity area of product data as a threshold value for determining a remaining amount associated with an order for a product in a predetermined cycle;The remaining amount associated with the order for the product indicated by the product data in the database is measured for each product data nameSecondSteps and the measured remainingSet in the threshold storage unitDetermine if less than thresholdThirdSteps andThirdAs a result of the step, if the number is small, the corresponding product data name is stored in the save area, and then it is determined whether or not the save area is full.4thStep and, if full, the remaining amount of any one of the threshold dropping product data names registered in the save area as a new threshold valueSetting the save area to a state where the product data name is not stored in the threshold storage unit, and performing the third to fifth steps within the predetermined period. Repeat for each order receivedIt is characterized in that the product data of the product data name stored in the save area is extracted as specific product data having a small remaining amount.
Further, a value of the current remaining amount among the two or more threshold dropping product data names registered in the save area is set toSaidIt is characterized in that it is set as a new threshold.
[0017]
In addition, specific product data with a high distribution request among a plurality of product data stored in the databaseDepending on the database systemA method for extracting specific product data to be extracted,
The database system is
PredeterminedA first step of setting a threshold “0” for determining the number of distribution requests to the product data for each cycle in the threshold storage unit;Of the databaseeachMeasure the number of distribution requests to product data for each product data nameSecondSteps and the measured number of delivery requestsSet in the threshold storage unitDetermine if a threshold has been exceededThirdSteps andThirdIf the result of the step is that the save area has been exceeded, the corresponding product data name is stored in the save area, and then it is determined whether or not the save area is full.4thAnd the current number of distribution requests for any one of the threshold-exceeding product data names registered in the save area if the storage area is full as a new threshold.Setting the save area to a state where the product data name is not stored in the threshold storage unit, and performing the third to fifth steps within the predetermined period. Repeat for each delivery request toIt is characterized in that the product data of the product data name stored in the save area is extracted as specific product data having a high distribution request frequency.
In addition, among the two or more threshold-exceeding product data names registered in the save area,Delivery request countIs the largest valueThe aboveIt is characterized in that it is set as a new threshold.
[0018]
According to the above means, while dynamically updating the threshold value, the commodity data with a high access frequency, the commodity data with a large distribution request, or the commodity data with a small stock quantity are narrowed down to the save area over time.
For this reason, when extracting the product data with a high access frequency, the product data with a high distribution request, or the product data with a small number of stocks, it is not necessary to search all the product data and sort them in the order of the access frequency. The effect on the processing capacity of the system can be reduced.
[0019]
BEST MODE FOR CARRYING OUT THE INVENTION
Hereinafter, the present invention will be described in detail based on an illustrated embodiment.
[0020]
FIG. 1 is a block diagram of an embodiment in which the present invention is applied to a case where data frequently accessed in a distributed database in an intelligent network is specified.
[0021]
In FIG. 1, a distributed database system management unit 101 corresponds to a service management layer 190 in an intelligent network, and is connected to a plurality of distributed database systems 102 via a communication network 103.
[0022]
The distributed database system 102 corresponds to the service control layer 191 in the intelligent network, and has a database access unit 105 that controls access to the database 106 accommodated in its own system, and an access frequency collection unit that collects the access frequency to the database 106. 108, a communication control unit 104 for connecting the distributed database system management unit 101 or another distributed database system 102 with the communication network 103, and processing of the communication control unit 104, the database access unit 105, and the access frequency collection unit 108. It comprises a CPU usage rate measuring unit 107 for collecting the usage rate of a central processing unit (hereinafter abbreviated as CPU) to be executed.
[0023]
Here, the CPU usage rate is a ratio of CPU time allocated to communication control, database access, and access frequency collection per unit time.
[0024]
The distributed database system management unit 101 of the present embodiment is the same as the conventional configuration, and detailed description of its configuration and operation is omitted. However, basically, the distributed database system The CPU usage rate and the name of the data with high access frequency at that time are received from each distributed database system 102, and based on the information, the distributed database system 102 with the low CPU usage rate has a higher CPU usage rate. In this method, the arrangement of frequently accessed data arranged in the distributed database system 102 is changed.
[0025]
The access frequency collection unit 108 in each of the distributed database systems 102 collects the CPU usage rate required for this and the data names with high access frequency.
[0026]
The access frequency collection unit 108 includes an access count addition unit 109 that counts the number of accesses to each data, a threshold excess information storage unit 110 that stores data that exceeds a threshold set by the dynamic threshold change unit 111, and a threshold excess When the data name save area becomes full, the dynamic threshold changing unit 111 changes the threshold again and determines a new threshold for collecting frequently accessed data again. And a threshold excess information periodic transmission unit 112 for notifying the CPU usage rate and the name of the frequently accessed data at that time, and performing processing for collecting the frequently accessed data again after completion of the notification.
[0027]
The threshold excess information storage unit 110 is an area for saving various kinds of information necessary to store the threshold information that changes every moment or the name of the data that exceeds the threshold, and the threshold measurement information 201 stored here is shown in FIG. As shown, it is composed of an access frequency collection identifier 202, a threshold 203, a threshold excess identifier 204, and a save area identifier 205.
[0028]
Here, the access frequency collection identifier 202 indicates that when the access frequency collection for a certain period of time is completed, the notification to the distributed database system management unit 101 is completed, and the collection of the access frequency is newly started, This is the information for distinguishing the collection from the collection.
[0029]
The threshold value 203 is a current threshold value that is updated by the dynamic threshold value change unit 111 each time the threshold excess data name save area 401 in FIG.
[0030]
The threshold excess identifier 204 is information for identifying whether or not the number of accesses of each data exceeds the threshold 203, whether or not the data has already been saved in the threshold excess data name save area 401 shown in FIG.
[0031]
The save area identifier 205 is information for identifying which of the threshold-exceeding data name save area 401 composed of the side A and the side B shown in FIG. 4 is currently used.
[0032]
FIG. 3 shows the configuration of each piece of data arranged in the database 106, including a data name 301, an access frequency collection identifier save 302 for saving an access frequency collection identifier 202 of the threshold measurement information 201, and a threshold of the threshold measurement information 201. It comprises a threshold excess identifier save 303 for saving the excess identifier 204, an access count 304 for saving the access count, and actual data 305.
[0033]
FIG. 4 shows an area for storing the data name when the number of accesses 304 exceeds the threshold value 203. The data area save data area 401 with the excess threshold value has a two-sided configuration of A side and B side. A threshold save 402 for saving the threshold 203 of the information 201, a registered number 403 indicating the number registered in the threshold excess data name save area 401, and a finite number (n in FIG. 4) of data names are stored. And a threshold excess data name 404.
[0034]
The processing outline of the access count adding unit 109 of the access frequency collecting unit 108 will be described with reference to FIG.
[0035]
When an access request to the database 106 occurs, control is passed from the database access unit 105 to the access count addition unit 109. The access count adding unit 109 extracts the access frequency collection identifier save 302 of the relevant data from the database 106 (step 501).
[0036]
It is determined whether or not the value of the extracted access frequency collection identifier save 302 matches the access frequency collection identifier 202 of the threshold measurement information 201 (step 502). In the case of a mismatch, the access frequency collection identifier 202 of the threshold measurement information 201 is set in the access frequency collection identifier save 302 of the relevant data because it is the first database access request since the access frequency collection is newly started (step 504). ), "0" is set to the access count 304 of the data (step 505), and "1" is added to the access count 304 of the data (step 506).
[0037]
As a result, “1” is set to the number of accesses 304 as the first database access request after newly starting the access frequency collection.
[0038]
On the other hand, if it is determined in step 502 that there is a match, since the access data has been accessed at least once since the access frequency was newly collected, “1” is added to the access count 304 of the relevant data. (Step 506), the latest access count 304 is set.
[0039]
Finally, control is passed from the access count adding unit 109 to the threshold excess information storage unit 110 (step 508).
[0040]
The processing outline of the threshold excess information storage unit 110 of the access frequency collection unit 108 will be described with reference to FIG.
[0041]
When the control is passed from the access count adding unit 109, the threshold excess information storage unit 110 extracts the access count 304 of the corresponding data calculated by the access count adding unit 109 (step 601). A comparison is made with the threshold 203 of the threshold measurement information 201 (step 602).
[0042]
If the number of accesses 304 exceeds the threshold 203, a threshold excess identifier save 303 of the relevant data is extracted to determine whether or not it has already been registered in the threshold excess data name save area 401 due to the current threshold excess (see FIG. Step 604), it is determined whether or not the extracted threshold excess identifier save 303 matches the threshold excess identifier 204 of the threshold measurement information 201 (step 605).
[0043]
If the threshold excess identifier save 303 and the threshold excess identifier 204 of the threshold measurement information 201 do not match, it is the first database access request after the change to the new threshold, so the threshold excess data name save area corresponding to the save area identifier 205 The data name 301 of the corresponding data is registered in 401, the registration number 403 is incremented by “1” (Step 607), and the threshold excess identifier 204 of the threshold measurement information 201 is set in the threshold excess identifier save 304 of the data. (Step 608).
[0044]
Thereafter, control is passed to the dynamic threshold changing unit 111 (step 609).
[0045]
On the other hand, if it is determined in step 602 that the threshold value has not been exceeded, and if it is determined in step 605 that the data has already been registered in the threshold-exceeding data name save area 401, and the match has been determined, the processing of the access frequency collection unit 108 ends ( Step 612).
[0046]
The processing outline of the dynamic threshold value changing unit 111 of the access frequency collecting unit 108 will be described with reference to FIG.
[0047]
When the control is passed from the threshold excess information storage unit 110, the dynamic threshold change unit 111 determines whether the currently used threshold excess data name save area 401 is full of the registration area (step 701).
[0048]
When the registration area is full, any one threshold excess data name 404 registered in the excess threshold data name save area 401 is extracted (step 703), and the current access count 304 of the extracted data name is set to a new value. The threshold is set to the threshold 203 of the threshold measurement information 201 (step 704).
[0049]
The method of arbitrarily selecting in the step 703 is that the excess threshold data name (1) 404 registered at the top of the excess threshold data name save area 401 or the i-th registered excess threshold data name (i) 404 is used. There may be.
[0050]
The arbitrarily selected data is registered again no matter how many times there is a data access request until the threshold excess data name save area 401 becomes full and the dynamic threshold changing unit 111 updates the threshold. This is not the case, and only the access count 304 is updated. For this reason, the access count 304 of the data at the time selected in step 703 is larger than the current threshold.
[0051]
Therefore, if the data arbitrarily selected in step 703 is data with a high access frequency, the updated threshold is set to a value larger than the current threshold. A value larger by "1" than the current threshold value 203 is set, and data with a high access frequency is narrowed down using the new threshold value.
[0052]
Next, the threshold excess identifier 204 is updated (step 705), and the save area identifier 205 is changed (step 706). Finally, the threshold of the threshold excess data name save area 401 corresponding to the changed save area identifier 205 is changed. The new threshold value 203 is set in the save 402, and “0” is set in the registration number 403 (step 707).
[0053]
On the other hand, if the registration area is not full at step 701, the threshold change is unnecessary, and the dynamic threshold change process ends.
[0054]
The threshold excess information periodical transmission unit 112 of the access frequency collection unit 108 arbitrarily pre-sets the threshold excess data name 404 registered in the threshold excess data name save area 401 collected by the threshold excess information storage unit 110 in the system. A function of notifying the distributed database system management unit 101 at a set fixed time interval is realized.
[0055]
The processing outline of the threshold excess information periodic transmission unit 112 will be described with reference to FIGS.
[0056]
8 shows the configuration of information to be transmitted to the distributed database system management unit 101, and shows the average within a certain time period measured by the CPU usage rate measurement unit 107 using the conventional technique. The area includes a CPU usage rate 802 which is an area for storing the CPU usage rate, a data name 804 exceeding the threshold, and an access count 805 for storing the access count for the data at the time of transmission.
[0057]
The threshold excess information periodic transmission unit 112 collects the CPU utilization from the CPU utilization measurement unit 107, sets the CPU utilization 802 of the threshold excess data name transmission information 801 (step 901), and saves the threshold excess data name save area (step 901). The current number of accesses 304 of the data name 404 registered in the data area 404 registered in the data area 404 registered in the threshold excess data name save area (side B) 401 is collected, and the data name 804, the access number 805, and the number of transmissions 803 are set. (Steps 902 and 903).
[0058]
Next, “0” is set to the registration number 403 on both sides of the threshold excess data name save area 401 (step 904), the access frequency collection identifier 202 of the threshold measurement information 201 is updated (step 905), and the threshold measurement information is further updated. The threshold 203 of 201 is initially set to “0” (step 906), and the process ends.
[0059]
As a result, the collection of frequently accessed data at fixed time intervals is restarted.
[0060]
A specific example in which the threshold value is dynamically changed will be described with reference to FIG.
In the specific example of FIG. 10, the number of data that can be registered in the threshold excess data name save area 401 is set to five, and the data is already registered in the save area, and the remaining one data is used as the save area A Indicates that the registration area 401 is full and the threshold is updated.
[0061]
When a database access request for the data name A5 occurs, the processing of the access count adding unit 109 is performed.
[0062]
Then, since the access frequency collection identifier save 1004 of the data name A5 matches the access frequency collection identifier 1001 of the threshold measurement information 201, the access count 1006 of the data name A5 is added by the processing of step 506 in FIG.
[0063]
In the threshold excess information storage unit 110, since the access count 1017 of the data name A5 is larger than the threshold 1002 of the threshold measurement information 201, the process of step 604 in FIG. 6 is executed. Also, since the threshold excess identifier save 1005 of the data name A5 does not match the threshold excess identifier 1003 of the threshold measurement information 201, the processing of step 607 in FIG. 6 is executed, and the threshold of the A side currently used as the save area is executed. The data name A5 is registered in the excess data name (5) 1012 of the excess data name save area 401, and the registered number 1010 is updated.
[0064]
Next, the threshold excess identifier 1003 of the threshold measurement information 201 is set in the threshold excess identifier save 1016 of the corresponding data A5, and the control is passed to the dynamic threshold changing unit 111.
[0065]
Since the registration area is full, the dynamic threshold changing unit 111 executes the processing after step 703 in FIG. 7 and sets a new threshold. As an example of a method for extracting an arbitrary threshold-exceeding data name in step 703 in FIG. 7, FIG. 10 shows a case where a threshold-exceeding data name registered at the head of a registration area is extracted as an example.
[0066]
In the example of FIG. 10, the data name A1 is registered at the top 1011 of the A side of the currently used threshold excess data name save area 401, and the threshold measurement is performed using the current access count 1015 of the data A1 as a new threshold. The threshold value 1007 of the information 201 is set.
[0067]
Next, the threshold excess identifier 1008 is updated, and the save area identifier 1009 is changed to the B side.
Finally, a new threshold value 1007 is set in the threshold save 1013 of the threshold excess data name save area 401 on the B side, and the registration number 1014 is initialized to “0”, and the processing of the dynamic threshold change unit 111 ends.
[0068]
In the processing example of the dynamic threshold updating unit 111 illustrated in FIG. 7, a method of extracting an arbitrary one of the threshold excess data names 404 (Step 703) and setting the access count 304 of the data at that time as the new threshold 203. However, among the plurality of threshold-exceeding data names 404, the one with the largest number of accesses 304 at that time may be used as the new threshold 203. According to this method, the new threshold value is updated based on the number of accesses of the data having a higher access frequency, so that the data having the higher access frequency can be narrowed down more quickly, and the data having the higher access frequency can be identified. If you hurry, it will be more effective.
[0069]
Further, in the processing example of the threshold excess information periodic transmission unit 112 illustrated in FIGS. 8 and 9, the access count 304 at that time of the threshold excess data name 404 registered in the threshold excess data name save area 401 is extracted. Then, the method of transmitting the data to the distributed database system management unit 101 has been described, but the two threshold excess data name save areas 401 shown in FIG. 4 may be transmitted as they are.
[0070]
When the initial setting of the threshold value 203 is performed (step 906), if the initial value is set not to “0” but to a condition such as “現在” of the current threshold value 203, the access performed after the first periodic transmission is performed. Frequent data can be narrowed down more quickly.
[0071]
Further, the distributed database system 102 does not autonomously identify frequently accessed data and does not periodically transmit the result. Instead, the distributed database system management unit 101 identifies the frequently accessed data according to an instruction from the distributed database system management unit 101. Alternatively, a method of starting and reporting the result according to an instruction from the distributed database system management unit 101 may be adopted.
[0072]
FIG. 11 is a diagram showing a configuration of a system in which a catalog seller realizes an online home shopping service, so-called virtual shopping.
The catalog distributor 1201 processes, on the server 1202, a request for more detailed information on the product described in the catalog or an order for the product, which is requested from each client 1206 of the customer 1205 via the network 1204, and processes the request from the server 1202. It provides the merchandise information stored in 1203 to the client 1206 or updates the stock status accompanying the order from the client 1206.
[0073]
In virtual shopping, it is difficult to accurately predict the number of accesses for each product, such as which product accesses more detailed information of which product, or the number of orders received for each product. For this reason, if it is possible to identify the products that are frequently accessed by customers and to change the information provided as appropriate, such as to make more detailed information on the products that are frequently accessed or to lower the prices of those products, it is possible to receive orders. It is also possible to further increase.
[0074]
In addition, if a case where orders are concentrated and inventory becomes insufficient can be detected at an earlier stage, it is not necessary to refuse orders or delay delivery of products, and it is possible to further improve serviceability to customers.
[0075]
However, as the number of target products increases, the number of frequently accessed products and orders increases, and when it is attempted to specify a low-stock product in real time, the effect on the processing capacity of the server 1202 becomes large, and the customer 1205 is sent to the customer 1205. The response is delayed.
[0076]
Therefore, by applying the present invention, it is possible to realize a system for specifying a product with a high access frequency in real time and specifying a product with a small stock. FIG. 12 shows the configuration of the threshold value measurement information 201 for realizing such a system, FIG. 13 shows the configuration of the database 1203, and FIG. 14 shows the configuration of the area for saving products with low stock.
[0077]
In FIG. 12, 202 to 205 are the same information as described in FIG. In the present embodiment, a stock threshold 1301, a stock threshold drop identifier 1302, and a stock threshold drop save area identifier 1303 are newly provided. These pieces of information are used when identifying frequently accessed data. Corresponding to the threshold 203, the threshold excess identifier 204, and the save area identifier 205.
[0078]
In FIG. 13, the stock number 1402 is data that is decremented as needed upon receiving an order from the client 1206, and the stock threshold drop identifier save 1401 indicates that the stock quantity 1402 of each product is smaller than the stock threshold 1301 when the stock quantity 1402 is smaller than the stock threshold 1301. This is information for identifying whether or not the data has already been saved in the threshold drop data name save area 1501.
[0079]
It should be noted that the specification of a product with a high access frequency can be realized by the processing described in FIGS. 5, 6, 7, and 9. However, the information on the CPU usage rate described in FIG. 9 is unnecessary.
[0080]
On the other hand, in order to specify a product with a small stock, the stock threshold is dynamically reduced. When the stock threshold drop data name save area 1501 shown in FIG. 14 becomes full, In the same flow as the processing flow of the dynamic threshold changing unit 111 shown in FIG. 7, a new inventory threshold 1301 is dynamically determined based on the current inventory quantity of the data arbitrarily selected from the inventory threshold drop data name save area 1501. Will be updated.
[0081]
That is, in the embodiment of FIG. 1, the threshold value is increased in accordance with the access frequency. However, as in the case of specifying a product with a small stock, the number, the number, the ratio, the required time, and the like of the identification target can be measured. When specifying a physical quantity that is small, the threshold value is dynamically updated in a smaller direction.
[0082]
As the initial value of the stock threshold 1301, the maximum value that can be represented by the area (byte length / bit length) of the stock quantity 1402 in the database 1203 is used. Alternatively, if the appropriate stock quantity is known in advance for each product, the ratio (%) of the stock quantity to the proper stock quantity can be set as the stock threshold instead of the stock quantity. A value of “100 (%)” may be used as the initial value of the threshold value 1301.
[0083]
In the system configuration of FIG. 11, by executing the processing described in FIGS. 5, 6, 7, and 9 on the server 1202, the virtual shopping does not impose a large burden on the server 1202, and the customer can select which merchandise item. It is possible to accurately measure the number of accesses for each product, such as whether more detailed information is accessed, or the number of orders for each product. As a result, it is possible to contribute to an increase in the number of orders by making the information of the products that are frequently accessed more detailed or reducing the prices of the products.
[0084]
In addition, it is possible to identify products that have a shortage of inventory due to a concentration of orders at an early stage, and to avoid rejecting orders or delaying the delivery of products, thereby further improving serviceability to customers.
[0085]
FIG. 15 shows a video-on-demand service using a video server having a distributed processing configuration having a load distribution function when access to specific video software (hereinafter abbreviated as video stream) is concentrated. FIG. 1 is a diagram illustrating a configuration of a system that provides a VOD service (hereinafter, abbreviated as VOD service).
[0086]
The VOD service provider 1601 receives a request from each client 1610 of the customer 1609 at the video server 1602 via the network 1608, and distributes a video stream to the client. In the example of FIG. 15, the video server 1602 comprises three load-balanced video stream transmission units 1604 and one VOD management unit 1606, each of which has a video stream storage unit 1603 and an access frequency. An access frequency database 1605 for collection is provided, and the VOD management unit 1606 and the video stream transmission unit 1604 are connected by a network 1607.
[0087]
In the video server 1602 having a load distribution configuration, when a case where requests are concentrated on a specific video stream occurs, the video stream on which requests are concentrated is converted to the video stream of the video stream transmitting unit 1604 having the lightest load. It has a function of distributing the load of the video stream transmitting unit 1604 by multiplexing and arranging it in the stream storage unit 1603 so as to avoid a situation in which a request from the client 1610 cannot be satisfied in advance.
[0088]
In the case of the VOD service as well, the distribution of demand from customers is not uniform, changes every moment, and depending on social factors, there are cases where a particular video stream is concentrated on a specific date and time. The more it becomes, the more difficult it is to identify frequently accessed video streams in real time.
[0089]
Thus, the present invention is applied to a video server having such characteristics, and the structure of threshold measurement information when specifying a video stream with high access frequency is shown in FIG. FIG. 17 shows the structure of the access frequency database 1605 in FIG.
[0090]
The threshold measurement information 1701 in FIG. 16 includes, for each of the three video stream transmission units 1604, a threshold 203, a threshold excess identifier 204, a save area identifier 205, and a video stream transmitted by the video stream transmission unit 1604. It comprises a total number of transmission streams 1703 for counting the total number.
[0091]
The threshold excess data name save area 1801 composed of two sides A and B is also configured to correspond to each of the three video stream transmission units 1604.
The access frequency database 1605 managed by the VOD management unit 1606 has a configuration in which the threshold excess identifier save 303 and the number of accesses 304 correspond to each of the three video stream transmission units 1604.
[0092]
The specification of a video stream with a high access frequency is realized by executing the processing described in FIGS. 5, 6, 7, and 9 for each of the three video stream transmission units.
[0093]
The multiplex arrangement of the video streams is such that the video stream transmitting section 1604 having the smallest total number of transmission streams 1604 has the data name save area exceeding the threshold specified by the video stream transmitting section 1604 having the largest total number of transmission streams 1703. This can be realized by multiplexing the video streams with the highest access frequency registered in 1801.
[0094]
As a result, it is possible to quickly cope with a case where access to a specific video stream is concentrated on a specific date and time, and to improve service for a user.
[0095]
Note that the present invention is not limited to the above-described embodiment, and is applied to all cases in which a measurable physical quantity such as the number, the number, the ratio, and the required time of a specific object is small or large. be able to.
[0096]
【The invention's effect】
As described above, according to the present invention, in a system provided with a database storing product data, such as an online shopping system, a sorting process is unnecessary, and a high frequency of access can be specified without setting a threshold value in advance. It is possible to quickly extract product data, specific product data with a large distribution request, or specific products with a small number of stocks, and reduce the processing capacity of the system. The extracted merchandise data can be used as reference for expanding and rearranging the merchandise data, supplementing the stock amount, and the like.
[Brief description of the drawings]
FIG. 1 is a block diagram of a distributed database system according to an embodiment of the present invention.
FIG. 2 is a diagram showing a configuration of threshold measurement information in FIG. 1;
FIG. 3 is a diagram showing a configuration of a database in FIG. 1;
FIG. 4 is a diagram showing a configuration of an area for saving a threshold excess data name in FIG. 1;
FIG. 5 is a flowchart showing a processing procedure of an access number adding unit in FIG. 1;
FIG. 6 is a flowchart illustrating a processing procedure of a threshold excess information storage unit in FIG. 1;
FIG. 7 is a flowchart illustrating a processing procedure of a dynamic threshold value changing unit in FIG. 1;
FIG. 8 is a diagram illustrating a configuration of information notified to a distributed database system management unit in FIG. 1;
9 is a flowchart illustrating a processing procedure of a threshold excess information periodic transmission unit in FIG. 1;
FIG. 10 is an explanatory diagram showing a specific example of dynamic threshold change according to the present invention.
FIG. 11 is a block diagram showing an embodiment of an online shopping service system to which the present invention is applied.
FIG. 12 is a diagram illustrating a configuration of threshold measurement information in FIG. 11;
FIG. 13 is a diagram showing a configuration of a database in FIG. 11;
FIG. 14 is a diagram showing a configuration of an area for saving a data name exceeding a threshold in FIG. 11;
FIG. 15 is a block diagram showing an embodiment of a video-on-demand service system to which the present invention is applied.
FIG. 16 is a diagram showing a configuration of threshold measurement information in FIG.
FIG. 17 is a diagram showing a configuration of an area for saving a threshold excess data name in FIG. 15;
18 is a diagram showing a configuration of an access frequency database in FIG.
FIG. 19 is a diagram showing a configuration of a conventional access frequency table.
[Explanation of symbols]
108: access frequency collection unit, 109: access count addition unit, 110: threshold excess information storage unit, 111: dynamic threshold change unit, 112: threshold excess information periodic transmission unit, 203: threshold, 304: access count, 401 ... Threshold excess data name save area.

Claims (6)

データベースに格納された複数の商品データのうちアクセス頻度の高い特定の商品データをデータベースシステムにより抽出する特定商品データの抽出方法であって、
前記データベースシステムが、
所定周期毎に商品データへのアクセス回数を判定するための閾値“0”を閾値記憶部に設定する第1のステップと、
前記所定周期内における前記データベースの商品データへのアクセス回数を商品データ名単位で測定する第2のステップと、
測定したアクセス回数が前記閾値記憶部に設定された閾値を超過したか否かを判定する第3のステップと、
第3のステップの結果、超過したならば該当商品データ名をセーブエリアに記憶した後、当該セーブエリアが満杯か否かを判定する第4のステップと、
満杯ならば当該セーブエリアに登録されている任意の1つの閾値超過商品データ名の現在のアクセス回数を新しい閾値として前記閾値記憶部に設定し、かつ当該セーブエリアを商品データ名が記憶されていない状態にする第5のステップとを備え、
前記第3のステップから第5のステップを前記所定周期内で商品データへのアクセス毎に繰り返し、前記セーブエリアに記憶されている商品データ名の商品データをアクセス頻度の高い特定の商品データとして抽出することを特徴とする特定商品データの抽出方法。
An extraction method of specific product data, wherein a specific product data having a high access frequency among a plurality of product data stored in a database is extracted by a database system ,
The database system is
A first step of setting a threshold “0” for determining the number of accesses to the product data at predetermined intervals in a threshold storage unit;
A second step of measuring the number of accesses to each product data of the database within the predetermined cycle for each product data name;
A third step of determining whether the measured number of accesses has exceeded a threshold set in the threshold storage unit ,
If the result of the third step is that the product data name is exceeded, the corresponding product data name is stored in the save area, and then a fourth step of determining whether or not the save area is full;
If it is full, the current access count of any one of the product data names exceeding the threshold value registered in the save area is set as a new threshold value in the threshold storage unit, and the save area does not store the product data name. And a fifth step of setting the state
The third to fifth steps are repeated for each access to the product data within the predetermined period, and the product data of the product data name stored in the save area is extracted as specific product data having a high access frequency. A method for extracting specific product data.
前記セーブエリアに登録されている2つ以上の閾値超過商品データ名の中で現在のアクセス回数が最大の値を、前記新しい閾値として設定することを特徴とする請求項1に記載の特定商品データの抽出方法。2. The specific product data according to claim 1, wherein a value having the largest current access count among two or more product data names exceeding the threshold value registered in the save area is set as the new threshold value. 3. Extraction method. データベースに格納された複数の商品データで示される商品のうち残量の少ない特定の商品の商品データをデータベースシステムにより抽出する特定商品データの抽出方法であって、
前記データベースシステムが、
所定周期毎に商品の受注に伴う残量を判定するための閾値として商品データの在庫数エリアで表現可能な最大の値を閾値記憶部に設定する第1のステップと、
前記所定周期内における前記データベースの商品データで示される商品の受注に伴う残量を商品データ名単位で測定する第2のステップと、
測定した残量が前記閾値記憶部に設定された閾値より少ないか否かを判定する第3のステップと、
第3ステップの結果、少ないならば該当商品データ名をセーブエリアに記憶した後、当該セーブエリアが満杯か否かを判定する第4のステップと、
満杯ならば当該セーブエリアに登録されている任意の1つの閾値降下商品データ名の商品残量を新しい閾値として前記閾値記憶部に設定し、かつ当該セーブエリアを商品データ名が記憶されていない状態にする第5のステップとを備え、
前記第3のステップから第5のステップを前記所定周期内で商品データへの受注毎に繰り返し、前記セーブエリアに記憶されている商品データ名の商品データを残量の少ない特定の商品データとして抽出することを特徴とする特定商品データの抽出方法。
A method of extracting specific product data by extracting, using a database system, product data of a specific product having a small remaining amount among products indicated by a plurality of product data stored in a database ,
The database system is
A first step of setting, in a threshold storage unit, a maximum value that can be expressed in a stock quantity area of product data as a threshold for determining a remaining amount associated with an order for a product at predetermined intervals;
A second step of measuring a remaining amount associated with an order for a product indicated by the product data in the database within the predetermined cycle, in units of product data name;
A third step of determining whether or not the measured remaining amount is smaller than a threshold set in the threshold storage unit ;
If the result of the third step is that there is less, the corresponding product data name is stored in the save area, and then a fourth step of determining whether or not the save area is full;
If the storage area is full, the remaining amount of the commodity of any one of the threshold-dropped commodity data names registered in the save area is set as a new threshold in the threshold storage unit, and the save area does not store the commodity data name. And a fifth step of
The third step to the fifth step are repeated every time an order is received for the product data within the predetermined period, and the product data of the product data name stored in the save area is extracted as specific product data having a small remaining amount. A method for extracting specific product data.
前記セーブエリアに登録されている2つ以上の閾値降下商品データ名の中で現在の残量が最小の値を、前記新しい閾値として設定することを特徴とする請求項3に記載の特定商品データの抽出方法。4. The specific product data according to claim 3, wherein a value with the smallest remaining amount among two or more product names of threshold-drop products registered in the save area is set as the new threshold. 5. Extraction method. データベースに格納された複数の商品データのうち配信要求の多い特定の商品データをデータベースシステムにより抽出する特定商品データの抽出方法であって、
前記データベースシステムが、
所定周期毎に商品データへの配信要求回数を判定するための閾値“0”を閾値記憶部に設定する第1のステップと、
前記所定周期内における前記データベースの商品データへの配信要求回数を商品データ名単位で測定する第2のステップと、
測定した配信要求回数が前記閾値記憶部に設定された閾値を超過したか否かを判定する第3のステップと、
第3のステップの結果、超過したならば該当商品データ名をセーブエリアに記憶した後、当該セーブエリアが満杯か否かを判定する第4のステップと、
満杯ならば当該セーブエリアに登録されている任意の1つの閾値超過商品データ名の現在の配信要求回数を新しい閾値として前記閾値記憶部に設定し、かつ当該セーブエリアを商品データ名が記憶されていない状態にする第5のステップとを備え、
前記第3のステップから第5のステップを前記所定周期内で商品データへの配信要求毎に繰り返し、前記セーブエリアに記憶されている商品データ名の商品データを配信要求頻度の高い特定の商品データとして抽出することを特徴とする特定商品データの抽出方法。
A specific product data extraction method for extracting a specific product data having a large distribution request among a plurality of product data stored in a database by a database system ,
The database system is
A first step of setting a threshold “0” in the threshold storage unit for determining the number of distribution requests to the product data at predetermined intervals;
A second step of measuring, for each product data name, the number of distribution requests to each product data in the database within the predetermined cycle ;
A third step of determining whether the measured number of distribution requests has exceeded a threshold set in the threshold storage unit ,
If the result of the third step is that the product data name is exceeded, the corresponding product data name is stored in the save area, and then a fourth step of determining whether or not the save area is full;
If it is full, the current number of distribution requests for any one of the product data names exceeding the threshold value registered in the save area is set as a new threshold value in the threshold storage unit, and the save area stores the product data name. And a fifth step of eliminating the
The third step to the fifth step are repeated for each distribution request to the commodity data within the predetermined period, and the commodity data of the commodity data name stored in the save area is replaced with specific commodity data having a high distribution request frequency. A method for extracting specific product data, characterized in that the specific product data is extracted.
前記セーブエリアに登録されている2つ以上の閾値超過商品データ名の中で現在の配信要求回数が最大の値を前記新しい閾値として設定することを特徴とする請求項5に記載の特定商品データの抽出方法。6. The specific product data according to claim 5, wherein a value having the maximum number of current distribution requests among two or more product data names exceeding the threshold registered in the save area is set as the new threshold. 7. Extraction method.
JP2002128320A 2002-04-30 2002-04-30 How to extract specific product data Expired - Fee Related JP3600985B2 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2002128320A JP3600985B2 (en) 2002-04-30 2002-04-30 How to extract specific product data

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2002128320A JP3600985B2 (en) 2002-04-30 2002-04-30 How to extract specific product data

Related Parent Applications (1)

Application Number Title Priority Date Filing Date
JP23940795A Division JP3444385B2 (en) 1995-09-19 1995-09-19 Access frequency threshold control method for distributed database

Publications (2)

Publication Number Publication Date
JP2003044480A JP2003044480A (en) 2003-02-14
JP3600985B2 true JP3600985B2 (en) 2004-12-15

Family

ID=19194283

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2002128320A Expired - Fee Related JP3600985B2 (en) 2002-04-30 2002-04-30 How to extract specific product data

Country Status (1)

Country Link
JP (1) JP3600985B2 (en)

Families Citing this family (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP5157736B2 (en) * 2008-08-07 2013-03-06 富士通株式会社 Network monitoring device, network monitoring system, and network monitoring method
JP4945807B2 (en) * 2008-12-02 2012-06-06 Necビッグローブ株式会社 Terminal device, server, information collection system, method, and program
WO2021038835A1 (en) * 2019-08-30 2021-03-04 富士通株式会社 Information processing device, and data flow creating program

Also Published As

Publication number Publication date
JP2003044480A (en) 2003-02-14

Similar Documents

Publication Publication Date Title
US20020052952A1 (en) Service execution method and apparatus
CN103023938B (en) A kind of service capability control method of server cluster and system
US20030187978A1 (en) Service request agency method, service request agency server and service request agency system
CN107801086A (en) The dispatching method and system of more caching servers
CN104731981A (en) Storage-side storage request management
CN110149394A (en) Dispatching method, device and the storage medium of system resource
CN110058940B (en) Data processing method and device in multi-thread environment
US20020007392A1 (en) Method and system for data layout and replacement in distributed streaming caches on the internet
CN110245153A (en) Product data processing method, system, computer equipment and storage medium
CN103248636B (en) The system and method downloaded offline
US20260037323A1 (en) Systems and methods for dynamically scaling remote resources
CN110460879B (en) Video request scheduling method, device, server and storage medium
CN111858659A (en) Data query method, device, device and storage medium based on row key salt value
CN115086299A (en) File downloading method, device, equipment, medium and program product
JP3600985B2 (en) How to extract specific product data
CN108874805B (en) Data processing method and device
CN110941771B (en) Commodity parallel dynamic pushing method in e-commerce platform
CN114328562B (en) Method and device for updating tag, computer readable storage medium and electronic equipment
JP3444385B2 (en) Access frequency threshold control method for distributed database
CN107396145A (en) One kind gets through IPTV, the advertisement placement method and advertisement delivery system of OTT resources
CN111311310B (en) Advertisement order pushing method and device, storage medium and electronic device
KR100989490B1 (en) Load balancing system between each server and its method
CN112689166A (en) Method and system for flexibly increasing and decreasing CDN hot content in real time
US20160285984A1 (en) Method and system for processing measurement data for website statistics
CN109035070B (en) Catering system based on internet of things search

Legal Events

Date Code Title Description
A131 Notification of reasons for refusal

Free format text: JAPANESE INTERMEDIATE CODE: A131

Effective date: 20040420

A521 Request for written amendment filed

Free format text: JAPANESE INTERMEDIATE CODE: A523

Effective date: 20040617

TRDD Decision of grant or rejection written
A01 Written decision to grant a patent or to grant a registration (utility model)

Free format text: JAPANESE INTERMEDIATE CODE: A01

Effective date: 20040907

A61 First payment of annual fees (during grant procedure)

Free format text: JAPANESE INTERMEDIATE CODE: A61

Effective date: 20040908

R150 Certificate of patent or registration of utility model

Free format text: JAPANESE INTERMEDIATE CODE: R150

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20131001

Year of fee payment: 9

LAPS Cancellation because of no payment of annual fees