(57)【要約】【課題】分散システムにおける各種の業務アプリケーションを作成する際に、個別の連携先システムの違いに対応するための作り込みをアプリケーションからは排除して、実際のシステムの動作内容、制約等との整合性を維持して必要な処理を実施することによりアプリケーション開発の生産性を向上させる。【解決手段】(1)「インタフェース連携」「タイミング連携」「データ連携」「処理連携」の階層に分け、各階層の処理モジュールは組込み可能とする。(2)連携先の他業務システム・外部システムの状態監視結果及び契約・運用ポリシーにて定める稼動条件を判定して、連携のための(1)の各階層の処理モジュールの組合せや実行内容を変更する。(3)連携先の他業務システムまたは外部システムから応答が無い場合もしくはアプリ要求に対して遅延する場合、 (1)の各階層の処理モジュールの組合せにより代替データ・機能を提供する。【選択図】図１
2015079431.tif 000002
【特許請求の範囲】
【請求項１】
ネットワークを介して相互接続した複数のコンピュータ上に稼働する各種業務アプリケーション間で、データおよび機能を連携して提供する業務システム連携装置であって、
前記ネットワークに接続したコンピュータ上に、
前記ネットワークを介して他コンピュータとの間で通信処理を行うデータ通信部と、
前記データ通信部を介して他コンピュータにて稼動する業務アプリケーションからの要求を受付け、応答を返す、アプリケーション要求受付部と、
各種の業務アプリケーション向けの業務ロジックの選択実行、および他のコンピュータまたは業務アプリケーションが提供する機能の呼出し実行を行う処理連携部と、
前記業務アプリケーションが要求するデータを取得するためのアクセス先となる連携先コンピュータまたは業務アプリケーションの決定・解決、１つ以上の連携先コンピュータまたは業務アプリケーションからの取得データの組合せ、前記要求元業務アプリケーション提供用のデータ構造作成、及びキャッシュの管理を行うデータ連携部と、
バッファの使用、ディレイの実施により連携先コンピュータまたは業務アプリケーションとの処理タイミングや処理周期の違いの調整、優先キューおよび通常キューを用いての前記要求元業務アプリケーションへのデータ提供の優先度制御を行うタイミング連携部と、
前記データ通信部を介して、各種の連携先コンピュータまたは業務アプリケーションに接続するためのプロトコル処理を行うインタフェース連携部と、
前記アプリケーション要求受付部からの指示により、前記要求元業務アプリケーションからの要求に対するデータまたは機能を提供するために、他のコンピュータまたは業務アプリケーションとの連携を行うために実行する前記処理連携部、前記データ連携部、前記タイミング連携部、前記インタフェース連携部の制御を行う連携制御部と、
を備えたことを特徴とする業務システム連携装置。
【請求項２】
請求項１に記載の業務システム連携装置において、
更に、前記業務アプリケーションからの要求に対して、要求に該当するデータまたは機能を１つ以上の連携先コンピュータまたは業務アプリケーションから取得し、組み合わせるための連携処理を実施する際に参照される状態監視テーブルと、
前記データ通信部を介して連携先のコンピュータまたは業務アプリケーションを含めるシステムの稼動状態の監視を行い、監視結果に基づき前記状態監視テーブルを更新する連携先システム監視部と、
前記データ通信部を介して、前記要求元業務アプリケーションの稼動状態の監視を行い、監視結果に基づき前記状態監視テーブルを更新するアプリケーション稼動監視部とを備え、
前記連携制御部が前記状態監視テーブルを参照して、前記処理連携部、前記データ連携部、前記タイミング連携部、前記インタフェース連携部への処理内容変更指示を行うことを特徴とする業務システム連携装置。
【請求項３】
請求項２に記載の業務システム連携装置において、
更に、連携先システムとの契約や運用ポリシーに関する情報を管理し、前記連携先のコンピュータまたは業務アプリケーションを含めるシステムとの連携の有効期間等を監視し、前記状態監視テーブルを更新する契約・運用ポリシー管理部を備えることを特徴とする業務システム連携装置。
【請求項４】
ネットワークを介して相互接続した複数のコンピュータ上に稼働する各種業務アプリケーション間で、データおよび機能を連携して提供する業務システム連携装置が実行する業務システム連携方法であって、
前記各コンピュータの業務アプリケーションの状態を監視するステップと、
前記コンピュータにて一定の制御周期に従って稼動する業務アプリケーションからの要求を受けて、前記業務アプリケーションの要求、またはシステムにて定める契約若しくは運用ポリシーに従って、該当する業務ロジックの選出若しくは他のコンピュータまたは業務アプリケーションで提供される機能の呼び出し、実行を行うことにより処理連携を行うステップと、
前記要求元業務アプリケーションの要求、または前記処理連携を行うステップにて実行される業務ロジック若しくは機能の実行結果、前記各コンピュータまたは業務アプリケーションを含めるシステムの状態監視結果に従って、必要とするデータの取得先を選定することによりデータ連携を行うステップと、
前記各コンピュータまたは業務アプリケーションを含めるシステムの状態監視結果に従って、前記データ連携を行うステップで選定したデータ取得先へのアクセスのタイミングの調整を行うことによるタイミング連携を行うステップと、
前記タイミング連携を行うステップで選定したデータ取得先へのインタフェース、通信プロトコル等の解決と、前記タイミング連携を行うステップで調整したタイミングに従ってアクセス処理を行うことによるインタフェース連携を行うステップと、
前記インタフェース連携を行うステップで取得したデータに対する変換、加工、関連データとの紐付け等を行うことによるデータ連携を行うステップと、
前記データ連携を行うステップでの結果として得られるデータに対して、前記選定された業務ロジックを実行することによる処理連携を行うステップと、
前記の一連の処理の結果としてのデータを前記要求元業務アプリケーションに返すステップとを有することを特徴とする業務システム連携方法。
【請求項５】
請求項１に記載する業務システム連携方法において、
前記インタフェース連携にて、他のコンピュータまたは業務アプリケーションからのデータを受信するステップと、
該データの内容判定に基づき、関連する他データの受信待ち、若しくは前記１つ以上のコンピュータまたは業務アプリケーションを含めるシステム、若しくは共通のデータベースを備えたコンピュータに対して関連する他データの問合せ取得を行うことによるインタフェース連携を行うステップと、
前記受信データ及び取得データの優先度判定を行い、該判定結果に基づき、前記受信データ及び取得データを優先キュー若しくは通常キューに格納することによるタイミング連携を行うステップと、
前記キューから取得したデータに対する変換、加工、関連データとの紐付け等を行うことによるデータ連携を行うステップと、
前記データ連携を行うステップでの結果として得られるデータに対して、選定された業務ロジックを実行すること、若しくは他のコンピュータまたは業務アプリケーションで提供される機能の呼び出し、実行することによる処理連携を行うステップと、
前記の一連の処理の結果としてのデータを前記要求元業務アプリケーションに提供するステップとを更に有することを特徴とする業務システム連携方法。
【請求項６】
請求項４または請求項５に記載の業務システム連携方法において、
前記業務システム連携装置に実装されるインタフェース連携、データ連携、処理連携の各階層における処理モジュールは、接続先の準拠規格、プロトコル、要求元の各々の業務アプリケーションの仕様に応じて各々作成されて、組込まれることを特徴とする業務システム連携方法。
【請求項７】
請求項５に記載の業務システム連携方法おいて、
前記処理連携を行うステップにて、各コンピュータまたは業務アプリケーションで提供される機能として、セキュリティ機能を呼び出し、実行した結果に基づき、前記要求元業務アプリケーションからの要求に対する処理の続行可否を判定する、若しくは記録の関連業務処理を並行実行することを特徴とする業務システム連携方法。
【請求項８】
請求項４または請求項５に記載の業務システム連携方法において、
前記連携されたデータ若しくは機能を使用する前記要求元業務アプリケーションの稼動状態の監視を行い、該要求元業務アプリケーションの周期達成が困難な場合は、代替可否判定に基づき、前記データ連携にて管理するキャッシュを用いて応答することを特徴とする業務システム連携方法。
【請求項９】
請求項８に記載の業務システム連携方法において、
前記連携されたデータ若しくは機能を使用する前記要求元業務アプリケーションの要求するデータが大量であることから１周期内に取得困難である場合は、タイミング連携にて事前収集を開始すること、若しくは該当データが無い場合は、代替可否判定に基づき他のコンピュータまたは業務アプリケーションにアクセスすることを特徴とする業務システム連携方法。
【請求項１０】
請求項４に記載の業務システム連携方法において、
前記他のコンピュータにて稼動する連携先業務アプリケーションの状態監視を行い、連携先コンピュータの業務アプリケーションにおける処理の周期や実行タイミングと、前記連携先コンピュータの業務アプリケーションからのデータや機能の提供を受ける前記要求元業務アプリケーションの周期や実行タイミングが互いにずれる場合、バッファを用いた一時蓄積やディレイの実施により調整を行うことを特徴とする業務システム連携方法。
【請求項１１】
請求項１０に記載の業務システム連携方法において、
前記連携先のコンピュータまたは業務アプリケーションを含めるシステムにて高負荷が発生する場合、該コンピュータまたは業務アプリケーションを含めるシステムへの接続の一時中断と、代替可否判定に基づき、データ連携にて管理するキャッシュを用いて応答すること、又は前記連携先のコンピュータまたは業務アプリケーションを含めるシステムに接続不能である場合、代替可否判定に基づき他のシステムにアクセスすることを特徴とする業務システム連携方法。
【請求項１２】
請求項４に記載の業務システム連携方法において、
設備機器及び制御系アプリケーションから収集するデータを蓄積、管理するデータベースを備えるコンピュータは、１つ以上の制御対象の設備機器及び制御系アプリケーションから継続的に送信される１つ以上のデータを受信し、該データをデータベースに蓄積し、前記要求元業務アプリケーション、または前記連携コンピュータの業務アプリケーションからの要求を受付けて、該当するデータを前記データベースから抽出し、提供することを特徴とする業務システム連携方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、ネットワークを介して相互接続した複数のコンピュータ上に稼働する各種業務アプリケーション間で、データおよび機能を連携して提供する業務システム連携装置およびその連携方法に関する。
【背景技術】
【０００２】
本技術分野の背景技術として、特開２０１１−０９０５１４号公報(特許文献１)がある。この公報には、異なる形式又は種類の業務データを取り扱う複数の情報処理装置間を連携するため、送信側装置から受信側装置へ通信ネットワークを介して形式又は種類の異なる複数種の情報データを伝送し、受信側装置において上記伝送された情報データに対し予め定義された情報処理ロジック及びポリシーに従い当該情報処理ロジックを実行するためのオブジェクトを用意する情報連携システムを開示している。そのシステムでは、送信側装置は、情報データと情報処理ロジック及びポリシーとを含む送信データを送信し、受信側装置は、受信した情報処理ロジックを実行するために必要なオブジェクトを、記憶手段又は前記送信側装置から取得して実行する手段を採用している。
【０００３】
また、特開２００３−１７７９４８号公報(特許文献２)がある。この公報には、ファイルシステム内のデータを含むデータの変換・流通などのデータ管理と業務アプリケーションとを分離、独立化させることを課題として、データ変換ポリシーを含むデータ属性を管理する属性管理手段と、データの変換および／または流通を行うべきタイミングをトリガとして検出するトリガ検出手段と、該トリガが検出された時、前記属性管理手段によって管理されているデータ属性に対応して、データの変換および／または流通の処理を行うデータ変換・流通手段とを備え、前記ファイルシステムを管理するオペレーティングシステムによって管理され、アプリケーションプログラムと独立に動作することを特徴とするデータの変換・流通を行うデータ管理機構が開示されている。
【先行技術文献】
【特許文献】
【０００４】
【特許文献１】特開２０１１−０９０５１４号公報
【特許文献２】特開２００３−１７７９４８号公報
【発明の概要】
【発明が解決しようとする課題】
【０００５】
本発明が対象とするのは、例えばスマートグリッド等の分野における分散システムであり、準拠する標準規格・仕様の異なる、不特定多数の設備機器がシステムに頻繁に着脱し、また異なる業務、異なる業種、異なる主体、異なる範囲内のシステム間での連携も柔軟に行う必要がある。またこれらの設備機器等からのデータのアプリケーションへの提供、異なるシステム間での連携を行う場合、インタフェース・プロトコルやデータ構造・データモデル、処理タイミング等を各々のアプリケーションに特化したものに変換、調整する必要がある。またこれらのアプリケーションも設備機器等を含むシステムに対する制御処理を行い、要求される周期を維持して連続稼動する、といった信頼性を求められる。
【０００６】
しかしながら、上記特許文献１に開示された技術では、データ利用側の業務アプリケーションが多種多様である場合、連携元でこれらの利用側に個別に対応することは困難である。このためある業務アプリケーションが必要とするデータ、機能に対して、連携する各業務システムまたは外部システムの準拠規格（手順、データモデル、インタフェース）は多種類であり、処理タイミングも異なり得る場合、業務アプリにてこれらに個別に追従して連携箇所の処理の作り込みや改修を行う必要があり、負荷が高くなる。
【０００７】
また上記特許文献２に開示された技術では、第一に、データ利用側の業務アプリケーション及び連携元システムがそれぞれのタイミング・周期で実行される場合に、これらのタイミング・周期の調整が困難である。つまり１つ以上の業務アプリケーションからのアクセスが、不特定のタイミングで発生することにより、連携先の他業務システムまたは外部システム側に高負荷発生、制御周期の妨害等を引き起こし、連携先システムでの機能・処理の性能・信頼性を損ね得る。第二に、連携先の他業務システムまたは外部システムから応答が無い場合もしくはアプリ要求に対して遅延する場合、これらのシステムからデータ、機能を取得している業務アプリの処理継続不能もしくは遅延による制御周期の維持不能に陥る場合がある。
【０００８】
本発明は、上述した課題を考慮したものであって、例えばスマートグリッド分野において、システム間の連携も含めて各種の業務アプリケーションを作成する際に、個別の連携先システムの違い、アプリケーション要件、非機能要件に対応するための作り込みをアプリケーションからは排除して、実際のシステムの動作内容、制約等との整合性を維持して必要な処理を実施することによりアプリケーション開発の生産性を向上させるための、分散システムにおける業務システム連携方法を提供することを目的とする。
【課題を解決するための手段】
【０００９】
上記課題を解決するために本発明では、ネットワークを介して相互接続した複数のコンピュータ上に稼働する各種業務アプリケーション間で、データおよび機能を連携して提供する業務システム連携装置を、前記ネットワークに接続したコンピュータ上に、前記ネットワークを介して他コンピュータとの間で通信処理を行うデータ通信部と、前記データ通信部を介して他コンピュータにて稼動する業務アプリケーションからの要求を受付け、応答を返す、アプリケーション要求受付部と、各種の業務アプリケーション向けの業務ロジックの選択実行、および他のコンピュータまたは業務アプリケーションが提供する機能の呼出し実行を行う処理連携部と、前記業務アプリケーションが要求するデータを取得するためのアクセス先となる連携先のコンピュータまたは業務アプリケーションを含めるシステムの決定・解決、１つ以上の連携先のコンピュータまたは業務アプリケーションを含めるシステムからの取得データの組合せ、前記要求元業務アプリケーション提供用のデータ構造作成、及びキャッシュの管理を行うデータ連携部と、バッファの使用、ディレイの実施により連携先コンピュータの業務アプリケーションとの処理タイミングや処理周期の違いの調整、優先キューおよび通常キューを用いての前記要求元業務アプリケーションへのデータ提供の優先度制御を行うタイミング連携部と、前記データ通信部を介して、各種の連携先のコンピュータまたは業務アプリケーションを含めるシステムに接続するためのプロトコル処理を行うインタフェース連携部と、前記アプリケーション要求受付部からの指示により、前記要求元業務アプリケーションからの要求に対するデータまたは機能を提供するために、他のコンピュータまたは業務アプリケーションとの連携を行うために実行する前記処理連携部、前記データ連携部、前記タイミング連携部、前記インタフェース連携部の制御を行う連携制御部と、を備えて構成した。
【００１０】
また、上記課題を解決するために本発明では、前記業務システム連携装置において、更に、前記業務アプリケーションからの要求に対して、要求に該当するデータまたは機能を１つ以上の連携先のコンピュータまたは業務アプリケーションを含めるシステムから取得し、組み合わせるための連携処理を実施する際に参照される状態監視テーブルと、前記データ通信部を介して連携先のコンピュータまたは業務アプリケーションを含めた連例先システムの稼動状態の監視を行い、監視結果に基づき前記状態監視テーブルを更新する連携先システム監視部と、前記データ通信部を介して、前記要求元業務アプリケーションの稼動状態の監視を行い、監視結果に基づき前記状態監視テーブルを更新するアプリケーション稼動監視部とを備え、前記連携制御部が前記状態監視テーブルを参照して、前記処理連携部、前記データ連携部、前記タイミング連携部、前記インタフェース連携部への処理内容変更指示を行うように構成した。
【００１１】
また、上記課題を解決するために本発明では、ネットワークを介して相互接続した複数のコンピュータ上に稼働する各種業務アプリケーション間で、データおよび機能を提供する処理を統合して仲介する業務システム連携装置が実行する業務システム連携方法において、前記各コンピュータの業務アプリケーションの状態を監視するステップと、前記コンピュータにて一定の制御周期に従って稼動する業務アプリケーションからの要求を受けて、前記業務アプリケーションの要求、またはシステムにて定める契約若しくは運用ポリシーに従って、該当する業務ロジックの選出若しくは他のコンピュータまたは業務アプリケーションを含めるシステムで提供される機能の呼び出し、実行を行うことにより処理連携を行うステップと、前記要求元業務アプリケーションの要求、または前記処理連携を行うステップにて実行される業務ロジック若しくは機能の実行結果、前記各コンピュータまたは業務アプリケーションを含めるシステムの状態監視結果に従って、必要とするデータの取得先を選定することによりデータ連携を行うステップと、前記各コンピュータまたは業務アプリケーションを含めるシステムの状態監視結果に従って、前記データ連携を行うステップで選定したデータ取得先へのアクセスのタイミングの調整を行うことによるタイミング連携を行うステップと、前記タイミング連携を行うステップで選定したデータ取得先へのインタフェース、通信プロトコル等の解決と、前記タイミング連携を行うステップで調整したタイミングに従ってアクセス処理を行うことによるインタフェース連携を行うステップと、前記インタフェース連携を行うステップで取得したデータに対する変換、加工、関連データとの紐付け等を行うことによるデータ連携を行うステップと、前記データ連携を行うステップでの結果として得られるデータに対して、前記選定された業務ロジックを実行することによる処理連携を行うステップと、前記の一連の処理の結果としてのデータを前記要求元業務アプリケーションに返すステップとを有するようにした。
【発明の効果】
【００１２】
本発明によれば、アプリケーション開発者は、各種の業務向けにフィールドから収集したデータや他業務システム、外部システムから取得するデータまたは機能を有効活用するためのデータ抽出またはデータアクセスに関連する煩雑な処理を作り込む必要がなく、アプリケーションロジックの開発に専念でき、開発工数の削減、エラー低減に寄与する。
【図面の簡単な説明】
【００１３】
【図１】本発明による分散システムにおける業務システム連携方法の概要を示す図である。
【図２】本発明の適用先である分散システムの概要を示す図である。
【図３】本発明による業務システム連携方法を実施する上での、分散システムを構成する複数のコンピュータ間での全体処理シーケンスを示す図である。
【図４】本発明における分散システムを構成し、前記データ蓄積サーバにおいてデータベースに蓄積するデータ及び、前記業務サーバが提供するデータもしくは機能を連携させて、アプリケーションに提供する、連携サーバのモジュール構成を示す図である。
【図５】本発明における分散システムを構成し、制御系における１つ以上の設備機器及び制御系アプリケーションから収集するデータをデータベースに蓄積、管理し、アプリケーションに対して前記データベースに蓄積するデータを提供する、データ蓄積サーバのモジュール構成を示す図である。
【図６】本発明における連携サーバにて管理される状態監視テーブルの構成を示す図である。
【図７】本発明における連携サーバでの、アプリケーションからの要求に対して、他業務システムまたは外部システムと連携し、データまたは機能を取得し、提供するための処理の流れを示すフローチャートである。
【図８】本発明における連携サーバでの、他業務システムまたは外部システムからデータを受信した際に、他業務システムまたは外部システムと連携し、アプリケーションに対して提供するための処理の流れを示すフローチャートである。
【図９】本発明における連携サーバでの、アプリケーション稼動状態または連携先のシステム稼動状態を監視し、該監視結果に基づき、他業務システムまたは外部システムとの連携方法を変更するための処理の流れを示すフローチャートである。
【図１０】本発明による業務システム連携方法を、配電自動化システム及びＥＶ管理システムとを連携する業務に適用する場合の例を示す図である。
【発明を実施するための形態】
【００１４】
図１は、本発明による分散システムにおける業務システム連携方法の概要を示す図である。
主な構成要素は、データ蓄積サーバ２０２に蓄積するデータ及び、業務サーバ２０４、２０５が提供するデータもしくは機能を連携させて、アプリケーションサーバ２０３におけるアプリケーションへと提供する連携サーバ２０１、制御系における１つ以上の設備機器及び制御系アプリケーションが稼働する１つ以上のコンピュータ２０６からの通信メッセージを制御系専用ネットワーク２１１及びゲートウェイ２０７を介して取得し、該メッセージに含まれるデータをデータベースに蓄積、管理するデータ蓄積サーバ２０２、業務アプリケーションが稼動するアプリケーションサーバ２０３、その他の業務に関するミドルウェアまたはアプリケーションが稼動する業務サーバ２０４、ゲートウェイ２０８及び広域ネットワーク２１２を介して接続する外部システムにおける業務サーバ２０５である。
【００１５】
連携サーバ２０１における処理は、インタフェース連携１０１、タイミング連携１０２、データ連携１０３、処理連携１０４の４つの階層に分類されている。
インタフェース連携１０１においては、他業務システム２０４や各種の連携先システム２０５に接続するために、各々のシステムが準拠するインタフェース規格や通信プロトコルに基づくプロトコル処理を行う。ここでこれらのプロトコル処理は外部定義１１１とともに後付けでも組込み可能とする。
タイミング連携１０２においては、バッファの使用やディレイの実施により他業務システム２０４や連携先システム２０５との処理タイミングや処理周期の違いの調整やキュー（優先キュー及び通常キュー）を用いてのアプリケーションへのデータ提供の優先度制御を行う。
【００１６】
データ連携１０３においては、前記アプリケーションが要求するデータを取得するためのアクセス先、連携先となる他業務システム２０４や外部システム２０５の決定・解決、１つ以上の連携先の他業務システム２０４や外部システム２０５からの取得データの組合せ、アプリケーション提供用のデータ構造作成、キャッシュの管理等を行う。ここで業務アプリケーション向けのデータ構造作成処理、加工処理は、外部定義１１２とともに後付けでも組込み可能とする。
【００１７】
処理連携１０４においては、各種の業務アプリケーション向けの業務ロジックの選択実行もしくは他業務システム２０４や外部システム２０５の提供する機能の呼出し実行を行う。ここで呼出す機能は、例えばセキュリティのための認証処理やログ記録、課金処理、等である。ここで業務アプリケーション向けの業務ロジック処理は、外部定義１１３とともに後付けでも組込み可能とする。
上記により本発明により実現するシステムは、稼動する業務アプリケーションや連携先となる業務システム２０４や外部システム２０５の変更、拡張、入替、に柔軟に対応可能とする。
【００１８】
アプリケーション稼動状態監視１０５、連携先システム状態監視１０７を常に実施して、これらの監視結果に基づいて、インタフェース連携１０１、タイミング連携１０２、データ連携１０３、処理連携１０４の各階層における処理内容の変更を実施する。これらは連携に伴う連携先システムへの負荷、処理妨害を回避し、業務アプリケーションの周期維持及び連携先の他業務システム２０４、外部システム２０５の信頼性保証を実現するためである。
【００１９】
また各々のアプリケーションに対しては、アプリケーション向けインタフェース１０８を介してアクセスさせるため、上記の連携先システムや処理の変更、拡張、入替はアプリケーションに対しては隠蔽する。
上記の各処理の詳細は以降の図にて述べる。
【００２０】
図２は、本発明の適用先である分散システムの概要を示す図である。
主な構成要素は、データ蓄積サーバ２０２に蓄積するデータ及び、業務サーバ２０４、２０５が提供するデータもしくは機能を連携させて、アプリケーションサーバ２０３におけるアプリケーションへと提供する連携サーバ２０１、制御系における１つ以上の設備機器及び制御系アプリケーションが稼働する１つ以上のコンピュータ２０６からの通信メッセージを制御系専用ネットワーク２１１及びゲートウェイ２０７を介して取得し、該メッセージに含まれるデータをデータベースに蓄積、管理するデータ蓄積サーバ２０２、業務アプリケーションが稼動するアプリケーションサーバ２０３、その他の業務に関するミドルウェアまたはアプリケーションが稼動する業務サーバ２０４、ゲートウェイ２０８及び広域ネットワーク２１２を介して接続する外部システムにおける業務サーバ２０５である。
上記の各サーバはそれぞれネットワーク２１１、２１２、２１３、２１４に接続しているが、これらはセキュリティ要件やネットワーク性能要件に基づいて異なる構成をとってもよい。
【００２１】
連携サーバ２０１の主なハードウェア構成は、処理装置（ＣＰＵ）２２１、記憶装置（メモリ、ハードディスク）２２２、通信装置２２３からなる。
データ蓄積サーバ２０２の主なハードウェア構成は、処理装置（ＣＰＵ）２３１、記憶装置（メモリ、ハードディスク）２３２、通信装置２２３からなる。
アプリケーションサーバ２０３の主なハードウェア構成は、処理装置（ＣＰＵ）２４１、記憶装置（メモリ、ハードディスク）２４２、通信装置２４３からなる。
データ蓄積サーバ２０４の主なハードウェア構成は、処理装置（ＣＰＵ）２５１、記憶装置（メモリ、ハードディスク）２５２、通信装置２５３からなる。
外部システムにおける業務サーバ２０５の主なハードウェア構成は、処理装置（ＣＰＵ）２６１、記憶装置（メモリ、ハードディスク）２６２、通信装置２６３からなる。
制御系における１つ以上の設備機器及び制御系アプリケーションが稼働する１つ以上のコンピュータ２０６の主なハードウェア構成は、処理装置（ＣＰＵ）２７１、記憶装置（メモリ、ハードディスク）２７２、通信装置２７３からなる。
ゲートウェイ２０７、２０８の主なハードウェア構成は、処理装置（ＣＰＵ）２８１、記憶装置（メモリ、ハードディスク）２８２、通信装置２８３からなる。
【００２２】
図３は、本発明による業務システム連携方法を実施する上での、分散システムを構成する複数のコンピュータ間での全体処理シーケンスを示す図である。
主な構成要素は、業務アプリケーションが稼動するアプリケーションサーバ２０３、データ蓄積サーバ２０２に蓄積するデータ及び、業務サーバ２０４、２０５が提供するデータもしくは機能を連携させて、アプリケーションに提供する連携サーバ２０１、システム内の制御系等から収集するデータをデータベースに蓄積、管理し、アプリケーションに対してデータを提供するデータ蓄積サーバ２０２、その他の業務に関するミドルウェアまたはアプリケーションが稼動する業務サーバ２０４、外部システムにおける業務サーバ２０５である。
【００２３】
アプリケーションサーバ２０３にて、Ｓ３３１において、業務連携サーバに対してデータまたは処理の実行要求を送信する。
連携サーバ２０１にて、Ｓ３１１において、Ｓ３３１のアプリケーションサーバ２０３からの要求を受付ける。Ｓ３１２において、前記要求を解釈し、データ取得先の決定、処理の割振り、等を行う。Ｓ３１３において、Ｓ３１２の結果に基づき、データ蓄積サーバ２０２に対してデータ要求を送信する。
データ蓄積サーバ２０２にて、Ｓ３２１において、Ｓ３１３の要求内容に基づき、該サーバにて管理するデータベースから該当するデータを抽出する。Ｓ３２２において、Ｓ３２１の抽出データを連携サーバ２０１に対して送信する。
連携サーバ２０１にて、Ｓ３１４において、Ｓ３２２のデータを取得する。Ｓ３１５において、Ｓ３１２の結果に基づき、業務サーバ２０４に対して、データまたは処理実行の要求を送信する。
業務サーバ２０４にて、Ｓ３４１において、Ｓ３１５の要求内容に基づき、該当する処理の実行を行う。Ｓ３４２において、Ｓ３４１の処理結果またはデータを連携サーバ２０１に対して送信する。
連携サーバ２０１にて、Ｓ３１６において、Ｓ３４２の処理結果またはデータを取得する。Ｓ３１７において、Ｓ３１２の結果に基づき、外部システムにおける業務サーバ２０５に対して、データまたは処理実行の要求を送信する。
外部システムにおける業務サーバ２０５にて、Ｓ３５１において、Ｓ３１７の要求内容に基づき、該当する処理の実行を行う。Ｓ３５２において、Ｓ３５１の処理結果またはデータを連携サーバ２０１に対して送信する。
連携サーバ２０１にて、Ｓ３１８において、Ｓ３５２の処理結果またはデータを取得する。なお上記のＳ３１９において、Ｓ３１４、Ｓ３１６、Ｓ３１８にて取得したデータまたは処理結果に基づいて、アプリケーションサーバ２０３に対する応答データの作成、加工と応答可否の判定を行う。Ｓ３１０において、Ｓ３１９の応答データをアプリケーションサーバ２０３に送信する。
アプリケーションサーバ２０３にて、Ｓ３３２において、Ｓ３１０の応答データを取得する。
【００２４】
図４は、本発明における分散システムを構成し、前記データ蓄積サーバ２０２におけるデータベースに蓄積するデータ及び、前記業務サーバが提供するデータもしくは機能を連携させて、アプリケーションに提供する、連携サーバ２０１のモジュール構成を示す図である。
連携サーバ２０１には、データベースに蓄積するデータ及び、他業務システムまたは外部システムが提供する１つ以上のデータもしくは機能を連携させて、アプリケーションに提供するミドルウェア４０１が導入される。
【００２５】
ミドルウェア４０１の主な構成要素は、データ通信部４１０を介してアプリケーションサーバ２０３にて稼動するアプリケーションからの要求を受付け、応答を返す、アプリケーション要求受付部４１１、アプリケーション要求受付部４１１からの指示により、前記アプリケーションからの要求に対するデータまたは機能を提供するために、他業務システムまたは外部システムとの連携を行うために実行する処理連携部４１３、データ連携部４１４、タイミング連携部４１５、インタフェース連携部４１６の制御及び状態監視テーブル４２１を参照して各連携部４１３〜４１６への処理内容変更指示を行う、連携制御部４１２、連携制御部４１２からの指示に従って、各種の業務アプリケーション向けの業務ロジックの選択実行、および他業務システムや外部システムの提供する機能の呼出し実行を行う、処理連携部４１３、連携制御部４１２からの指示に従って、前記アプリケーションが要求するデータを取得するためのアクセス先となる連携先システムの決定・解決、１つ以上の連携先システムからの取得データの組合せ、アプリケーション提供用のデータ構造作成、キャッシュ４２４の管理等を行う、データ連携部４１４、連携制御部４１２からの指示に従って、バッファ４２３の使用やディレイの実施により連携先システムとの処理タイミングや処理周期の違いの調整やキュー４２２（優先キュー及び通常キュー）を用いての前記アプリケーションへのデータ提供の優先度制御を行う、タイミング連携部４１５、連携制御部４１２からの指示に従って、データ通信部４１０を介して、各種の連携先システムに接続するためのプロトコル処理を行う、インタフェース連携部４１６、データ通信部４１０を介して連携先のコンピュータまたは業務アプリケーションを含めた連携先システムの稼動状態の監視を行い、監視結果に基づき状態監視テーブル４２１を更新する、連携先システム監視部４１７、データ通信部４１０を介してアプリケーションサーバ２０３にて稼動するアプリケーションの稼動状態の監視を行い、監視結果に基づき状態監視テーブル４２１を更新する、アプリケーション稼動監視部４１８、連携先システムとの契約や運用ポリシーに関する情報を管理し、前記システムとの連携の有効期間等を監視し、状態監視テーブル４２１を更新する、契約・運用ポリシー管理部４１９、通信媒体２１３を介して他サーバとの間で通信処理を行う、データ通信部４１０である。
【００２６】
処理連携部４１３にて、各種の業務アプリケーション向けの処理を提供する業務ロジックは、ライブラリ４３１として組込み可能とする。データ連携部４１４にて、各種の業務アプリケーション向けのデータ構造の作成、データ加工等の処理は、ライブラリ４３２として組込み可能とする。インタフェース連携部４１６にて、各種の連携先システムと接続するためのプロトコル処理は、ライブラリ４３３として組込み可能とする。
【００２７】
図５は、本発明における分散システムを構成し、制御系における１つ以上の設備機器及び制御系アプリケーションから収集するデータをデータベースに蓄積、管理し、アプリケーションに対して前記データベースに蓄積するデータを提供する、データ蓄積サーバのモジュール構成を示す図である。
【００２８】
データ蓄積サーバ２０２には、データベースへのアクセス管理、アプリケーションや他システムへのインタフェース提供等を行うミドルウェア５０１、システム内で収集し、アプリケーションに提供するデータを蓄積するためのデータベース５０２が導入される。
【００２９】
ミドルウェア５０１の主な構成要素は、データベース５０２へのアクセス処理を行う、データベースアクセス部５１１、データ通信部５１４を介してフィールド機器２０６から送信され、ファイアウォール２０９、ゲートウェイ２０７を経由して転送されてくるデータを受け取り、データベース５０２に格納するデータ格納部５１２、アプリケーションサーバ２０３で稼動するアプリケーションや連携サーバ２０１で稼動するミドルウェアからの要求に対して、データベース５０２に蓄積されるデータを提供する、データ提供部５１３、通信媒体２１３を介して他サーバとの通信処理を行う、データ通信部５１４である。
【００３０】
図６は、本発明における連携サーバにて管理される状態監視テーブルの構成を示す図である。
状態監視テーブル４２１は、アプリケーションからの要求に対して、要求に該当するデータまたは機能を１つ以上の連携先システムから取得し、組み合わせるための連携処理を実施する際に参照される。主な構成要素は、連携先システム状態監視テーブル６０１と連携先データ状態監視テーブル６０２とである。
【００３１】
連携先システム状態監視テーブル６０１の主な構成要素は、システム識別情報６１１、有効期間６１２、契約・運用条件６１３、代替条件６１４、稼動状態６１５、負荷状態６１６、最新更新時刻６１７である。システム識別情報６１１には、連携先システムを識別する情報が格納される。有効期間６１２には、システム識別情報６１１に該当する連携先システムとの連携の有効期間が格納される。前記有効期間は前記連携先システムとの契約、運用条件により決定される。契約・運用条件６１３には、システム識別情報６１１に該当する連携先システムとの契約内容に基づく条件や運用条件が格納される。代替条件６１４には、システム識別情報６１１に該当する連携先システムとの接続不可時の代替システムの要否、代替実施のための条件が格納される。稼動状態６１５には、システム識別情報６１１に該当する連携先システムの最新の稼動状態が格納される。負荷状態６１６には、システム識別情報６１１に該当する連携先システムの最新の負荷状態が格納される。最新更新時刻６１７には、６１１〜６１６のデータが最後に更新された時刻が格納される。
【００３２】
連携先データ状態監視テーブル６０２の主な構成要素は、データ識別情報６２１、システム識別情報６２２、有効期間６２３、契約・運用条件６２４、代替条件６２５、状態６２６、値更新時刻６２７、最新更新時刻６２８である。データ識別情報６２１には、システム内で使用されるデータを識別する情報が格納される。システム識別情報６２２には、データ識別情報６２１に該当するデータの提供元である、連携先システムを識別する情報が格納される。有効期間６２３には、データ識別情報６２１に該当するデータへのアクセスに関する有効期間が格納される。契約・運用条件６２４には、データ識別情報６２１に該当するデータに関して、システム識別情報６２２に該当する連携先システムとの契約内容に基づく条件や運用条件が格納される。代替条件６２５には、データ識別情報６２１に該当するデータへのアクセス不可時の、代替データの要否、代替データへのアクセスのための条件が格納される。状態６２６には、データ識別情報６２１に該当するデータの状態が格納される。値更新時刻６２７には、データ識別情報６２１に該当するデータが最後に更新された時刻が格納される。最新更新時刻６２８には、６２１〜６２７のデータが最後に更新された時刻が格納される。
これらのテーブルに格納される情報は、連携先システム及びデータが登録される度に追加され、連携先システムの状態監視が実施される度に更新される。
【００３３】
図７は、本発明における連携サーバでの、アプリケーションからの要求に対して、他業務システムまたは外部システムと連携し、データまたは機能を取得し、提供するための処理の流れを示すフローチャートである。
Ｓ７０１において、アプリケーションサーバ２０３にて稼動する業務アプリケーションからの要求を受付ける。Ｓ７０２において、Ｓ７０１にて受付けたアプリケーションからの要求内容を解析、判定する。Ｓ７０３において、Ｓ７０２の結果として、外部呼出しが不要である場合、以降のＳ７０４〜Ｓ７０６の処理は実施しない。Ｓ７０３において、Ｓ７０２の結果として、外部呼出しが要である場合、Ｓ７０４において、外部呼出しを実行する。ここで外部呼出しとは、他業務システムまたは外部システムが提供する機能を呼出し、実行することを指す。Ｓ７０５において、外部呼出しの１つとして、セキュリティ判定を行う場合、セキュリティ判定の結果、処理続行不可である場合、Ｓ７０６において、前記アプリケーションに対して異常結果を返送して終了する。ここでセキュリティ判定とは、認証、アクセス権限判定、等を指す。Ｓ７０５において、セキュリティ判定を行わない場合、もしくはセキュリティ判定の結果、処理続行許可である場合、Ｓ７０７において、業務ロジックの実行が不要である場合、以降のＳ７０８の処理は実施しない。Ｓ７０７において、業務ロジックの実行が必要である場合、Ｓ７０８において、該当する業務ロジックの選定を行う。Ｓ７０９において、Ｓ７０２の結果として、アプリケーションが必要とするデータの抽出を行う。ここでアプリケーションが必要とするデータは１つ以上あり、順次抽出、取得する必要があるとする。Ｓ７１０において、Ｓ７０９で抽出したデータがキャッシュにて代替可能である場合、Ｓ７１１において、キャッシュより該当するデータを取得し、Ｓ７０９の処理に戻る。Ｓ７１０において、Ｓ７０９で抽出したデータがキャッシュにて代替不可である場合、Ｓ７１２において、該当データを取得するためのアクセス先の検索及び解決を行う。Ｓ７１３において、連携先データ状態監視テーブル６０２を参照して、該データがアクセス不可である場合、Ｓ７０９の処理に戻る。Ｓ７１３において、連携先データ状態監視テーブル６０２を参照して、該データがアクセス可能である場合、Ｓ７１４において、前記データを取得するための、連携先システムとのタイミング連携処理を実施する。本処理の詳細は図９にて説明する。Ｓ７１５において、前記データを取得するために連携先システムに接続するためのインタフェースの選択を行う。Ｓ７１６において、Ｓ７１５で選択したインタフェースアダプタを実行して、前記連携先システムに接続し、データ取得等を行うためのプロトコル処理を実施する。Ｓ７１７において、Ｓ７１６までの処理の結果として、Ｓ７０２の結果としてアプリケーションの要求に対して必要な全てのデータ取得を完了していない場合、Ｓ７０９の処理に戻る。Ｓ７１７において、Ｓ７１６までの処理の結果として、Ｓ７０２の結果としてアプリケーションの要求に対して必要な全てのデータ取得を完了している場合、Ｓ７１８において、Ｓ７０２の結果として優先度判定に基づき、優先キューまたは通常キューに格納する。優先キューに格納されるデータは優先的にアプリケーションに提供される。一方、通常キューに格納されるデータはキューに格納される順にアプリケーションに提供される。Ｓ７１９において、Ｓ７１７までに取得したデータを、Ｓ７１８のキューから取り出し、Ｓ７０２の結果から、アプリケーションに提供するためのデータ組合せ、加工、データ構造作成を実施する。Ｓ７２０において、業務ロジックの実行が必要でない場合、以降のＳ７２１の処理は実施しない。Ｓ７２０において、業務ロジックの実行が必要である場合、Ｓ７２１において、Ｓ７１９の結果のデータを用いて、業務ロジックの実行を行う。Ｓ７２２において、Ｓ７２１までの処理の結果として、アプリケーションに対して応答結果データを返送する。
【００３４】
図８は、本発明における連携サーバでの、他業務システムまたは外部システムからデータを受信した際に、他業務システムまたは外部システムと連携し、アプリケーションに対して提供するための処理の流れを示すフローチャートである。
Ｓ８０１において、１つのインタフェースアダプタにおいて、他業務システムまたは外部システムからのデータを受信する。Ｓ８０２において、Ｓ８０１にて受信したデータをバッファに格納する。Ｓ８０３において、Ｓ８０１にて受信したデータの判定を行う。ここでは、送信元の特定、該当データを渡すべきアプリケーション、該アプリケーションに渡すべき他のデータの有無、データ加工・データ構造作成の有無、等を判定する。Ｓ８０４において、Ｓ８０３の結果として、他のデータ受信待ちが必要である場合、Ｓ８０１〜Ｓ８０３の処理を繰り返す。Ｓ８０４において、Ｓ８０３の結果として、他のデータ受信待ちが不要である場合、Ｓ８０５において、他業務システムまたは外部システムに対して他データの問合せが必要である場合、Ｓ８０６において、該当する他業務システムまたは外部システムに対して他データの問合せ及び取得を行う。Ｓ８０５において、他業務システムまたは外部システムに対して他データの問合せが不要である場合、Ｓ８０６の処理は実施しない。Ｓ８０７において、Ｓ８０６までに取得したデータの優先度判定を行う。判定結果として優先である場合、Ｓ８０８において、Ｓ８０６までに取得したデータを優先キューに格納する。Ｓ８０７において、優先度判定の結果として通常である場合、Ｓ８０９において、Ｓ８０６までに取得したデータを通常キューに格納する。ここで優先キューに格納されるデータは優先的にアプリケーションに提供される。一方、通常キューに格納されるデータはキューに格納される順にアプリケーションに提供される。Ｓ８１０において、Ｓ８０８またはＳ８０９のキューからデータを取り出し、アプリケーションに提供するためのデータ組合せ、加工、データ構造作成を実施する。Ｓ８１１において、業務ロジックの実行が必要でない場合、以降のＳ８１２の処理は実施しない。Ｓ８１１において、業務ロジックの実行が必要である場合、Ｓ８１２において、Ｓ８１０の結果のデータを用いて、業務ロジックの実行を行う。Ｓ８１３において、Ｓ８０３の結果から、外部呼出しが不要である場合、以降のＳ８１４の処理は実施しない。Ｓ８１３において、Ｓ８０３の結果から、外部呼出しが必要である場合、Ｓ８１４において、外部呼出しを実行する。ここで外部呼出しとは、他業務システムまたは外部システムが提供する機能を呼出し、実行することを指す。Ｓ８１５において、外部呼出しの１つとして、セキュリティ判定を行う場合、セキュリティ判定の結果、処理続行不可である場合、Ｓ８１７において、Ｓ８１４までの処理の結果として得られたデータを破棄して、終了する。ここでセキュリティ判定とは、認証、アクセス権限判定、等を指す。Ｓ８１５において、セキュリティ判定を行わない場合、もしくはセキュリティ判定の結果、処理続行許可である場合、Ｓ８１６において、Ｓ８１４までの処理の結果として得られたデータをアプリケーションへの提供データとして、アプリケーションに送信する。
【００３５】
図９は、本発明における連携サーバでの、アプリケーション稼動状態または連携先のシステム稼動状態を監視し、該監視結果に基づき、他業務システムまたは外部システムとの連携方法を変更するための処理の流れを示すフローチャートである。
主な構成要素は、アプリケーション稼動状態を監視し、該監視結果に基づき、他業務システムまたは外部システムとの連携方法を変更するための処理の流れを示すフローチャートＳ９０１と、連携先のシステム稼動状態を監視し、該監視結果に基づき、他業務システムまたは外部システムとの連携方法を変更するための処理の流れを示すフローチャートＳ９０２である。
【００３６】
フローチャートＳ９０１では、Ｓ９１１において、アプリケーション稼動状態を取得する。Ｓ９１２において、Ｓ９１１で取得したアプリケーション稼動状態が、アプリケーションの所定の周期が達成不能である場合、Ｓ９１４において、該当アプリケーションが必要とするデータが代替可能である場合、Ｓ９１５において、データ連携部４１４にてキャッシュを使用するように変更する。Ｓ９１４において、該当アプリケーションが必要とするデータが代替不可である場合、Ｓ９１６において、例えばエラーメッセージなどを送り、該当アプリケーションを終了させる。Ｓ９１５、Ｓ９１６の処理実施後はＳ９１３の処理へ進む。Ｓ９１２において、Ｓ９１１で取得したアプリケーション稼動状態が、正常である場合、Ｓ９１３において、該当アプリケーションが要求するデータの状態を取得する。Ｓ９１７において、Ｓ９１３で取得した該当アプリケーションが要求するデータの状態が、該当データ無しである場合、Ｓ９１８において、該当アプリケーションが要求する前記データが代替可能である場合、Ｓ９１０において、インタフェース連携部４１６にて他システムにアクセスするように変更する。Ｓ９１８において、該当アプリケーションが要求する前記データが代替不可である場合、Ｓ９３１において、例えばエラーメッセージなどを送り、該当アプリケーションを終了させる。Ｓ９１７において、Ｓ９１３で取得した該当アプリケーションが要求するデータの状態が、大量データ有りで、全データをその都度問合せ取得しようとすると該当アプリケーションの周期を達成できない場合は、Ｓ９１９において、タイミング連携部４１５にて、該当データの事前収集を開始させる。これらの一連の処理は一定の周期で定期的に実施される。
【００３７】
フローチャートＳ９０２では、Ｓ９２１において、連携先システムの状態を取得する。Ｓ９２２において、Ｓ９２１で取得した連携先システム状態として、正常である場合、Ｓ９２１の処理に戻る。Ｓ９２１で取得した連携先システム状態として、アプリケーションとの周期のずれがある場合、Ｓ９２３において、タイミング連携部４１５にて、バッファ、ディレイを用いて、データ送受信のタイミングを調整して、周期ずれを解消する。Ｓ９２１で取得した連携先システム状態として、高負荷発生である場合、Ｓ９２４において、該連携先システムとの接続を一時中断して、データ連携部４１４にてキャッシュを使用する。Ｓ９２１で取得した連携先システム状態として、接続不能である場合、Ｓ９２５において、前記連携先システムが提供するデータが代替可能である場合、Ｓ９２６において、インタフェース連携部４１６にて他システムにアクセスするように変更する。Ｓ９２５において、前記連携先システムが提供するデータが代替不可である場合、Ｓ９２７において、例えばエラーメッセージなどを送り、該連携先システムからのデータを使用するアプリケーションを終了させる。Ｓ９２３乃至Ｓ９２７の処理実施後はＳ９２１の処理へ進む。これらの一連の処理は一定の周期で定期的に実施される。
【００３８】
図１０は、本発明による業務システム連携方法を、配電自動化システム及びＥＶ管理システムを連携する業務に適用する場合の例を示す図である。
配電自動化システム１００１とＥＶ管理システム１００２とは広域ネットワーク１００３を介して相互接続している。配電自動化システム１００１の主な構成要素は、配電機器１０１３からのデータを配電系統ネットワーク１０１４、ゲートウェイ２０７を介して収集し、データベース１０１２に蓄積、管理するデータ蓄積サーバ２０２、配電自動化システム１００１における需給調整等のアプリケーション１０１１が稼動するアプリケーションサーバ０２０３、本発明によるインタフェース連携１０１、タイミング連携１０２、データ連携１０３、処理連携１０４が導入される連携サーバ２０１、広域ネットワーク１００３へのゲートウェイ２０８である。またＥＶ管理システム１００２の主な構成要素は、ＥＶ１０２３に対する充電を行う充電機器１０２２、ＥＶ管理用ネットワーク１０２４、ゲートウェイ１０２５を介して、ＥＶ充電機器１０２２との間で定期的に前記充電機器１０２２の動作に関する計画情報及び実績情報のやり取りを行う、ＥＶ管理アプリケーション１０２１が稼動する、ＥＶ管理システム１００２における業務サーバ２０５、広域ネットワーク１００３へのゲートウェイ１０２６である。
【００３９】
配電自動化システム１００１における需給調整等を実施するアプリケーション１０１１は、定期的に配電系統に接続する設備等の電力使用実績の監視や電力使用計画の収集等を行い、電力需要量の予測及び需給調整を実施している。ここでより精度高く需給調整を行うためには、配電自動化システム１００１とＥＶ管理システム１００２とが連携して、ＥＶ管理システム１００２における、配電系統から大量の電力の供給を受けるＥＶ充電機器１０２２による電力使用実績及び電力使用計画を、配電自動化システム１００１における需給調整等を行うアプリケーション１０１１が定期的に取得できるとよい。ただし配電自動化システム１００１及びＥＶ管理システム１００２は独立した事業主体によるシステムであり、各々異なる構造のデータを扱い、異なる制御周期で稼動する。またそれぞれのシステムの性能、信頼性維持は必須となる。
【００４０】
そこで上記の配電自動化システム１００１とＥＶ管理システム１００２の連携を実現するためには、連携サーバ０２０１を介した連携を行う。配電自動化システム１００１とＥＶ管理システム１００２とでは、準拠する通信プロトコル、アプリケーションの制御周期、扱うデータ構造がお互いに異なるとすると、連携サーバ２０１におけるインタフェース連携１０１にて、ＥＶ管理システム１００２における業務サーバ２０５との間で通信を行うためのプロトコル処理を用意する。タイミング連携１０２にて、バッファもしくはディレイを用いることで、ＥＶ管理システム１００２におけるＥＶ管理アプリケーション１０２１との制御周期または処理タイミングのずれを吸収して、配電自動化システム１００１における需給調整等を行うアプリケーション１０１１の制御周期または処理タイミングに合わせて、前記ＥＶ管理アプリケーション１０２１からのデータを、需給調整等を行うアプリケーション１０１１に提供する。データ連携０１０３にて、ＥＶ管理システム１００２にて用いるデータ構造から配電自動化システム１００１にて用いるデータ構造へと変換する。また各システムで個別に管理されるＩＤ管理体系のマッピングも実施する。
【００４１】
また配電自動化システム１００１とＥＶ管理システム１００２とは異なる事業主体により運営されるシステムであるため、契約による連携内容の取り決め、制限があり得る。そこで連携サーバ２０１における処理連携１０４にて、配電自動化システム１００１における需給調整等を行うアプリケーション１０１１に、ＥＶ管理システム１００２におけるＥＶ管理アプリケーション１０２１から取得したデータを提供する際に、契約に基づく正当な連携を保証するために、認証処理、課金処理、証跡ログ作成処理、等を呼出し、実行する。
【符号の説明】
【００４２】
１０１  インタフェース連携
１０２  タイミング連携
１０３  データ連携
１０４  処理連携
１０５  アプリケーション稼動状態監視
１０６  契約・運用ポリシー管理
１０７  連携先システム状態監視
１０８  アプリケーション向けインタフェース
１１１  外部定義(I/F)
１１２  外部定義(データ)
１１３  外部定義(処理)
２０１  連携サーバ
２０２  データ蓄積サーバ
２０３  業務アプリケーションが稼動するアプリケーションサーバ
２０４  その他の業務アプリケーションが稼動する業務サーバ
２０５  外部システムにおける業務サーバ
２０６  設備機器及び制御系アプリケーションが稼働するコンピュータ
２０７，２０８  ゲートウェイ
２１１，２１２，２１３，２１４  ネットワーク
４０１  ミドルウェア
４１０  データ通信部
４１１  アプリケーション要求受付部
４１２  連携制御部
４１３  処理連携部
４１４  データ連携部
４１５  タイミング連携部
４１６  インタフェース連携部
４１７  連携先システム監視部
４１８  アプリケーション稼動監視部
４１９  契約・運用ポリシー管理部
４２１  状態監視テーブル
４２２  キュー
４２３  バッファ
４２４  キャッシュ
５０１  ミドルウェア
５０２  データベース
５１１  データベースアクセス部
５１２  データ格納部
５１３  データ提供部
５１４  データ通信部
６０１  連携先システム状態監視テーブル
６０２  連携先データ状態監視テーブル
１００１  配電自動化システム
１００２  ＥＶ管理システム
１０１１  需給調整等のアプリケーション
１０１２  データベース
１０１３  配電機器
１０１４  配電系統ネットワーク
１０２１  ＥＶ管理アプリケーション
１０２２  ＥＶ充電機器
１０２３  ＥＶ
１０２４  ＥＶ管理用ネットワーク
１０２５，１０２６  ゲートウェイ
【図１】
2015079431.tif 000003
【図２】
2015079431.tif 000004
【図３】
2015079431.tif 000005
【図４】
2015079431.tif 000006
【図５】
2015079431.tif 000007
【図６】
2015079431.tif 000008
【図７】
2015079431.tif 000009
【図８】
2015079431.tif 000010
【図９】
2015079431.tif 000011
【図１０】
2015079431.tif 000012