JP6261389B2 - データ送信装置及びデータ送信方法及びプログラム - Google Patents

Description

本発明は、データを送信する技術に関する。

ＩＤ（Ｉｄｅｎｔｉｔｙ）管理システムは、複数のテナントから利用され、人事情報などの変更により、入退室機器に対し、変更された情報を配信する。
また、入退室機器から通行履歴を取得し、保管する。
ＩＤ管理システムの稼動後に特定のテナントＡで障害が発生した場合など、試験用のテナントＢを用いるなどして、テナントＡに関する多量の通行履歴を再現し、障害を確認する。
試験データの投入にあたっては、ＩＤ管理システムのＤＢに対して直接通行履歴のデータを与える方式や、ユーザ通行操作をシミュレートしてＩＤ管理システムのＤＢにシミュレーションにより得られた通行履歴のデータを投入する方式がある。
前者の方式は、後者に比べ迅速にデータの作成ができるが、ＤＢの設計情報が必要であったり、サービスの設計者の意図しないようなデータを投入できるなどするため、実際に試験を行い始めてから、データの問題に気づくなどして、手戻りが発生しやすい。
後者の方式は、前者に比べユーザ通行操作のシミュレーションを行う時間がかかるが、サービスの設計者の意図しないデータが投入されないため、前者で発生する手戻りは発生しない。
本明細書は、後者のシミュレーションによる通行履歴データの投入を対象にする。

特開２００４−３２６３８６号公報

特許文献１では、データを高速に投入し続け、試験対象システムにおいて、エラーが発生するようになると、データ投入速度を自動的に落とす方式が示されている。
この方式を前述のＩＤ管理システムに適用した場合は、シミュレーションによる試験用の通行履歴データの投入負荷により、エラーが発生する直前の高負荷状態になりうる。
ＩＤ管理システムでは、障害が発生していないテナントに対するデータ処理を継続させながら、シミュレーションによる試験用の通行履歴データの投入を行うため、特許文献１の方式によれば、試験用の通行履歴データの投入により、障害が発生していないテナントに対するサービスレベルの低下を引き起こす可能性がある。

本発明は、このような事情に鑑みたものであり、サービスレベルの低下を伴わずに、データを送信することを主な目的とする。

本発明に係るデータ送信装置は、
データ処理が行われるデータ処理装置にデータを送信するデータ送信装置であって、
前記データ処理装置においてデータ処理が行われないと推測される推測空き時間を抽出する推測空き時間抽出部と、
前記推測空き時間抽出部により抽出された推測空き時間に、前記データ処理装置へのデータ送信を行うデータ送信部とを有することを特徴とする。

本発明によれば、データ送信先であるデータ処理装置でデータ処理が行われないと推測される推定空き時間においてデータ送信を行うため、データ処理装置におけるサービスレベルを低下させることがない。

実施の形態１に係るシステム構成例を示す図。 実施の形態１に係るテナント優先度管理テーブルの例を示す図。 実施の形態１に係る受信履歴管理テーブルの例を示す図。 実施の形態１に係る配信履歴管理テーブルの例を示す図。 実施の形態１に係るテナント情報管理テーブルの例を示す図。 実施の形態１に係るデータ管理テーブルの例を示す図。 実施の形態１に係るデータ管理テーブルの例を示す図。 実施の形態１に係るテナント−ユーザＩＤ−カード管理テーブルの例を示す図。 実施の形態１に係るデータ投入システムのハードウェア構成例を示す図。 実施の形態１に係るＩＤ管理部の動作例を示すフローチャート図。 実施の形態１に係るテナント情報管理部の動作例を示すフローチャート図。 実施の形態１に係るデータ投入速度制御部の動作例を示すフローチャート図。 実施の形態１に係るデータ投入部の動作例を示すフローチャート図。 実施の形態１に係るデータ管理部の動作例を示すフローチャート図。 実施の形態１に係る応答時間記録部の動作例を示すフローチャート図。 実施の形態１に係る入力部の動作例を示すフローチャート図。 実施の形態１に係るデータ投入完了予測部の動作例を示すフローチャート図。 実施の形態１に係るデータ出力部の動作例を示すフローチャート図。 実施の形態１に係るデータ入力部の動作例を示すフローチャート図。

実施の形態１．
図１は、本実施の形態に係るシステム構成例を示す。

図１において、ＩＤ管理システム００は、入退室機器２１に接続され、複数のテナントにおける通行履歴データを管理する。
ＩＤ管理システム００は、データ処理装置の例に相当する。
データ投入システム１０は、ＩＤ管理システム００が管理対象としているいずれかのテナントにおいて障害が発生した場合に、障害の解析のためのテストデータをＩＤ管理システム００に送信する。
データ投入システム１０は、データ送信装置の例に相当する。
また、入退室機器２１は、カードＩＤによって通行の許可あるいは不許可を判定する機器である。

ここで、ＩＤ管理システム００及びデータ投入システム１０の詳細構成を説明する前に、ＩＤ管理システム００及びデータ投入システム１０の動作の概要を説明する。

