4.5. AMQ to REST API サンプルインテグレーションの作成およびデプロイ
AMQ to REST API サンプルインテグレーションを作成してデプロイする場合、主なステップは次のとおりです。
前提条件
- 提供された Red Hat AMQ ブローカーへのコネクションが作成されている必要があります。
- 提供された Todo アプリケーションへの API クライアントコネクションが作成されている必要があります。
- Damage Reporter ステップを提供するエクステンションをアップロードしている必要があります。
4.5.1. 最初のコネクションの選択
Fuse Online で、AMQ to REST API サンプルインテグレーションを作成するには、先に最初のコネクションを選択します。
前提条件
- 提供された Red Hat AMQ ブローカーを起動している必要があります。
- メッセージブローカーへのコネクションが作成されている必要があります。
手順
- Fuse Online で左側にある Integrations をクリックします。
- Create Integration をクリックします。
- Choose a connection ページで AMQ コネクションをクリックします。上記の例の名前を指定した場合は、Red Hat AMQ Broker 1 をクリックします。
- Choose an action ページで、Subscribe for messages アクションを選択し、指定したキューからメッセージを受信します。
-
Destination name フィールドに、データを取得するキューの名前として
inventoryReceivedを入力します。 - Destination type フィールドをクリックし、Queue を選択します。
- 他のフィールドは空白のままにします。
- Next をクリックします。Fuse Online は出力データタイプを指定するよう要求します。このサンプルインテグレーションには必要ありません。
- Next をクリックして最初のコネクションをインテグレーションに追加します。
次のステップ
インテグレーションの実行中、Red Hat AMQ に接続すると、インテグレーションは inventoryReceived キューでメッセージを監視します。メッセージが利用可能になると、インテグレーションはそのメッセージを Damage Reporter ステップに渡します。ただし、そのステップをインテグレーションに追加するには、先にインテグレーションの最後のコネクションを選択する必要があります。
4.5.2. 最後のコネクションの選択
Fuse Online で AMQ to REST API サンプルインテグレーションの作成を続けるには、最初のコネクションを追加した後、最後のコネクションをインテグレーションに追加します。
前提条件
- 提供された OpenAPI ドキュメントをアップロードし、Todo App API コネクターを作成している必要があります。
- Todo App API コネクターを使用して Todo App API コネクションを作成している必要があります。
手順
- Fuse Online の Choose a connection ページで、作成した To Do アプリケーションコネクションをクリックします。上記の例の名前を割り当てた場合は、Todo App API Client をクリックします。
- Choose an action ページで Create new task を選択します。これは、特定の破損商品に対処するための連絡先情報を提供します。
- Next をクリックして最後のコネクションをインテグレーションに追加します。
4.5.3. Damage Reporter ステップの追加
最初および最後のコネクションがある場合、 Red Hat AMQ ブローカーからメッセージを受信し、受領時に破損した商品を特定するカスタムステップを追加することができます。
前提条件
- Damage Reporter カスタムステップを提供するエクステンションをアップロードしている必要があります。
- 最初のコネクションおよび最後のコネクションをインテグレーションに追加済みである必要があります。
手順
- Fuse Online のインテグレーションビジュアライゼーションで、プラス記号をクリックします。
- Damage Reporter をクリックします。
Next をクリックして Damage Reporter ステップをインテグレーションに追加します。
注記： Data Type Mismatch 警告アイコン
が Damage Reporter ステップの横に表示される場合は、無視できます。
4.5.4. データマッピングステップの追加
AMQ to REST API サンプルインテグレーションの作成を続けるには、データマッピングステップを追加する必要があります。この手順により、Damage Reporter ステップの出力の task フィールドを、REST API がアクセスするデータベースの task フィールドと関連付けます。
前提条件
- Damage Reporter ステップをインテグレーションに追加済みである必要があります。
手順
- Fuse Online のインテグレーションビジュアライゼーションで、Damage Reporter ステップと最後のコネクションの間にあるプラス記号をクリックします。
- Data Mapper をクリックします。データマッパーで、左側の Source パネルに Damage Reporter ステップの出力のフィールドが表示されます。右側の Target パネルに、API がアクセスするデータベースのフィールドが表示されます。
Source パネルで
taskフィールドをクリックした後、Create New Mapping アイコンをクリックします。Mapping Details パネルが表示されます。
- Mapping Details ターゲットパネルの Targets で、/body/task を選択します。
- 右上の Done をクリックします。
結果
インテグレーションが完了し、パブリッシュできる状態になります。
Data Type Mismatch 警告アイコンが表示された場合は、無視できます。
4.5.5. インテグレーションの命名とデプロイ
AMQ to REST API サンプルインテグレーションは、Red Hat AMQ の最初のコネクション、Damage Reporter ステップ、データマッパーステップ、および最後に Todo App Client API コネクションがある場合に完了します。ここの指示に従ってデプロイします。
前提条件
- 最初のコネクションおよび最後のコネクションをインテグレーションに追加済みである必要があります。
- 最初と最後のコネクションの間に Damager Reporter ステップを追加済みである必要があります。
- Damage Reporter ステップと、Todo App API へのコネクションの間にデータマッパーステップを追加済みである必要があります。
手順
- Fuse Online の右上の Publish をクリックします。
-
Name フィールドに、インテグレーションの名前を入力します。たとえば、
AMQ to REST API Sample Integrationなどです。 - 任意で、Description フィールドに、このインテグレーションに関する便利な情報を入力します。
右上の Save and publish をクリックします。
Fuse Online はインテグレーションのデプロイを開始し、この環境のインテグレーションのリストを表示します。AMQ to REST API インテグレーションのエントリーに、パブリッシュステージを示す進捗インジケーターが表示されます。Fuse Online はインテグレーションのランタイムを生成し、ランタイムの準備ができると開始します。これには数分かかります。
Fuse Online アカウントは、同時に実行可能なインテグレーションの数が制限されています。詳細は、価格プランを参照してください。インテグレーションの最大数をすでに実行している場合、別のインテグレーションの実行を開始する前にインテグレーションを停止する必要があります。
すでに最大数のインテグレーションが稼働中である場合、以下のステップにしたがってインテグレーションを停止します。
- 左側のパネルで Integrations をクリックします。
-
停止するインテグレーションのエントリーで、右端の
をクリックします。
- ポップアップで Stop をクリックします。
インテグレーションの停止後、別のインテグレーションを以下のように起動します。
- 左側のパネルで Integrations をクリックします。
-
起動するインテグレーションのエントリーで、右端の
をクリックします。
- ポップアップで Start をクリックします。
