JP3600985B2 - How to extract specific product data - Google Patents
How to extract specific product data Download PDFInfo
- 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
Links
- 238000000034 method Methods 0.000 claims description 37
- 238000000605 extraction Methods 0.000 claims description 5
- 238000013075 data extraction Methods 0.000 claims 1
- 238000012545 processing Methods 0.000 description 33
- 238000005259 measurement Methods 0.000 description 25
- 230000005540 biological transmission Effects 0.000 description 22
- 238000010586 diagram Methods 0.000 description 19
- 238000007726 management method Methods 0.000 description 16
- 230000000737 periodic effect Effects 0.000 description 7
- 238000004891 communication Methods 0.000 description 6
- 239000000284 extract Substances 0.000 description 6
- 230000000694 effects Effects 0.000 description 3
- 230000003111 delayed effect Effects 0.000 description 2
- 238000007796 conventional method Methods 0.000 description 1
- 238000005315 distribution function Methods 0.000 description 1
- 230000001502 supplementing effect Effects 0.000 description 1
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
[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
[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
[0022]
The distributed
[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
[0025]
The access
[0026]
The access
[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
[0028]
Here, the access
[0029]
The
[0030]
The
[0031]
The
[0032]
FIG. 3 shows the configuration of each piece of data arranged in the
[0033]
FIG. 4 shows an area for storing the data name when the number of
[0034]
The processing outline of the access
[0035]
When an access request to the
[0036]
It is determined whether or not the value of the extracted access frequency collection identifier save 302 matches the access
[0037]
As a result, “1” is set to the number of
[0038]
On the other hand, if it is determined in
[0039]
Finally, control is passed from the access
[0040]
The processing outline of the threshold excess information storage unit 110 of the access
[0041]
When the control is passed from the access
[0042]
If the number of
[0043]
If the threshold excess identifier save 303 and the
[0044]
Thereafter, control is passed to the dynamic threshold changing unit 111 (step 609).
[0045]
On the other hand, if it is determined in
[0046]
The processing outline of the dynamic threshold value changing unit 111 of the access
[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
[0048]
When the registration area is full, any one threshold excess data name 404 registered in the excess threshold data name save
[0049]
The method of arbitrarily selecting in the
[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
[0051]
Therefore, if the data arbitrarily selected in
[0052]
Next, the
[0053]
On the other hand, if the registration area is not full at
[0054]
The threshold excess information periodical transmission unit 112 of the access
[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
[0057]
The threshold excess information periodic transmission unit 112 collects the CPU utilization from the CPU
[0058]
Next, “0” is set to the
[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
[0061]
When a database access request for the data name A5 occurs, the processing of the access
[0062]
Then, since the access frequency collection identifier save 1004 of the data name A5 matches the access
[0063]
In the threshold excess information storage unit 110, since the
[0064]
Next, the threshold excess identifier 1003 of the
[0065]
Since the registration area is full, the dynamic threshold changing unit 111 executes the processing after
[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
[0067]
Next, the
Finally, a
[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
[0069]
Further, in the processing example of the threshold excess information periodic transmission unit 112 illustrated in FIGS. 8 and 9, the
[0070]
When the initial setting of the
[0071]
Further, the distributed
[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
[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
[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
[0077]
In FIG. 12, 202 to 205 are the same information as described in FIG. In the present embodiment, a
[0078]
In FIG. 13, the
[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
[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
[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
[0087]
In the
[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
[0090]
The
[0091]
The threshold excess data name save
The
[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
[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.
前記データベースシステムが、
所定周期毎に商品の受注に伴う残量を判定するための閾値として商品データの在庫数エリアで表現可能な最大の値を閾値記憶部に設定する第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.
前記データベースシステムが、
所定周期毎に商品データへの配信要求回数を判定するための閾値“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.
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)
| 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 |
-
2002
- 2002-04-30 JP JP2002128320A patent/JP3600985B2/en not_active Expired - Fee Related
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 |