ＩＤ管理システム００が管理対象としているいずれかのテナントにおいて障害が発生すると、データ投入システム１０は、ＩＤ管理システム００がデータ処理を行っていないと推定される時間（推定空き時間）を抽出し、推定空き時間に、障害の解析のためのテストデータをＩＤ管理システム００に送信する。
データ投入システム１０がＩＤ管理システム００に送信するテストデータは、入退室機器２１からＩＤ管理システム００に送信される通行履歴データを模擬したデータである。
ＩＤ管理システム００は、データ投入システム１０から送信されたデータをＤＢに格納して、障害の原因を解析する。

また、データ投入システム１０は、データ投入が完了するまでに要すると予測される投入完了予測時間（送信完了所要時間）を算出し、算出した投入完了予測時間をデータ投入システム１０のオペレータに提示する。
データ投入システム１０のオペレータは、データ投入システム１０に対して投入完了予測時間の繰り上げを指示することができる。
繰り上げの指示方法としては、繰り上げる時間である繰り上げ指示時間を指定し、繰り上げ指示時間分の繰り上げを指示する方法と、繰り上げ指示時間を指定しないで繰り上げを指示する方法がある。
前者の方法により繰り上げが指示された場合は、データ投入システム１０は、投入完了予測時間と、繰り上げ指示時間と、ＩＤ管理システム００への未送信データのデータ量とに基づき、データの投入間隔（送信間隔）を算出する。
そして、データ投入システム１０は、推測空き時間でのデータ送信を停止し、ＩＤ管理システム００におけるデータ処理の実行有無に関わらず、算出した投入間隔で、ＩＤ管理システム００へのデータ送信を行う。
また、後者の方法により繰り上げが指示された場合は、データ投入システム１０は、閾値以下の優先度のデータ処理、換言すれば、低優先度のテナントに関するデータ処理のみが行われていると推測される時間（推測低優先度処理時間）を抽出する。
そして、データ投入システム１０は、推測空き時間及び推測低優先度処理時間に、ＩＤ管理システム００へのデータ送信を行う。

次に、図１に示すＩＤ管理システム００とデータ投入システム１０の構成要素を説明する。

ＩＤ管理システム００において、ＩＤ管理部０１は、ユーザの通行権限の変更に際して、入退室機器２１に変更データを送信し、かつ、ユーザが入退室機器２１を通行した際に通行履歴を受信する。

テナント−ユーザＩＤ−カード管理テーブル記憶部０２は、テナント−個人ＩＤ−カード管理テーブルを記憶する。
テナント−個人ＩＤ−カード管理テーブルは、ユーザＩＤとカードＩＤと入退室機器を管理するテーブルである。
以下では、テナント−個人ＩＤ−カード管理テーブルをテナント−個人ＩＤ−カード管理テーブル０２０と表記する。

受信履歴管理テーブル記憶部０３は、受信履歴管理テーブルを記憶する。
受信履歴管理テーブル記憶部０３は、ＩＤ管理システム００のオペレータからの指示（例えばユーザの通行権限の変更データを）を入力部０７から受信し、あるいは、入退室機器２１から通行履歴データを受信し、指示の受信履歴及び通行履歴データの受信履歴を受信履歴管理テーブルに書き込む。
以下では、受信履歴管理テーブルを受信履歴管理テーブル０３０と表記する。

配信履歴管理テーブル記憶部０４は、配信履歴管理テーブルを記憶する。
配信履歴管理テーブルは、入退室機器２１に対してユーザの通行権限の変更データを配信した履歴が示されるテーブルである。
以下では、配信履歴管理テーブルを配信履歴管理テーブル０４０と表記する。

テナント情報管理部０５は、テナント情報管理テーブル記憶部０６に記憶されているテナント情報管理テーブルに、テナントの受信や配信のジョブごとに開始時刻と終了時刻を書き込む。
以下では、テナント情報管理テーブルをテナント情報管理テーブル０６０と表記する。
また、テナント情報管理部０５は、データ投入システム１０のデータ投入速度制御部１６から問合せがあった場合に、データ投入速度制御部１６から問合せのあった時刻におけるＩＤ管理システム００のデータ処理実績を解析する。
また、テナント情報管理部０５は、テナント情報管理テーブル０６０及びテナント優先度管理テーブル記憶部０８に記憶されているテナント優先度管理テーブルを参照して、問合せのあった時刻における優先度別のＩＤ管理システム００のデータ処理実績を解析する。
そして、テナント情報管理部０５は、解析結果をデータ投入速度制御部１６に応答する。

テナント優先度管理テーブル記憶部０８は、テナント優先度管理テーブルを記憶する。
テナント優先度管理テーブルは、テナントごとの優先度を管理する。
以下では、テナント優先度管理テーブルをテナント優先度管理テーブル０８０と表記する。

入力部０７は、ユーザの通行権限を設定する。

次に、データ投入システム１０において、データ投入部１１は、入退室機器２１とＩＤ管理部０１間の通信プロトコルを利用して、入退室機器２１の通行履歴データを模擬したテストデータを、ＩＤ管理部０１に送信する。
また、データ投入部１１は、投入したデータに対するＩＤ管理部０１の応答時間を計測する。
データ投入部１１は、データ送信部の例に相当する。

データ管理部１２は、データ投入部１１からの要求を受けて、データ管理テーブル記憶部１３内のデータ管理テーブルを参照し、データ管理テーブルから順にレコードを取り出し、データ投入部１１に渡す。
データ管理部１２は、入退室機器２１の通行履歴データを模擬したテストデータを、データ投入部１１に渡す。
以下では、データ管理テーブルをデータ管理テーブル１３０と表記する。

