ラボ 3: Anypiont MQ 及び Notification APIを通じた Order Fulfillment の更新をブロードキャスト

Anypointのクラウドメッセージングサービスを使用して、パブリッシュとサブスクライブのメッセージングパターンを構成します。

Order Fulfillment APIフローを拡張して、AnyPoint MQに単一のSend Notificationメッセージを発行します。

Exchange 2.0を利用して、Gmail/TwitterおよびSlackコネクタを再利用して、2つのNotificationサブスクライバを作成します。

DataWeave を使用して、Notification API コール間のデータ変換を管理します。

Anypoint StudioからプロセスAPIを含むMuleアプリを実行してテストします。

Anypoint Platform にサインインして、MQ を選択してみましょう。

次に、パブリッシュとサブスクライブの通知パターンをサポートするために必要なキューデスティネーションを作成してみましょう。

Sandbox 環境を選択します。

右上隅の ボタンを押して、QUEUEを選択 します。

最初のキューのIDを <ユーザ名>-order-user-notification-queue とします。

他のすべてのフィールドはデフォルト値のまま、Create Queue を選択します。

2つ目のキューを作成し、<ユーザー名>-order-slack-notification-queue というIDを入力します。

他のすべてのフィールドはデフォルト値のまま、Create Queue を選択します。

次に、キューへのメッセージの送受信を可能にするために、AnypointMQ Exchangeを設定する必要があります。

右上隅の ボタンを押して、Exchangeを選択 します。

Exchangeに <ユーザー名>-order-exchange というIDを入力して、先ほどのステップで作成した2つのキューをそれぞれ選択します。

Save Changes を選択します。

Anypoint MQの最後の設定は、Client Appを作成することです。 クライアントアプリを設定することで、Anypoint MQホストにアプリケーションを安全に登録することができます。

左側のナビバーの Client Apps リンクを選択し、続いてページ右上の　+　を選択します。

<username>-order-notifications とアプリケーションに名前をつけます。

Save Changes を選択し、画面が更新されるまで数秒待つと、新しく作成されたクライアントアプリケーショ ンの登録が表示されます。 アプリケーションが正常に登録されると、Client IDとClient Secretが表示されます。

ID とシークレットは、このラボの後半のステップで使用するため、 メモして おいてください。

src/test/resources フォルダに移動し、右ボタンを押します。

New → Folder を選択します。

フォルダ名 を examples とします。

src/test/resources/examples で、publish-message-example.json という名前の新しいファイルを作成します。

以下のテキストをコピーして貼り付けてください:

{
	"order_id":"1",
	"customer_data":{
		"id": "b4285d5f-69c1-40fc-97b3-d112a6366b68",
  		"email": "test_email123@example.com",
	  	"name": "Mike Prowl",
	  	"phone": "1-(951)768-8479",
	  	"shippingAddress": {
	    	"address1": null,
	    	"city": "Houston",
	    	"country": "USA",
	    	"postalCode": "77045",
	    	"state": "Texas"
	  	},
	  	"billingAddress": {
	    	"address1": null,
	    	"city": "Riverside",
	    	"country": "USA",
	    	"postalCode": "92513",
	    	"state": "California"
  		}
	},
	"products":[
		{
			"id": 3,
			"productName": "Hoodie",
			"quantity": 1
		},
		{
			"id": 5,
			"productName": "Mug",
			"quantity": 2
		}
	]
}

example ファイルを保存して閉じます。

次に、Anypoint MQ Componentをパレットに追加します。

パレットに移動し、 Search in Exchange を押します。

検索ボックスに Anypoint と入力してください。

Anypoint MQ コネクタを選択します。

Add> ボタンを押します。

Finish を押します。

最後の Transform Message コンポーネントを削除します。

Anypoint MQパレットで、Scatter Gatherコンポーネントの後にPublishアイコンをドラッグ＆ドロップします。

Publishアイコンをクリックします。

新しいConnector Configurationを作成してAnypoint MQクライアントを構成します。

OK を押します。

General セクションでは

ボタンをクリックします。

Define metadata リンクをクリックします。

Add ボタンを押して新しいデータ型を作成します。

publish_message_example　という名前をつけて、create type を押してください。

タイプのドロップダウンリストでJSONを選択します。

ドロップダウンから example を選択し、パスとして examples/publish-message-example.json を記述します。

Select を押します。

プロジェクトを保存します。

User Definedウィンドウからpublish-message-exampleを選択します。

完了したら Select を押します。

実際の変換を次のものに置き換えます:

%dw 2.0
output application/json
---
{
	order_id: vars.order_id as Number,
	customer_data: {
		id: payload."1".payload.id,
		email: payload."1".payload.email,
		name: payload."1".payload.name,
		phone: payload."1".payload.phone,
		shippingAddress: {
			address1: payload."1".payload.shippingAddress.text,
			city: payload."1".payload.shippingAddress.city,
			country: payload."1".payload.shippingAddress.country,
			postalCode: payload."1".payload.shippingAddress.postalCode,
			state: payload."1".payload.shippingAddress.state
		},
		billingAddress: {
			address1: payload."1".payload.billingAddress.text,
			city: payload."1".payload.billingAddress.city,
			country: payload."1".payload.billingAddress.country,
			postalCode: payload."1".payload.billingAddress.postalCode,
			state: payload."1".payload.billingAddress.state
		}
	},
	products: payload."0".payload.products map ( orderLineItem , indexOfOrderLineItem ) -> {
		id: orderLineItem.id as Number,
		productName: orderLineItem.productName as String,
		quantity: orderLineItem.quantity as Number
	}
}

