JP2004361993A

JP2004361993A - Web service system, flow development support device, flow development support program, and flow development support method

Info

Publication number: JP2004361993A
Application number: JP2003155927A
Authority: JP
Inventors: Shinichi Nagano; 伸一長野; Tetsuo Hasegawa; 哲夫長谷川; Akihiko Osuga; 昭彦大須賀
Original assignee: Toshiba Corp
Current assignee: Toshiba Corp
Priority date: 2003-05-30
Filing date: 2003-05-30
Publication date: 2004-12-24
Anticipated expiration: 2023-05-30
Also published as: JP3947136B2

Abstract

【課題】比較的小さな処理を行うための単位フローを柔軟に組合わせて、全体として論理的な１つのＷｅｂサービスフローを動的に組み立てて実行する。
【解決手段】フロー実行装置２から出力され、プラン名が示された要求情報を要求入力部１３ａにより入力する。この入力された要求情報に示されるプラン名を含むプラン情報を抽出部１３ｂがプランリスト１１から抽出する。抽出されたプラン情報のうちの１つを選択部１３ｃが選択する。この選択されたプラン情報に示されるフロー名に対応する単位フローの実行をフロー実行装置２に対して依頼するための実行要求を出力部１３ｄが出力する。そして、上記の実行要求に対する応答としてフロー実行装置２から出力される実行結果情報を応答入力部１３ｅが入力する。この実行結果情報に応じた結果通知情報を、上記の要求情報に基づく単位フローの実行の結果として通知部１３ｆがフロー実行装置２へ通知する。
【選択図】図１A method for dynamically assembling and executing one logical Web service flow as a whole by flexibly combining unit flows for performing relatively small processing.
A request input unit outputs request information output from a flow execution device and indicating a plan name. The extracting unit 13b extracts the plan information including the plan name indicated in the input request information from the plan list 11. The selection unit 13c selects one of the extracted plan information. The output unit 13d outputs an execution request for requesting the flow execution device 2 to execute the unit flow corresponding to the flow name indicated in the selected plan information. Then, the response input unit 13e inputs execution result information output from the flow execution device 2 as a response to the execution request. The notification unit 13f notifies the flow execution device 2 of the result notification information corresponding to the execution result information as a result of the execution of the unit flow based on the request information.
[Selection diagram] Fig. 1

Description