応答時間記録部１４は、ＩＤ管理部０１からの応答時間をデータ管理テーブル記憶部１３のデータ管理テーブル１３０に記録する。

データ投入完了予測部１５は、投入完了予測時間を算出し、投入完了予測時間とデータの投入開始時刻からデータの投入完了時刻を予測し、また、投入完了予測時刻に対するオペレータからの繰り上げ指示を受け取る。
データ投入完了予測部１５は、繰り上げ指示時間を指定されてオペレータから繰り上げ指示を受けた場合は、投入完了予測時間と、繰り上げ指示時間と、ＩＤ管理システム００への未送信データのデータ量とに基づき、データの投入間隔を算出する。
データ投入完了予測部１５は、送信完了時間算出部、繰り上げ指示取得部及び送信間隔算出部の例に相当する。

データ投入速度制御部１６は、障害が発生し、障害の解析のためにデータ投入部１１からＩＤ管理システム００にデータを投入する必要が生じた場合に、ＩＤ管理システム００のテナント情報管理部０５に空き時間の有無を問い合わせる。
具体的には、データ投入速度制御部１６は、過去に、現在時刻と同じ時刻においてＩＤ管理システム００でデータ処理が行われたか否かを問い合わせる。
そして、データ投入速度制御部１６は、テナント情報管理部０５からの応答に基づき、ＩＤ管理システム００でデータ処理が行われないと推測される推測空き時間を抽出する。
更に、データ投入速度制御部１６は、データ投入部１１に推測空き時間にＩＤ管理部０１へデータを送信するよう指示する。
また、データ投入完了予測部１５が繰り上げ指示時間を指定されずにオペレータから繰り上げ指示を受けた場合は、データ投入速度制御部１６は、過去に、現在時刻と同じ時刻においてＩＤ管理システム００で行われたデータ処理は低優先度のテナントに対するデータ処理のみであるか否かを問い合わせる。
データ投入速度制御部１６は、テナント情報管理部０５からの応答に基づき、優先度のデータ処理のみが行われると推測される推測低優先度処理時間を抽出する。
そして、データ投入速度制御部１６は、データ投入部１１に推測空き時間及び推測低優先度処理時間にＩＤ管理部０１へデータを送信するよう指示する。
また、データ投入速度制御部１６は、データ投入完了予測部１５から投入間隔を通知された場合は、データ投入部１１に、通知された投入間隔でデータを送信するよう指示する。
データ投入速度制御部１６は、推測空き時間抽出部の例に相当する。

データ出力部１７は、データ管理テーブル記憶部１３のデータ管理テーブル１３０を外部ファイルに出力する。
データ入力部１８は、外部ファイルを取り込み、データ管理テーブル１３０を構築する。

ＩＤ管理システム００では、ＩＤ管理部０１が入退室機器２１から通行履歴データを受信し、通行履歴データの受信履歴を受信履歴管理テーブル０３０に書き込む。
更に、ＩＤ管理部０１は、入力部０７がＩＤ管理システム００のオペレータから受け付けた指示内容を受信し、受信した指示内容を受信履歴管理テーブル０３０に書き込む。
例えば、テナントＡにおいて、ユーザ３０が入退室機器２１を通行できるように変更する場合は、入力部０７は、オペレータから、テナントＩＤ＝Ａ、ユーザＩＤ＝ユーザ３０、入退室機器＝入退室機器２１というデータを受け付ける。
図１６を用いて、入力部０７の動作を説明する。

入力部０７は、入力を待つ（Ｓ０７０１）。
入力部０７は、テナントＩＤ＝Ａ、ユーザＩＤ＝ユーザ３０、入退室機器ＩＤ＝入退室機器２１を受け取った場合に、これらをＩＤ管理部０１に渡す（Ｓ０７０２）。

図１０を用いて、ＩＤ管理部０１の動作を説明する。

ＩＤ管理部０１は、入力部０７より、テナントＩＤ＝Ａ、ユーザＩＤ＝ユーザ３０、入退室機器＝入退室機器２１を受け取る（Ｓ００１）。
ＩＤ管理部０１は、受け取ったデータを受信履歴管理テーブル０３０に出力する（Ｓ００２）。
この際に、新しく受信履歴管理テーブル０３０上にない、ジョブＩＤを生成する。
ジョブＩＤ＝１００００００１であって、現在時刻が“２０１３／１２／４（水）００：００：００”であれば、図３の受信履歴管理テーブル０３０の第１レコードのように出力する。
同様に、同じジョブが完了した時刻を第２レコードのように出力する。
次に、ＩＤ管理部０１は、ユーザＩＤ＝ユーザ３０に関連付けられたカードＩＤを、テナント−ユーザＩＤ−カード管理テーブル０２０（図８）で検索する（Ｓ００３）。
この結果、ＩＤ管理部０１は、カード３０を取得する。
次に、ＩＤ管理部０１は、指定された入退室機器＝入退室機器２１に、上記で検索されたカードＩＤ＝カード３０を配信する（Ｓ００４）。
これにより、入退室機器２１では、カード３０に対して通行許可を与える。
さらに、ＩＤ管理部０１は、配信履歴管理テーブル０４０に配信履歴を出力する（Ｓ００５）。
この際に、新しく配信履歴管理テーブル上にない、ジョブＩＤを生成する。
ジョブＩＤ＝２００００００１であって、時刻が“２０１３／１２／４（水）０１：００：００”であれば、図４の配信履歴管理テーブル０４０の第１レコードのように出力する。
同様に、同じジョブが完了した時刻を第２レコードのように出力する。