プロジェクトを保存します。

Advanced設定に進みます。

Outputセクションで、以下の値を設定します:

Publishコンポーネントの後にTransformコンポーネントを追加します。

以下の dataweave スクリプトを使用して Transform を完成させます:

%dw 2.0
output application/json
---
{
	order_id: vars.order_id as Number,
	username: payload."1".payload.name
}

Notification フローをカプセル化するために、新しいMule Configuration fileを作成します。

新しい設定ファイルの名前を notification_subscribers.xml とします。

空白のキャンバス上に Subscriber Anypoint MQコンポーネントをドラッグして、Gmail/Twitterチャンネルを対象とした最初のフローの構築を開始します。

フロー名を notification-user-listener に変更します。

コンポーネントの名前を Twitter Notificaton Subscriber に変更します。

Anypoint MQ Connector Configurationオブジェクトを再利用します。

Generalセクションの下にあるQueueフィールドに、宛先を <ユーザー名>-order-user-notification-queue と設定します。

saveボタンを押してください。

Metadata タブに移動します。

Add metadata ボタンを押します。

Output: Payload を選択して、編集ボタンを押します。

メタデータの publish_message_example を選択し、Select ボタンを押します。

Search in Exchange に移動し、Notification API を検索します。

Create id by id リソースをドラッグ＆ドロップでして作成します。

コネクタをダブルクリックして、プロパティを表示します。Mule Properties View に設定するコンポーネントのプロパティが表示されます。

アイコンをクリックして、次のように新しい設定を作成します:

下記の値を設定します。

OK クリックします。

General セクションでは、以下のパラメータを設定します:

Create id by id request data項目の を押して、以下のDataWeaveロジックをコードエディタに追加します:

%dw 2.0
output application/java
var customer=payload.customer_data.name default ""
var order_id=payload.order_id default 0
---
{
	body: "Thank you " ++ customer ++ ", your order (#" ++ order_id ++ ") has been received.",
	subject: "Order " ++ order_id
}

最後に Logger コンポーネントを追加します。これは、通知が送信されたことを示すログエントリを出力します。

Messageには以下の文字列を入れます。 Notification to Twitter successfully Sent

フローの設定を保存します。

別の Subscriber Anypoint MQ コンポーネントをキャンバスにドラッグします。これにより、新しいフローが作成されます。

フローの名前を notification-slack-listener に変更します。

コンポーネントの名前を Slack Notificaton Subscriber に変更します。

Anypoint MQ Connector Configuration オブジェクトを再利用します。

宛先を <ユーザー名>-order-slack-notification-queue に構成します。

構成は、以下のイメージとなるはずです:

Metadata タブに移動します。

Add metadata ボタンを押します。

Output: Payload を選択して、編集ボタンを押します。

メタデータの publish_message_example を選択し、Select ボタンを押します。

Notification APIコネクタか らコンポーネント Create slack を追加します。

すでに作成した Connector の設定を再利用します。

General セクションで、次のパラメータを設定します。

を押して、以下のDataWeaveロジックをコードエディタに追加します。:

%dw 2.0
output application/json
---
{
	userId: payload.customer_data.id,
	productList: payload.products map ( product , indexOfProduct ) -> {
		qty: product.quantity,
		name: product.productName
	}
}

最後に Logger コンポーネントを追加します。これは、通知が送信されたことを示すログエントリを出力します。

Messageには以下の文字列を入れます。Notification to Slack Successfully Sent

フロー設定を保存します。

前のラボで行ったように、アプリケーションを起動します。(アプリケーションを右クリックし、Run AS > Mule Application を選択します。

Anypoint Studioで API Console View を開いたら、/orders_fulfillment リソースの POST ボタンをクリックします。

Accept フィールドに application/json を入力します。

リクエストボディを確認し、SEND ボタンをクリックします。

リクエストが送信されると、200 番のレスポンスコードと API の JSON レスポンスが表示されます。

ブロードキャストされた通知メッセージを表示するには、インストラクターと一緒に GMail、Twitter、および/または Slack チャンネルを確認してください。

Anypoint Studioを使用して、Order Fulfillment Stubを実装してプロセスAPIレイヤーを完成させます。

Scatter-Gatherフロー・コントロールとRAML Consumerオブジェクトを構成して、注文と顧客システムAPIをオーケストレーションします。

DataWeaveを使用して、システムとAPIのレスポンスを管理し、目的の結果セットを生成します。

RAMLコンシューマからのライブAPIコールを使用して、システムAPIレイヤーを横断するプロセスAPI実装をテストしました。