(57)【要約】【課題】連続体の処理を実行する処理システムにおける、所望の日時及び箇所に存在する連続体の対象物に関するトレーサビリティ情報を抽出する際の処理負荷を低減できるようにする。【解決手段】データ管理サーバ１００において、複数の状態検出ポイントにおいて逐次検出される検出データを取得するデータ受信部１１１と、複数の状態検出ポイントのそれぞれの検出データと、それぞれの状態検出ポイントとつながる接続状態検出ポイントを特定可能なポイント特定情報と、状態検出ポイントと接続状態検出ポイントとの間を連続体が通過する経過時間とを対応付けたセンサデータ管理テーブル１１５を記憶装置に記憶させるデータ格納部１０８と、を備えるようにする。【選択図】図１
2019020835.tif 000002
【特許請求の範囲】
【請求項１】
所定の連続体に対する一連の処理における複数の状態検出ポイントで逐次検出された前記連続体に関する検出データを管理するデータ管理装置であって、
複数の前記状態検出ポイントにおいて逐次検出される前記検出データを取得するデータ取得部と、
複数の前記状態検出ポイントのそれぞれの前記検出データと、それぞれの前記状態検出ポイントとつながる状態検出ポイントである接続状態検出ポイントを特定可能なポイント特定情報と、前記状態検出ポイントと前記接続状態検出ポイントとの間を前記連続体が通過する経過時間とを対応付けた検出データ管理情報を記憶装置に記憶させるデータ登録部と、
を備えるデータ管理装置。
【請求項２】
検索対象の状態検出ポイントを示すポイント指定情報と、検索対象の日時とを含む検索条件を受け付ける条件受付部と、
前記検出データ管理情報における、前記検出データに対応付けられている前記ポイント特定情報と、前記経過時間とに基づいて、前記連続体の同一対象が前記接続状態検出ポイントに位置する時点における検出データを取得する接続先検出データ取得処理を、前記検索条件に合致する検出データに対して実行するとともに、前記接続先検出データ取得処理を実行することにより取得された検出データに対して実行する情報取得部と、
前記情報取得部により取得された複数の前記状態検出ポイントにおける前記検出データを所定の表示装置に表示出力する出力部と、
をさらに備える
請求項１に記載のデータ管理装置。
【請求項３】
前記接続状態検出ポイントは、前記状態検出ポイントの直前の状態検出ポイント、又は前記状態検出ポイントの直後の状態検出ポイントの少なくともいずれか一方である
請求項１又は請求項２に記載のデータ管理装置。
【請求項４】
前記検出データ管理情報は、互いに対応する、前記検出データと、前記ポイント特定情報と、前記経過時間とを同一レコードに格納するテーブルにより構成されている
請求項１から請求項３のいずれか一項に記載のデータ管理装置。
【請求項５】
前記接続状態検出ポイントは、前記状態検出ポイントの直後の状態検出ポイントを含み、
前記データ登録部は、第１状態検出ポイントでの第１時点における直前の状態検出ポイントである第２状態検出ポイントとの間の前記経過時間が決定された場合に、前記第２状態検出ポイントでの前記第１時点よりも前記経過時間だけ前の時点である第２時点における検出データに対して、前記第２状態検出ポイントと前記第１状態検出ポイントとの間の経過時間として、前記決定された経過時間を対応付ける
請求項４に記載のデータ管理装置。
【請求項６】
前記検出データ管理情報は、前記検出データを格納する第１テーブルと、前記ポイント特定情報と前記経過時間とを格納する第２テーブルにより構成されている
請求項１から請求項３のいずれか一項に記載のデータ管理装置。
【請求項７】
前記第２テーブルでは、前記経過時間に対して、前記経過時間が有効である期間の情報が対応付けられている
請求項６に記載のデータ管理装置。
【請求項８】
前記状態検出ポイントと前記接続状態検出ポイントとの間の前記経過時間が変化したか否かを検知する変化検知部と、
変化後の経過時間に基づいて、前記検出データに対して対応付ける、前記状態検出ポイントと前記接続状態検出ポイントとの間の前記経過時間を決定する経過時間決定部と、
をさらに備える
請求項１から請求項７のいずれか一項に記載のデータ管理装置。
【請求項９】
前記変化検知部は、前記検出データに基づいて、前記経過時間が変化したか否かを判定し、前記変化後の経過時間を算出する
請求項８に記載のデータ管理装置。
【請求項１０】
前記変化後の経過時間は、現在の状態が維持された場合の将来における経過時間を示しており、
前記経過時間決定部は、前記経過時間が変化した時点から前記変化後の経過時間が経過するまでの間は、前記経過時間が、変化前の経過時間から前記変化後の経過時間に所定の変化をするものとして、前記経過時間を算出する
請求項９に記載のデータ管理装置。
【請求項１１】
前記データ登録部は、前記経過時間を外部装置から受信して登録する
請求項１から請求項１０のいずれか一項に記載のデータ管理装置。
【請求項１２】
前記連続体に対する一連の処理を実行する処理システムと、前記処理システムにおける複数の状態検出ポイントでの前記連続体に関する検出データを逐次検出する複数のセンサと、前記検出データを受信して管理するデータ管理装置と、を備える連続体処理管理システムであって、
前記データ管理装置は、
複数の前記状態検出ポイントにおいて逐次検出される前記検出データを取得するデータ取得部と、
複数の前記状態検出ポイントのそれぞれの前記検出データと、それぞれの前記状態検出ポイントとつながる状態検出ポイントである接続状態検出ポイントを特定可能なポイント特定情報と、前記状態検出ポイントと前記接続状態検出ポイントとの間を前記連続体が通過する経過時間とを対応付けた検出データ管理情報を記憶部に記憶させるデータ登録部と、
を備える連続体処理管理システム。
【請求項１３】
前記データ管理装置は、
検索対象の状態検出ポイントを示すポイント指定情報と、検索対象の日時とを含む検索条件を受け付ける条件受付部と、
前記検出データ管理情報における、前記検出データに対応付けられている前記ポイント特定情報と、前記経過時間とに基づいて、前記連続体の同一対象が前記接続状態検出ポイントに位置する時点における検出データを取得する接続先検出データ取得処理を、前記検索条件に合致する検出データに対して実行するとともに、前記接続先検出データ取得処理を実行することにより取得された検出データに対して実行する情報取得部と、
前記情報取得部により取得された複数の前記状態検出ポイントにおける前記検出データを所定の表示装置に表示出力する出力部と、
をさらに備える
請求項１２に記載の連続体処理管理システム。
【請求項１４】
所定の連続体に対する一連の処理における複数の状態検出ポイントで逐次検出された前記連続体に関する検出データを管理するデータ管理装置によるデータ管理処理方法であって、
複数の前記状態検出ポイントにおいて逐次検出される前記検出データを取得し、
複数の前記状態検出ポイントのそれぞれの前記検出データと、それぞれの前記状態検出ポイントとつながる状態検出ポイントである接続状態検出ポイントを特定可能なポイント特定情報と、前記状態検出ポイントと前記接続状態検出ポイントとの間を前記連続体が通過する経過時間とを対応付けた検出データ管理情報を記憶装置に記憶させる
データ管理処理方法。
【請求項１５】
検索対象の状態検出ポイントを示すポイント指定情報と、検索対象の日時とを含む検索条件を受け付け、
前記検出データ管理情報における、前記検出データに対応付けられている前記ポイント特定情報と、前記経過時間とに基づいて、前記連続体の同一対象が前記接続状態検出ポイントに位置する時点における検出データを取得する接続先検出データ取得処理を、前記検索条件に合致する検出データに対して実行するとともに、前記接続先検出データ取得処理を実行することにより取得された検出データに対して実行し、
取得された複数の前記状態検出ポイントにおける前記検出データを所定の表示装置に表示出力させる
請求項１４に記載のデータ管理処理方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、例えば、液体、気体等の連続体に対する一連の処理における複数の状態検出ポイントで取得された連続体に関する検出データを管理するデータ管理装置等に関する。
【背景技術】
【０００２】
近年、工場設備や現場に設置された機器、センサ等から収集した現場データを一括管理することが可能なデータ管理システムが提供されている。従来は、このように収集したデータを、現場設備の状態をリアルタイムに運用者のユーザ端末の画面に表示して現場を監視する集中監視システムなどに利用してきた。
【０００３】
これに対して、最近は、情報通信技術の向上により、収集した大量のセンサや機器のデータを、設備の予兆検知、製品品質に問題が生じた場合のトレーサビリティ、根本原因分析等へ活用するニーズが増えてきている。
【０００４】
このような大量データの分析を行う際には、データを様々な観点で抽出する必要がある。データを抽出する方法の例としては、特定のセンサデータを時系列順に並べたり、同一時刻で複数のセンサデータを並べたりといった単純なものに加え、特定の製品に紐づく各工程のセンサデータをトレースして抽出したりするものもある。
【０００５】
例えば、特許文献１には、トレースが困難な流体である水のトレーサビリティを可能にするシステムが開示されており、このシステムでは、水処理場の一連の処理プロセスにおいて、特定の日時、プロセスが指定されると、その時点・箇所の水質情報だけでなく、それ以前の処理プロセスでの水質情報を、時間を遡ってトレースし、これらの情報を一覧表示することができる。
【先行技術文献】
【特許文献】
【０００６】
【特許文献１】特開２００６−４３６０６号公報
【発明の概要】
【発明が解決しようとする課題】
【０００７】
処理プロセスにおけるデータ分析を行う際には、分析者や分析アプリケーションは様々な角度でデータを眺めて異常点を検出しようとするため、様々な日時や箇所（プロセス）を対象としてトレーサビリティ情報を、短時間で大量に取得できる必要がある。
【０００８】
これに対して、特許文献１の技術では、ユーザからのトレーサビリティ情報要求をトリガーとして、現場データや設備情報の検索、及び計算を繰り返すことにより、必要なトレーサビリティ情報を抽出しており、１回のトレーサビリティ情報の抽出作業に大きな負荷がかかってしまう。
【０００９】
特に、年々収集するデータ量が増加していく傾向にあるため、このように増加したデータに対する検索及び計算を実行するための処理負荷が大きくなってしまう問題がある。また、このような状況において、短時間で大量の要求を処理するためには、多くの計算機リソースが必要となるという課題がある。
【００１０】
本発明は、上記事情に鑑みなされたものであり、その目的は、連続体の処理を実行する処理システムにおける、所望の日時及び箇所に存在する連続体の対象物に関するトレーサビリティ情報を抽出する際の処理負荷を低減することのできる技術を提供することにある。
【課題を解決するための手段】
【００１１】
上記目的を達成するため、一観点に係るデータ管理装置は、所定の連続体に対する一連の処理における複数の状態検出ポイントで逐次検出された連続体に関する検出データを管理するデータ管理装置であって、複数の状態検出ポイントにおいて逐次検出される検出データを取得するデータ取得部と、複数の状態検出ポイントのそれぞれの検出データと、それぞれの状態検出ポイントとつながる状態検出ポイントである接続状態検出ポイントを特定可能なポイント特定情報と、状態検出ポイントと接続状態検出ポイントとの間を連続体が通過する経過時間とを対応付けた検出データ管理情報を記憶装置に記憶させるデータ登録部と、を備える。
【発明の効果】
【００１２】
本発明によれば、連続体の処理を実行する処理システムにおける、所望の日時及び箇所に存在する連続体の対象物に関するトレーサビリティ情報を抽出する際の処理負荷を低減することができる。
【図面の簡単な説明】
【００１３】
【図１】図１は、第１実施形態に係る水処理管理システムの全体構成図である。
【図２】図２は、第１実施形態に係るデータ管理サーバのハードウェア構成図である。
【図３】図３は、第１実施形態に係るトレース情報管理テーブルの構成図である。
【図４】図４は、第１実施形態に係る設備情報管理テーブルの構成図である。
【図５】図５は、第１実施形態に係るセンサデータ管理テーブルの構成図である。
【図６】図６は、第１実施形態に係るデータ登録処理のフローチャートである。
【図７】図７は、第１実施形態に係るトレーサビリティ情報作成表示処理のフローチャートである。
【図８】図８は、第２実施形態に係る水処理管理システムの全体構成図である。
【図９】図９は、第２実施形態に係るセンサデータ管理テーブルの構成図である。
【図１０】図１０は、第２実施形態に係る経過時間管理テーブルの構成図である。
【図１１】図１１は、第２実施形態に係るデータ登録処理のフローチャートである。
【図１２】図１２は、第２実施形態に係るトレーサビリティ情報表示処理のフローチャートである。
【図１３】図１３は、第３実施形態に係るセンサデータ管理テーブルの構成図である。
【発明を実施するための形態】
【００１４】
実施形態について、図面を参照して説明する。なお、以下に説明する実施形態は特許請求の範囲に係る発明を限定するものではなく、また実施形態の中で説明されている諸要素及びその組み合わせの全てが発明の解決手段に必須であるとは限らない。
【００１５】
以下の説明では、「ＡＡＡテーブル」の表現にて情報を説明することがあるが、情報は、どのようなデータ構造で表現されていてもよい。すなわち、情報がデータ構造に依存しないことを示すために、「ＡＡＡテーブル」を「ＡＡＡ情報」と呼ぶことができる。
【００１６】
まず、第１実施形態に係る連続体処理管理システムの一例である水処理管理システムについて説明する。
【００１７】
図１は、第１実施形態に係る水処理管理システムの全体構成図である。
【００１８】
水処理管理システム１は、データ管理装置の一例としてのデータ管理サーバ１００と、ユーザ端末１０と、管理者端末２０と、処理システムの一例としての現場システム５０とを備える。データ管理サーバ１００は、通信路３０を介して、ユーザ端末１０、管理者端末２０と相互に接続されている。また、データ管理サーバ１００は、通信路４０を介して、現場システム５０と相互に接続されている。通信路３０と、通信路４０とは、それぞれ、ＷＡＮ（Ｗｉｄｅ  Ａｒｅａ  Ｎｅｔｗｏｒｋ）であっても、ＬＡＮ（Ｌｏｃａｌ  Ａｒｅａ  Ｎｅｔｗｏｒｋ）であってもよい。また、通信路３０と通信路４０は、同一の通信路として構成してもよい。
【００１９】
ユーザ端末１０は、トレーサビリティ情報を入手したい運用者が、データ管理サーバ１００にアクセスするために使用する端末である。管理者端末２０は、水処理管理システム１のシステム全体を管理するシステム管理者（以下、管理者ともいう）が、データ管理サーバ１００内の設備に関する情報を参照、更新、追加、削除等する管理業務を行うために使用する端末である。
【００２０】
現場システム５０は、水処理を行うプラント（水処理プラント）に配置されたシステムである。水処理プラントとしては、例えば、浄水処理プラントである。浄水処理プラントは、例えば、着水井、凝集沈殿池、ろ過池、塩素消毒設備等の設備（処理プロセス）を有する。現場システム５０は、１以上のコントローラ５２と、１以上のセンサ５３と、ゲートウェイ５１とを備える。センサ５３は、例えば、水処理プラントの処理プロセスの各設備に内蔵、又は外付けされており、各設備における水に関する各種データ（例えば、流量、流速、温度、ｐＨ等）を検出し、コントローラ５２に送信する。コントローラ５２は、水処理プラントの設備を統括制御する。コントローラ５２は、コントローラ５２内の制御実績に関するデータや、センサ５３により検出された検出データ（センサデータ）等のデータ（現場データ）をゲートウェイ５１に送信する。ゲートウェイ５１は、通信路４０を介して、コントローラ５２から収集した現場データをデータ管理サーバ１００に送信する。
【００２１】
データ管理サーバ１００は、ユーザインタフェース（Ｉ／Ｆ）１０５、管理者インタフェース（Ｉ／Ｆ）１０６、条件受付部、情報取得部、及び出力部の一例としてのトレース情報取得部１０７、データ登録部の一例としてのデータ格納部１０８、変化検知部及び経過時間決定部の一例としてのデータ変換部１０９、経過時間算出部１１０、データ取得部の一例としてのデータ受信部１１１、通信インタフェース（Ｉ／Ｆ）１１２、トレース情報管理テーブル１１３、設備情報管理テーブル１１４、及び検出データ管理情報の一例としてのセンサデータ管理テーブル１１５を備える。
【００２２】
ユーザＩ／Ｆ１０５は、ユーザ端末１０からトレーサビリティ情報要求を受信するためのインタフェースである。ユーザＩ／Ｆ１０５は、ユーザ端末１０からトレーサビリティ情報要求を受け取ると、トレース情報取得部１０７に対し、トレーサビリティ情報作成を指示する。管理者Ｉ／Ｆ１０６は、管理者端末２０から設備情報の管理業務を受け付けるためのインタフェースである。管理者Ｉ／Ｆ１０６は、管理者端末２０からの管理者の要求に従って設備情報管理テーブル１１４の情報を更新する。
【００２３】
トレース情報取得部１０７は、ユーザＩ／Ｆ１０５からトレーサビリティ情報作成の指示を受け取ると、トレーサビリティ情報要求に従って、センサデータ管理テーブル１１５を検索し、トレーサビリティ情報を作成し、トレース情報管理テーブル１１３に格納し、ユーザ端末１０に表示するトレーサビリティ画面の情報を作成する。トレース情報取得部１０７による詳細な処理については、図７を参照して後述する。
【００２４】
通信Ｉ／Ｆ１１２は、現場システム５０のゲートウェイ５１から送信される送信パケットを受信するためのインタフェースである。通信Ｉ／Ｆ１１２は、ゲートウェイ５１から受信したパケットをデータ受信部１１１に渡す。
【００２５】
データ受信部１１１は、通信Ｉ／Ｆ１１２から受け取ったパケットから現場データを再構築して、各種データ処理やデータベースへの格納処理に利用できるようにし、データ変換部１０９に渡す。
【００２６】
データ変換部１０９は、受け取った現場データのうちのセンサデータに対し、このセンサデータが取得された箇所（処理プロセス）（取得チェックポイントという）の前の箇所（前チェックポイント）に設けられた設備の設備ＩＤ（ポイント特定情報の一例）と、前チェックポイントから取得チェックポイントに水が到達する経過時間とを含む情報（前チェックポイント情報）を付与してデータ格納部１０８に渡す。また、データ変換部１０９は、例えば、現場データのうちの流量に関するセンサデータや、設備のメンテナンス情報のデータ等の、前チェックポイントから取得チェックポイントまでの経過時間に影響を及ぼすデータを常時監視しており、監視しているデータが事前に設定された再計算条件を満たしたことを検知したら、経過時間算出部１１０に前チェックポイントからの経過時間を再計算させ、再計算により得られた経過時間に基づいてデータ変換部１０９の内部で保持している前チェックポイントからの経過時間を更新する。
【００２７】
データ格納部１０８は、データ変換部１０９から渡されたセンサデータと、センサデータに対して付与された前チェックポイント情報とをセンサデータ管理テーブル１１５に格納する。経過時間算出部１１０は、データ変換部１０９からの指示に応じて、データ変換部１０９から渡されたセンサデータ、設備情報管理テーブル１１４やセンサデータ管理テーブル１１５に蓄積されている過去のセンサデータや設備情報を参照し、前チェックポイントからの最新の経過時間を算出し、データ変換部１０９に返す。データ変換部１０９の詳細な処理については、図６を参照して後述する。
【００２８】
トレース情報管理テーブル１１３、設備情報管理テーブル１１４、及びセンサデータ管理テーブル１１５については、図３〜図５を用いて後述する。
【００２９】
次に、データ管理サーバ１００のハードウェア構成について説明する。
【００３０】
図２は、第１実施形態に係るデータ管理サーバのハードウェア構成図である。
【００３１】
データ管理サーバ１００は、ホストＣＰＵ（Ｃｅｎｔｒａｌ  Ｐｒｏｃｅｓｓｉｎｇ  Ｕｎｉｔ）２０１、ホストメモリ２０２、周辺インタフェース（Ｉ／Ｆ）２０３、記憶装置２０４、通信インタフェース１１２、及びバス２０６を備える。ホストＣＰＵ２０１、ホストメモリ２０２、周辺Ｉ／Ｆ２０３、記憶装置２０４、及び通信Ｉ／Ｆ１１２は、バス２０６を介して相互にデータ交換可能に接続されている。
【００３２】
ホストＣＰＵ２０１は、記憶装置２０４に保持されているプログラムを実行する。ホストメモリ２０２は、例えば、揮発性記憶装置であり、ホストＣＰＵ２０１がプログラムを実行する際において、ワーキングメモリ及び入出力データの一時バッファとして用いられる。周辺Ｉ／Ｆ２０３は、マウス、キーボード、モニタ等の入出力装置や、ＵＳＢ（Ｕｎｉｖｅｒｓａｌ  Ｓｅｒｉａｌ  Ｂｕｓ）メモリ等の外部ストレージ等の各種周辺機器をデータ管理サーバ１００に接続するためのインタフェースである。記憶装置２０４は、磁気ディスク装置、フラッシュＲＯＭ（Ｒｅａｄ  Ｏｎｌｙ  Ｍｅｍｏｒｙ）等から構成され、ＯＳ（Ｏｐｅｒａｔｉｎｇ  Ｓｙｓｔｅｍ）、各種ドライバ、各種アプリケーションプログラムや、プログラムで使用される各種情報（例えば、管理者または保守者によって設定される情報等）を格納する。記憶装置２０４は、例えば、トレース情報管理テーブル１１３、設備情報管理テーブル１１４、及びセンサデータ管理テーブル１１５を格納する。
【００３３】
通信Ｉ／Ｆ１１２は、データ管理サーバ１００が通信路３０，４０を介してユーザ端末１０、管理者端末２０、現場システム５０と通信を行う際のインタフェースを提供する。通信Ｉ／Ｆ１１２は、２つ以上あってもよい。
【００３４】
ここで、図１におけるトレース情報取得部１０７、データ格納部１０８、データ変換部１０９、経過時間算出部１１０、及びデータ受信部１１１は、例えば、ホストＣＰＵ２０１が記憶装置２０４のプログラムを実行することにより構成される。なお、トレース情報取得部１０７、データ格納部１０８、データ変換部１０９、経過時間算出部１１０、及びデータ受信部１１１の少なくとも一部の機能をハードウェア回路で実現するようにしてもよい。
【００３５】
次に、トレース情報管理テーブル１１３について説明する。
【００３６】
図３は、第１実施形態に係るトレース情報管理テーブルの構成図である。
【００３７】
トレース情報管理テーブル１１３は、トレーサビリティ情報要求に対応して検出された特定の日時及び特定の場所におけるセンサデータの内容を示すレコードを格納する。トレース情報管理テーブル１１３のレコードは、要求ＩＤ３０１、指定日時３０２、指定場所３０３、及び表示情報３０４のフィールドを有する。
【００３８】
要求ＩＤ３０１には、ユーザ端末１０から送信される各トレーサビリティ情報要求を一意に識別するための識別子（要求ＩＤ）が格納される。要求ＩＤ３０１の要求ＩＤが同一であるレコード（図３の例では、１番目〜６番目のレコード）は、同一のトレーサビリティ情報要求に対応する情報であることを表す。指定日時３０２には、トレーサビリティ情報のタイムスタンプ（日時）が格納される。指定場所３０３には、トレーサビリティ情報が生成された場所を示す情報が格納される。表示情報３０４には、指定日時３０２の日時、及び指定場所３０３の場所で観測されたセンサデータのセンサ値等が格納される。
【００３９】
トレース情報管理テーブル１１３は、データ管理サーバ１００が出荷された初期状態においては、何も情報が格納されておらず、ユーザ端末１０からトレーサビリティ情報要求を受信した場合に、トレース情報取得部１０７により、レコードが追加される。
【００４０】
次に、設備情報管理テーブル１１４について説明する。
【００４１】
図４は、第１実施形態に係る設備情報管理テーブルの構成図である。
【００４２】
設備情報管理テーブル１１４は、水処理プラントにおける各種設備ごとに対応するレコードを格納する。設備情報管理テーブル１１４のレコードは、設備ＩＤ４０１、設備タイプ４０２、設備名４０３、設備状態４０４、及び設備仕様４０５のフィールドを含む。
【００４３】
設備ＩＤ４０１には、各設備を一意に識別するための識別子（設備ＩＤ）が格納される。ここで対象とする設備としては、水処理の処理プロセスを行う設備のほかに、その設備に設けられるセンサ等も含まれる。設備タイプ４０２には、設備の分類が格納される。設備名４０３には、レコードに対応する設備の名称が格納される。設備状態４０４には、レコードに対応する設備の稼働状態が格納される。稼動状態としては、設備が稼働している状態を示す「稼動中」や、設備がメンテナンスされている状態を示す「メンテナンス中」等がある。設備仕様４０５には、レコードに対応する設備の仕様情報が格納される。仕様情報としては、例えば、設備が処理プロセスを行う設備であれば、その設備の容積等があり、例えば、設備がセンサであれば、センサによるセンサ値の単位等がある。この仕様情報は、例えば、経過時間算出部１１０がこの設備を水が通過するために要する経過時間を算出する際に利用される。
【００４４】
設備情報管理テーブル１１４は、例えば、現場システム５０が新たに構築された時に、システム管理者によって管理者端末２０経由で作成され、現場システム５０の運転開始後は、現場設備（センサも含む）の追加や入れ替えなどが発生した際や、定期メンテナンスや故障などによって現場設備の稼働状態が変更された際等に、システム管理者によって変更される。
【００４５】
次に、センサデータ管理テーブル１１５について説明する。
【００４６】
図５は、第１実施形態に係るセンサデータ管理テーブルの構成図である。
【００４７】
センサデータ管理テーブル１１５は、各センサが逐次取得するセンサデータ毎に対応するレコードを格納する。センサデータ管理テーブル１１５のレコードは、タイムスタンプ５０１、設備ＩＤ５０２、センサ値５０３、前チェックポイント設備ＩＤ５０４、及び経過時間５０５のフィールドを含む。
【００４８】
タイムスタンプ５０１は、レコードに対応するセンサデータが観測（検出）された日時情報（タイムスタンプ）が格納される。設備ＩＤ５０２には、レコードに対応するセンサデータを観測した設備（センサ）の識別子（設備ＩＤ）が格納される。図５の例では、設備ＩＤ５０２に格納される設備ＩＤは、設備情報管理テーブル１１４の設備ＩＤ４０１に格納される設備ＩＤと共通のものとなっている。センサ値５０３には、レコードに対応するセンサデータ、すなわち、センサによって現場で観測されたセンサ値が格納される。なお、センサ値５０３のセンサ値の単位などの仕様情報は、レコードの設備ＩＤに対応する設備情報管理テーブル１１４のレコードの設備仕様４０５に格納されている。前チェックポイント設備ＩＤ５０４には、レコードに対応するセンサデータが観測された設備が設置されている処理プロセス（状態検出ポイント）の前（例えば、直前）の処理プロセス（状態検出ポイント：接続状態検出ポイント）に設置された同種の設備を示す識別子が格納される。経過時間５０５には、現場システム５０の処理対象である水が、レコードの前チェックポイント設備ＩＤ５０４の設備ＩＤが示す設備が配置された処理プロセス（状態検出ポイント）を通過してから、レコードの設備ＩＤ５０２の設備ＩＤが示す設備の処理プロセス（接続状態検出ポイント）を通過するまでの経過時間が格納される。
【００４９】
例えば、図５に示すセンサデータ管理テーブル１１５の１番目のレコードは、時刻「2017-03-01 12:00:00.000」に、設備ＩＤ「９」、すなわち、「１系ろ過池出口ｐＨメータ」（図４の設備情報管理テーブル１１４を参照）で観測されたセンサ値が「７．０」であり、その一つ前の処理プロセスの設備の設備ＩＤが「９」、すなわち「1系凝集沈殿池ｐＨメータ」であり、1系凝集沈殿池ｐＨメータから１系ろ過池出口ｐＨメータまでの経過時間が「1:00:00」、換言すると、１系ろ過池出口ｐＨメータに到達した水は、１時間前に１系凝集沈殿値ｐＨメータを通過していることを表している。このレコードによると、このレコードが示すセンサ値の一つ前の処理プロセスのセンサ値のレコードを取得する場合には、センサデータ管理テーブル１１５から、設備ＩＤが「９」であり、且つタイムスタンプが１時間前の「2017-03-01 11:00:00.000」であるレコードを取得すればよい。したがって、１つ前の処理プロセスのセンサ値を同一のテーブル内で容易に検出することができ、処理負荷を低減することができる。
【００５０】
なお、図５に示すセンサデータ管理テーブル１１５では、水処理プラントにおいて、各設備の一つ前の処理プロセスが、一意の処理プロセスに特定できるものと想定した例を示しているが、例えば、水処理プラントが同一の処理プロセスを多重化して構築している場合には、或る設備に対して、前チェックポイントの設備が複数存在する場合があるが、この場合には、レコード内に「前チェックポイント」及び「経過時間」のフィールドの組を複数用意し、そのフィールドに情報を格納するようにすればよい。なお、この場合は、或る設備ＩＤ及び日時を起点としたトレーサビリティ情報は、複数の前チェックポイントのそれぞれを辿って取得されるセンサデータの集合、すなわち、過去の方向にツリー状に広がる形のセンサデータの集合となる。
【００５１】
次に、データ管理サーバ１００の処理動作について説明する。
【００５２】
図６は、第１実施形態に係るデータ登録処理のフローチャートである。
【００５３】
データ登録処理は、データ管理サーバ１００が、現場システム５０からセンサデータを受信した場合に実行される。センサデータは、例えば、センサ５３により観測した時間を示すタイムスタンプと、センサ５３を示す設備ＩＤと、センサ５３により観測されたセンサ値とを含む。
【００５４】
まず、データ管理サーバ１００のデータ変換部１０９は、通信Ｉ／Ｆ１１２及びデータ受信部１１１を介してセンサデータを受信すると、センサデータのうち、経過時間に影響を与えるセンサデータ（流量値など）や、設備情報管理テーブル１１４に格納されている現場設備情報（設備リプレースやメンテナンスなど）をチェックし（ステップ６０１）、そのセンサデータが観測されたチェックポイントまでの経過時間を再計算すべきか否かを判断する（ステップ６０２）。なお、データ変換部１０９が設備情報管理テーブル１１４を直接監視して経過時間を再計算すべきか否かを判断するようにしているが、例えば、データ変換部１０９が、設備情報管理テーブル１１４の設備情報の変更時に管理者Ｉ／Ｆ１０６からの通知を受けるようにしておき、通知を受けたか否かにより、経過時間を再計算すべきか否かを判断するようにしてもよい。
【００５５】
ここで、データ変換部１０９がチェック対象とすべき情報や再計算をすべきか否かの判断条件は、例えば、データ管理サーバ１００のシステム構築時に予め設定されていてもよく、また、例えば設定ファイルやデータベースによって管理しておき、システム管理者によって後から変更可能としてもよい。また、再計算をすべきか否かの判断条件については、センサデータの値が所定の閾値を超えるとの条件（例えば、水の流量値が所定の閾値を超えたこと）であってもよく、例えば、センサデータについて移動平均や累積値などを考慮した条件であってもよく、また、これらに限定されない。
【００５６】
この結果、経過時間の再計算が不要である場合（ステップ６０２：ＮＯ）には、データ変換部１０９は、処理をステップ６０４に進める。一方、経過時間の再計算が必要である場合（ステップ６０２：ＹＥＳ）には、データ変換部１０９は、経過時間算出部１１０にこの設備ＩＤの設備についての経過時間の再計算を指示し、指示を受けた経過時間算出部１１０は、設備情報管理テーブル１１４の設備の容積などの仕様情報や、センサデータ管理テーブル１１５の過去のセンサデータや最新のセンサデータを用いて経過時間を算出し、データ変換部１０９が内部に保持している経過時間を、算出した経過時間に更新し（ステップ６０３）、処理をステップ６０４に進める。これにより、チェックポイント間の経過時間を処理プラントの状況に応じて適切に変更することができる。
【００５７】
なお、経過時間算出部１１０がその時点の最新のセンサ値（例えば、流量、流速等）に基づいて算出する経過時間（算出経過時間）は、厳密にいうと、その時点における経過時間ではなく、その時点のセンサ値の状態が維持された場合における経過時間となる場合がある。すなわち、算出経過時間は、その算出経過時間が経過した時点での経過時間を示す場合がある。したがって、その時点から、算出経過時間が経過するまでの間においては、実際の経過時間は、直前の経過時間と算出経過時間との間の時間となる。
【００５８】
このことを考慮すると、例えば、多少の誤差が許容される場合においては、算出経過時間を、その時点の直後からの経過時間としてもよく、また、算出経過時間を経過するまでは、直前の経過時間を用い、算出経過時間を経過した後から算出経過時間を経過時間としてもよい。
【００５９】
一方、経過時間をより高精度に維持する必要がある場合には、その時点から、算出経過時間が経過するまでの間においては、直前の経過時間から算出経過時間へ所定の変化をするものとして、この変化を示す式（例えば、線形式）に基づいて各時点の経過時間を算出するようにしてもよい。この場合には、データ変換部１０９は、経過時間を算出するために必要な情報を内部に保持しておくようにすればよい。
【００６０】
ステップ６０４では、データ変換部１０９は、センサデータに対し、前チェックポイントの設備ＩＤ及び経過時間を付与した登録用データを作成し、データ格納部１０８に渡す。なお、前チェックポイントの設備ＩＤは、例えば、現場システム５０から予め取得するようにしてもよく、また、設備情報管理テーブル１１４のレコードに、各設備に対する前のチェックポイントの設備ＩＤを格納するようにしておき、設備情報管理テーブル１１４から取得するようにしてもよい。次いで、データ格納部１０８は、渡された登録用データを用いてセンサデータ管理テーブル１１５にレコードを登録する（ステップ６０５）。
【００６１】
次に、トレーサビリティ情報作成表示処理について説明する。
【００６２】
図７は、第１実施形態に係るトレーサビリティ情報作成表示処理のフローチャートである。
【００６３】
トレーサビリティ情報作成表示処理は、例えば、データ管理サーバ１００が、ユーザ端末１０から、トレーサビリティ情報要求を受信した場合に実行される。トレーサビリティ情報要求は、例えば、トレーサビリティ情報を表示させる対象となる日時（指定日時）と、表示させる対象となる設備名（指定場所：チェックポイント）とを含む。なお、トレーサビリティ情報要求において、設備名に代えて、設備ＩＤとしてもよく、チェックポイントを特定できる情報（ポイント特定情報）であればよい。
【００６４】
まず、データ管理サーバ１００のトレース情報取得部１０７は、ユーザＩ／Ｆ１０５を介してトレーサビリティ情報要求を受信すると、トレーサビリティ情報要求を一意に特定するための要求ＩＤを生成し、トレーサビリティ情報要求中の指定日時及び設備名に対応する設備ＩＤをキーとして、センサデータ管理テーブル１１５を参照して、対応するレコードを特定し、特定したレコードからセンサデータを取得し、生成した要求ＩＤと、指定日時と、設備名と、センサデータとを含むレコードをトレース情報管理テーブル１１３に登録する（ステップ７０１）。なお、設備名に対応する設備ＩＤは、設備情報管理テーブル１１４の設備名４０３に、トレーサビリティ情報要求中の設備名を含むレコードから取得することができる。
【００６５】
また、トレース情報取得部１０７は、取得したセンサデータ管理テーブル１１５のレコードに、前チェックポイント情報（前チェックポイントの設備ＩＤ及び経過時間）が存在するか否かを確認する（ステップ７０２）。
【００６６】
この結果、前チェックポイント情報が存在する場合（ステップ７０２：ＹＥＳ）には、トレース情報取得部１０７は、前チェックポイントの設備ＩＤと経過時間とを取得し（ステップ７０３）、現処理プロセスのタイムスタンプから取得した経過時間を遡った日時、すなわち、現処理プロセスと同一の測定対象である水が前チェックポイントを通過した日時（通過日時）を算出する（ステップ７０４）。次いで、トレース情報取得部１０７は、算出した通過日時及び前チェックポイントの設備ＩＤを検索キーとして、センサデータ管理テーブル１１５を参照し、前チェックポイントでの通過日時におけるセンサ値を取得し、生成した要求ＩＤと、通過日時と、前チェックポイントの設備名と、取得したセンサデータとを含むレコードをトレース情報管理テーブル１１３に登録し（ステップ７０５）、処理をステップ７０２に進める。なお、次のステップ７０２では、ステップ７０５で取得したセンサデータ管理テーブル１１５のレコードを対象に処理が行われることとなる。
【００６７】
上記したステップ７０２〜７０５の処理によると、取得されたセンサデータ管理テーブル１１５のレコードにおける前チェックポイント情報に従って、前チェックポイントのセンサデータに対応するレコードを取得する処理（接続先検出データ取得処理）と、このレコードのセンサデータを含むレコードをトレース情報管理テーブル１１３に登録する処理とが、前チェックポイント情報が存在しないレコードが取得されるまで再帰的に実行される。
【００６８】
一方、前チェックポイント情報が存在しない場合（ステップ７０２：ＮＯ）、すなわち、トレーサビリティ情報要求に基づく、前方の処理プロセスについての全てのトレーサビリティ情報の取得が完了した場合には、トレース情報取得部１０７は、トレース情報管理テーブル１１３を参照し、今回の要求ＩＤに一致する全レコード（全トレーサビリティ情報）を取得し、取得した全てのレコードに基づいて、ユーザ端末１０に表示するトレーサビリティ情報画面の画面情報を生成し、ユーザ端末１０に返信する（ステップ７０６）。これにより、ユーザ端末１０の図示しない表示装置に、トレーサビリティ情報画面が表示されることとなる。例えば、トレース情報取得部１０７は、同一の要求ＩＤのレコードの情報を、それぞれの指定日時に基づいて時系列順に並べたり、それぞれの指定場所に応じて処理システムの地図上にマッピングしたりして、トレーサビリティ情報画面を生成する。
【００６９】
以上説明したように、第１実施形態によると、センサデータ管理テーブル１１５の同一のレコードのデータに基づいて、前チェックポイントに対応する設備ＩＤと、取得すべき日時を特定でき、その情報をキーとして、同一のセンサデータ管理テーブル１１５を検索することにより、同一の対象についての前チェックポイントでのセンサデータを取得することができるので、トレーサビリティ情報を抽出する際の処理負荷を低減することができる。
【００７０】
次に、第２実施形態に係る連続体処理管理システムの一例である水処理管理システムについて説明する。なお、第１実施形態に係る水処理管理システムと同様な構成、要素については、同一符号を付すこととし、重複する説明を省略する。
【００７１】
第２実施形態に係る水処理管理システムは、第１実施形態に係る水処理管理システムにおいて、センサデータと、前チェックポイントの設備の設備ＩＤ及び経過時間とをセンサデータ管理テーブル１１５の同一のレコードで管理していたものを、前チェックポイントの設備の設備ＩＤ及び経過時間を、センサデータを管理するテーブル（第１テーブル：センサデータ管理テーブル８１５）とは別のテーブル（第２テーブル：後述する経過時間管理テーブル８１９）で管理するようにしたものである。このように、前チェックポイントの設備の設備ＩＤ及び経過時間を、センサデータを管理するテーブルとは別のテーブルで管理することにより、センサデータを管理するテーブル自体を変更する必要がないので、多くのデータ管理サーバにおいて適用しやすい。
【００７２】
図８は、第１実施形態に係る水処理管理システムの全体構成図である。
【００７３】
水処理管理システム１は、データ管理サーバ１００に代えて、データ管理サーバ８００を備える。データ管理サーバ８００は、第１実施形態に係るデータ管理サーバ１００のセンサデータ管理テーブル１１５に代えて、センサデータ管理テーブル８１５（図９参照）を備え、新たに、経過時間管理テーブル８１９（図１０参照）を備えている。ここで、本実施形態では、センサデータ管理テーブル８１５及び経過時間管理テーブル８１９が検出データ管理情報に対応する。また、データ管理サーバ８００は、第１実施形態に係るデータ管理サーバ１００のトレース情報取得部１０７、データ変換部１０９、及び経過時間算出部１１０に代えて、トレース情報取得部８０７、データ変換部８０９、及び経過時間算出部８１０を備えている。これらトレース情報取得部８０７、データ変換部８０９、及び経過時間算出部８１０の動作については、図１１及び図１２を参照して後述する。
【００７４】
次に、センサデータ管理テーブル８１５について説明する。
【００７５】
図９は、第２実施形態に係るセンサデータ管理テーブルの構成図である。なお、図５に示す第１実施形態に係るセンサデータ管理テーブルと同一部分については、同一の符号を付している。
【００７６】
センサデータ管理テーブル８１５は、タイムスタンプ５０１、設備ＩＤ５０２、及びセンサ値５０３のフィールドを含むレコードを格納する。センサデータ管理テーブル８１５では、レコード毎に、前チェックポイントの設備ＩＤ及び経過時間を格納する必要がないので、センサデータ管理テーブル８１５に必要なデータ容量を低減することができる。
【００７７】
次に、経過時間管理テーブル８１９について説明する。
【００７８】
図１０は、第２実施形態に係る経過時間管理テーブルの構成図である。
【００７９】
経過時間管理テーブル８１９は、各設備の前チェックポイントの設備ＩＤや、経過時間の履歴を管理するテーブルである。経過時間管理テーブル８１９は、例えば、経過時間算出部８１０が経過時間を再計算するタイミングで更新される。経過時間管理テーブル８１９は、設備ＩＤ１００１、有効開始日時１００２、有効終了日時１００３、前チェックポイント設備ＩＤ１００４、及び経過時間１００５のフィールドを含むレコードを格納する。
【００８０】
設備ＩＤ１００１には、センサデータを観測する設備（センサ）の識別子（設備ＩＤ）が格納される。有効開始日時１００２には、レコードにおける情報（前チェックポイントの設備ＩＤ及び経過時間）が有効である期間の開始日時が格納される。有効終了日時１００３には、レコードにおける情報が有効である期間の終了日時が格納される。なお、現在有効である情報を格納しているレコードの有効終了日時１００３には、ＮＵＬＬが格納される。前チェックポイント設備ＩＤ１００４には、レコードに対応する設備ＩＤが設置されている処理プロセスの前（例えば、直前）の処理プロセスに設置された同種の設備を示す識別子（設備ＩＤ）が格納される。経過時間１００５には、現場システムの処理対象である水が、レコードの前チェックポイント設備ＩＤ１００４の設備ＩＤが示す設備が配置された処理プロセスを通過してから、レコードの設備ＩＤ１００１の設備ＩＤが示す設備の処理プロセスを通過するまでの経過時間が格納される。
【００８１】
経過時間管理テーブル８１９において、例えば、設備ＩＤが「９」の設備についての、日時「2017-03-03 12:00:00.000」における前チェックポイントの設備ＩＤと経過時間とを取得する場合には、図１０の１番目のレコードを参照すればよく、設備ＩＤが「９」の設備についての、日時「2017-03-12 12:00:00.000」における前チェックポイントの設備ＩＤと経過時間とを取得する場合には、図１０の２番目のレコードを参照すればよい。このように、経過時間管理テーブル８１９によると、或る時点における前チェックポイントの設備ＩＤと経過時間とを適切に取得することができる。また、経過時間管理テーブル８１９においては、或る設備に対する前チェックポイントの設備ＩＤと経過時間とが変わっていない期間については、センサデータ管理テーブル８１５の同一の設備における複数のセンサデータのレコードに対応するレコードとして、１つのレコードを格納しておけばよい。このため、センサデータ管理テーブルに大量のセンサデータに対応するレコードを格納しておく必要がある場合においては、第１実施形態に示したように、センサデータ管理テーブルにおいてレコード毎に、前チェックポイントの設備ＩＤ及び経過時間を格納しておく場合に比して、経過時間管理テーブル８１９に必要なデータ容量を低減することができる。
【００８２】
次に、データ管理サーバ８００の処理動作について説明する。
【００８３】
図１１は、第２実施形態に係るデータ登録処理のフローチャートである。なお、図６に示すデータ登録処理と同様な部分については同様な符号を付す。
【００８４】
データ登録処理は、データ管理サーバ８００が、現場システム５０からセンサデータを受信した場合に実行される。センサデータは、例えば、センサ５３により観測した時間を示すタイムスタンプと、センサ５３を示す設備ＩＤと、センサ５３により観測されたセンサ値とを含む。
【００８５】
ステップＳ６０２において、経過時間の再計算が不要である場合（ステップ６０２：ＮＯ）には、データ変換部８０９は、処理をステップ１１０５に進める。一方、経過時間の再計算が必要である場合（ステップ６０２：ＹＥＳ）には、データ変換部８０９は、経過時間算出部８１０にこの設備ＩＤの設備についての経過時間の再計算を指示し、指示を受けた経過時間算出部８１０は、設備情報管理テーブル１１４の設備の容積などの仕様情報や、センサデータ管理テーブル８１５の過去のセンサデータや最新のセンサデータを用いて経過時間を算出し、データ変換部８０９が内部に保持している経過時間を、算出した経過時間に更新し（ステップ１１０３）、処理をステップ１１０４に進める。
【００８６】
なお、経過時間算出部１１０がその時点の最新のセンサ値に基づいて算出される経過時間（算出経過時間）は、厳密にいうと、その時点における経過時間ではなく、その時点のセンサ値の状態が維持された場合における経過時間となる場合がある。すなわち、算出経過時間は、その算出経過時間が経過した時点での経過時間を示している。したがって、その時点から、算出経過時間が経過するまでの間においては、実際の経過時間は、直前の経過時間と算出経過時間との間の時間となる。
【００８７】
このことを考慮すると、例えば、多少の誤差が許容される場合においては、算出経過時間を、その時点の直後からの経過時間としてもよく、また、算出経過時間を経過するまでは、直前の経過時間を用い、算出経過時間を経過した後から算出経過時間を経過時間としてもよい。
【００８８】
一方、経過時間をより高精度に維持する必要がある場合には、その時点から、算出経過時間が経過するまでの間においては、直前の経過時間から算出経過時間へ所定の変化をするものとして、この変化を示す式（例えば、線形式）に基づいて各時点の経過時間を算出するようにしてもよい。この場合には、データ変換部８０９は、経過時間を算出するために必要な情報を内部に保持しておくようにすればよい。
【００８９】
ステップ１１０４では、経過時間算出部８１０は、経過時間管理テーブル８１９のこの設備に対応する直前の経過時間に対応するレコードの有効終了日時１００３に現在日時を格納し、さらに、経過時間管理テーブル８１９に新しい経過時間に対応するレコードを追加し、処理をステップ１１０５に進める。ここで、例えば、この時点の直後から経過時間として算出経過時間を用いる場合においては、追加したレコードの設備ＩＤ１００１には、この設備に対応する設備ＩＤを格納し、有効開始日時１００２には、現在日時を格納し、有効終了日時１００３には、「ＮＵＬＬ」を格納し、前チェックポイント設備ＩＤ１００４には、その時点の前チェックポイントの設備の設備ＩＤを格納し、経過時間１００５には、算出した経過時間を格納する。また、例えば、算出経過時間を経過するまでは、直前の経過時間を用い、算出経過時間を経過した後から算出経過時間を経過時間とする場合には、それに対応するようにレコードの更新及び追加を行うようにすればよく、また、その時点から、算出経過時間が経過するまでの間においては、直前の経過時間から算出経過時間への変化を示す式（例えば、線形式）に基づいて各時点の経過時間を算出するようにする場合には、経過時間を算出するために必要な情報をレコードに追加して格納するようにすればよい。
【００９０】
ステップ１１０５では、データ変換部８０９は、センサデータから登録用データを作成し、データ格納部８０８に渡す。次いで、データ格納部８０８は、渡された登録用データを用いてセンサデータ管理テーブル１１５にレコードを登録する（ステップ１１０６）。
【００９１】
次に、トレーサビリティ情報作成表示処理について説明する。
【００９２】
図１２は、第２実施形態に係るトレーサビリティ情報作成表示処理のフローチャートである。
【００９３】
トレーサビリティ情報作成表示処理は、例えば、データ管理サーバ８００が、ユーザ端末１０から、トレーサビリティ情報要求を受信した場合に実行される。トレーサビリティ情報要求は、例えば、トレーサビリティ情報を表示させる対象となる日時（指定日時）と、表示させる対象となる設備名（指定場所）又は設備ＩＤとを含む。
【００９４】
まず、データ管理サーバ８００のトレース情報取得部８０７は、ユーザＩ／Ｆ１０５を介してトレーサビリティ情報要求を受信すると、トレーサビリティ情報要求を一意に特定するための要求ＩＤを生成し、トレーサビリティ情報要求中の指定日時及び設備名をキーとして、センサデータ管理テーブル８１５を参照して、対応するレコードを特定し、特定したレコードからセンサデータを取得し、生成した要求ＩＤと、指定日時と、設備名と、センサ値とを含むレコードをトレース情報管理テーブル１１３に登録する（ステップ１２０１）。
【００９５】
次に、トレース情報取得部８０７は、経過時間管理テーブル８１９を参照し、指定日時及び設備名に対応する設備ＩＤをキーとして、前チェックポイント情報（前チェックポイントの設備ＩＤ及び経過時間）を検索し（ステップ１２０２）、前チェックポイント情報が存在するか否かを確認する（ステップＳ１２０３）。
【００９６】
この結果、前チェックポイント情報が存在する場合（ステップＳ１２０３：ＹＥＳ）には、トレース情報取得部８０７は、経過時間管理テーブル８１９から前チェックポイントの設備ＩＤと経過時間とを取得し（ステップ１２０４）、現処理プロセスのタイムスタンプから取得した経過時間を遡った日時、すなわち、現処理プロセスの測定対象と同一の水が前チェックポイントを通過した日時（通過日時）を算出する（ステップ１２０５）。次いで、トレース情報取得部８０７は、算出した通過日時及び前チェックポイントの設備ＩＤを検索キーとして、センサデータ管理テーブル８１５を参照し、前チェックポイントでの通過日時におけるセンサデータを取得し、生成した要求ＩＤと、通過日時と、全チェックポイントの設備名と、取得したセンサデータのセンサ値とを含むレコードをトレース情報管理テーブル１１３に登録する（ステップ１２０６）。
【００９７】
次いで、トレース情報取得部８０７は、経過時間管理テーブル８１９を参照し、前チェックポイントの設備ＩＤおよび前チェックポイントの通過日時をキーとして、前チェックポイントの設備のさらに前のチェックポイントの設備ＩＤおよび経過時間を取得し（ステップＳ１２０７）、処理をステップ１２０３に進める。
【００９８】
上記したステップ１２０３〜１２０７の処理によると、取得されたセンサデータ管理テーブル８１５のレコードに対応する経過時間管理テーブル８１９に格納された前チェックポイント情報に従って、センサデータ管理テーブル８１５の前チェックポイントのセンサデータに対応するレコードを取得する処理（接続先検出データ取得処理）と、このレコードのセンサデータを含むレコードをトレース情報管理テーブル１１３に登録する処理とが、前チェックポイント情報が存在しなくなるまで再帰的に実行される。
【００９９】
一方、前チェックポイント情報が存在しない場合（ステップ１２０３：ＮＯ）、すなわち、トレーサビリティ情報要求に基づく全てのトレーサビリティ情報の取得が完了した場合には、トレース情報取得部８０７は、トレース情報管理テーブル１１３を参照し、今回の要求ＩＤに一致する全レコード（全トレーサビリティ情報）を取得し、取得した全てのレコードに基づいて、ユーザ端末１０に表示するトレーサビリティ情報画面の画面情報を生成し、ユーザ端末１０に返信する（ステップ１２０８）。例えば、トレース情報取得部１０７は、同一の要求ＩＤのレコードの情報を、それぞれの指定日時に基づいて時系列順に並べたり、それぞれの指定場所に応じて処理システムの地図上にマッピングしたりして、トレーサビリティ情報画面を生成する。
【０１００】
以上説明したように、第２実施形態によると、経過時間管理テーブル８１９を参照することにより、前チェックポイントに対応する設備ＩＤと、前チェックポイントとの間の経過時間を取得でき、センサデータ管理テーブル８１５のレコードから取得される日時と経過時間とに基づいて算出される通過日時と、設備ＩＤと、をキーとして、センサデータ管理テーブル８１５を検索することにより、同一の対象についての前チェックポイントでのセンサデータを取得することができるので、トレーサビリティ情報を抽出する際の処理負荷を低減することができる。
【０１０１】
次に、第３実施形態に係る連続体処理管理システムの一例である水処理管理システムについて説明する。なお、第３実施形態においては、便宜的に、図１に示す第１実施形態に係る水処理管理システムの符号を用いて説明することとする。
【０１０２】
第３実施形態に係る水処理管理システムは、第１実施形態に係る水処理管理システムでは、トレーサビリティ情報要求に指定された設備と、その前方のチェックポイントの設備についてのセンサデータ等をトレースできるようにしていたものを、トレーサビリティ情報要求に指定された設備に対する前方だけでなく、後方のチェックポイントの設備についてのセンサデータ等をトレースできるようにしたものである。
【０１０３】
第３実施形態に係るデータ管理サーバは、センサデータ管理テーブル１１５に代えてセンサデータ管理テーブル１３１５を備える。また、第３実施形態に係るデータ管理サーバは、トレース情報取得部１０７及びデータ変換部１０９による処理に、新たな処理を追加している。
【０１０４】
次に、センサデータ管理テーブル１３１５について説明する。
【０１０５】
図１３は、第３実施形態に係るセンサデータ管理テーブルの構成図である。
【０１０６】
センサデータ管理テーブル１３１５は、センサデータ管理テーブル１１５のレコードに対して、新たに、後チェックポイント設備ＩＤ５０６と、経過時間５０７とのフィールドを追加したものである。後チェックポイント設備ＩＤ５０６には、レコードに対応するセンサデータが観測された設備が設置されている処理プロセスの後（例えば、直後）の処理プロセスに設置された同種の設備を示す識別子が格納される。経過時間５０７には、現場システムの処理対象である水が、レコードの設備ＩＤ５０２の設備ＩＤが示す設備の処理プロセスを通過してから、レコードの後チェックポイント設備ＩＤ５０６の設備ＩＤが示す設備が配置された処理プロセスを通過するまでの経過時間が格納される。
【０１０７】
第３実施形態に係るデータ登録処理について、第１実施形態に係るデータ登録処理と違う点を便宜的に図６を用いて説明する。
【０１０８】
ステップ６０４において、第３実施形態に係るデータ変換部１０９は、センサデータ（本処理の説明において対象センサデータという）に対し、前チェックポイントの設備ＩＤ及び経過時間、後チェックポイントの設備ＩＤを付与した登録用データを作成し、データ格納部１０８に渡す。なお、後チェックポイントの設備ＩＤは、例えば、現場システム５０から予め取得するようにしてもよく、また、設備情報管理テーブル１１４のレコードに、各設備に対する後のチェックポイントの設備ＩＤを格納するようにしておき、設備情報管理テーブル１１４から特定するようにしてもよい。
【０１０９】
また、データ変換部１０９は、センサデータ管理テーブル１３１５から、後チェックポイント設備ＩＤ５０６が対象センサデータを観測した設備ＩＤであり、且つ、タイムスタンプ５０１のタイムスタンプが、対象センサデータのタイムスタンプから前チェックポイントからの経過時間だけ遡った日時であるレコードを特定し、データ格納部１０８に、特定したレコードの経過時間５０７に、前チェックポイントからの経過時間を格納させる。これにより、対象センサデータのチェックポイントを後チェックポイントとするチェックポイントのセンサデータに対応するレコードに対して、適切に後チェックポイントまでの経過時間を格納することができる。
【０１１０】
次に、第３実施形態に係るトレーサビリティ情報作成表示処理について、第１実施形態に係るトレーサビリティ情報作成表示処理と違う点について、便宜的に図７を用いて説明する。
【０１１１】
第１実施形態に係るトレーサビリティ情報作成表示処理においては、ステップ７０２〜７０５の処理により、トレーサビリティ情報要求の対象の設備に対する前方のチェックポイントに関するセンサデータを取得する処理を行うようにしているが、第３実施形態に係るトレーサビリティ情報作成表示処理においては、ステップ７０２〜７０５の処理を実行した後に、ステップ７０２〜７０５と同様な処理により、トレーサビリティ情報要求の対象の設備に対する後方のチェックポイントに関するセンサデータを取得する処理を行う。ここで、後方のチェックポイントに関するセンサデータを取得する処理は、ステップ７０２〜７０５の処理における前チェックポイントを後チェックポイントと読み替え、ステップ７０４においては、現処理プロセスで測定対象となった水が後チェックポイントを通過した日時（通過日時）を、現処理プロセスのタイムスタンプに、取得した経過時間（後チェックポイントまでの経過時間）を加算した日時とすればよい。
【０１１２】
また、ステップ７０６においては、トレース情報取得部１０７は、トレーサビリティ情報要求の対象の設備に対する前方のチェックポイントに関するセンサデータを取得する処理と、トレーサビリティ情報要求の対象の設備に対する後方のチェックポイントに関するセンサデータを取得する処理と、により取得された全てのセンサデータを対象にユーザ画面の画面情報を作成する。
【０１１３】
以上説明したように第３実施形態によると、トレーサビリティ情報要求の対象の設備に対する前方のチェックポイントと後方のチェックポイントとのセンサデータを含む情報をユーザに提供することができる。また、第３実施形態によると、センサデータ管理テーブル１１５の同一のレコードのデータに基づいて、センサデータ管理テーブル１１５を検索することにより、同一の対象についての前チェックポイント及び後チェックポイントのセンサデータを取得することができるので、トレーサビリティ情報を抽出する際の処理負荷を低減することができる。
【０１１４】
なお、本発明は、上述の実施形態に限定されるものではなく、本発明の趣旨を逸脱しない範囲で、適宜変形して実施することが可能である。
【０１１５】
例えば、上記実施形態では、チェックポイント間の経過時間をデータ管理サーバ１００（８００）で算出するようにしていたが、本発明はこれに限られず、例えば、現場システム５０のゲートウェイ５１（外部装置）で算出して、算出結果をデータ管理サーバ１００に通知するようにしてもよい。この場合には、ゲートウェイ５１内に、経過時間を算出するために必要な情報（例えば、設備管理情報テーブル１１４と同様な情報）を格納しておくようすればよい。
【０１１６】
また、上記第２実施形態においては、上記第１実施形態のセンサデータ管理テーブルの一部を別テーブルとして管理するようにして、第１実施形態と同様な処理を実行するようにしていたが、これと同様に、上記第３実施形態におけるセンサデータ管理テーブルの一部を別テーブルとして管理するようにし、第３実施形態と同様な処理を実行するようにしてもよい。具体的には、例えば、第２実施形態に係る経過時間管理テーブル８１９のレコードに、後チェックポイント設備ＩＤ５０６と、経過時間５０７とに対応するフィールドを追加するようにし、第３実施形態と同様な処理を実行するようにしてもよい。このようにすると、トレーサビリティ情報要求の対象の設備に対する前方のチェックポイント及び後方のチェックポイントに関するセンサデータをトレーサビリティ情報として出力することができる。
【０１１７】
また、上記第３実施形態においては、トレーサビリティ情報要求の対象の設備に対する前方のチェックポイント及び後方のチェックポイントに関するセンサデータをトレーサビリティ情報として出力するようにしていたが、本発明はこれに限られず、例えば、トレーサビリティ情報要求の対象の設備とその後方のチェックポイントのトレーサビリティ情報のみを出力するようにしてもよく、要は、トレーサビリティ情報要求の対象の設備とその前方又はその後方の少なくとも一方のチェックポイントのトレーサビリティ情報を出力すればよい。
【０１１８】
また、上記実施形態では、処理対象とする連続体の一例として水を例に説明しているが、本発明はこれに限られず、処理対象とする連続体としては、水以外の液体であってもよく、液体に限らず気体であってもよい。
【０１１９】
また、上記実施形態において、ＣＰＵが行っていた処理の一部又は全部を、ハードウェア回路で行うようにしてもよい。また、上記実施形態におけるプログラムは、プログラムソースからインストールされてよい。プログラムソースは、プログラム配布サーバ又は記憶メディア（例えば可搬型の記憶メディア）であってもよい。
【符号の説明】
【０１２０】
１…水処理管理システム、１０…ユーザ端末、２０…管理者端末、３０，４０…通信路、５０…現場システム、５１…ゲートウェイ、５３…センサ、１００…データ管理サーバ、１０７…トレース情報取得部、１０８…データ格納部、１０９…データ変換部、１１０…経過時間算出部、１１１…データ受信部、１１３…トレース情報管理テーブル、１１４…設備情報管理テーブル、１１５，８１５，１３１５…センサデータ管理テーブル、８１９…経過時間管理テーブル
【図１】
2019020835.tif 000003
【図２】
2019020835.tif 000004
【図３】
2019020835.tif 000005
【図４】
2019020835.tif 000006
【図５】
2019020835.tif 000007
【図６】
2019020835.tif 000008
【図７】
2019020835.tif 000009
【図８】
2019020835.tif 000010
【図９】
2019020835.tif 000011
【図１０】
2019020835.tif 000012
【図１１】
2019020835.tif 000013
【図１２】
2019020835.tif 000014
【図１３】
2019020835.tif 000015