また、図１１を用いて、テナント情報管理部０５の動作を説明する。

テナント情報管理部０５は、入力や配信が行われた日、時刻をテナントごとに管理する。
テナント情報管理部０５は、受信履歴管理テーブル０３０（図３）を参照し、ジョブＩＤ順に処理する。
テナント情報管理部０５は、受信履歴管理テーブル０３０上で、ジョブＩＤの一致するレコードを抽出し、時刻をテナント情報管理テーブル０６０（図５）に出力する（Ｓ０５０１）。
例えば、図３のジョブＩＤ＝１０００００００１では、テナント情報管理部０５は、図５上の第１レコードのように出力する。
さらに、テナント情報管理部０５は、配信履歴管理テーブル０４０（図４）を参照し、ジョブＩＤの一致するレコードを抽出し、時刻をテナント情報管理テーブル０６０（図５）に出力する（Ｓ０５０２）。
例えば、図４のジョブＩＤ＝２０００００００１では、図５の第２レコードのように出力する。
ここでは、説明の便宜上、テナント情報管理部０５の動作として、入力部０７を介したオペレータからの指示の受信履歴及び配信履歴をテナント情報管理テーブル０６０に反映させる例のみを説明している。
しかしながら、テナント情報管理部０５は、入退室機器２１からの通行履歴データの受信履歴もテナント情報管理テーブル０６０に反映させる。
テナント情報管理テーブル０６０の各レコードは、ＩＤ管理部０１におけるデータ処理の実績を表している。

次に、テナント情報管理部０５は、データ投入速度制御部１６からの空き時間の問い合わせの有無を確認する（Ｓ０５０３）。
いずれかのテナントに障害が発生した場合に、データ投入速度制御部１６からの空き時間の問い合わせが発生する。

データ投入速度制御部１６から空き時間の問い合わせがあった場合（Ｓ０５０３でＹＥＳ）は、テナント情報管理部０５は、現在時刻をシステムから取得し、テナント情報管理テーブル０６０（図５）を検索し、現在時刻を含む時間帯を持つレコードがなければ、データ投入速度制御部１６にＯＫを返す。
現在時刻を含む時間帯を持つレコードがあれば、データ投入速度制御部１６にＮＧを返す（Ｓ０５０４）。
つまり、テナント情報管理テーブル０６０（図５）に現在時刻を含む時間帯を持つレコードがなければ、過去に現在時刻と同じ時刻にＩＤ管理部０１においてデータ処理が行わなかったことになる。
例えば、現在時刻が“００：００：０７”であれば、図５のテナント情報管理テーブル０６０の第１レコードとマッチするため、テナント情報管理部０５はデータ投入速度制御部１６にＮＧを返す。
また、例えば、現在時刻が“００：１６：００”であれば、図５のテナント情報管理テーブル０６０上でマッチしないため、テナント情報管理部０５はデータ投入速度制御部１６にＯＫを返す。
なお、テナント情報管理部０５が過去のどの程度の期間についてテナント情報管理テーブル０６０を検索するかについては、予めシステム管理者が設定しておく。
例えば、過去１年間にわたって現在時刻と同じ時刻にＩＤ管理部０１においてデータ処理が行われていなければ、ＯＫと応答するという運用が考えられる。

また、データ投入速度制御部１６から空き時間の問合せがない場合（Ｓ０５０３でＮＯ）は、テナント情報管理部０５は、データ投入速度制御部１６から低優先度処理時間の問合せの有無を確認する（Ｓ０５０５）。
データ投入速度制御部１６は、データ投入システム１０のオペレータから繰り上げ指示時間を指定されずに繰り上げ指示を受けた場合に、低優先度処理時間の問合せとして、過去に現在時刻と同じ時刻に行われたデータ処理が低優先度のテナントに対するデータ処理のみであるか否かを問い合わせる。

データ投入速度制御部１６から空き時間の問い合わせがあった場合（Ｓ０５０５でＹＥＳ）は、テナント情報管理部０５は、現在時刻をシステムから取得し、テナント情報管理テーブル０６０（図５）を検索し、現在時刻を含む時間帯を持つレコードがなければ、データ投入速度制御部１６にＯＫを返す。
現在時刻を含む時間帯を持つレコードがあれば、そのレコードが対象としているテナントの優先度が低優先度であれば、データ投入速度制御部１６にＯＫを返す。
そのレコードが対象としているテナントの優先度が高優先度であれば、データ投入速度制御部１６にＮＧを返す。
テナントの優先度が低優先度であるか高優先度であるかは、テナント優先度管理テーブル０８０（図２）を参照して判別する。
図２のテナント優先度管理テーブル０８０では、テナントＩＤ＝Ａが優先度が低く、テナントＩＤ＝Ｂが優先度が高い。
例えば、現在時刻が“１：３０：００”であれば、図５のテナント情報管理テーブル０６０上では第２レコードがマッチし、テナント情報管理部０５はデータ投入速度制御部１６にＮＧを返す。

