(57)【要約】【課題】一周期内に複数のアクセスポイントからの情報収集を終えることを可能とする。【解決手段】複数の対象装置に記憶されたデータを、前記複数の対象装置に並列アクセスが可能な複数のプロセスにより収集するデータ収集装置であって、各対象装置について想定されたデータ収集時間の長い順に、前記複数のプロセスに対してアクセスする対象装置を割当てて、前記データを取得する取得部を含む。【選択図】図９
2017069661.tif 000002
【特許請求の範囲】
【請求項１】
複数の対象装置に記憶されたデータを、前記複数の対象装置に並列アクセスが可能な複数のプロセスにより収集するデータ収集装置において、
各対象装置について想定されたデータ収集時間の長い順に、前記複数のプロセスに対してアクセスする対象装置を割当てて、前記データを取得する取得部、
を含むデータ収集装置。
【請求項２】
前記取得部は、或る一周期における実際のデータ収集時間を、次回の一周期について想定されたデータ収集時間として用いる
請求項１に記載のデータ収集装置。
【請求項３】
前記取得部は、過去の２以上の周期における前記複数の対象装置のデータ収集時間を統計処理した結果に基づき想定されたデータ収集時間を、次回の一周期について想定されたデータ収集時間として用いる
請求項１に記載のデータ収集装置。
【請求項４】
前記取得部は、或る地域で或る時間に発生するイベントに基づき想定されたデータ収集時間を用いる
請求項１に記載のデータ収集装置。
【請求項５】
複数の対象装置に記憶されたデータを、前記複数の対象装置に並列アクセスが可能な複数のプロセスにより収集する複数のデータ収集装置と、
前記複数のデータ収集装置の管理装置とを含み、
前記複数のデータ収集装置のそれぞれは、
各対象装置について想定されたデータ収集時間の長い順に、前記複数のプロセスに対してアクセスする対象装置を割当てて、前記データを取得する取得部、を含み、
前記管理装置は、前記想定されたデータ収集時間を管理する管理部と、前記複数のデータ収集装置が取得したデータを蓄積する蓄積部とを含む
データ収集システム。
【請求項６】
複数の対象装置に記憶されたデータを、前記複数の対象装置の少なくとも２つに並列アクセスが可能な複数のプロセスにより収集するデータ収集装置が、各対象装置について想定されたデータ収集時間の長い順に前記複数のプロセスに対してアクセスする対象装置を割当てて、前記データを取得する、
ことを含むデータ収集方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、データ収集装置，データ収集システム，及びデータ収集方法に関する。
【背景技術】
【０００２】
スマートフォン，タブレット端末などの無線端末の普及に伴い、無線端末をインターネット等のネットワークに繋ぐことで無線端末の利用者が情報を入手できるようにするサービスが増加している。
【０００３】
例えば、日本全国でサービスができるように、駅、空港、オフィスビル、店、屋外などあらゆるところに無線ＬＡＮ（Local Area Network）のアクセスポイント（以下「ＡＰ」と表記）が配置されている。その結果、ＡＰ数が急激に増加している。
【０００４】
ＡＰは、無線端末の利用状況を示すデータ（例えば、端末毎の接続情報）など、アソシエーション分析に有用なデータを蓄積する。従来、各ＡＰからデータを収集する収集サーバと、各ＡＰから収集されたデータを管理する収集管理サーバとがネットワークに配置される。各収集サーバは、複数のＡＰのそれぞれに対するポーリングを行い、ＡＰに蓄積されたデータを収集する。ＡＰ数の増加に伴い、収集サーバの数も増加する。
【先行技術文献】
【特許文献】
【０００５】
【特許文献１】特開平９−３２１７５８号公報
【特許文献２】特開平１０−４１８７７号公報
【特許文献３】特表２００８−５１２０４７号公報
【発明の概要】
【発明が解決しようとする課題】
【０００６】
複数のＡＰに記憶された情報を複数台の収集サーバで収集する場合、各収集サーバがデータを収集するＡＰを決定する方法（各収集サーバに対するＡＰの割り当て方法）としては、以下の２つがある。
【０００７】
１つは、各収集サーバに予め複数のＡＰが固定して割り当てられ、各収集サーバがＡＰからデータを収集する一周期内に、割り当てられた複数のＡＰの全てからデータを収集する方法（「第１の方法」と称する）である。もう一つは、各収集サーバが、或る周期内で収集が未実施のＡＰを選択する方法（「第２の方法」と称する）である。
【０００８】
収集されるデータの情報量は、ＡＰ付近を往来する人の数や、無線端末の利用状況により増減する。第１の方法では、ＡＰの配置エリアの一時的な混雑（ＡＰ利用者の増加）によって、或るＡＰから収集するデータの情報量が膨らんだ場合に、データの収集に要する時間が一周期の時間長を超過する場合があった。
【０００９】
通常、収集サーバの処理能力は、処理負荷のピークに対して或る程度の余裕を持って処理できるように決定される。このため、上記したようなＡＰの配置エリアの一時的な混雑が滅多に発生しない場合であっても、混雑時におけるデータの収集が一周期の時間内で完了するように、収集サーバの設備やリソースの増強がなされる。しかし、増強される設備やリソースは、普段は使用されない無駄なものとなる問題があった。
【００１０】
一方、第２の方法では、データの収集が未実施のＡＰがランダムに選択され、当該ＡＰ
からデータが収集される。しかしながら、例えば、ＡＰの選択のタイミングが一周期の後半であるのに対し、当該ＡＰからのデータ収集に要する時間の長さが一周期の半分以上の長さであると、一周期内でデータ収集が終わらない問題があった。
【００１１】
本発明は、一周期内に複数の対象装置からのデータ収集を完了可能とする技術を提供することを目的とする。
【課題を解決するための手段】
【００１２】
本発明の一側面は、複数の対象装置に記憶されたデータを、前記複数の対象装置についての並列アクセスが可能な複数のプロセスにより収集するデータ収集装置である。このデータ収集装置は、各対象装置について想定されたデータ収集時間の長い順に、前記複数のプロセスに対してアクセスする対象装置を割当てて、前記データを取得する取得部を含む。
【発明の効果】
【００１３】
本発明によれば、一周期内に複数の対象装置からの情報収集を終えることができる。
【図面の簡単な説明】
【００１４】
【図１】図１は、データの収集システムの一例を示す。
【図２】図２は、データ収集におけるＡＰの割り当て方法の説明図である。
【図３】図３は、アソシエーションデータの管理の説明図である。
【図４】図４は、上述した第１の方法を適用した例と、その問題が生じる第１のケースとを示す図である。
【図５】図５は、第１の方法における問題が生じる第２のケースの説明図である。
【図６】図６は、第２の方法の適用例とその問題の説明図である。
【図７】図７は、実施形態に係るデータ収集方法の説明図である。
【図８】図８は、実施形態のデータ収集方法を、第１の方法の説明に用いた第２のケースに当てはめた例を示す。
【図９】図９は、実施形態に係るデータ収集システムの構成例を模式的に示す。
【図１０】図１０は、収集管理サーバのハードウェア構成例を示す。
【図１１】図１１は、収集サーバのハードウェア構成例を示す。
【図１２】図１２は、アクセスポイントのハードウェア構成例を示す。
【図１３】図１３は、図９に示した収集対象ＡＰ一覧テーブル（リスト）のデータ構造例を示す。
【図１４】図１４は、或るアクセスポイント（ＡＰ＃２）に対するエントリを収集対象ＡＰ一覧テーブルに追加する例を示す。
【図１５】図１５は、収集対象ＡＰ一覧テーブルの特殊指定のテーブルに対し、ＡＰ＃２に係るエントリが記憶（登録）された例を示す。
【図１６】図１６は、各収集サーバの情報取得部（ＣＰＵ）が行う処理例を示すフローチャートである。
【図１７】図１７は、想定時間決定処理の一例を示すフローチャートである。
【図１８】図１８は、想定時間決定処理の他の一例を示すフローチャートである。
【図１９】図１９は、実施形態の作用効果の一例を説明する図である。
【発明を実施するための形態】
【００１５】
以下、図面を参照して実施形態について説明する。実施形態の構成は例示であり、実施形態の構成に限定されない。
【００１６】
実施形態では、一例として、Internet Protocol（ＩＰ）ネットワーク上の無線ＬＡＮ
（Local Area Network）のアクセスポイント（ＡＰ）の情報収集方式について説明する。
実施形態では、一例として、収集サーバがSimple Network Management Protocol（ＳＮＭＰ）を用いて情報を収集する。無線ＬＡＮは、無線網の一例であり、無線網は、例えば、IEEE802.11シリーズの規格、WiFi規格に適合する無線ＬＡＮを含む。但し、無線網は、これら以外の規格に基づく無線網を含み得る。ＳＮＭＰは、情報収集のために使用されるプロトコルの一例であり、ＳＮＭＰ以外のプロトコルを適用し得る。
【００１７】
アクセスポイント（ＡＰ）とは、無線端末の相互接続，無縁端末のネットワークへの接続を可能にする無線機の一つである。無線端末は、例えば、ラップトップ型のパーソナルコンピュータ（ＰＣ），タブレット端末，スマートフォン，フィーチャーフォン，Personal Digital Assistant（ＰＤＡ）などを含む。
【００１８】
図１は、データの収集システムの一例を示す。収集システムは、単数又は複数の収集サーバ１０と、収集管理サーバ１１を含む。各収集サーバ１０は、複数のアクセスポイント（ＡＰ）１２のそれぞれに対してポーリングを行い、ＡＰ１２に記憶（蓄積）されているデータを収集する。ＡＰ１２から情報を収集する方法としては、例えば、ＡＰ１２から送信されるＳＮＭＰトラップ通知を収集サーバ１０が受信する方法がある。但し、ＳＮＭＰトラップ通知の受信は、必須ではなく、これ以外の収集方法を適用し得る。
【００１９】
各収集サーバ１０は、収集したデータを収集管理サーバ１１に送る。収集管理サーバ１１は、各収集サーバ１０により収集されたデータを記憶するデータベース（ＤＢ）１１ａを有する。
【００２０】
収集サーバ１０には、ピーク時（ＡＰ利用者の最大増加時、或いは負荷が最大となる時期）における各ＡＰからの情報収集量（収集に要する時間（「収集時間」ともいう））を見越した数のＡＰが、データ収集対象のＡＰ１２として割り当てられる。
【００２１】
換言すれば、ピーク時の収集時間（収集情報量）が想定され、データ収集が余裕を持って終了するように、データ収集を行う１つの周期（一周期）の時間長が決定される。そして、各収集サーバの収集時間が一周期の時間内に収まるように、各収集サーバがデータを収集するＡＰの数が設定される。ＡＰの数が増加し、既存数の収集サーバでは一周期内に全てのＡＰからデータを収集できない場合に、収集サーバが増設される。
【００２２】
複数の収集サーバ１０によって複数のＡＰ１２からデータを収集する場合における、各収集サーバ１０へのＡＰ１２の割り当て方法としては、第１の方法と、第２の方法とがある。図２に示すように、第１の方法では、各収集サーバ１２の処理能力を考慮して、一周期内にデータ収集を終えられると考えられる数のＡＰ１２が固定的に割り当てられる。
【００２３】
第２の方法では、収集管理サーバ１１が、収集サーバ１０によるＡＰ１２からのデータの収集状況を管理し、データ未収集のＡＰ１２を収集管理サーバ１１にランダムに割り当て、ＡＰ１２が割り当てられた収集サーバ１０がデータ収集を行う。
【００２４】
ここで、ＡＰ１２から収集されるデータ（収集対象のデータ）の一例である、アソシエーションデータ（端末毎の接続情報）について説明する。アソシエーションデータは、ＡＰ１２の利用状況を示すデータである。図３は、アソシエーションデータの管理の説明図である。
【００２５】
図３に示す様に、ＡＰ１２の無線エリア１２ａ（「セル」と呼ばれる）内に無線端末１３が移動すると、無線端末１３とＡＰ１２との接続処理が行われる。無線端末１３がＡＰ１２に接続し、両者間でデータ通信が開始される手続は、「アソシエーション」と呼ばれる。手続が開始されると、無線端末１３のMedia Access Control（ＭＡＣ）アドレスと、
アソシエーション確立からの経過時間を示す端末接続時間とが、アソシエーションデータとしてＡＰ１２に記憶される。アソシエーションデータ（ＭＡＣアドレス及び端末接続時間）は、例えば、テーブル（ＡＰ収集情報テーブル）１４のエントリとして記憶される。
【００２６】
無線端末１３が無線エリア１２ａの外に移動すると、無線端末１３とＡＰ１２との接続が切断され、一定時間経過の後に、対応するエントリがテーブル１４から削除される。すなわち、エージング処理が行われる。エージング処理のために、テーブル１４に対するエージングタイマが設けられ、エージングタイマが満了する毎に、無線エリア１２ａに存在しない無線端末１３のエントリが削除される。なお、テーブル１４のサイズ（記憶可能なエントリ数）には上限があり、テーブル１４に対するエントリの登録数が上限に達すると、古いエントリから順に上書きされる。
【００２７】
収集サーバ１０が、アソシエーションデータを収集する場合には、収集サーバ１０は、テーブル１４からエントリが削除される前に、ＡＰ１２からアソシエーションデータを取得する。このため、収集サーバ１０は、ＡＰ１２のエージング周期内、即ち、エージングタイマの満了前に、各ＡＰ１２に対するポーリングを完了する。
【００２８】
ここで、テーブル１４がフルになると古いエントリが上書きされることに鑑み、データ収集の周期を短くする（収集サーバ１０の収集効率を向上させる）と、輻輳時に、より多くのエントリを収集できる可能性がある。
【００２９】
アソシエーションデータの情報量は、ＡＰ１２付近の人の往来、すなわち、ＡＰ１２の無線エリア内に存する無線端末１３の数、無線端末１３の利用状況によって左右される。すなわち、ＡＰ１２の無線エリア１２ａに存在し、且つＡＰ１２との通信を行う無線端末１３の数が多くなるほど、テーブル１４に記憶されるアソシエーションデータのエントリ数（すなわち、収集サーバ１０が収集する情報量）は増加する。
【００３０】
図４は、上述した第１の方法を適用した例と、その問題が生じる第１のケースとを示す図である。図４において、収集サーバ１０の一つとして収集サーバ１０ａがあり、収集サーバ１０ａには、アソシエーションデータの収集対象のＡＰ１２として、ＡＰ（１）〜（１０）が固定的に割り当てられている。
【００３１】
第１の方法における収集サーバ１０は、複数のＡＰ１２からアソシエーションデータを収集するためのプロセスを、並列に実行する。状況によっては、１つの収集サーバ１０は、一周期内に数十万のＡＰからアソシエーションデータを収集することがある。このような場合に、ＡＰ１２からUser Datagram Protocol（ＵＤＰ）で送信される大量の情報を受信すると、収集サーバ１０のバッファがオーバーフローする可能性がある。このため、収集サーバ１０が一時期に収集する情報量がプロセス数で制限され、一周期の時間内に、複数個のプロセスのそれぞれが所定数（例えば数個）のＡＰをポーリングし、アソシエーションデータを収集する。
【００３２】
図４に示す例では、収集サーバ１０ａは、所定数（図４の例では５）のプロセス１〜５を実行する。プロセス１は、アソシエーションデータを収集する一周期の時間内に、ＡＰ（１）及びＡＰ（６）からアソシエーションデータを収集する。プロセス２は、一周期の時間内に、ＡＰ（２）及びＡＰ（７）からアソシエーションデータを収集する。プロセス３は、一周期の時間内に、ＡＰ（３）及びＡＰ（８）からアソシエーションデータを収集する。プロセス４は、一周期の時間内に、ＡＰ（４）及びＡＰ（９）からアソシエーションデータを収集する。プロセス５は、一周期の時間内に、ＡＰ（５）及びＡＰ（１０）からアソシエーションデータを収集する。
【００３３】
ところが、第１の方法では、以下の問題が生じることがある。図４において、イベントの開催等によって、ＡＰ（９）の無線エリアで無線端末１３が混雑し、ＡＰ（９）のテーブル１４に大量のアソシエーションデータが蓄積されたと仮定する。この場合、収集サーバ１０のプロセス５は、ＡＰ（９）からのアソシエーションデータの収集が一周期の時間内に終わらないことがある。
【００３４】
上述したように、アソシエーションデータはエージング処理によってテーブル１４から削除されるため、一周期の時間内に収集できなかったアソシエーションデータは次の周期では収集できない。また、上記したように、一周期の時間長は短い方が好ましい。よって、アソシエーションデータを漏れなく収集するため、規定の一周期内で収集が終えられるように、収集サーバ１０ａの処理能力を向上させる、或いは、ＡＰ（９）用の収集サーバ１０を増設する、といった、設備や能力の増強が行われる。
【００３５】
図５は、第１の方法における問題が生じる第２のケースの説明図である。図５に示す第２のケースでは、都心におけるＡＰ１２の設置エリアと、郊外におけるＡＰ１２の設置エリアとを考える。平日の昼間の時間帯では、人は郊外から都心に移動している。一方、平日の夜間の時間帯や、休日では、人の郊外から都心への移動は少なく、都心の人口より郊外における人口が増える。
【００３６】
第１の方法では、上記した人の移動を考慮することなく、固定的なＡＰ１２の割り当てが行われる。このため、都心の平日昼間の時間帯におけるＡＰ１２の無線エリアの混雑ピークにおいても、余裕を持ってアソシエーションデータを収集できるように、収集サーバ１０の処理能力及び台数が用意される。第１のケース及び第２のケースのいずれにおいても、混雑のピークに合わせた収集サーバ１０の増強は、普段は使用されない無駄なリソースを維持することになる。
【００３７】
図６は、第２の方法の適用例とその問題の説明図である。図６において、都心及び郊外に配置された複数のＡＰ１２に関して、複数の収集サーバ１０（図６では、収集サーバ１０ｂ，１０ｃ，１０ｄ）がアソシエーションデータの収集を行う。収集サーバ１０ｂ，１０ｃ，１０ｄのそれぞれは、例えば、収集管理サーバ１１（図６では不図示）からの指示に従い、アソシエーションデータの収集が未実施のＡＰ１２をランダムに選択し、収集を行う。
【００３８】
ところが、図６における収集サーバ１０ｂのプロセス５のように、或るＡＰ１２（ＡＰ（ｘ）とする）に膨大なアソシエーションデータが蓄積されており、アソシエーションデータの収集が一周期の時間内に終了しない場合が起こり得る。
【００３９】
以上のように、第１の方法と第２の方法のとの双方において、一周期の時間内にデータ収集が終了しない場合が起こり得る。このために、普段は無駄となる収集サーバの設備増強を行うことは非効率であった。
【００４０】
以下に説明する実施形態では、一周期内にデータ収集が終えられるようにして、収集サーバの規模（収集サーバの台数や各収集サーバが有する処理能力）を小さくすることのできるデータ収集方法、データ収集装置、データ収集システムについて説明する。
【００４１】
実施形態に係るデータ収集装置は、複数の対象装置に記憶されたデータを、前記複数の対象装置に（例えば、複数の対象装置の少なくとも２つに）並列アクセスが可能な複数のプロセスにより収集するデータ収集装置である。このデータ収集装置は、各対象装置について想定されたデータ収集時間の長い順に、前記複数のプロセスに対してアクセスする対象装置を割当てて、前記データを取得する取得部を含む。並列アクセスは、複数のプロセ
スのそれぞれが、自身に割り当てられた対象装置へのアクセスを並列に実行することをいう。
【００４２】
実施形態の説明では、データ収集装置の一例が、収集サーバ１０Ａであり、対象装置の一例がＡＰ１２である例について説明する。但し、データ収集装置は、収集サーバ以外の装置であっても良い。また、対象装置は、収集対象のデータを記憶している限り、ＡＰ以外の装置であっても良い。また、収集対象のデータは、例えば、ＡＰ１２に記憶されるアソシエーションデータであるが、アソシエーションデータ以外のデータであっても良い。
【００４３】
図７は、実施形態に係るデータ収集方法の説明図である。図７において、例えば、図７の上段には、図４を用いて説明した第１の方法を用いた第１のケースが図示されている。第１の方法では、収集サーバ１０のプロセス１〜５がデータを収集するＡＰ１２が決定されているだけである。各ＡＰ１２からデータを収集するのに要する時間、すなわちデータ収集時間は考慮されていない。この結果、ＡＰ（９）のデータ収集時間のように、その終期が一周期の終期より遅くなり、収集できないデータが発生する。
【００４４】
これに対し、実施形態では、周期毎に、各ＡＰ１２について、データの収集（取得）に係る時間が想定される。実施形態に係る収集サーバ１０Ａは、想定された各対象装置におけるデータ収集時間が長い順に、複数のプロセスに対してアクセスする対象装置を割り当て、各プロセスが各ＡＰ１２にアクセスしてデータを取得する。プロセス１〜５は、「前記複数の対象装置に並列アクセスが可能な複数のプロセス」の一例である。
【００４５】
例えば、図７の下段には、第１のケースに対し、実施形態に係るデータ収集方法を適用した場合における各ＡＰの各プロセスに対する割り当て結果が示されている。図７に示すように、ＡＰ（１）〜（１０）のそれぞれについてのデータ収集時間が、第１の方法について示したデータ収集時間（図７の上段）と同等の長さ（時間長）であると想定する。
【００４６】
この場合、収集サーバ１０Ａは、データ収集時間が長い順でＡＰをソートし、各ＡＰをプロセス１〜５に振り分ける。この結果、ＡＰ（１）〜（１０）のうち、データ収集時間が最も長いＡＰ（９）が最初のプロセス１に割り当てられる。従って、ＡＰ（９）に対するデータ収集が、一周期の始期から開始される。この結果、ＡＰ（９）に対するデータ収集を、一周期の終期よりも前に終える（完了する）ことができる。
【００４７】
また、残りのＡＰ（１）〜（８），（１０）も、想定されるデータ収集時間の長い順で、プロセスに割り当てられる。図７に示す例では、各ＡＰ（１），（３），（４），（７），（８）におけるデータ収集時間が同じであり、各ＡＰ（２），（５），（６），（１０）におけるデータ収集時間が同じであり、後者の時間長は、前者の時間長の訳半分となっている。
【００４８】
データ収集時間が同じ長さの場合には、例えば、ＡＰ１２に予め割り当てられた番号の昇順又は降順で、プロセスに対するＡＰ１２の割り当てが行われる。図７の例では、番号が小さい順を昇順として、ＡＰ（１），（３），（４），（７）がプロセス２〜５に割り当てられている。次のＡＰ（８）は、プロセス１（ＡＰ（９）の後ろ）に割り当てると、データ収集時間の終期が一周期の終期よりも遅くなるので、プロセス２（ＡＰ（１）の後ろ）に割り当てられている。残りのＡＰ（２），（５），（６），（１０）は、同様の手法でプロセス２〜５に割り当てられている。
【００４９】
実施形態によるデータ収集方法によれば、データ収集の一周期内で、データ収集対象の装置（対象装置）であるＡＰ（１）〜（１０）の全てのデータ収集を終えることができる。これによって、収集サーバの増強がなくても、データを漏れなく収集することが可能と
なる。
【００５０】
また、実施形態によるデータ収集方法によれば、第１の方法に比べて、複数の対象装置（複数のＡＰ１２（ＡＰ（１）〜（１０））の全てからデータを収集し終わる時期を、第１の方法より早めることができる（図７参照）。よって、想定されるデータ収集時間によっては、データ収集のための一周期の時間長を短くし得る。換言すれば、依り多くのデータ（アソシエーションデータのエントリ）を収集し得る。
【００５１】
なお、上記の説明では、収集サーバ１０Ａが各プロセスに対するＡＰ１２の割り当てを実施しているように説明した。もっとも、各収集サーバ１０Ａの各プロセスに対すＡＰ１２の割り当てが、図７において図示しない収集管理サーバ１１にて実施されるようにしても良い。この場合、収集管理サーバ１１における割り当て結果が各収集サーバ１０Ａに通知され、各収集サーバ１０Ａが、割り当て結果に従ってデータ収集を行う。
【００５２】
図８は、実施形態のデータ収集方法を、第１の方法の説明に用いた第２のケースに当てはめた例を示す。図８に示すように、収集サーバ１０Ａが、想定されたデータ収集時間の長い順にＡＰを選択する。これによって、図８に示すように、平日の昼間の時間帯であっても、平日の夜間の時間帯又は休日であっても、複数のＡＰ１２からのデータ収集が一周期の時間内に終えられるようにＡＰの割り当てがなされる。
【００５３】
さらに、実施形態によるデータ収集方法によれば、図８に示すように、収集サーバ１０Ａに関して、平日の昼間の時間帯に実施するデータ収集の負荷と、平日の夜間の時間帯や休日に実施するデータ収集の負荷とを同程度にすることができる。このように、データ収集処理が、複数の収集サーバ１０Ａに効率的に割り当てられることによって、データ収集に要する収集サーバ１０Ａの数を削減できる。換言すれば、収集サーバの規模を小さくし、維持管理に係るコストを抑えることができる。
【００５４】
＜データ収集システムの構成例＞
図９は、実施形態に係るデータ収集システムの構成例を模式的に示す。図９において、データ収集システムは、収集管理サーバ１１Ａと、収集管理サーバ１１Ａにネットワークを介して接続された複数の（ｍ個の：ｍは正の整数）収集サーバ１０Ａ（＃１〜＃ｍ）とを含んでいる。また、データ収集システムは、各収集サーバ１０Ａにネットワークを介して接続された複数の（ｎ個の：ｎは正の整数）ＡＰ１２（＃１〜＃ｎ）を含んでいる。
【００５５】
ＡＰ１２は、アクセスポイントメイン機能（メイン機能）１２１と、情報管理部１２２と、収集情報テーブル１２３と、情報伝達部１２４５とを含んでいる。メイン機能１２１は、無線電波の放射により無線エリア（セル）を形成し、無線エリアに報知情報を送信する。無線エリア内に存在し、報知情報を受信する無線端末１３は、ＡＰ１２との通信を行うために、報知情報を用いてＡＰ１２と無線端末１３との間でアソシエーションを確立する手続を行い、アソシエーションを確立する。
【００５６】
情報管理部１２２は、無線端末１３からのアクセスによって得られた情報を、その都度、収集情報テーブル１２３に蓄積し、管理する。例えば、情報管理部１２２は、無線端末１３とのアソシエーション（無線端末１３との接続）の確立によって生成されるアソシエーションデータを、収集情報テーブル１２３に格納する。
【００５７】
収集情報テーブル１２３は、図３に示したテーブル１４と同じものであり、例えば、アソシエーションを確立した無線端末１３毎に、無線端末１３のＭＡＣアドレスと、当該無線端末１３の端末接続時間とを含むエントリを記憶する。情報管理部１２２は、収集情報テーブル１２３に対するアソシエーションデータの書き込み、更新、削除を行う。情報管
理部１２２は、上述したエージング処理を行う。また、収集情報テーブル１２３のエントリ登録数が上限に達したときに、古いエントリから順に上書きを行う。
【００５８】
情報伝達部１２４は、収集サーバ１０Ａからのポーリングに応じて、収集情報テーブル１２３に記憶（蓄積）されているアソシエーションデータを読み出して収集サーバ１０Ａに送信する。
【００５９】
収集サーバ１０Ａは、情報取得部１０１と、情報蓄積部１０２とを含む。情報取得部１０１は、予め定められたデータ収集のための一周期（「ポーリング周期」とも呼ぶ）にて、複数のＡＰ１２（＃１〜＃ｎ）について、想定されたデータ収集時間が長い順に、複数のプロセス１〜５にＡＰ１２を割り当てて、ポーリング（アクセス）を行い、アソシエーションデータを収集する。収集サーバ１０Ａは、複数のＡＰ１２へのアクセスを、収集管理サーバ１１Ａで管理される収集対象ＡＰ一覧テーブル１１２に基づいて行う。情報取得部１０１は、「取得部」の一例である。
【００６０】
情報蓄積部１０２は、情報取得部１０１によって取得されたアソシエーションデータを、収集管理サーバ１１Ａへ送信する。アソシエーションデータは、収集管理サーバ１１Ａに含まれる情報蓄積テーブル１１３にて保管される。
【００６１】
収集管理サーバ１１Ａは、収集時間管理部１１１と、収集対象ＡＰ一覧テーブル１１２（以下、リスト１１２と表記）と、情報蓄積テーブル１１３とを含む。収集時間管理部１１１は、ＡＰ１２毎に想定されたデータ収集時間をリスト１１２に予め設定する。リスト１１２は、「管理部」の一例であり、情報蓄積テーブル１１３は、「蓄積部」の一例である。
【００６２】
リスト１１２には、例えば、ＡＰ１２の識別子と、ＡＰ１２について想定されるデータ収集時間（想定時間）と、データの収集済か未収集かを示すステータスとが記憶される。想定時間は、例えば、データ収集システムの管理者が、実験や、過去の実績値の統計処理などを通じて得た想定時間が設定される。収集サーバ１０Ａの情報取得部１０１は、収集管理サーバ１１Ａのリスト１１２にアクセスし、ＡＰ１２のアクセス順（ポーリング順）を決定する。情報蓄積テーブル１１３には、各収集サーバ１０Ａで収集されたデータが各収集サーバ１０Ａから受信されて蓄積される。複数のプロセス１〜５に対するＡＰ１２の割り当ては、例えば、プロセス１→２→３→４→５→１．．．のラウンドロビンで行われる。
【００６３】
図１０は、収集管理サーバ１１Ａのハードウェア構成例を示す。収集管理サーバ１１Ａとして、例えば、パーソナルコンピュータ（ＰＣ），ワークステーション（ＷＳ）のような汎用コンピュータを適用できる。或いは、収集管理サーバ１１Ａとして、サーバマシンのような専用のコンピュータを適用することもできる。
【００６４】
図１０に示すように、収集管理サーバ１１Ａは、例えば、バスを介して相互に接続された、Central Processing Unit（ＣＰＵ）２１と、メモリ２２と、記憶媒体２３と、回線
インタフェース（回線Ｉ／Ｆ）２４とを含む。メモリ２２は、主記憶装置として使用され、プログラムの展開領域，ＣＰＵ２１の作業領域，データのバッファ（記憶）領域として使用される。メモリ２２は、例えばRandom Access Memory（ＲＡＭ），或いはＲＡＭとRead Only Memory（ＲＯＭ）との組み合わせで形成される。
【００６５】
記憶媒体２３は、補助記憶装置として使用される。補助記憶装置は、例えば、ハードディスクドライブ（ＨＤＤ），Solid State Drive（ＳＳＤ），フラッシュメモリ，Electrically Erasable Programmable Read-Only Memory（ＥＥＰＲＯＭ）などの不揮発性記憶媒
体で形成される。記憶媒体２３は、データやプログラムの記憶領域として使用される。メモリ２２及び記憶媒体２３の少なくとも一方には、上述したリスト１１２，情報蓄積テーブル１１３が記憶される。  
【００６６】
回線インタフェース２４は、ネットワークに接続され、収集管理サーバ１１Ａと各収集サーバ１０Ａとの通信を司る。回線インタフェース２４として、例えば、Local Area Network（ＬＡＮ）カードやネットワークインタフェースカード（ＮＩＣ）と呼ばれる通信インタフェースカードを適用できる。
【００６７】
ＣＰＵ２１は、プロセッサの一例であり、記憶媒体２３に記憶されたプログラムをメモリ２２にロードして実行する（メモリ２２に含まれるＲＯＭに記憶されたプログラム（ファームウェア）を実行する場合もある）。
【００６８】
これによって、ＣＰＵ２１は、図９に示した収集時間管理部１１１として動作する。収集時間管理部１１１としての動作において、ＣＰＵ２１は、回線インタフェース２４を用いて収集サーバ１０Ａと通信する。
【００６９】
図１１は、収集サーバ１０Ａのハードウェア構成例を示す。収集サーバ１０Ａとして、例えば、上述したＰＣ，ＷＳ，サーバマシンなどを適用可能である。図１１に示すように、収集サーバ１０Ａは、バスを介して相互に接続されたＣＰＵ３１と、メモリ３２と、記憶媒体３３と、回線インタフェース（回線Ｉ／Ｆ）３４とを含む。
【００７０】
メモリ３２，記憶媒体３３，回線インタフェース３４の機能は、メモリ２２，記憶媒体３３，回線インタフェース２４と同様である。メモリ２２，記憶媒体２３，回線インタフェース２４について説明したものと同様のものをメモリ３２，記憶媒体３３，回線インタフェース３４として適用可能である。
【００７１】
ＣＰＵ３１は、プロセッサの一例であり、記憶媒体３３に記憶されたプログラムをメモリ３２にロードして実行する（メモリ３２に含まれるＲＯＭに記憶されたプログラム（ファームウェア）を実行する場合もある）。
【００７２】
これによって、ＣＰＵ３１は、図９に示した情報取得部１０１及び情報蓄積部１０２として動作する。情報取得部１０１及び情報蓄積部１０２のそれぞれとしての動作において、ＣＰＵ３１は、回線インタフェース３４を用いてＡＰ１２、或いは収集管理サーバ１１Ａと通信する。また、ＣＰＵ３１は、上記した複数のプロセス（プロセス１〜５）の生成、及びプロセス１〜５によるデータ収集を行う。ＣＰＵ３１は、プロセス１〜５に対してＡＰ１２を割り当て、各プロセスにＡＰ１２からのデータ収集を行わせる。  
【００７３】
図１２は、アクセスポイント（ＡＰ）１２のハードウェア構成例を示す。図１２に示すように、ＡＰ１２は、バスを介して相互に接続されたＣＰＵ４１と、メモリ４２と、記憶媒体４３と、回線インタフェース（回線Ｉ／Ｆ）４４と、無線インタフェース４５を含む。
【００７４】
メモリ４２，記憶媒体４３，回線インタフェース４４の機能は、メモリ２２，記憶媒体３３，回線インタフェース２４と同様である。メモリ２２，記憶媒体２３，回線インタフェース２４について説明したものと同様のものをメモリ４２，記憶媒体４３，回線インタフェース４４として適用可能である。メモリ４２及び記憶媒体４３の少なくとも一方に、収集情報テーブル１２３が記憶される。
【００７５】
無線インタフェース４５は、無線端末１３との無線通信を司る。無線インタフェース４
５は、例えば、データとベースバンド信号との間の変換処理を行うベースバンド回路と、ベースバンド信号と無線信号との変換処理を行うRadio Frequency（ＲＦ）回路と、アン
テナとを含む。
【００７６】
ＣＰＵ４１は、プロセッサの一例であり、記憶媒体４３、或いはメモリ４２のＲＯＭに記憶されたプログラムをメモリ４２にロードして実行する。これによって、ＣＰＵ４１は、図９に示したメイン機能１２１，情報管理部１２２，情報伝達部１２４として動作することができる。
【００７７】
メイン機能１２１として動作するＣＰＵ４１は、例えば、無線インタフェース４５の動作を制御し、無線インタフェース４５から電波を放射させて無線エリアを形成し、報知情報を送信して、無線端末１３からの接続要求（アソシエーションの確立要求）を待つ。報知情報を受信した無線端末１３からの接続要求が受信されると、アソシエーションの確立手続を無線端末１３との間で確立する。確立後に、無線端末１３との間で無線を用いたデータ通信を行う。
【００７８】
情報管理部１２２として動作するＣＰＵ４１は、アソシエーションが確立された無線端末１３のＭＡＣアドレスと端末接続時間とを収集情報テーブル１２３に記憶する。情報伝達部１２４として動作するＣＰＵ４１は、回線インタフェース４４を用いて収集サーバ１０Ａと通信する。
【００７９】
なお、ＣＰＵ２１，ＣＰＵ３１，ＣＰＵ４１で実行される処理の少なくとも一部は、ハードウェアを用いて実行されるようにしても良い。ハードウェアは、Field Programmable
Gate Array（ＦＰＧＡ）のようなプログラマブルロジックデバイス（ＰＬＤ）や、集積
回路（ＩＣ，ＬＳＩ，Application Specific Integrated Circuit（ＡＳＩＣ））を含む
。
【００８０】
図１３は、収集対象ＡＰ一覧テーブル１１２（リスト１１２）のデータ構造例を示す。図１３において、リスト１１２は、平日用の収集対象ＡＰ一覧テーブル（リスト）１１２ａと、休日用の収集対象ＡＰ一覧テーブル（リスト）１１２ｂと、特殊指定の収集対象ＡＰ一覧テーブル（リスト）１１２ｃとを含んでいる。なお、リスト１１２は、収集管理サーバ１１ＡにおけるＤＢ１１ａ内に保持されることができる。
【００８１】
リスト１１２ａ，及びリスト１１２ｂは、同じデータ構造を有している。すなわち、各リストは、当日（平日又は休日）における「収集周期」と、「ＡＰ番号」と、「想定収集時間」と、「実収集時間」と、「実施状況」とを含む１以上のレコード（エントリ）を記憶する。
【００８２】
「収集周期」として、データ収集の一周期の開始時刻が記憶される。一周期の時間長は予め決められている。例えば一周期の時間長は５分に設定されるが、時間長は適宜設定可能である。「ＡＰ番号」は、ＡＰ１２の固有の識別情報である。
【００８３】
「想定収集時間」は、ＡＰ番号で特定されるＡＰ１２からデータを収集するのに要すると想定された時間を示す。想定収集時間として、例えば、データ収集システムの管理者、或いは保守者によって決められた値が設定される。「実収集時間」は、実際のデータ収集において要した時間が記憶される。「実施状況」は、収集周期で特定される一周期における、データ収集の実施状況を示す。実施形態では、実施状況として、データ収集が実施されていないことを示す「未実施」，データ収集中であることを示す「収集中」，及びデータ収集が終了していることを示す「収集済」の何れかのステータスが設定される。
【００８４】
リスト１１２ａ，リスト１１２ｂのそれぞれには、当日に実施される複数回の収集周期に対応するレコード（エントリ）が記憶される。これに対し、リスト１１２ｃには、「収集周期日時」として、イベントの開始時刻などが記憶される。もっとも、リスト１１２ｃでも、１つのレコード（エントリ）が「ＡＰ番号」と、「想定収集時間」と、「実収集時間」と、「実施状況」とを含む点はリスト１１２ａ，１１２ｂと同じである。
【００８５】
図１４は、ＡＰ＃２に対するエントリをリスト１１２ａ及びリスト１１２ｂに追加する例を示す。この場合、図１４に示すように、収集時間管理部１１１は、リスト１１２ａ及びリスト１１２ｂに、収集周期，ＡＰ番号，想定収集時間，実収集時間（初期値として、例えば想定収集時間と同値を設定），及び実施状況を設定する。
【００８６】
図１５は、リスト１１２ｃに対し、ＡＰ＃２に係るエントリが記憶（登録）された例を示す。リスト１１２ｃには、イベントが発生する地域、時刻（或る地域で或る時間に発生するイベント）を予め考慮した想定収集時間が設定される。
【００８７】
図１５に示すように、例えばＡＰ＃２が存在する地域において、２０１４年１２月３１日の２３：５５から２０１５年１月１日の０：００の間、イベントにより無線端末１３の利用者が増える場合には、想定収集時間を含むエントリをリスト１１２ｃに設定する。  
【００８８】
図１６は、各収集サーバ１０Ａの情報取得部１０１（ＣＰＵ３１）が行う処理例を示すフローチャートである。図１６の処理は、データ収集の周期に合わせて周期的に起動する。
【００８９】
０１では、情報取得部１０１は、収集管理サーバ１１Ａが有する収集対象ＡＰ一覧テーブル１１２（リスト１１２）から「想定収集時間」の大きいＡＰ１２を検索する。０１において、情報取得部１０１は、リスト１１２の検索に際し、収集日（当日）が平日か休日かで検索対象のリストを、リスト１１２ａとリスト１１２ｂから使い分ける。但し、検索は、リスト１１２ｃも含めて行う。
【００９０】
検索条件としては、収集周期の時刻が現在時刻の周期であり、実施状況が「未収集」で、想定収集時間が最も大きいものが検索される。このとき、特殊指定（リスト１１２ｃ）からは、現在時刻の条件に一致するエントリの有無が検索される。
【００９１】
０２では、情報取得部１０１は、検索結果（検索条件に合致するエントリ）が得られたか否かを判定する。検索結果が得られなかった場合（０２，ＮＯ）、すなわち、当該収集周期でデータを収集するＡＰ１２が無くなった場合には、図１６の処理を終了する。検索結果がある場合には（０２，ＹＥＳ）、処理が０３に進む。
【００９２】
０３では、情報取得部１０１は、リスト１１２から検索されたエントリに「収集中」を設定する。０４では、情報取得部１０１は、検索されたエントリに含まれたＡＰ番号を有するＡＰ１２を、プロセスに割り当てる。情報取得部１０１は、複数のプロセス１〜５を管理しており、０３で検索されたエントリで特定されるＡＰ１２を、次にＡＰ１２が割り当てられるプロセスに割り当てる。ＡＰ１２が割り当てられたプロセスは、割り当てられたＡＰ１２にアクセスし、収集情報テーブル１２３に蓄積されているデータを取得する。
【００９３】
０５では、情報取得部１０１は、データ収集が愁傷すると、検索したエントリ中の実施状況に「収集済」を設定するとともに、実際のデータ収集時間をエントリ中の「実収集時間」に設定する。
【００９４】
０６では、情報取得部１０１は、リスト１１２における、０１で検索されたエントリ中
の収集状況を「未収集」に設定する。これは、次回の同一時間帯におけるデータ収集のために、予め収集状況が「未収集」に設定される。０７では、情報取得部１０１は、想定時間決定処理（サブルーチン）を行い、処理を０１に戻す。
【００９５】
図１７は、想定時間決定処理の一例を示すフローチャートである。図１７における０７ａの処理では、情報取得部１０１は、今周期の「実収集時間」を、次周期の「想定収集時間」に設定する。例えば、図１７に示すように、周期が５分毎に開始され、００：０５に開始される周期のエントリ（エントリ１とする）と、００：１０に開始される周期のエントリ（エントリ２とする）とがあると仮定する。
【００９６】
エントリ１において、想定収集時間が１０秒（１０ｓ）に設定されている一方で、実収集時間が５秒（５ｓ）であった場合には、情報取得部１０１は、今周期の実収集時間を、次周期のエントリ２の想定収集時間に設定する。０７ａの処理は、「或る一周期における実際のデータ収集時間を、次回の一周期について想定されたデータ収集時間として用いる」ことの一例である。
【００９７】
今周期と次周期との間において、ＡＰ１２の無線エリアに存在する無線端末１３の数に大きな差はないと考えられる場合に、０７ａの処理が実行される。これによって、想定収集時間を実際に近づけることができ、ＡＰの選択順序を正確に行うことが可能となる。
【００９８】
図１８は、想定時間決定処理の他の一例を示すフローチャートである。図１８における０７ｂの処理では、情報取得部１０１は、次周期の月曜日から金曜日までの「実収集時間」の平均を、次周期の「想定収集時間」に設定する。
【００９９】
例えば、図１８に示すように、リスト１１２のエントリには、月曜日から金曜日までの実収集時間が記憶される。図１８の例では、実収集時間は曜日毎に管理される。情報取得部１０１は、０７ｂの処理において、実収集時間の平均値を算出し、平均値を次周期の「想定収集時間」に設定する。これによって、今周期の実収集時間が特異値であった場合の影響を小さくすることができる。０７ｂの処理は、「過去の２以上の周期における前記複数の対象装置のデータ収集時間を統計処理した結果に基づき想定されたデータ収集時間を、次回の一周期について想定されたデータ収集時間として用いる」ことの一例である。
【０１００】
或いは、他の想定収集時間の設定処理として、先週得られた、次周期と同じ時間帯の実収集時間を次周期の想定収集時間として設定することが考えられる。これら以外の手法用いて想定された収集時間が想定収集時間として設定されても良い。
【０１０１】
０７ａ又は０７ｂで想定収集時間が設定されると、エントリの情報が収集サーバ１０Ａから収集管理サーバ１１Ａに送信される。収集時間管理部１１１（ＣＰＵ２１）が、当該エントリをリスト１１２に記憶する。０７の処理が終了すると、処理が０１に戻り、次のＡＰ１２が決定される。
【０１０２】
＜実施形態の作用効果＞
情報取得部１０１は、図１６に示した処理を繰り返し、リスト１１２中の今周期のエントリに登録された全てのＡＰ１２に対するデータ収集を、ＡＰ１２に対応する想定収集時間の長い順に行う。このように、情報取得部１０１は、「各対象装置について想定されたデータ収集時間の長い順に、前記複数のプロセスに対してアクセスする対象装置を割当てて、前記データを取得する取得部」の一例である。
【０１０３】
実施形態によれば、上述したデータ収集が行われることで、一周期内においてデータを収集する複数のＡＰ１２の全てからデータを収集し終えることができる。すなわち、一周
期内に複数の対象装置からの情報収集を終えることができる。このため、第１の方法や第２の方法について説明したような、収集サーバの増強を回避して無駄なリソースや設備が生じるのを抑えることができる。
【０１０４】
例えば、第１の方法であると、図５に示したように、郊外と都心とのそれぞれでピークの情報量を考慮した収集サーバ１０が配備される。これに対し、実施形態のデータ収集方法によれば、郊外及び都心のトータルでのピークの時間帯の情報量を処理可能な収集サーバ１０Ａを設置することで、処理の効率化を図り、設置数を抑えることができる（図８）。
【０１０５】
さらに、リスト１１２ｃに対し、或る地域で或る時間に生じるイベントに基づき想定されたデータ収集時間としての想定収集時間を含むエントリが登録（記憶）され、データ収集対象のＡＰ１２の検索に使用される。これによって、不定期のイベントによる無線端末１３の数の増加に合わせたデータ収集が可能となり、取得漏れを抑えることができる。
【０１０６】
例えば、図１９に示すように、イベントの発生する周期において、イベント会場内にあるＡＰ１２（ＡＰ１２ｘとする）に対し、比較的長い想定収集時間を設けておき、一周期内にＡＰ１２ｘに蓄積された大量のデータを収集する時間が確保できるようにする。
【０１０７】
なお、実施形態では収集管理サーバ１１Ａがリスト１１２を一元管理しているが、各収集サーバ１０Ａが、データ収集対象のＡＰ１２についてのリストを個別に有していても良い。また、各収集サーバ１０における複数のプロセスに対するＡＰ１２の割り当てが、例えば、データ収集装置以外の装置、例えば収集管理サーバ１１Ａで行われても良い。このとき、収集管理サーバ１１Ａ（データ収集装置以外の装置の一例）は、複数の収集サーバ１０のうちの一部に対する割り当てを行っても良く、複数の収集サーバ１０の全てに対する割り当てを行っても良い。この場合、収集サーバ１０では、例えばＣＰＵ３１が、収集管理サーバ１１Ａでの割り当て結果を参照し、収集サーバ１０の各プロセスにＡＰ１２を割り当てて、各プロセスが自身に割り当てられたＡＰ１２からデータを取得する。以上説明した実施形態の構成は、適宜組み合わせることができる。
【符号の説明】
【０１０８】
１０Ａ・・・収集サーバ
１１Ａ・・・収集管理サーバ
１２・・・アクセスポイント
１３・・・無線端末
２１，３１・・・ＣＰＵ
２２，３２・・・メモリ
２３，３３・・・記憶媒体
１０１・・・情報取得部
１１１・・・収集時間管理部
１１２・・・収集対象ＡＰ一覧テーブル
【図９】
2017069661.tif 000003
【図１０】
2017069661.tif 000004
【図１２】
2017069661.tif 000005
【図１６】
2017069661.tif 000006
【図１】
2017069661.tif 000007
【図２】
2017069661.tif 000008
【図３】
2017069661.tif 000009
【図４】
2017069661.tif 000010
【図５】
2017069661.tif 000011
【図６】
2017069661.tif 000012
【図７】
2017069661.tif 000013
【図８】
2017069661.tif 000014
【図１１】
2017069661.tif 000015
【図１３】
2017069661.tif 000016
【図１４】
2017069661.tif 000017
【図１５】
2017069661.tif 000018
【図１７】
2017069661.tif 000019
【図１８】
2017069661.tif 000020
【図１９】
2017069661.tif 000021