【０００１】
【発明の属する技術分野】
本発明は、ウェブサービスフローの一部の処理を定義した複数の単位フローを組合わせてウェブサービスフローを展開することでウェブサービスを提供するウェブサービスシステムと、上記単位フローを個別に実行するフロー実行装置によるウェブサービスフローの展開を支援するためのフロー展開支援装置、フロー展開支援プログラムおよびフロー展開支援方法に関する。
【０００２】
【従来の技術】
近年、情報処理技術の進展に伴い、企業内情報システムや企業間商取引システムが備え持つアプリケーションプログラムを、ネットワークを介して呼び出して利用し、計算結果を受け取ることができる新しい仕組みが広まりつつある。このような仕組みはウェブサービス（Ｗｅｂサービス）と呼ばれ、ＷｅｂやＸＭＬ（ｅｘｔｅｎｓｉｂｌｅｍａｒｋｕｐｌａｎｇｕａｇｅ）といったオープンな技術を使って実現されている。現在標準化が進められているＳＯＡＰ（ｓｉｍｐｌｅｏｂｊｅｃｔａｃｃｅｓｓｐｒｏｔｏｃｏｌ）、ＷＳＤＬ（ｗｅｂｓｅｒｖｉｃｅｓｄｅｓｃｒｉｐｔｉｏｎｌａｎｇｕａｇｅ）、ＵＤＤＩ（ｕｎｉｖｅｒｓａｌｄｅｓｃｒｉｐｔｉｏｎ，ｄｉｓｃｏｖｅｒｙａｎｄｉｎｔｅｇｒａｔｉｏｎ）の３つの仕様は、Ｗｅｂサービスの最も基本的な操作である、Ｗｅｂサービスの記述、発見、呼び出しを実現するものである。これらの技術を使うことによって、Ｗｅｂサービス利用者とＷｅｂサービス提供者との間の１対１の連携が可能となる。
【０００３】
しかし、企業内情報システムや企業間商取引システムでは、より複雑なシステム連携が求められている。その実現に向けた新しいソフトウェア技術の研究開発が強く求められている。その１つとして複数のＷｅｂサービスに対する呼び出しをビジネスプロセスやワークフローとして取りまとめる仕組みが挙げられる。現在、複数のＷｅｂサービスに対する呼び出し手順を定義したＷｅｂサービスフローを記述するための標準言語として、ＢＰＥＬ４ＷＳ（ｂｕｓｉｎｅｓｓｐｒｏｃｅｓｓｅｘｅｃｕｔｉｏｎｌａｎｇｕａｇｅｆｏｒｗｅｂｓｅｒｖｉｃｅｓ）、ＷＳＦＬ（ｗｅｂｓｅｒｖｉｃｅｓｆｌｏｗｌａｎｇｕａｇｅ）、ＸＬＡＮＧ、ＷＳＣＩ、ＢＰＭＬ（ｂｕｓｉｎｅｓｓｐｒｏｃｅｓｓｍｏｄｅｌｉｎｇｌａｎｇｕａｇｅ）などの数多くの提案がなされている。これらのＷｅｂサービスフロー記述言語では、１つの論理的なＷｅｂサービスフローを１つのＷｅｂサービスフロー記述として定義する（非特許文献１乃至非特許文献５を参照）。
【０００４】
【非特許文献１】
「Ｗｅｂサービス合成のための振舞い記述のしくみ」、人工知能学会誌、ｖｏｌ．１７，ｎｏ．４，２００２年。
【０００５】
【非特許文献２】
「ＷｅｂＳｅｒｖｉｃｅｓアーキテクチャーの概要」、ｈｔｔｐ：／／ｗｗｗ−６．ｉｂｍ．ｃｏｍ／ｊｐ／ｄｅｖｅｌｏｐｅｒｗｏｒｋｓ／ｗｅｂｓｅｒｖｉｃｅｓ／００１２０１／ｊ＿ｗ−ｏｖｒ．ｈｔｍｌ
【０００６】
【非特許文献３】
「ＷｅｂＳｅｒｖｉｃｅｓアーキテクト：第１回：ダイナミックｅ−ｂｕｓｉｎｅｓｓの紹介」、ｈｔｔｐ：／／ｗｗｗ−６．ｉｂｍ．ｃｏｍ／ｊｐ／ｄｅｖｅｌｏｐｅｒｗｏｒｋｓ／ｗｅｂｓｅｒｖｉｃｅｓ／０１０６０８／ｊ＿ｗｓ−ａｒｃ１．ｈｔｍｌ
【０００７】
【非特許文献４】
「ＢＰＥＬ４ＷＳによるビジネス・プロセス：ＢＰＥＬ４ＷＳについて第１回」、ｈｔｔｐ：／／ｗｗｗ−６．ｉｂｍ．ｃｏｍ／ｊｐ／ｄｅｖｅｌｏｐｅｒｗｏｒｋｓ／ｗｅｂｓｅｒｖｉｃｅｓ／０２１０２５／ｊ＿ｗｓ−ｂｐｅｌｃｏｌ１．ｈｔｍｌ
【０００８】
【非特許文献５】
「ＢｕｓｉｎｅｓｓＰｒｏｃｅｓｓＥｘｅｃｕｔｉｏｎＬａｎｇｕａｇｅｆｏｒＷｅｂＳｅｒｖｉｃｅｓ，Ｖｅｒｓｉｏｎ１。０」、ｈｔｔｐ：／／ｗｗｗ−１０６．ｉｂｍ．ｃｏｍ／ｄｅｖｅｌｏｐｅｒｗｏｒｋｓ／ｗｅｂｓｅｒｖｉｃｅｓ／ｌｉｂｒａｒｙ／ｗｓ−ｂｐｅｌ／，２００２。
【０００９】
【非特許文献１】
「ＷｅｂＳｅｒｖｉｃｅｓＤｅｓｃｒｉｐｔｉｏｎＬａｎｇｕａｇｅ（ＷＳＤＬ）Ｖｅｒｓｉｏｎ１．２」、ｈｔｔｐ：／／ｗｗｗ．ｗ３．ｏｒｇ／ＴＲ／２００３／ＷＤ−ｗｓｄｌ１２−２００３０１２４／，２００３。
【００１０】
【発明が解決しようとする課題】
ところが、大規模なビジネスプロセスでは、プロセスの実行状況に応じて呼び出すＷｅｂサービスを切り替えたいという要求が非常に強い。上記Ｗｅｂサービスフロー記述言語の場合、Ｗｅｂサービス選択の記述をするために、Ｗｅｂサービスフロー内で条件文を多用しなければならない。その結果として、本来Ｗｅｂサービスフローで実現したい意味的な処理に対して、制御文や個々のＷｅｂサービス呼び出し処理の定義の割合が相対的に多くなり、記述が複雑で見通しの悪いＷｅｂサービスフロー定義となってしまっている。
【００１１】
本発明は、このような事情を考慮してなされたものであり、その目的とするところは、比較的小さな処理を行うための単位フローを柔軟に組合わせて、全体として論理的な１つのＷｅｂサービスフローを動的に組み立ててＷｅｂサービスを実現することが可能なウェブサービスシステムを提供することにある。そしてそのために、単位フローを個別に実行するフロー実行装置によるウェブサービスフローの展開を効率的に支援することが可能なフロー展開支援装置、フロー展開支援プログラムおよびフロー展開支援方法を提供することを別の目的とする。
【００１２】
【課題を解決するための手段】
以上の目的を達成するために本発明は、同一種類の複数のウェブサービスを個別に提供するウェブサービス提供装置と、前記ウェブサービスを利用する処理を含む複数の処理の手順をそれぞれ示した複数の単位フローに応じた処理を個別に実行するフロー実行装置と、前記ウェブサービスの種類を示すプラン名とそのウェブサービスを利用する処理の手順を示した前記単位フローのフロー名とを対応付けたプラン情報を記憶するプラン記憶装置と、フロー展開支援装置とを具備し、さらに、前記フロー実行装置に設けられ、前記ユーザ端末からの要求に応じて前記単位フローのうちの１つに応じた処理を起動する第１の起動手段と、前記フロー実行装置に設けられ、前記第１の起動手段により起動された処理に前記プラン名によるフロー呼出しが含まれている場合に当該プラン名を含む呼出し要求を出力する手段と、前記フロー展開支援装置に設けられ、前記呼出し要求を入力する手段と、前記フロー展開支援装置に設けられ、入力された前記呼出し要求に示される前記プラン名を含む前記プラン情報を前記プラン記憶装置から１つ選択する手段と、前記フロー展開支援装置に設けられ、選択された前記プラン情報に示される前記フロー名を示した実行要求を出力する手段と、前記フロー実行装置に設けられ、前記実行要求に示される前記フロー名の前記単位フローに応じた処理を起動する第２の起動手段と、前記フロー実行装置に設けられ、前記第２の起動手段により起動された処理により得られる第１の実行結果情報を前記実行要求に対する回答として出力する手段と、前記フロー展開支援装置に設けられ、前記第１の実行結果情報を入力する手段と、前記フロー展開支援装置に設けられ、入力された前記第１の実行結果情報を前記呼出し要求に対する回答として出力する手段と、前記フロー実行装置に設けられ、前記呼出し要求に対する回答として出力された前記第１の実行結果情報を前記フロー呼出しが指定されていた前記単位フローに応じて実行されている処理で利用するために入力する手段と、前記フロー実行装置に設けられ、前記ユーザ端末からの要求に応じて起動した処理により得られる第２の実行結果情報を前記ユーザ端末からの要求に対する回答として出力する手段とを備えた。
【００１３】
このような手段を講じたことにより、フロー実行装置では、ユーザ端末からの要求に応じて単位フローのうちの１つに応じた処理が起動され、この起動された処理にプラン名によるフロー呼出しが含まれている場合に当該プラン名を含む呼出し要求が出力される。フロー展開支援装置では、上記の呼出し要求が入力され、この入力された呼出し要求に示されるプラン名を含むプラン情報がプラン記憶装置から１つ選択される。さらにフロー展開支援装置では、選択されたプラン情報に示されるフロー名を示した実行要求が出力される。フロー実行装置では、上記の実行要求に示されるフロー名の単位フローに応じた処理が起動され、この処理により得られる第１の実行結果情報が上記の実行要求に対する回答として出力される。フロー展開支援装置では、上記の第１の実行結果情報が入力され、この入力された第１の実行結果情報が上記の呼出し要求に対する回答として出力される。フロー実行装置では、上記の呼出し要求に対する回答として出力された第１の実行結果情報をフロー呼出しが指定されていた単位フローに応じて実行されている処理で利用するために入力される。フロー実行装置では、ユーザ端末からの要求に応じて起動した処理により得られる第２の実行結果情報がユーザ端末からの要求に対する回答として出力される。
【００１４】
【発明の実施の形態】
以下、図面を参照して本発明の一実施形態につき説明する。
図１は本実施形態に係るＷｅｂサービスシステムのブロック図である。
【００１５】
Ｗｅｂサービスフローは、Ｗｅｂサービスに対する呼び出し順序を定義した文書である。最も単純なＷｅｂサービスフローには、一連のＷｅｂサービスを逐次的に読み出すものが挙げられる。また、より複雑なＷｅｂサービスフローでは、Ｗｅｂサービスを選択したり、複数のＷｅｂサービスに対する呼び出しを並列に行う処理を定義できる。
【００１６】
本実施形態のＷｅｂサービスシステムは、あらかじめ意味的な処理の流れを定義した大きなレベルでのフローと、個々の処理の実現方法を定義した小さなレベルでのフローとに分割して定義しておき、上位レベルのフローが必要とする下位レベルのフローを実行時に適宜に呼び出すことによって、全体として論理的な１つのＷｅｂサービスフローを動的に組み立てて実行することができる仕組みを提供するものである。具体的には、小さなレベルのフローとして、航空便の空席検索、航空便の座席予約、宿泊施設の空室検索、あるいは宿泊施設の宿泊予約などといった処理を個々に行うための手順を、また大きなレベルのフローとして、旅行プランを作成する手順をそれぞれ定義しておくことにより、大きさレベルのフローに従って小さなレベルのフローを組合わせることで、旅行プランの作成をするＷｅｂサービスフローを組み立てて実行する。
【００１７】
このＷｅｂサービスシステムは、フロー展開支援装置１、フロー実行装置２、ユーザ端末３およびサービス提供ホスト４−１，４−２，４−３…を含む。そして、これらのフロー展開支援装置１、フロー実行装置２、ユーザ端末３およびサービス提供ホスト４−１，４−２，４−３…は、インターネット５を介して通信可能とされる。
【００１８】
フロー展開支援装置１は、フロー実行装置２がＷｅｂサービスフローを展開するのを支援する。フロー実行装置２は、上記の大きなレベルのフローや小さなレベルのフローに相当する単位フロー２１を複数有しており、この単位フロー２１を個別に実行する。単位フロー２１は、例えば航空会社が提供するＷｅｂサイトへインターネット５を介してアクセスして、当該航空会社に関する空席検索を行うなどの処理である。そしてフロー実行装置２は、インターネット５を介してＷｅｂサービスフロー名を含む要求を受け取ると、指定の単位フロー２１を実行し、その結果を要求元へ返す。このようなフロー実行装置２を実現するアプリケーションプログラムの例として、米ＩＢＭ製のＢＰＷＳ４Ｊ（ｂｕｓｉｎｅｓｓｐｒｏｃｅｓｓｅｘｅｃｕｔｉｏｎｌａｎｇｕａｇｅｆｏｒｗｅｂｓｅｒｖｉｃｅｓＪａｖａ（ＴＭ）ｒｕｎｔｉｍｅ）やＷｅｂＳｐｈｅｒｅＡｐｐｌｉｃａｔｉｏｎＳｅｒｖｅｒなどが知られている。
【００１９】
ユーザ端末３は、インターネット５へのアクセス機能を有したコンピュータ端末である。ユーザ端末３は、Ｗｅｂサービスを受けようとするユーザに対するインタフェース処理を行う。すなわちユーザ端末３は例えば、ユーザ操作に応じてフロー実行装置２に宛てて実行要求を送出したり、フロー実行装置２から返される結果をユーザに提示したりする。
【００２０】
サービス提供ホスト４−１，４−２，４−３…は、上記の空席検索のようなＷｅｂサービスを提供する。
【００２１】
図２はフロー展開支援装置１の構成を示すブロック図である。
図２に示すようにフロー展開支援装置１は、プランリスト１１、実行状態データベース１２および支援処理部１３を含む。
このフロー展開支援装置１は、例えば汎用のサーバ装置やコンピュータ装置を基本ハードウェアとして用いることができる。そして支援処理部１３は、上記のサーバ装置やコンピュータ装置に搭載されたプロセッサにフロー展開支援プログラムを実行させることにより実現することができる。このときに支援処理部１３は、上記のフロー展開支援プログラムがサーバ装置やコンピュータ装置に予めインストールされて実現されても良いし、ＣＤ−ＲＯＭなどのようなリムーバブルな記録媒体に記録して、あるいはネットワークを介して上記のフロー展開支援プログラムを配布し、このフロー展開支援プログラムをサーバ装置やコンピュータ装置に適宜インストールして実現されても良い。プランリスト１１および実行状態データベース１２は、上記のサーバ装置やコンピュータ装置に内蔵されたメモリやハードディスク装置などの記憶デバイス、上記のサーバ装置やコンピュータ装置に外付けされたメモリやハードディスク装置などの記憶デバイス、さらにはフロッピー（Ｒ）ディスクなどのようなリムーバブルな記録媒体などを適宜利用して実現することができる。
【００２２】
プランリスト１１は、Ｗｅｂサービスフローを展開するためのルール情報（メタ情報）を記述したプラン情報（以下では、プランと称する）を複数保持する。
【００２３】
実行状態データベース１２は、Ｗｅｂサービスフローの実行状態を保持する。
【００２４】
支援処理部１３はさらに、要求入力部１３ａ、抽出部１３ｂ、選択部１３ｃ、出力部１３ｄ、応答入力部１３ｅ、通知部１３ｆおよび更新部１３ｇを含む。
【００２５】
要求入力部１３ａは、フロー実行装置２から出力されるフロー展開要求をインターネット５を介して入力する。フロー展開要求には、プラン名およびデータなどが含まれる。要求入力部１３ａは、入力したフロー展開要求に含まれるプラン名を抽出部１３ｂへ出力し、データを更新部１３ｇへ出力する。
【００２６】
抽出部１３ｂは、要求入力部１３ａから出力されるプラン名と同一のプラン名を含み、かつ実行状態データベース１２に記憶された実行状態と所定の関係を持った事前条件を持ったプランをプランリスト１１から全て抽出する。抽出部１３ｂは、抽出したプランを選択部１３ｃへ出力する。抽出部１３ｂは、該当するプランを抽出することができなかった場合には、その旨を通知部１３ｆへ通知する。
【００２７】
選択部１３ｃは、抽出部１３ｂから出力されたプランのうちの１つを選択する。選択部１３ｃは、選択した１つのプランを出力部１３ｄおよび更新部１３ｇへ出力する。
【００２８】
出力部１３ｄは、選択部１３ｃから出力されたプランに示される単位フローの実行要求をフロー実行装置２に宛ててインターネット５へ送出する。
【００２９】
応答入力部１３ｅは、出力部１３ｄが出力した実行要求に基づいて単位フローを実行した結果としてフロー実行装置２が出力する実行結果情報をインターネット５を介して入力する。応答入力部１３ｅは、入力した実行結果情報を通知部１３ｆおよび更新部１３ｇに出力する。
【００３０】
通知部１３ｆは、応答入力部１３ｅが出力した実行結果情報を含んだ結果通知情報を作成し、この結果通知情報をフロー実行装置２に宛ててインターネット５へ送出する。
【００３１】
更新部１３ｇは、要求入力部１３ａから出力されたデータ、選択部１３ｃから出力されたプランに含まれる事後条件、あるいは応答入力部１３ｅから出力された実行結果情報に基づいて実行状態データベース１２に記憶された情報を更新する。
【００３２】
次に以上のように構成されたＷｅｂサービスシステムの動作につき説明する。
ここでは、サービス提供ホスト４−１，４−２，４−３が、ＡＩＲ１，ＡＩＲ２，ＡＩＲ３なる航空会社に関して空席検索や座席予約のＷｅｂサービスを提供することとする。またフロー実行装置２が有する単位フロー２１のうちの１つは、ユーザからの要求に応じて旅行プランを作成する処理を記述したものとする。以降においてこの単位フロー２１は、旅行プラン作成フローと称する。単位フロー２１のうちの３つは、サービス提供ホスト４−１，４−２，４−３がそれぞれ提供するＷｅｂサービスを利用して空席検索を行う処理を記述したものとする。以降においてこれらの単位フロー２１は、空席検索フローと称する。
【００３３】
図３はＷｅｂサービスシステムの各部の間での情報の流れをインターネット５を省略して示した図である。
上記のようにフロー実行装置２は、旅行プラン作成フロー２１−１および空席検索フロー２１−２，２１−３，２１−４を有している。
【００３４】
さて、実行状態データベース１２は、初期状態として空、すなわち実行状態なしとしておいても良いし、事前に１つあるいは複数個の状態を登録しておいても良い。実行状態データベース１２内の状態は、支援処理部１３の実行が進むに連れて、更新部１３ｇからの操作によって削除されたり、新規に追加されたりする。各状態は次に述べる述語と呼ばれるデータ形式で保持される。
【００３５】
以下、述語について述べる。例として、「成田は出発地である」という文を考える。この文は、「成田」という個体が「出発地である」という性質を持っていることを表している。ここで、主語の「成田」という個体に記号「ＮＡＲＩＴＡ」を、文の述語である「出発地である」に記号「ＦＲＯＭ」を与え、「成田は出発地である」という文を「ＦＲＯＭ（ＮＡＲＩＴＡ）」と表現する。この「ＦＲＯＭ（ＮＡＲＩＴＡ）」という表現を述語と呼び、「ＦＲＯＭ」を述語記号と呼ぶ。「ＦＲＯＭ（ＮＡＲＩＴＡ）」は個体「成田」が出発地であることを示すが、不特定の個体が出発地であることを表現するためには、変数「ｆｒｏｍ」を用いて「ＦＲＯＭ（ｆｒｏｍ）」と表す。また、複数個の引数を持つ述語は、「述語記号（引数１，引数２，…）」と表現する。従って例えば、文字列「１２３４５６７」は航空会社「ＡＩＲ１」のマイルアカウントの「ＩＤ」であるという関係は、述語記号「ＩＤ」を用いて「ＩＤ（ＡＩＲ１，１２３４５６７）」と表現する。
【００３６】
ここで、本実施形態にて具体例を説明するために用いる述語を以下に挙げ、それぞれの述語が表す意味を簡単に説明する。
【００３７】
− ＦＲＯＭ（ｆｒｏｍ）：ｆｒｏｍは出発地である。
【００３８】
− ＴＯ（ｔｏ）：ｔｏは目的地である。
【００３９】
− ＤＡＴＥ（ｄａｔｅ）：ｄａｔｅは搭乗日時である。
【００４０】
− ＩＤ（ａｉｒｌｉｎｅ，ｉｄ）：文字列ｉｄは航空会社ａｉｒｌｉｎｅのマイルアカウントＩＤである。
【００４１】
− ＡＶＡＩＬＡＢＬＥ（ｆｌｉｇｈｔ）：フライトｆｌｉｇｈｔは空席がある。
【００４２】
− ＢＥＬ（ｕ，Ｐ）：ユーザｕは述語Ｐについて信じている。
【００４３】
図４は実行状態データベース１２の一例を示す図である。図４に示す実行状態データベース１２は、３つの状態、「ＢＥＬ（ＮＡＧＡＮＯ，ＩＤ（ＡＩＲ１，１２３４５６７））」、「ＢＥＬ（ＨＡＳＥＧＡＷＡ，ＩＤ（ＡＩＲ２、１１１２２２３３３））」、「ＢＥＬ（ＯＨＳＵＧＡ，ＩＤ（ＡＩＲ２，４４４５５５６６６））」を保持している。例えば、「ＢＥＬ（ＮＡＧＡＮＯ，ＩＤ（ＡＩＲ１，１２３４５６７））」は、［ユーザ「ＮＡＧＡＮＯ」は、文字列「１２３４５６７」は航空会社「ＡＩＲ１」のマイルアカウントＩＤであると信じている。］という情報を表す。
【００４４】
プランリスト１１には、プランを予め登録しておく。
上記プランは、プランＩＤ、プラン名、事前条件、フロー呼び出し、ならびに事後条件の５つの項目から構成される。プランＩＤは、プランリスト１１内でユニークな識別子である。プラン名はプランの名前を表す文字列であり、複数の異なるプランに対して同一のプラン名を定義しても良い。事前条件は、プランを選択するための必要条件であり、述語形式で記述する。フロー呼び出しは、フロー実行装置２に対して単位フローの実行を依頼するための情報を定義したものであり、フロー実行装置２が保持している単位フローを特定するためのフロー名と、その単位フローへ渡す引数データと、依頼した結果として受け取ったデータを格納する変数の３種類を指定する。事後条件は、プランを選択し単位フローを呼び出した効果としての条件であり、述語形式で記述する。
【００４５】
図５はプランリスト１１の一例を示す図である。図５に示すプランリスト１１は、３つのプランを保持しており、それぞれのプランＩＤは上から順に「ｐｌａｎ１」、「ｐｌａｎ２」、「ｐｌａｎ３」である。また、いずれも同じプラン名「ｓｅａｒｃｈ」が定義されている。これらの３つのプランは、空席検索フロー２１−２，２１−３，２１−４にそれぞれ対応している。そして「ｓｅａｒｃｈ」は、空席検索に対して割り当てられたプラン名である。
【００４６】
以下、プランＩＤが「ｐｌａｎ１」であるプランを例に取り、その定義について詳細に述べる。
【００４７】
プラン名は「ｓｅａｒｃｈ」である。
【００４８】
事前条件は、以下の通りである。
ＢＥＬ（ｕ，ＦＲＯＭ（ｆｒｏｍ）） ∧
ＢＥＬ（ｕ，ＴＯ（ｔｏ）） ∧
ＢＥＬ（ｕ，ＤＡＴＥ（ｄａｔｅ）） ∧
ＢＥＬ（ｕ，ＩＤ（ＡＩＲ１，ｎｕｍｂｅｒ）
この事前条件は、次の４つの述語の論理積（ＡＮＤ演算）として表されている。
ＢＥＬ（ｕ，ＦＲＯＭ（ｆｒｏｍ））
ＢＥＬ（ｕ，ＴＯ（ｔｏ））
ＢＥＬ（ｕ，ＤＡＴＥ（ｄａｔｅ））
ＢＥＬ（ｕ，ＩＤ（ＡＩＲ１，ｎｕｍｂｅｒ））
すなわち、以下のような条件が表現されている。
ユーザｕは、ｆｒｏｍが出発地であると信じている、かつ
ユーザｕは、ｔｏが目的地であると信じている、かつ
ユーザｕは、ｄａｔｅが搭乗日時であると信じている、かつ
ユーザｕは、文字列ｎｕｍｂｅｒが航空会社ＡＩＲ１のマイルアカウントＩＤであると信じている。
【００４９】
フロー呼び出しは、次の通りである。
ｆｌｉｇｈｔ＝ｃａｌｌ（”ＡＩＲ１ＳｅａｒｃｈＳｅｒｖｉｃｅＦｌｏｗ”，ｆｒｏｍ，ｔｏ，ｄａｔｅ，ｉｄ）
すなわち、航空会社ＡＩＲ１の空席検索サービスを特定するフロー名が「ＡＩＲ１ＳｅａｒｃｈＳｅｒｖｉｃｅＦｌｏｗ」である単位フローを呼び出し、４つの引数データ、ｆｒｏｍ、ｔｏ、ｄａｔｅ、ｉｄ、を渡して、その呼び出し結果として受け取るデータを変数ｆｌｉｇｈｔに格納することを表している。
【００５０】
事後条件は、以下の通りである。
【００５１】
ＢＥＬ（ｕ，ＡＶＡＩＬＡＢＬＥ（ｆｌｉｇｈｔ）） ∧
ＢＥＬ（ｕ，ＩＤ（ＡＩＲ１，ｎｕｍｂｅｒ））
この条件は、［ユーザｕは、フライトｆｌｉｇｈｔに空席があると信じている］ということを表現している。
【００５２】
図６は旅行プランを作成するＷｅｂサービスフローを実行に関するシーケンス図である。
【００５３】
さて、ユーザがユーザ端末３によりフロー実行装置２にアクセスした上で、旅行プランの作成を要求する操作を行ったとする。このときに図６に示すように、ユーザ端末３からフロー実行装置２へ、旅行プラン作成フロー２１−１の実行要求６１が送られる。旅行プラン作成フロー２１−１には、「航空便の空席検索→航空便の座席予約→宿泊施設の空室検索…」といった具合に、旅行プラン作成の手順が定義されるが、各処理の詳細については定義されていない。そこで旅行プラン作成フロー２１−１は、「航空便の空席検索」に対応したプラン名「ｓｅａｒｃｈ」を示したフロー展開要求６２をフロー展開支援装置１へ送る。フロー展開要求６２には、ユーザＩＤ、ならびに他の単位フロー２１へ引き渡すためのデータ等が含まれる。
【００５４】
フロー展開支援装置１ではフロー展開要求６２を受けると、このフロー展開要求に示されるプラン名、ユーザＩＤ、ならびに他のフロー実行部へ引き渡すデータが要求入力部１３ａにより入力される。そしてこのように要求入力部１３ａが上記の各種情報を入力したことに応じて、支援処理部１３では図７に示すような推論処理が開始される。
【００５５】
なお、ユーザＩＤは、上記ユーザを表す識別子であり、例えば、ユーザ名を指定する。また、上記データは、パラメータ名と値との組で表わされ、１組または複数組のいずれが受け渡されても良い。
【００５６】
図７は推論処理のフローチャートである。
ステップＳＴ１では要求入力部１３ａが、上述のようにフロー実行部２ａから出力されたプラン名、ユーザＩＤ、ならびに他のフロー実行部へ引き渡すためのデータを受け取る。
【００５７】
ステップＳＴ２では更新部１３ｇが、要求入力部１３ａにより受け取られたデータに対して、パラメータ名を述語記号とし、値を述語の引数にセットした述語データを生成して、この述語データを実行状態データベース１２に登録する。例えば、ユーザＩＤとして「ＮＡＧＡＮＯ」、出発地に関する入力として、パラメータ名が「ＦＲＯＭ」、値が「ＮＡＲＩＴＡ」から成るデータが要求入力部１３ａにより受け取られた場合は、更新部１３ｇは述語データ「ＢＥＬ（ＮＡＧＡＮＯ，ＦＲＯＭ（ＮＡＲＩＴＡ））」を生成し、これを実行状態データベース１２へ登録する。
【００５８】
ステップＳＴ３では抽出部１３ｂが、プランリスト１１の中から、プラン名が要求入力部１３ａで入力されたものと同じで、かつ実行状態データベース１２内の述語を使って事前条件を単一化できるプランｐを探す。なお単一化できるプランとは、述語に含まれる全ての変数に代入可能な値を持つ述語を見つけることができるプランを指す。
【００５９】
ステップＳＴ４では抽出部１３ｂが、プランｐが存在するか否かを確認する。そして、プランｐが存在したならば、抽出部１３ｂが抽出したプランｐを選択部１３ｃに渡し、ステップＳＴ５に進む。
【００６０】
ステップＳＴ５では選択部１３ｃが、１つのプランｐを選択する。抽出部１３ｂによりプランｐが１つしか抽出されていないのであれば、選択部１３ｃはこの１つのプランｐを選択すればよい。抽出部１３ｂによりプランｐが複数抽出されたのであれば、ある適当な基準のもとで選択すればよい。例えば、最初に抽出部１３ｂにより最初に発見されたものを選択したり、事前条件の述語数の多いものを選択するなどの手法が挙げられる。
【００６１】
ステップＳＴ６では出力部１３ｄが、選択部１３ｃにて選択されたプランｐに関してステップＳＴ３で求めた単一化、すなわち変数への代入を、プランｐで定義しているフロー呼び出しと事後条件との変数に対して適用する。
【００６２】
ステップＳＴ７では出力部１３ｄが、フロー実行装置２を呼び出し、ステップＳＴ６にて求めたフロー呼び出しに含まれる単位フローのフロー名と、その単位フローに引き渡すデータとを含んだ実行要求を送る。
【００６３】
例えば、プラン名「ｓｅａｒｃｈ」に対応する単位フロー２１としては、空席検索フロー２１−２，２１−３，２１−４の３つがあるが、このうちの空席検索フロー２１−２が選択されたのだとするならば、図３および図６に示すように出力部１３ｄから空席検索フロー２１−２へと実行要求６３が送られる。
【００６４】
この実行要求を受けたならばフロー実行装置２は、実行要求に示されたフロー名を持つ単位フローを実行する。この結果、上記の例では、空席検索フロー２１−２が起動されることになる。空席検索フロー２１−２は、サービス提供ホスト４−１が提供するＷｅｂサービスを利用して空席検索を行う手順が記述されたものである。従って空席検索フロー２１−２は、図６に示すようにサービス提供ホスト４−１へ空席検索要求６４を送り、この要求の応答としてサービル提供ホスト４−１から返される空席情報６５を受け取る。さらに空席検索フロー２１−２は、空席情報６５を含んだ実行結果情報６６を、実行要求６３に対する応答として図６に示すようにフロー展開支援装置１へ送る。この実行結果情報６６は、フロー展開支援装置１では応答入力部１３ｅに入力される。
【００６５】
支援処理部１３では、図７におけるステップＳＴ７にて出力部１３ｄが実行要求を出力した後には、ステップＳＴ８に進む。ステップＳＴ８では応答入力部１３ｅが、実行依頼が正常終了したか否かを確認する。そして、実行依頼が正常終了したのであれば、ステップＳＴ９へ進む。
【００６６】
ステップＳＴ９では更新部１３ｇが、応答入力部１３ｅが受け取った実行結果情報６６を、プランｐのフロー呼び出しで指定した変数に代入する。また、単一化した事後条件にも同じ述語が存在する場合には、更新部１３ｇがその述語にも実行結果情報６６を代入する。
【００６７】
ステップＳＴ１０では更新部１３ｇが、ステップＳＴ６で単一化した事前条件に含まれる各述語を実行状態データベース１２から削除し、次にステップＳＴ９で単一化した事後条件に含まれる各述語を実行状態データベース１２へ登録する。
【００６８】
最後にステップＳＴ１１では通知部１３ｆが、応答入力部１３ｅにより受けられた実行結果情報６６の内容を示した結果通知情報６７を、フロー展開要求６２に対する応答として図６に示すように旅行プラン作成フロー２１−１へ送る。
【００６９】
さて、図７におけるステップＳＴ３においてプランｐを見つけることができなかったならば、ステップＳＴ４からステップＳＴ１１へ進む。また、実行依頼が異常終了した場合は、ステップＳＴ８からステップＳＴ１１へ進む。これらの場合にステップＳＴ１１において通知部１３ｆは、結果通知情報６７をフロー展開に失敗したことを示すものとする。
【００７０】
以降、上記と同様な流れにより、航空便の空席予約や宿泊施設の空室検索などが順次行われて行く。そして、これらの処理により得られた各種の情報に基づいて旅行プラン作成フロー２１−１が旅行プランを作成する。この旅行プランを示す実行結果情報６８が、実行要求６１に対する応答として旅行プラン作成フロー２１−１からユーザ端末３へ図６に示すように送られる。
【００７１】
続いて、フロー展開支援装置１の動作についてさらに詳細に説明する。
まずフロー展開要求６２に、プラン名「ｓｅａｒｃｈ」、ユーザＩＤ「ＮＡＧＡＮＯ」、ならびにデータ「（ＦＲＯＭ，ＮＡＲＩＴＡ），（ＴＯ，ＩＴＡＭＩ），（ＤＡＴＥ，２００３／０４／０１１０：００）」が示されているとする。
【００７２】
更新部１３ｇが、データ「（ＦＲＯＭ、ＮＡＲＩＴＡ）」から述語「ＢＥＬ（ＮＡＧＡＮＯ，ＦＲＯＭ（ＮＡＲＩＴＡ））」を、データ「（ＴＯ，ＩＴＡＭＩ）」から述語「ＢＥＬ（ＮＡＧＡＮＯ，ＴＯ（ＩＴＡＭＩ））」を、データ「（ＤＡＴＥ，２００３／０４／０１１０：００）」から「ＢＥＬ（ＮＡＧＡＮＯ，ＤＡＴＥ（２００３／０４／０１１０：００））」をそれぞれ生成し、実行状態データベース１２へ登録する。このとき、実行状態データベース１２は、図４に示す状態から３つの述語が増えて図８に示す状態へと更新される。
【００７３】
一方、抽出部１３ｂが、プラン名「ｓｅａｒｃｈ」を持ち、かつ実行状態データベース１２内の述語を使って事前条件を単一化できるプランｐを探す。
ここでは、プラン名「ｓｅａｒｃｈ」を持つプランは、「ｐｌａｎ１」、「ｐｌａｎ２」、「ｐｌａｎ３」の３つである。
【００７４】
「ｐｌａｎ１」の事前条件は、次の通りである。
ＢＥＬ（ｕ，ＦＲＯＭ（ｆｒｏｍ）） ∧
ＢＥＬ（ｕ，ＴＯ（ｔｏ）） ∧
ＢＥＬ（ｕ，ＤＡＴＥ（ｄａｔｅ）） ∧
ＢＥＬ（ｕ，ＩＤ（ＡＩＲ１，ｎｕｍｂｅｒ））
図８に示される実行状態データベース１２と照らし合わせると、次の５つの全ての変数への代入が、すわなち単一化が可能であることが分かる。
ｕ＝ＮＡＧＡＮＯ
ｆｒｏｍ＝ＮＡＲＩＴＡ
ｔｏ＝ＩＴＡＭＩ
ｄａｔｅ＝２００３／０４／０１１０：００
ｎｕｍｂｅｒ＝１２３４５６７
この時、単一化した事前条件は、次の通りとなる。
ＢＥＬ（ＮＡＧＡＮＯ，ＦＲＯＭ（ＮＡＲＩＴＡ）） ∧
ＢＥＬ（ＮＡＧＡＮＯ，ＴＯ（ＩＴＡＭＩ）） ∧
ＢＥＬ（ＮＡＧＡＮＯ，ＤＡＴＥ（２００３／０４／０１１０：００）） ∧
ＢＥＬ（ＮＡＧＡＮＯ，ＩＤ（ＡＩＲ１，１２３４５６７））
これらの単一化した事前条件は、実行状態データベース１２の各述語と一致する。従って、「ｐｌａｎ１」はプランｐの候補となる。
【００７５】
「ｐｌａｎ２」の事前条件は、次の通りである。
ＢＥＬ（ｕ，ＦＲＯＭ（ｆｒｏｍ）） ∧
ＢＥＬ（ｕ，ＴＯ（ｔｏ）） ∧
ＢＥＬ（ｕ，ＤＡＴＥ（ｄａｔｅ）） ∧
ＢＥＬ（ｕ，ＩＤ（ＡＩＲ２，ｎｕｍｂｅｒ））
図８に示される実行状態データベース１２と照らし合わせると、次の４つの変数への代入が、すなわち単一化が可能である。
ｕ＝ＮＡＧＡＮＯ
ｆｒｏｍ＝ＮＡＲＩＴＡ
ｔｏ＝ＩＴＡＭＩ
ｄａｔｅ＝２００３／０４／０１１０：００
しかし、「ＢＥＬ（ｕ，ＩＤ（ＡＩＲ２、ｎｕｍｂｅｒ））」に対応する述語が実行状態データベース１２に存在しないため、変数「ｎｕｍｂｅｒ」への代入はできない。従って、「ｐｌａｎ２」はプランｐの候補ではない。「ｐｌａｎ３」についても同様に、「ＢＥＬ（ｕ，ＩＤ（ＡＩＲ３，ｎｕｍｂｅｒ））」に対応する述語が実行状態データベース１２に存在しないため、変数「ｎｕｍｂｅｒ」への代入はできない。従って、「ｐｌａｎ３」もプランｐの候補ではない。
【００７６】
以上のようにして、抽出部１３ｂではプランｐとして「ｐｌａｎ１」が抽出される。このとき、１つのプランのみが抽出されたのであるから、選択部１３ｃは上記の「ｐｌａｎ１」をそのまま選択する。
【００７７】
出力部１３ｄが、「ｐｌａｎ１」の事前条件に対する単一化を、「ｐｌａｎ１」のフロー呼び出しおよび事後条件に適用する。「ｐｌａｎ１」のフロー呼び出しは、次の通りである。
ｆｌｉｇｈｔ＝ｃａｌｌ（”ＡＩＲ１ＳｅａｒｃｈＳｅｒｖｉｃｅＦｌｏｗ”，ｆｒｏｍ，ｔｏ，ｄａｔｅ，ｎｕｍｂｅｒ）
このフロー呼び出しに対して単一化を適用すると、次の通りとなる。
ｆｌｉｇｈｔ＝ｃａｌｌ（”ＡＩＲ１ＳｅａｒｃｈＳｅｒｖｉｃｅＦｌｏｗ”，ＮＡＲＩＴＡ，ＩＴＡＭＩ，２００３／０４／０１
１０：００，１２３４５６７）
また、事後条件は、次の通りである。
ＢＥＬ（ｕ，ＡＶＡＩＬＡＢＬＥ（ｆｌｉｇｈｔ）） ∧
ＢＥＬ（ｕ，ＩＤ（ＡＩＲ１，ｎｕｍｂｅｒ）
この事後条件に対して単一化を適用すると、次の通りとなる。
ＢＥＬ（ＮＡＧＡＮＯ，ＡＶＡＩＬＡＢＬＥ（ｆｌｉｇｈｔ）） ∧
ＢＥＬ（ＮＡＧＡＮＯ，ＩＤ（ＡＩＲ１，１２３４５６７）
変数「ｆｌｉｇｈｔ」に関しては、この段階では変数のままとする。
【００７８】
次に出力部１３ｄは、フロー実行装置２に対して実行要求６３を送る。この実行要求６３には、上記の単一化したフロー呼び出しから、Ｗｅｂサービスフロー名「ＡＩＲ１ＳｅａｒｃｈＳｅｒｖｉｃｅＦｌｏｗ」と、４つのデータ「ＮＡＲＩＴＡ」、「ＩＴＡＭＩ」、「２００３／０４／０１１０：００」、「１２３４５６７」とを含める。「ＡＩＲ１ＳｅａｒｃｈＳｅｒｖｉｃｅＦｌｏｗ」は、空席検索フロー２１−２に付与されたＷｅｂサービスフロー名である。このため、実行要求６３により空席検索フロー２１−２が起動される。
【００７９】
空席検索フロー２１−２により空席便「ＡＩＲ１−０７９」が見つかったものとする。この場合、この「ＡＩＲ１−０７９」を含んだ実行結果情報６６が空席検索フロー２１−２から返されることになる。そしてこの実行結果情報６６は応答入力部１３ｅで入力され、更新部１３ｇに渡される。更新部１３ｇでは、実行結果情報６６に含まれた上記の「ＡＩＲ１−０７９」を、単一化したフロー呼び出しの変数「ｆｌｉｇｈｔ」へ代入する。従って、変数「ｆｌｉｇｈｔ」の値は「ＡＩＲ１−０７９」となる。このとき、前述の単一化した事後条件は、次の通りとなる。
ＢＥＬ（ＮＡＧＡＮＯ，ＡＶＡＩＬＡＢＬＥ（ＡＩＲ１−０７９）） ∧
ＢＥＬ（ＮＡＧＡＮＯ，ＩＤ（ＡＩＲ１，１２３４５６７）
続いて更新部１３ｇは、次のデータを実行状態データベース１２から削除する。
ＢＥＬ（ＮＡＧＡＮＯ，ＦＲＯＭ（ＮＡＲＩＴＡ））
ＢＥＬ（ＮＡＧＡＮＯ，ＴＯ（ＩＴＡＭＩ））
ＢＥＬ（ＮＡＧＡＮＯ，ＤＡＴＥ（２００３／０４／０１１０：００））
ＢＥＬ（ＮＡＧＡＮＯ，ＩＤ（ＡＩＲ１，１２３４５６７））
これとともに更新部１３ｇは、前述の単一化した事後条件に含まれる次の２つの述語を実行状態データベース１２に追加する。
ＢＥＬ（ＮＡＧＡＮＯ，ＡＶＡＩＬＡＢＬＥ（ＡＩＲ１−０７９））
ＢＥＬ（ＮＡＧＡＮＯ，ＩＤ（ＡＩＲ１，１２３４５６７）
従って、実行状態データベース１２は図８の状態から図９の状態へと更新される。
最後に通知部１３ｆが、「ＡＩＲ１−０７９」を示した結果通知情報６７を、呼び出し元である旅行プラン作成フロー２１−１へ送る。
【００８０】
以上のように本実施形態によれば、フロー展開支援装置１はフロー展開要求を受け取るたびに、その要求に応じて適切な単位フロー２１を１つ選択し、この単位フロー２１の実行を要求する。またフロー展開支援装置１は、要求した単位フロー２１を実行した結果得られる情報を、フロー展開要求元の単位フロー２１へと返す。従って、フロー実行装置２においては、１つの単位フロー２１から間接的に他の単位フロー２１を呼び出すことができる。そしてこの結果として、複数の単位フロー２１を柔軟に組合わせて１つの論理的なＷｅｂサービスフローを構築して実行することが可能となる。
【００８１】
また本実施形態によれば、例えば単位フローが新たに追加されたような場合には、プランリスト１１を更新することにより、上記の新たに追加された単位フローを利用可能とすることができる。具体的には、ＡＩＲ４なる航空会社の空席検索Ｗｅｂサービスに対する呼び出しを行う単位フローが追加されたとするならば、プラン名が「ｓｅａｒｃｈ」であり、フロー呼び出しを「ｆｌｉｇｈｔ＝ｃａｌｌ（”ＡＩＲ４ＳｅａｒｃｈＳｅｒｖｉｃｅＦｌｏｗ”，ｆｒｏｍ，ｔｏ，ｄａｔｅ，ｉｄ）」としたプランをプランリスト１１に追加することにより、前述の旅行の計画を立てる単位フローは何ら修正しなくとも、この旧来からある単位フローから上記の新しく追加された単位フローを呼び出して使用することが可能である。すなわち本実施形態によれば、個々の単位フローの開発は、他の単位フローの詳細を考慮することなく行うことができる。また、Ｗｅｂサービスフローの拡張も、一部の単位フローの更新や追加などにより容易に行うことが可能となる。
【００８２】
また本実施形態によれば、プランに事前条件を含めるとともに、Ｗｅｂサービスフローの実行状態を実行状態データベース１２に記憶しておき、実行状態データベース１２内の情報を使って事前条件を単一化できるプランを抽出することとしているので、Ｗｅｂサービスフローの実行状態に応じて適切な単位フローを実行させることができる。
【００８３】
この実施形態は、次のような種々の変形実施が可能である。
プランリスト１１および実行状態データベース１２はフロー展開支援装置１に含まれていなくても良い。その場合、フロー展開支援装置１からプランリスト１１および実行状態データベース１２へアクセスするための通信手段をフロー展開支援装置１に設ける。
【００８４】
プランリスト１１からのプランの抽出は、プラン名のみに基づいて行うようにしても良い。この場合、プランには事前条件および事後条件を含まなくて良い。また実行状態データベース１２は不要となる。
【００８５】
実行状態データベース１２の更新には、事後条件を考慮しなくても良い。
【００８６】
フロー実行装置２は１つである必要はなく、複数のフロー実行装置２がそれぞれ持つ単位フロー２１を適宜に展開するようにしても良い。
【００８７】
各単位フロー２１が示す処理内容は任意であって良い。そして、ユーザ端末３とのインタフェース処理が示された単位フロー２１は、他の単位フロー２１を１度のみ利用するものであっても良い。
【００８８】
なお、本発明は上記実施形態そのままに限定されるものではなく、実施段階ではその要旨を逸脱しない範囲で構成要素を変形して具体化できる。また、上記実施形態に開示されている複数の構成要素の適宜な組み合わせにより、種々の発明を形成できる。例えば、実施形態に示される全構成要素から幾つかの構成要素を削除してもよい。さらに、異なる実施形態にわたる構成要素を適宜組み合わせてもよい。
【００８９】
【発明の効果】
本発明によれば、比較的小さな処理を行うための単位フローを柔軟に組合わせて、全体として論理的な１つのＷｅｂサービスフローを動的に組み立てて実行することが可能となる。
【図面の簡単な説明】
【図１】本発明の一実施形態に係るＷｅｂサービスシステムのブロック図。
【図２】図１中のフロー展開支援装置１の構成を示すブロック図。
【図３】Ｗｅｂサービスシステムの各部の間での情報の流れを示した図。
【図４】図２中の実行状態データベース１２の一例を示す図。
【図５】図２中のプランリスト１１の一例を示す図。
【図６】旅行プランを作成するＷｅｂサービスフローを実行に関するシーケンス図。
【図７】推論処理のフローチャート。
【図８】図２中の実行状態データベース１２の更新例を示す図。
【図９】図２中の実行状態データベース１２の更新例を示す図。
【符号の説明】
１…フロー展開支援装置、２…フロー実行装置、２ａ，２ｂ…フロー実行部、１１…プランリスト、１２…実行状態データベース、１３…支援処理部、１３ａ…要求入力部、１３ｂ…抽出部、１３ｃ…選択部、１３ｄ…出力部、１３ｅ…応答入力部、１３ｆ…通知部、１３ｇ…更新部。[0001]
TECHNICAL FIELD OF THE INVENTION
The present invention provides a web service system that provides a web service by developing a web service flow by combining a plurality of unit flows that define a part of the processing of the web service flow, and a flow that individually executes the unit flow. The present invention relates to a flow development support device, a flow development support program, and a flow development support method for supporting development of a web service flow by an execution device.
[0002]
[Prior art]
In recent years, with the progress of information processing technology, a new mechanism that can use an application program provided in an in-company information system or an inter-company business transaction system by calling it via a network and receiving a calculation result is spreading. Such a mechanism is called a web service (Web service), and is realized by using an open technology such as the Web or XML (extensible markup language). Currently, SOAP (simple object access protocol), WSDL (web services description language), UDDI (universal description service, the operation of the basic operation of the description and the operation of the description and operation, which is the basic operation of the description and operation) are described. It describes, discovers, and invokes services. By using these technologies, one-to-one cooperation between a Web service user and a Web service provider becomes possible.
[0003]
However, in-house information systems and inter-company commerce systems require more complex system cooperation. There is a strong need for research and development of new software technologies to achieve this. As one of them, there is a mechanism for collecting calls to a plurality of Web services as a business process or a workflow. Currently, as a standard language for describing a Web service flow that defines a calling procedure for a plurality of Web services, BPEL4WS (business process execution language for web services), WSFL (web services flow, LANG, XLANG, XLANG, XLAN, XA, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANXG, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANX, LANXG, LANX, LANX, LANX, LAN, X, X, and X) Numerous proposals have been made, such as process modeling language. In these Web service flow description languages, one logical Web service flow is defined as one Web service flow description (see Non-Patent Documents 1 to 5).
[0004]
[Non-patent document 1]
"A Mechanism of Behavior Description for Web Service Composition", Journal of the Japanese Society for Artificial Intelligence, vol. 17, no. 4, 2002.
[0005]
[Non-patent document 2]
"Overview of Web Services Architecture", http: // www-6. ibm. com / jp / developerworks / webservices / 001201 / j_w-ovr. html
[0006]
[Non-Patent Document 3]
"Web Services Architect: Part 1: Introduction to Dynamic e-business", http: // www-6. ibm. com / jp / developerworks / webservices / 010608 / j_ws-arc1. html
[0007]
[Non-patent document 4]
"Business Process by BPEL4WS: 1st about BPEL4WS", http: // www-6. ibm. com / jp / developerworks / webservices / 021025 / j_ws-bpelcol1. html
[0008]
[Non-Patent Document 5]
"Business Process Execution Language for Web Services, Version 1.0", http: // www-106. ibm. com / developerworks / webservices / library / ws-bpel /, 2002.
[0009]
[Non-patent document 1]
"Web Services Description Language (WSDL) Version 1.2", http: // www. w3. org / TR / 2003 / WD-wsdl12-20030124 /, 2003.
[0010]
[Problems to be solved by the invention]
However, in a large-scale business process, there is a very strong demand to switch a Web service to be called according to the execution state of the process. In the case of the Web service flow description language, conditional statements must be frequently used in the Web service flow in order to describe Web service selection. As a result, the ratio of the definition of the control statement and the individual Web service call processing is relatively increased with respect to the semantic processing that is originally desired to be realized by the Web service flow, and the description is complicated and the Web service flow definition with poor visibility is difficult. It has become.
[0011]
The present invention has been made in view of such circumstances, and an object of the present invention is to flexibly combine unit flows for performing relatively small processing to form one logical Web as a whole. An object of the present invention is to provide a web service system capable of realizing a web service by dynamically assembling a service flow. For this purpose, it is necessary to separately provide a flow development support device, a flow development support program, and a flow development support method capable of efficiently supporting the development of a web service flow by a flow execution device that individually executes a unit flow. The purpose of.
[0012]
[Means for Solving the Problems]
In order to achieve the above object, the present invention provides a web service providing apparatus that individually provides a plurality of web services of the same type, and a plurality of procedures each showing a procedure of a plurality of processes including a process using the web service. A flow execution device that individually executes a process according to a unit flow, and a plan in which a plan name indicating the type of the web service is associated with a flow name of the unit flow indicating a procedure of a process using the web service A plan storage device for storing information; and a flow development support device, further provided in the flow execution device, for performing a process corresponding to one of the unit flows in response to a request from the user terminal. A first activating means for activating, and a flow call by the plan name provided to the process executed by the first activating means provided in the flow executing device. Is included, means for outputting a call request including the plan name, means provided in the flow expansion support device, means for inputting the call request, and means provided in the flow expansion support device for input. Means for selecting one of the plan information including the plan name indicated in the call request from the plan storage device, and indicating the flow name provided in the flow expansion support device and indicated in the selected plan information. Means for outputting the execution request, the second execution means provided in the flow execution device, for starting a process corresponding to the unit flow having the flow name indicated in the execution request, and the second execution means provided in the flow execution device. Means for outputting, as a response to the execution request, first execution result information obtained by the process started by the second starting means; Means for inputting the first execution result information provided in the expansion support device, and means for outputting the input first execution result information as a response to the call request, provided for the flow expansion support device To use the first execution result information provided in the flow execution device and output as a response to the call request in a process executed according to the unit flow for which the flow call is specified. And a means provided in the flow execution device and outputting second execution result information obtained by a process activated in response to a request from the user terminal as a response to the request from the user terminal. Equipped.
[0013]
By taking such means, in the flow execution device, a process corresponding to one of the unit flows is started in response to a request from the user terminal, and a flow call by a plan name is included in the started process. If it is included, a call request including the plan name is output. In the flow development support device, the above-described call request is input, and one piece of plan information including the plan name indicated in the input call request is selected from the plan storage device. Further, the flow deployment support device outputs an execution request indicating the flow name indicated in the selected plan information. In the flow execution device, a process corresponding to the unit flow of the flow name indicated in the above-mentioned execution request is started, and the first execution result information obtained by this process is output as a response to the above-mentioned execution request. In the flow development support device, the first execution result information is input, and the input first execution result information is output as a response to the call request. In the flow execution device, the first execution result information output as a response to the above-described call request is input for use in a process executed in accordance with the unit flow for which the flow call is specified. In the flow execution device, the second execution result information obtained by the process started in response to the request from the user terminal is output as a response to the request from the user terminal.
[0014]
BEST MODE FOR CARRYING OUT THE INVENTION
Hereinafter, an embodiment of the present invention will be described with reference to the drawings.
FIG. 1 is a block diagram of a Web service system according to the present embodiment.
[0015]
The Web service flow is a document that defines the calling order for the Web service. The simplest Web service flow is one that sequentially reads out a series of Web services. Further, in a more complicated Web service flow, it is possible to define a process for selecting a Web service or performing a call for a plurality of Web services in parallel.
[0016]
The Web service system according to the present embodiment is divided into a large-level flow in which a semantic processing flow is defined in advance and a small-level flow in which a method of realizing each processing is defined. The present invention provides a mechanism capable of dynamically assembling and executing one logical Web service flow as a whole by appropriately calling a lower-level flow required by an upper-level flow at the time of execution. Specifically, as a small-level flow, procedures for individually performing processes such as air flight vacancy search, air flight seat reservation, accommodation vacancy search, or accommodation accommodation reservation are performed. By defining a procedure for creating a travel plan as a level flow, a web service flow for creating a travel plan is assembled and executed by combining small-level flows according to a size-level flow. .
[0017]
This Web service system includes a flow deployment support device 1, a flow execution device 2, a user terminal 3, and service providing hosts 4-1, 4-2, 4-3,... The flow development support device 1, the flow execution device 2, the user terminal 3, and the service providing hosts 4-1, 4-2, 4-3... Can communicate via the Internet 5.
[0018]
The flow development support device 1 supports the flow execution device 2 to develop a Web service flow. The flow execution device 2 has a plurality of unit flows 21 corresponding to the large-level flows and the small-level flows, and executes the unit flows 21 individually. The unit flow 21 is a process of, for example, accessing a Web site provided by an airline via the Internet 5 and performing a vacancy search for the airline. When receiving the request including the Web service flow name via the Internet 5, the flow execution device 2 executes the specified unit flow 21, and returns the result to the request source. Examples of application programs for realizing such a flow execution device 2 include BPWS4J (business process execution language for web services Java (TM) run time) and WebSphere Application from IBM.
[0019]
The user terminal 3 is a computer terminal having a function of accessing the Internet 5. The user terminal 3 performs an interface process for a user who wants to receive a Web service. That is, for example, the user terminal 3 sends an execution request to the flow execution device 2 in response to a user operation, or presents a result returned from the flow execution device 2 to the user.
[0020]
The service providing hosts 4-1, 4-2, 4-3,... Provide Web services such as the above-described vacancy search.
[0021]
FIG. 2 is a block diagram showing a configuration of the flow development support device 1.
As shown in FIG. 2, the flow development support device 1 includes a plan list 11, an execution state database 12, and a support processing unit 13.
The flow development support device 1 can use, for example, a general-purpose server device or a computer device as basic hardware. The support processing unit 13 can be realized by causing a processor mounted on the server device or the computer device to execute the flow development support program. At this time, the support processing unit 13 may be realized by installing the above-described flow development support program in a server device or a computer device in advance, recording the program on a removable recording medium such as a CD-ROM, or The flow development support program may be distributed via a network, and the flow development support program may be installed on a server device or a computer device as appropriate. The plan list 11 and the execution state database 12 include a storage device such as a memory and a hard disk device built in the server device and the computer device, and a storage device such as a memory and a hard disk device external to the server device and the computer device. Further, it can be realized by appropriately using a removable recording medium such as a floppy (R) disk or the like.
[0022]
The plan list 11 holds a plurality of plan information (hereinafter, referred to as a plan) that describes rule information (meta information) for developing a Web service flow.
[0023]
The execution state database 12 holds the execution state of the Web service flow.
[0024]
The support processing unit 13 further includes a request input unit 13a, an extraction unit 13b, a selection unit 13c, an output unit 13d, a response input unit 13e, a notification unit 13f, and an update unit 13g.
[0025]
The request input unit 13a inputs a flow development request output from the flow execution device 2 via the Internet 5. The flow development request includes a plan name, data, and the like. The request input unit 13a outputs the plan name included in the input flow development request to the extracting unit 13b, and outputs data to the updating unit 13g.
[0026]
The extraction unit 13b lists plans having the same plan name as the plan name output from the request input unit 13a and having a precondition having a predetermined relationship with the execution state stored in the execution state database 12. Extract all from 11. The extraction unit 13b outputs the extracted plan to the selection unit 13c. When the corresponding plan cannot be extracted, the extracting unit 13b notifies the notifying unit 13f of the fact.
[0027]
The selection unit 13c selects one of the plans output from the extraction unit 13b. The selection unit 13c outputs one selected plan to the output unit 13d and the update unit 13g.
[0028]
The output unit 13d sends a request to execute the unit flow indicated in the plan output from the selection unit 13c to the flow execution device 2 to the Internet 5.
[0029]
The response input unit 13e inputs, via the Internet 5, execution result information output by the flow execution device 2 as a result of executing the unit flow based on the execution request output by the output unit 13d. The response input unit 13e outputs the input execution result information to the notifying unit 13f and the updating unit 13g.
[0030]
The notification unit 13f creates result notification information including the execution result information output by the response input unit 13e, and sends the result notification information to the flow execution device 2 to the Internet 5.
[0031]
The update unit 13g stores in the execution state database 12 based on data output from the request input unit 13a, post-conditions included in the plan output from the selection unit 13c, or execution result information output from the response input unit 13e. Update the information provided.
[0032]
Next, the operation of the Web service system configured as described above will be described.
Here, it is assumed that the service providing hosts 4-1, 4-2, and 4-3 provide a web service for vacant seat search and seat reservation for the airlines AIR1, AIR2, and AIR3. Also, one of the unit flows 21 included in the flow execution device 2 describes a process of creating a travel plan in response to a request from a user. Hereinafter, this unit flow 21 is referred to as a travel plan creation flow. Three of the unit flows 21 describe a process of performing a vacancy search using a Web service provided by each of the service providing hosts 4-1, 4-2, and 4-3. Hereinafter, these unit flows 21 are referred to as vacant seat search flows.
[0033]
FIG. 3 is a diagram showing the flow of information between the units of the Web service system, omitting the Internet 5.
As described above, the flow execution device 2 has the travel plan creation flow 21-1 and the vacancy search flows 21-2, 21-3, and 21-4.
[0034]
Now, the execution state database 12 may be empty as an initial state, that is, there may be no execution state, or one or more states may be registered in advance. The state in the execution state database 12 is deleted or newly added by an operation from the update unit 13g as the execution of the support processing unit 13 proceeds. Each state is held in a data format called a predicate described below.
[0035]
Hereinafter, the predicate will be described. As an example, consider the sentence "Narita is the place of departure". This sentence indicates that the individual “Narita” has the property of “is a departure place”. Here, the symbol "NARITA" is given to the individual "Narita" as the subject, and the symbol "FROM" is given to "the departure place" which is a sentence predicate, and the sentence "Narita is the departure place" is given as "FROM ( Narita) ". The expression “FROM (NARITA)” is called a predicate, and “FROM” is called a predicate symbol. “FROM (NARITA)” indicates that the individual “Narita” is a departure place, but in order to express that an unspecified individual is a departure place, “FROM (from) is used by using a variable“ from ”. ". A predicate having a plurality of arguments is expressed as “predicate symbol (argument 1, argument 2,...)”. Therefore, for example, the relationship that the character string “1234567” is the “ID” of the mileage account of the airline “AIR1” is expressed as “ID (AIR1, 1234567)” using the predicate symbol “ID”.
[0036]
Here, the predicates used to describe a specific example in the present embodiment will be described below, and the meaning of each predicate will be briefly described.
[0037]
-FROM (from): From is the place of departure.
[0038]
TO (to): to is the destination.
[0039]
-DATE (date): date is boarding date and time.
[0040]
ID (airline, id): The character string id is a mile account ID of the airline airline.
[0041]
-AVAILABLE (flight): The flight flight has vacant seats.
[0042]
BEL (u, P): User u believes in predicate P.
[0043]
FIG. 4 is a diagram illustrating an example of the execution state database 12. The execution state database 12 shown in FIG. 4 has three states: “BEL (NAGANO, ID (AIR1, 1234567))”, “BEL (HASEGAWA, ID (AIR2, 111222333))”, and “BEL (OHSUGA, ID (AIR2)). , 444555666)) ". For example, "BEL (NAGANO, ID (AIR1, 1234567))" states that "user" NAGANO "believes that character string" 1234567 "is the mileage account ID of airline" AIR1 ". ].
[0044]
The plan is registered in the plan list 11 in advance.
The plan is composed of five items: plan ID, plan name, precondition, flow call, and postcondition. The plan ID is a unique identifier in the plan list 11. The plan name is a character string representing the name of the plan, and the same plan name may be defined for a plurality of different plans. The precondition is a necessary condition for selecting a plan, and is described in a predicate form. The flow call defines information for requesting the flow execution device 2 to execute a unit flow, and a flow name for specifying the unit flow held by the flow execution device 2 and its unit. Specify three types of argument data to be passed to the flow and variables to store the data received as the request result. The post condition is a condition as an effect of selecting a plan and calling a unit flow, and is described in a predicate form.
[0045]
FIG. 5 is a diagram illustrating an example of the plan list 11. The plan list 11 shown in FIG. 5 holds three plans, and the plan IDs of each plan are “plan1”, “plan2”, and “plan3” in order from the top. In addition, the same plan name “search” is defined in each case. These three plans correspond to the vacancy search flows 21-2, 21-3, and 21-4, respectively. “Search” is a plan name assigned to the vacant seat search.
[0046]
Hereinafter, the definition of the plan whose plan ID is “plan1” will be described in detail.
[0047]
The plan name is “search”.
[0048]
The preconditions are as follows.
BEL (u, FROM (from)) ∧
BEL (u, TO (to)) ∧
BEL (u, DATE (date)) ∧
BEL (u, ID (AIR1, number)
This precondition is expressed as a logical product (AND operation) of the following four predicates.
BEL (u, FROM (from))
BEL (u, TO (to))
BEL (u, DATE (date))
BEL (u, ID (AIR1, number))
That is, the following conditions are expressed.
User u believes that from is the place of departure, and
User u believes that to is the destination, and
User u believes that date is the boarding date and time, and
User u believes that the string number is the mile account ID of airline AIR1.
[0049]
The flow call is as follows.
flight = call ("AIR1 Search Service Flow", from, to, date, id)
That is, a unit flow having a flow name “AIR1 Search Service Flow” specifying a vacancy search service of the airline AIR1 is called, and four argument data, “from”, “to”, “date”, and “id” are passed and received as the call result. This indicates that data is stored in the variable "flight".
[0050]
The post-conditions are as follows.
[0051]
BEL (u, AVAILABLE (flight)) ∧
BEL (u, ID (AIR1, number))
This condition expresses that [user u believes that there is a vacant seat on flight flight].
[0052]
FIG. 6 is a sequence diagram for executing a Web service flow for creating a travel plan.
[0053]
Now, it is assumed that the user accesses the flow execution device 2 with the user terminal 3 and then performs an operation for requesting creation of a travel plan. At this time, as shown in FIG. 6, the execution request 61 of the travel plan creation flow 21-1 is sent from the user terminal 3 to the flow execution device 2. In the travel plan creation flow 21-1, a procedure for creating a travel plan is defined, for example, "search for vacant seats on airmail → seat reservation for airmail → vacancy search for accommodation facilities ...". Is not defined. Therefore, the travel plan creation flow 21-1 sends the flow development request 62 indicating the plan name “search” corresponding to “search for vacant seats on airmail” to the flow development support device 1. The flow development request 62 includes a user ID, data to be delivered to another unit flow 21, and the like.
[0054]
When the flow development support device 1 receives the flow development request 62, the plan name, the user ID, and the data to be transferred to another flow execution unit indicated in the flow development request are input by the request input unit 13a. Then, in response to the request input unit 13a inputting the above various information, the support processing unit 13 starts an inference process as shown in FIG.
[0055]
The user ID is an identifier representing the user, and specifies, for example, a user name. Further, the data is represented by a set of a parameter name and a value, and one or a plurality of sets may be passed.
[0056]
FIG. 7 is a flowchart of the inference processing.
In step ST1, the request input unit 13a receives the plan name, the user ID, and the data to be transferred to another flow execution unit output from the flow execution unit 2a as described above.
[0057]
In step ST2, the updating unit 13g generates, for the data received by the request input unit 13a, predicate data in which a parameter name is used as a predicate symbol and a value is set to an argument of the predicate, and this predicate data is stored in the execution state database Register in 12. For example, when the request input unit 13a receives data including “NAGANO” as the user ID and the parameter name “FROM” and the value “NARITA” as the input related to the departure place, the update unit 13g transmits the predicate data “BEL”. (NAGANO, FROM (NARITA)) ", and registers this in the execution state database 12.
[0058]
In step ST3, the extraction unit 13b selects, from the plan list 11, a plan whose plan name is the same as the one input in the request input unit 13a and whose preconditions can be unified using a predicate in the execution state database 12. Look for p. Note that a plan that can be unified refers to a plan that can find a predicate having a value that can be assigned to all variables included in the predicate.
[0059]
In step ST4, the extraction unit 13b checks whether the plan p exists. If the plan p exists, the extraction unit 13b passes the extracted plan p to the selection unit 13c, and proceeds to step ST5.
[0060]
In step ST5, the selection unit 13c selects one plan p. If only one plan p has been extracted by the extraction unit 13b, the selection unit 13c may select this one plan p. If a plurality of plans p have been extracted by the extraction unit 13b, they may be selected based on some appropriate criteria. For example, a method of first selecting the one found first by the extraction unit 13b, or selecting a precondition having a large number of predicates is used.
[0061]
In step ST6, the output unit 13d sets the unification obtained in step ST3 for the plan p selected by the selection unit 13c, that is, substitutes the variable into a variable between the flow call and the post-condition defined in the plan p. Apply to
[0062]
In step ST7, the output unit 13d calls the flow execution device 2, and sends an execution request including the flow name of the unit flow included in the flow call obtained in step ST6 and data to be transferred to the unit flow.
[0063]
For example, there are three unit flows 21 corresponding to the plan name "search", i.e., vacancy search flows 21-2, 21-3, and 21-4. Of these, the vacancy search flow 21-2 is selected. If so, the execution request 63 is sent from the output unit 13d to the vacancy search flow 21-2 as shown in FIGS.
[0064]
Upon receiving the execution request, the flow execution device 2 executes the unit flow having the flow name indicated in the execution request. As a result, in the above example, the vacancy search flow 21-2 is activated. The vacancy search flow 21-2 describes a procedure for performing a vacancy search using a Web service provided by the service providing host 4-1. Accordingly, the vacancy search flow 21-2 sends the vacancy search request 64 to the service providing host 4-1 as shown in FIG. 6, and receives the vacancy information 65 returned from the service providing host 4-1 in response to this request. Further, the vacant seat search flow 21-2 sends the execution result information 66 including the vacant seat information 65 to the flow deployment support device 1 as a response to the execution request 63 as shown in FIG. The execution result information 66 is input to the response input unit 13e in the flow development support device 1.
[0065]
In the support processing unit 13, after the output unit 13d outputs the execution request in step ST7 in FIG. 7, the process proceeds to step ST8. In step ST8, the response input unit 13e checks whether the execution request has been normally completed. If the execution request has been completed normally, the process proceeds to step ST9.
[0066]
In step ST9, the updating unit 13g substitutes the execution result information 66 received by the response input unit 13e for a variable specified by the flow call of the plan p. When the same predicate exists in the unified post condition, the update unit 13g substitutes the execution result information 66 for the predicate.
[0067]
In step ST10, the updating unit 13g deletes each predicate included in the preconditions unified in step ST6 from the execution state database 12, and then deletes each predicate included in the postcondition unified in step ST9 in the execution state. Register in the database 12.
[0068]
Finally, in step ST11, the notifying unit 13f uses the result notification information 67 indicating the content of the execution result information 66 received by the response input unit 13e as a response to the flow development request 62, as shown in FIG. Send to 21-1.
[0069]
If the plan p cannot be found in step ST3 in FIG. 7, the process proceeds from step ST4 to step ST11. If the execution request ends abnormally, the process proceeds from step ST8 to step ST11. In these cases, in step ST11, the notifying unit 13f indicates that the result notification information 67 has failed to develop the flow.
[0070]
Thereafter, according to the same flow as described above, vacant seat reservation for airmail, vacancy search for accommodation facilities, and the like are sequentially performed. Then, a travel plan creation flow 21-1 creates a travel plan based on various information obtained by these processes. The execution result information 68 indicating the travel plan is sent from the travel plan creation flow 21-1 to the user terminal 3 as shown in FIG.
[0071]
Next, the operation of the flow development support device 1 will be described in more detail.
First, in the flow development request 62, the plan name “search”, the user ID “NAGANO”, and the data “(FROM, NARITA), (TO, ITAMI), (DATE, 2004/04/0110: 00)” are shown. Suppose you have
[0072]
The updating unit 13g converts the predicate “BEL (NAGANO, FROM (NARITA))” from the data “(FROM, Narita)” and the predicate “BEL (NAGANO, TO (ITAMI))” from the data “(TO, ITAMI)”. And “BEL (NAGANO, DATE (2003/04/01 10:00))” are generated from the data “(DATE, 2003/04/01 10:00)” and registered in the execution state database 12. At this time, the execution state database 12 is updated to the state shown in FIG. 8 by adding three predicates from the state shown in FIG.
[0073]
On the other hand, the extraction unit 13b searches for a plan p having the plan name “search” and capable of unifying the precondition using the predicate in the execution state database 12.
Here, the three plans having the plan name “search” are “plan1”, “plan2”, and “plan3”.
[0074]
The pre-conditions for “plan1” are as follows.
BEL (u, FROM (from)) ∧
BEL (u, TO (to)) ∧
BEL (u, DATE (date)) ∧
BEL (u, ID (AIR1, number))
In comparison with the execution state database 12 shown in FIG. 8, it can be seen that assignment to all the following five variables can be unified, that is, unified.
u = NAGANO
from = NARITA
to = ITAMI
date = 2003/04/01 10:00
number = 1234567
At this time, the unified preconditions are as follows.
BEL (NAGANO, FROM (NARITA)) ∧
BEL (NAGANO, TO (ITAMI)) ∧
BEL (NAGANO, DATE (2003/04/01 10:00)) ∧
BEL (NAGANO, ID (AIR1, 1234567))
These unified preconditions match each predicate in the execution state database 12. Therefore, “plan1” is a candidate for the plan p.
[0075]
The pre-conditions for “plan2” are as follows.
BEL (u, FROM (from)) ∧
BEL (u, TO (to)) ∧
BEL (u, DATE (date)) ∧
BEL (u, ID (AIR2, number))
In light of the execution state database 12 shown in FIG. 8, substitution to the following four variables, that is, unification is possible.
u = NAGANO
from = NARITA
to = ITAMI
date = 2003/04/01 10:00
However, since the predicate corresponding to “BEL (u, ID (AIR2, number))” does not exist in the execution state database 12, it cannot be assigned to the variable “number”. Therefore, “plan2” is not a candidate for plan p. Similarly, the predicate corresponding to “BEL (u, ID (AIR3, number))” does not exist in the execution state database 12 for “plan3”, and therefore cannot be assigned to the variable “number”. Therefore, “plan3” is not a candidate for plan p.
[0076]
As described above, the extraction unit 13b extracts “plan1” as the plan p. At this time, since only one plan has been extracted, the selecting unit 13c directly selects the above-mentioned “plan1”.
[0077]
The output unit 13d applies the unification of the pre-condition of “plan1” to the flow call and the post-condition of “plan1”. The flow call of “plan1” is as follows.
flight = call ("AIR1 Search Service Flow", from, to, date, number)
When unification is applied to this flow call, it becomes as follows.
flight = call (“AIR1 Search Service Flow”, NARITA, ITAMI, 2003/04/01)
10:00, 1234567)
The post-conditions are as follows.
BEL (u, AVAILABLE (flight)) ∧
BEL (u, ID (AIR1, number)
Applying unification to this postcondition is as follows.
BEL (NAGANO, AVAILABLE (flight)) ∧
BEL (NAGANO, ID (AIR1, 1234567)
The variable “flight” is left as a variable at this stage.
[0078]
Next, the output unit 13d sends an execution request 63 to the flow execution device 2. The execution request 63 includes the Web service flow name “AIR1 Search Service Flow” and the four data “NARITA”, “ITAMI”, “2003/04/01 10:00” from the unified flow call. , “1234567”. “AIR1 Search Service Flow” is a Web service flow name assigned to the vacancy search flow 21-2. Thus, the execution request 63 starts the vacancy search flow 21-2.
[0079]
It is assumed that the vacant flight “AIR1-079” is found by the vacant seat search flow 21-2. In this case, the execution result information 66 including “AIR1-079” is returned from the vacancy search flow 21-2. Then, the execution result information 66 is input by the response input unit 13e and passed to the update unit 13g. The updating unit 13g substitutes the above “AIR1-079” included in the execution result information 66 into the variable “flight” of the unified flow call. Therefore, the value of the variable “flight” is “AIR1-079”. At this time, the above-mentioned unified post-conditions are as follows.
BEL (NAGANO, AVAILABLE (AIR1-079)) ∧
BEL (NAGANO, ID (AIR1, 1234567)
Subsequently, the updating unit 13g deletes the next data from the execution state database 12.
BEL (NAGANO, FROM (NARITA))
BEL (NAGANO, TO (ITAMI))
BEL (NAGANO, DATE (2003/04/01 10:00))
BEL (NAGANO, ID (AIR1, 1234567))
At the same time, the update unit 13g adds the following two predicates included in the unified post condition to the execution state database 12.
BEL (NAGANO, AVAILABLE (AIR1-079))
BEL (NAGANO, ID (AIR1, 1234567)
Therefore, the execution state database 12 is updated from the state of FIG. 8 to the state of FIG.
Finally, the notification unit 13f sends the result notification information 67 indicating “AIR1-079” to the trip plan creation flow 21-1, which is the calling source.
[0080]
As described above, according to the present embodiment, each time the flow development support device 1 receives a flow development request, it selects one appropriate unit flow 21 according to the request and requests execution of the unit flow 21. . Further, the flow development support device 1 returns information obtained as a result of executing the requested unit flow 21 to the unit flow 21 that is the flow development request source. Therefore, in the flow execution device 2, one unit flow 21 can indirectly call another unit flow 21. As a result, it is possible to construct and execute one logical Web service flow by flexibly combining a plurality of unit flows 21.
[0081]
Further, according to the present embodiment, for example, when a unit flow is newly added, by updating the plan list 11, the newly added unit flow can be used. Specifically, if a unit flow for calling the airline vacancy search Web service AIR4 is added, the plan name is “search” and the flow call is “flight = call (“ AIR4 Search Service Flow). By adding the plan “, from, to, date, id)” to the plan list 11, the unit flow for planning the above-mentioned trip can be modified from the old unit flow to the new unit flow without any modification. It is possible to call and use the added unit flow. That is, according to the present embodiment, the development of each unit flow can be performed without considering the details of other unit flows. Further, the expansion of the Web service flow can be easily performed by updating or adding a part of the unit flow.
[0082]
Further, according to the present embodiment, the precondition can be included in the plan, the execution state of the Web service flow can be stored in the execution state database 12, and the precondition can be unified using the information in the execution state database 12. Since the plan is extracted, an appropriate unit flow can be executed according to the execution state of the Web service flow.
[0083]
This embodiment can be implemented in the following various modifications.
The plan list 11 and the execution state database 12 need not be included in the flow development support device 1. In this case, communication means for accessing the plan list 11 and the execution state database 12 from the flow development support device 1 is provided in the flow development support device 1.
[0084]
Extraction of a plan from the plan list 11 may be performed based on only the plan name. In this case, the plan need not include the pre-condition and the post-condition. Further, the execution state database 12 becomes unnecessary.
[0085]
When updating the execution state database 12, it is not necessary to consider the post condition.
[0086]
The number of the flow execution devices 2 does not need to be one, and the unit flows 21 of the plurality of flow execution devices 2 may be appropriately developed.
[0087]
The processing content indicated by each unit flow 21 may be arbitrary. The unit flow 21 in which the interface processing with the user terminal 3 is indicated may use another unit flow 21 only once.
[0088]
Note that the present invention is not limited to the above-described embodiment as it is, and can be embodied by modifying constituent elements in an implementation stage without departing from the scope of the invention. Various inventions can be formed by appropriately combining a plurality of constituent elements disclosed in the above embodiments. For example, some components may be deleted from all the components shown in the embodiment. Further, components of different embodiments may be appropriately combined.
[0089]
【The invention's effect】
According to the present invention, it is possible to flexibly combine unit flows for performing relatively small processes and dynamically assemble and execute one logical Web service flow as a whole.
[Brief description of the drawings]
FIG. 1 is a block diagram of a Web service system according to an embodiment of the present invention.
FIG. 2 is a block diagram showing a configuration of a flow development support device 1 in FIG.
FIG. 3 is a diagram showing a flow of information between each unit of the Web service system.
FIG. 4 is a diagram showing an example of an execution state database 12 in FIG. 2;
FIG. 5 is a view showing an example of a plan list 11 in FIG. 2;
FIG. 6 is a sequence diagram for executing a Web service flow for creating a travel plan.
FIG. 7 is a flowchart of an inference process.
FIG. 8 is a diagram showing an example of updating an execution state database 12 in FIG. 2;
9 is a diagram showing an example of updating the execution state database 12 in FIG.
[Explanation of symbols]
DESCRIPTION OF SYMBOLS 1 ... Flow development support apparatus, 2 ... Flow execution apparatus, 2a, 2b ... Flow execution part, 11 ... Plan list, 12 ... Execution state database, 13 ... Support processing part, 13a ... Request input part, 13b ... Extraction part, 13c ... selection unit, 13d ... output unit, 13e ... response input unit, 13f ... notification unit, 13g ... update unit.

Claims

In a web service system for providing a web service to a user terminal,
A plurality of web service providing apparatuses for individually providing a plurality of web services of the same type;
A flow execution device that individually executes processes corresponding to a plurality of unit flows each showing a procedure of a plurality of processes including a process using the web service,
A plan storage device that stores plan information that associates a plan name indicating the type of the web service with a flow name of the unit flow indicating a procedure of a process using the web service;
A flow development support device,
further,
Means for providing a call request including the plan name when one of the unit flows selected in response to a request from the user terminal includes a flow call by the plan name, provided in the flow execution device; ,
When provided in the flow development support device and receives the call request, the plan information including the plan name indicated in the call request is selected from the plan storage device, and the selected plan information is indicated in the selected plan information. Means for outputting an execution request indicating the flow name;
Means provided in the flow execution device for extracting a unit flow having the flow name indicated in the execution request and outputting first execution result information obtained by executing the extracted unit flow as a response to the execution request When,
Means provided in the flow development support device, for inputting the first execution result information, and outputting the input first execution result information as a response to the call request;
The first execution result information is provided in the flow execution device, and the first execution result information is input for use in a process executed in accordance with the unit flow for which the flow call is specified, and the first execution result information obtained in the process is input. Means for outputting the execution result information of step 2 as a response to a request from the user terminal.

Supports a flow execution device that individually executes a plurality of unit flows each showing a procedure of a plurality of processes including a process using a web service, and uses a plan name indicating a type of the web service and the web service. A flow development support device that can access a plan storage device that stores plan information that associates the flow name of the unit flow with the flow of the unit flow indicating the procedure of the process.
Means for inputting the call request indicating the plan name from the flow execution device;
Means for selecting one of the plan information from the plan storage device, the plan information including the plan name indicated in the call request;
Means for outputting an execution request indicating the flow name indicated in the selected plan information to the flow execution device,
Means for inputting execution result information as a response to the execution request from the flow execution device,
Means for outputting the execution result information to the flow execution device as a response to the call request.

Supports a flow execution device that individually executes a plurality of unit flows each showing a procedure of a plurality of processes including a process using a web service, and uses a plan name indicating a type of the web service and the web service. A plan storage device that stores plan information in which a flow name of the unit flow indicating a procedure of the process to be performed is associated with a precondition, and a status that stores status information indicating an execution status of the process in the flow execution device. A flow development support device that can access a storage device,
Means for inputting the call request indicating the plan name from the flow execution device;
Select one of the plan information from the plan storage device, the plan information including the plan name indicated in the call request and including the precondition having a predetermined relationship with the state information stored in the state storage means. Means to
Means for outputting an execution request indicating the flow name indicated in the selected plan information to the flow execution device,
Means for inputting execution result information as a response to the execution request from the flow execution device,
Means for outputting the execution result information to the flow execution device as a response to the call request.

4. The apparatus according to claim 3, further comprising: a unit configured to update the state information based on the data when the call request information includes data used in a process corresponding to the unit flow. Flow development support device.

3. The apparatus according to claim 2, further comprising: means for updating the state information based on the post condition and the execution result information when the selected plan information includes a post condition. A flow development support device as described in the above.

A computer that can access a plan storage device that stores plan information that associates a plan name indicating the type of the web service with a flow name of the unit flow indicating a procedure of a process using the web service,
Means for inputting a call request indicating the plan name from a flow execution device;
Selecting means for selecting one of the plan information including the plan name indicated in the call request from the plan storage device;
Means for outputting an execution request indicating the flow name indicated in the selected plan information to the flow execution device,
Means for inputting execution result information as a response to the execution request from the flow execution device,
A flow development support program functioning as means for outputting the execution result information to the flow execution device as a response to the call request.

A plan storage device for storing plan information in which a plan name indicating a type of a web service and a flow name of the unit flow indicating a procedure of a process using the web service are associated with a precondition, and a flow execution device. A computer that can access a state storage device that stores state information indicating an execution state of the processing,
Means for inputting the call request indicating the plan name from the flow execution device;
Select one of the plan information from the plan storage device, the plan information including the plan name indicated in the call request and including the precondition having a predetermined relationship with the state information stored in the state storage means. Means to
Means for outputting an execution request indicating the flow name indicated in the selected plan information to the flow execution device,
Means for inputting execution result information as a response to the execution request from the flow execution device,
A flow development support program functioning as means for outputting the execution result information to the flow execution device as a response to the call request.

8. The computer according to claim 7, further comprising, when data used in the processing corresponding to the unit flow is included in the call request information, updating the state information based on the data. Flow development support program described in 1.

When the post-condition is included in the selected plan information, the computer is further made to function as means for updating the state information based on the post-condition and the execution result information. Item 8. A flow development support program according to Item 7.

While referring to the plan information stored in the plan storage device and associating the plan name indicating the type of the web service with the flow name of the unit flow indicating the procedure of the process using the web service, the web service In a flow development support method for supporting a flow execution device that individually executes a plurality of unit flows each showing a procedure of a plurality of processes including a process to be used,
A call request indicating the plan name is input from the flow execution device,
Selecting one of the plan information including the plan name indicated in the call request from the plan storage device;
An execution request indicating the flow name indicated in the selected plan information is output to the flow execution device,
Entering execution result information as a response to the execution request from the flow execution device,
Outputting the execution result information as a response to the call request to the flow execution device.

The plan information stored in the plan storage device and associated with the plan name indicating the type of the web service, the flow name of the unit flow indicating the procedure of the process using the web service, and the precondition, and the state storage device A flow for individually executing a plurality of unit flows each showing a procedure of a plurality of processes including a process of using the web service, with reference to state information indicating the execution state of the process in the flow execution device, which is stored. In a flow development support method for supporting an execution device,
A call request indicating the plan name is input from the flow execution device,
Select one of the plan information from the plan storage device, the plan information including the plan name indicated in the call request and including the precondition having a predetermined relationship with the state information stored in the state storage means. And
An execution request indicating the flow name indicated in the selected plan information is output to the flow execution device,
Entering execution result information as a response to the execution request from the flow execution device,
Outputting the execution result information as a response to the call request to the flow execution device.