次に、データ投入システム１０の動作例を説明する。
データ投入システム１０は、ＩＤ管理システム００に対し、データを投入し、完了予測を行って、オペレータに完了予測時刻を表示する。
さらに完了予測時刻の繰り上げ指示をオペレータから受け取り、データ投入速度を速めることが可能である。

図１２を用いて、データ投入速度制御部１６の動作を示す。

データ投入速度制御部１６は、データ投入完了予測部１５から、繰り上げ指示時間ｘ、投入間隔ｗを受け取ったか否かを判定する（Ｓ１２０１）。

データ投入完了予測部１５から繰り上げ指示時間ｘ及び投入間隔ｗのいずれも受け取っていない場合（Ｓ１２０１でＮＯ）は、データ投入速度制御部１６は、テナント情報管理部０５に、現在が空き時間であるかどうかを問い合わせる（Ｓ１２０２）。
この問合せに基づき、テナント情報管理部０５は、図１１のＳ０５０４の処理を行う。

Ｓ１２０１において、データ投入完了予測部１５から繰り上げ指示時間ｘ＝０を受け取った場合（ＹＥＳ、ｘ＝０）は、データ投入速度制御部１６は、テナント情報管理部０５に、現在が空き時間又は低優先度処理時間であるかどうかを問い合わせる（Ｓ１２０３）。
この問合せに基づき、テナント情報管理部０５は、図１１のＳ０５０６の処理を行う。

そして、データ投入速度制御部１６は、テナント情報管理部０５からの応答がＯＫであるかＮＧであるかを判定する（Ｓ１２０４）。
テナント情報管理部０５からの応答がＯＫである場合（Ｓ１２０４でＯＫ）は、データ投入速度制御部１６は、データ投入部１１を投入間隔０で起動する（Ｓ１２０５）。
つまり、データ投入速度制御部１６は、現在が推測空き時間又は推定低優先度処理時間であると判断する。
一方、テナント情報管理部０５からの応答がＮＧである場合（Ｓ１２０４でＮＧ）は、データ投入速度制御部１６は、処理をＳ１２０１に戻す。

また、Ｓ１２０１において、データ投入完了予測部１５から繰り上げ指示時間ｘ≠０及び投入間隔ｗを受け取った場合（ＹＥＳ、ｘ≠０、ｗ）は、データ投入速度制御部１６は、データ投入部１１を投入間隔ｗで起動する（Ｓ１２０６）。
この結果、データ投入部１１は、ＩＤ管理部０１におけるデータ処理の実行有無に関わらず、投入間隔ｗごとに一定周期でデータをＩＤ管理部０１に送信することになる。

次に、図１３を用いて、データ投入部１１の動作を示す。

データ投入部１１は、データ投入速度制御部１６により投入間隔ごとに起動される（Ｓ１３０１）。
データ投入速度制御部１６がデータ投入部１１を投入間隔０で起動する場合（図１２のＳ１２０５）は、待機時間なくＳ１３０２が実行される。
一方、データ投入速度制御部１６がデータ投入部１１を投入間隔ｗで起動する場合（図１２のＳ１２０６）は、投入間隔ｗごとに、Ｓ１３０２が実行される。

次に、データ投入部１１は、データ管理部１２から１件のデータをデータＩＤと共に取得し、ＩＤ管理部０１に送信し、ＩＤ管理部０１からの応答を待つ（Ｓ１３０２）。

ＩＤ管理部０１から応答があった場合に、データ投入部１１は、データ投入からＩＤ管理部０１からの応答を受信するまでの応答時間を計測し、応答時間記録部１４にデータＩＤと応答時間を渡す（Ｓ１３０３）。

以降、データ投入部１１は、Ｓ１３０１〜Ｓ１３０３の動作を繰り返し、ＩＤ管理部０１へのデータ投入を繰り返す。

なお、データ投入部１１は、所定の閾値時間が経過しても、ＩＤ管理部０１からの応答がない場合は、推測空き時間であっても、以降のデータ投入を停止する。
このような場合は、ＩＤ管理部０１が現在データ処理を行っているためにＩＤ管理部０１から応答が遅延していると推定することができるため、データ投入部１１は以降のデータ投入を停止することが望ましい。

次に、図１４を用いて、データ管理部１２の動作を説明する。

データ管理部１２は、データ投入部１１からのデータ取得要求を受けた場合（Ｓ１４０１でＹＥＳ）に、データ管理テーブル１３０（図６）を参照し、投入時刻が空のレコードの投入データをデータＩＤと共に返す。
図６の例では、データＩＤ＝００００００００００３のレコードを取得し、投入データ“カードＩＤ＝カード３０、入退室機器＝入退室機器２１、通行日時＝２０１３／１１／２１ １２：０１：００”をデータ投入部１１に返し、投入時刻列に現在時刻を記載する。

次に、図１５を用いて応答時間記録部１４の動作を説明する。

応答時間記録部１４は、データ投入速度制御部１６から平均応答時間などの問い合わせを受け取ったかを判定する（Ｓ１５０１）。
データ投入速度制御部１６から平均応答時間などの問い合わせを受け取っていない場合（Ｓ１５０１でＮＯ）は、応答時間記録部１４は、データ投入部１１から応答時間を渡される。
応答時間記録部１４は、データ投入部１１から渡された応答時間をデータ管理テーブル１３０に記載する（Ｓ１５０２）。
例えば、データＩＤ＝００００００００００３のデータの投入時刻が“２０１３／１２／３（火）００：１５：００”であり、応答時間が１分であった場合は、データ管理テーブル１３０は、図７のようになる。

一方、平均応答時間などの問い合わせを受け取った場合（Ｓ１５０１でＹＥＳ）は、応答時間記録部１４は、データ管理テーブル１３０の応答時間列を集計し、平均応答時間ｒを算出する（Ｓ１５０３）。
また、応答時間記録部１４は、残件数、データＩＤ＝００００００００１の投入時刻を求め、返す（Ｓ１５０３）。
平均応答時間ｒは以下のように算出する。
ｒ＝Σ（投入したデータの応答時間）／（投入済のデータ件数）
図７のデータ管理テーブル１３０では、平均応答時間ｒは次のようになる。
ｒ＝Σ１／３＝（１＋１＋１）／３＝１
また、残件数は、全データ件数と投入済のデータ件数の差分より算出する。
例えば、図７の例では、全データ件数は３０００件であり（末尾のデータのデータＩＤが０００００００３０００）、投入済みのデータ件数は３であるため、残件数は、３０００−３＝２９９７件として算出される。
以上より、応答時間記録部１４は、ｒ＝１分、残件数＝２９９７件、データＩＤ＝００００００００１の投入時刻は、“２０１３／１２／３（火）１１：５５：００“として返す。

次に、図１７を用いてデータ投入完了予測部１５の動作を説明する。

データ投入完了予測部１５は、テストデータ投入完了に要すると予測される投入完了予測時間ｄを算出する。
投入完了予測時間ｄは、次の数式により求める。
ｄ＝テストデータ全件数／（テストデータ投入済件数／テストデータ投入を行った時間）
図７のデータ管理テーブル１３０では、テストデータ投入を行った時間は、最新の投入データのデータＩＤ＝００００００００００３とデータＩＤ＝００００００００００１の投入時刻の差分により求めるため、２０分である。
このため、ｄは以下のようになる。
ｄ＝３０００／（３／２０）＝２００００分
そして、データ投入完了予測部１５は、テスト開始日時＝２０１３／１２／３（火）１１：５５：００に投入完了予測時間ｄを加えた値“２０１３／１２／１７（火） ０９：１５：００”をオペレータに表示する（Ｓ１７０１）。

次に、データ投入完了予測部１５は、オペレータから投入完了予測時間の繰上げ指示（ｘ時間）を受けたか否かを判定する（Ｓ１７０２）。

オペレータから繰上げ指示がない場合（Ｓ１７０２でＮＯ）は、現状のままデータ投入が継続される。

繰り上げ指示時間が指定されない繰り上げ指示があった場合（Ｓ１７０２で、ＹＥＳ、ｘ＝０）は、データ投入完了予測部１５は、データ投入速度制御部１６にｘ＝０を送る（Ｓ１７０６）。
これに基づき、データ投入速度制御部１６は、図１２のＳ１２０３の処理を行う。

繰り上げ指示時間が指定された繰り上げ指示があった場合（Ｓ１７０２で、ＹＥＳ、ｘ≠０）は、データ投入完了予測部１５は、応答時間記録部１４に、テストデータの残数、テストデータ投入日時を問い合わせ、応答時間記録部１４からこれらの値を取得する（Ｓ１７０３）。
このとき、応答時間記録部１４では、図１５のＳ１５０３の処理が行われる。

次に、データ投入完了予測部１５は、繰上げ指示時間ｘ、テストデータの残件、テストデータの投入開始時刻から、データ投入間隔ｗを算出する（Ｓ１７０４）。
ここでは、オペレータから、ｘ＝４８、つまり、４８時間の繰り上げが指示された場合を想定する。
前述のように、投入完了予測時間ｄは、２００００分である。
データ投入間隔ｗは、以下にて算出される。
ｗ＝（完了予定までの時間）／（残件）
＝（ｄ−（ｘ）×６０）／残件
＝（２００００−４８×６０）／２９９７≒５．７（分）

次に、データ投入完了予測部１５は、ｘ＝４８時間と、ｗ＝５．７分／件をデータ投入速度制御部１６に送信する（Ｓ１７０５）。
これにより、データ投入速度制御部１６は、図１２のＳ１２０１において、繰り上げ指示時間ｘ＝４８時間、投入間隔ｗ＝５．７分／件を受け取ったことにより、データ投入部１１を投入間隔ｗ＝５．７時間／件ごとに起動する（Ｓ１２０６）。

次に、図１８を用いてデータ出力部１７の動作を説明する。

データ出力部１７は、データ管理テーブル１３０から、データＩＤ＝００００００００００１のレコードを取り出す（Ｓ１８０１）。
取り出したレコードを列ごとに、カンマ区切りでデータを作成する。
つまり、“００００００００００１”、“２０１２／１２／３（火）１１：５５：００”、“１”、“カードＩＤ＝カード３０、入退室機器＝入退室機器２１、通行日時＝２０１３／１１／２１ １０：００：００”のデータを作成し、外部ファイルに出力する（Ｓ１８０２）。
以降は、Ｓ１８０１〜Ｓ１８０２を繰り返し、外部ファイルを作成する。

次に、図１９を用いてデータ入力部１８の動作を説明する。

データ入力部１８は、上記で作成した外部ファイルから１レコードを取得する（Ｓ１９０１）。
取得したレコードから、カンマごとにデータを取り出し、データ管理テーブル１３０にセットする（Ｓ１９０２）。

以上のように、本実施の形態によれば、データ送信先であるＩＤ管理システム００でデータ処理が行われないと推測される推定空き時間においてテストデータの送信を行うため、ＩＤ管理システム００におけるサービスレベルを低下させることなく、障害の解析を行うことができる。

最後に、本実施の形態に示したデータ投入システム１００のハードウェア構成例を図９を参照して説明する。
データ投入システム１００はコンピュータであり、データ投入システム１００の各要素をプログラムで実現することができる。
データ投入システム１００のハードウェア構成としては、バスに、演算装置９０１、外部記憶装置９０２、主記憶装置９０３、通信装置９０４、入出力装置９０５が接続されている。

演算装置９０１は、プログラムを実行するＣＰＵ（Ｃｅｎｔｒａｌ Ｐｒｏｃｅｓｓｉｎｇ Ｕｎｉｔ）である。
外部記憶装置９０２は、例えばＲＯＭ（Ｒｅａｄ Ｏｎｌｙ Ｍｅｍｏｒｙ）やフラッシュメモリ、ハードディスク装置である。
主記憶装置９０３は、ＲＡＭ（Ｒａｎｄｏｍ Ａｃｃｅｓｓ Ｍｅｍｏｒｙ）である。
通信装置９０４は、ＮＩＣ（Ｎｅｔｗｏｒｋ Ｉｎｔｅｒｆａｃｅ Ｃａｒｄ）に対応する。
入出力装置９０５は、例えばマウス、キーボード、ディスプレイ装置等である。

プログラムは、通常は外部記憶装置９０２に記憶されており、主記憶装置９０３にロードされた状態で、順次演算装置９０１に読み込まれ、実行される。
プログラムは、図１に示す「〜部」（データ管理テーブル記憶部１３以外、以下も同様）として説明している機能を実現するプログラムである。
更に、外部記憶装置９０２にはオペレーティングシステム（ＯＳ）も記憶されており、ＯＳの少なくとも一部が主記憶装置９０３にロードされ、演算装置９０１はＯＳを実行しながら、図１に示す「〜部」の機能を実現するプログラムを実行する。
また、本実施の形態の説明において、「〜の判断」、「〜の判定」、「〜の抽出」、「〜の算出」、「〜の設定」、「〜の選択」、「〜の生成」、「〜の受信」、「〜の取得」等として説明している処理の結果を示す情報やデータや信号値や変数値が主記憶装置９０３にファイルとして記憶されている。

なお、図９の構成は、あくまでもデータ投入システム１００のハードウェア構成の一例を示すものであり、データ投入システム１００のハードウェア構成は図９に記載の構成に限らず、他の構成であってもよい。

また、本実施の形態に示す手順により、本発明に係るデータ送信方法を実現可能である。

００ ＩＤ管理システム、０１ ＩＤ管理部、０２ テナント−ユーザＩＤ−カード管理テーブル記憶部、０３ 受信履歴管理テーブル記憶部、０４ 配信履歴管理テーブル記憶部、０５ テナント情報管理部、０６ テナント情報管理テーブル記憶部、０７ 入力部、０８ テナント優先度管理テーブル記憶部、１０ データ投入システム、１１ データ投入部、１２ データ管理部、１３ データ管理テーブル記憶部、１４ 応答時間記録部、１５ データ投入完了予測部、１６ データ投入速度制御部、１７ データ出力部、１８ データ入力部、２１ 入退室機器。

Claims (10)

1. 優先度が設定されたデータ処理が行われるデータ処理装置にデータを送信するデータ送信装置であって、
   前記データ処理装置においてデータ処理が行われないと推測される推測空き時間を抽出するとともに、前記データ処理装置において閾値以下の優先度のデータ処理のみが行われると推測される推測低優先度処理時間を抽出する推測空き時間抽出部と、
   前記推測空き時間抽出部により抽出された推測空き時間及び前記推測低優先度処理時間に、前記データ処理装置へのデータ送信を行うデータ送信部とを有することを特徴とするデータ送信装置。
2. データ処理が行われるデータ処理装置にデータを送信するデータ送信装置であって、
   前記データ処理装置においてデータ処理が行われないと推測される推測空き時間を抽出する推測空き時間抽出部と、
   前記推測空き時間抽出部により抽出された推測空き時間に、前記データ処理装置へのデータ送信を行うデータ送信部と、
   前記データ処理装置へのデータ送信が完了するまでに要する送信完了所要時間を算出する送信完了所要時間算出部と、
   前記送信完了所要時間から繰り上げ指示時間分繰り上げて前記データ処理装置へのデータ送信を完了するよう指示する繰り上げ指示を取得する繰り上げ指示取得部と、
   前記送信完了所要時間と、前記繰り上げ指示時間と、前記データ処理装置への未送信データのデータ量とに基づき、前記データ送信部によるデータの送信間隔を算出する送信間隔算出部とを有し、
   前記データ送信部は、
   前記繰り上げ指示取得部が前記繰り上げ指示を取得した場合に、前記推測空き時間でのデータ送信を停止し、前記データ処理装置におけるデータ処理の実行有無に関わらず、前記送信間隔算出部により算出された送信間隔で、前記データ処理装置へのデータ送信を行うことを特徴とするデータ送信装置。
3. 前記データ送信部は、
   送信したデータに対する前記データ処理装置からの応答を、閾値時間を超えても受信しない場合に、前記推測空き時間であっても、前記データ処理装置へのデータ送信を停止することを特徴とする請求項１又は２に記載のデータ送信装置。
4. 前記推測空き時間抽出部は、
   前記データ処理装置において過去にデータ処理が行われなかった時間と同時刻の時間を推測空き時間とすることを特徴とする請求項１又は２に記載のデータ送信装置。
5. 前記推測空き時間抽出部は、
   前記データ処理装置において過去に閾値以下の優先度のデータ処理のみが行われた時間と同時刻の時間を推測低優先度処理時間とすることを特徴とする請求項１に記載のデータ送信装置。
6. 前記データ送信部は、
   入退室機器から前記データ処理装置に送信される通行履歴データを模擬したデータを、前記推測空き時間に、前記データ処理装置に送信することを特徴とする請求項１又は２に記載のデータ送信装置。
7. コンピュータが、優先度が設定されたデータ処理が行われるデータ処理装置にデータを送信するデータ送信方法であって、
   前記コンピュータが、前記データ処理装置においてデータ処理が行われないと推測される推測空き時間を抽出するとともに、前記データ処理装置において閾値以下の優先度のデータ処理のみが行われると推測される推測低優先度処理時間を抽出する推測空き時間抽出ステップと、
   前記コンピュータが、前記推測空き時間抽出ステップにより抽出された推測空き時間及び前記推測低優先度処理時間に、前記データ処理装置へのデータ送信を行うデータ送信ステップとを有することを特徴とするデータ送信方法。
8. コンピュータが、データ処理が行われるデータ処理装置にデータを送信するデータ送信方法であって、
   前記コンピュータが、前記データ処理装置においてデータ処理が行われないと推測される推測空き時間を抽出する推測空き時間抽出ステップと、
   前記コンピュータが、前記推測空き時間抽出ステップにより抽出された推測空き時間に、前記データ処理装置へのデータ送信を行うデータ送信ステップと、
   前記コンピュータが、前記データ処理装置へのデータ送信が完了するまでに要する送信完了所要時間を算出する送信完了所要時間算出ステップと、
   前記コンピュータが、前記送信完了所要時間から繰り上げ指示時間分繰り上げて前記データ処理装置へのデータ送信を完了するよう指示する繰り上げ指示を取得する繰り上げ指示取得ステップと、
   前記コンピュータが、前記送信完了所要時間と、前記繰り上げ指示時間と、前記データ処理装置への未送信データのデータ量とに基づき、前記データ送信ステップによるデータの送信間隔を算出する送信間隔算出ステップとを有し、
   前記データ送信ステップにおいて、
   前記コンピュータが、
   前記繰り上げ指示取得ステップにより前記繰り上げ指示が取得された場合に、前記推測空き時間でのデータ送信を停止し、前記データ処理装置におけるデータ処理の実行有無に関わらず、前記送信間隔算出ステップにより算出された送信間隔で、前記データ処理装置へのデータ送信を行うことを特徴とするデータ送信方法。
9. 優先度が設定されたデータ処理が行われるデータ処理装置にデータを送信するコンピュータに、
   前記データ処理装置においてデータ処理が行われないと推測される推測空き時間を抽出するとともに、前記データ処理装置において閾値以下の優先度のデータ処理のみが行われると推測される推測低優先度処理時間を抽出する推測空き時間抽出処理と、
   前記推測空き時間抽出処理により抽出された推測空き時間及び前記推測低優先度処理時間に、前記データ処理装置へのデータ送信を行うデータ送信処理とを実行させることを特徴とするプログラム。
10. データ処理が行われるデータ処理装置にデータを送信するコンピュータに、
    前記データ処理装置においてデータ処理が行われないと推測される推測空き時間を抽出する推測空き時間抽出処理と、
    前記推測空き時間抽出処理により抽出された推測空き時間に、前記データ処理装置へのデータ送信を行うデータ送信処理と、
    前記データ処理装置へのデータ送信が完了するまでに要する送信完了所要時間を算出する送信完了所要時間算出処理と、
    前記送信完了所要時間から繰り上げ指示時間分繰り上げて前記データ処理装置へのデータ送信を完了するよう指示する繰り上げ指示を取得する繰り上げ指示取得処理と、
    前記送信完了所要時間と、前記繰り上げ指示時間と、前記データ処理装置への未送信データのデータ量とに基づき、前記データ送信処理によるデータの送信間隔を算出する送信間隔算出処理とを実行させ、
    前記データ送信処理において、
    前記繰り上げ指示取得処理により前記繰り上げ指示が取得された場合に、前記コンピュータに、前記推測空き時間でのデータ送信を停止させ、前記データ処理装置におけるデータ処理の実行有無に関わらず、前記送信間隔算出処理により算出された送信間隔で、前記データ処理装置へのデータ送信を行わせることを特徴とするプログラム。

Images