---
schema_version: "1"
id: cb431e513170aae736ebabf90455961cddcd987106f9e944977ee5e4d75221ec
title: Amazon SQS Connector 5.7 の例
collection: mulesoft
version: current
locale: ja-jp
portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/amazon-sqs-connector-examples.md
canonical_url: https://docs.mulesoft.com/jp/amazon-sqs-connector/5.7/amazon-sqs-connector-examples
source_site: docs.mulesoft.com
content_type: documentation
content_hash: ea6ed32c5ab88b0cf6a42d4705abfc5ef3edfb6c83d64b4ffcc20e92a6facef6
description: MuleSoft Documentation Site
release: "5.7"
latest: false
---
# Amazon SQS Connector 5.7 の例

この例は、メタデータと共にメッセージを Amazon SQS キューに送信し、キューから受信します。この例は次の 2 つのフローに分割されます。

1. 最初のフローは、メタデータと共にメッセージを送信し、キューのメッセージ数を取得して、メッセージが送信されたことを確認する。
2. 2 番目のフローは、メッセージを受信し、メッセージ本文を記録する。

![sqs-message-flow](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-message-flow.png)

この例では一部の項目値に変数を使用しています。コードで変数をそれらの値に置き換えるか、​`src/main/resources/mule-artifact.properties`​ ファイルで各変数の値を指定できます。

この例を試す前に、Anypoint Studio (Studio) にアクセスし、\[Mule Palette (Mule パレット)\] ビューに Amazon SNS と Amazon SQS のエントリが表示されていることを確認します。表示されていない場合、​[「Amazon SQS Studio 設定」](https://docs.mulesoft.com/jp/amazon-sqs-connector/5.7/amazon-sqs-connector-studio)​の指示に従って両方のコネクタをインストールします。

## [](#メッセージを送信するフローを作成する)メッセージを送信するフローを作成する

まず、メッセージをキューに送信するフローを作成します。フローの作成には、新しい Mule プロジェクトの作成と、Listener コンポーネント、Transform Message コンポーネント、SQS Send Message 操作、Logger コンポーネント、SQS Get approximate number of messages 操作、および 2 番目の Logger コンポーネントの設定が含まれます。

1. Studio で新しい Mule プロジェクトを作成します。
2. \[Mule Palette (Mule パレット)\] で​**「HTTP」**​を検索し、​**Listener**​ 操作を選択します。
    
    ![select-listener](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-select-listener.png)
3. **Listener**​ 操作をキャンバスにドラッグします。
4. **Listener**​ 設定で、​**\[Connector configuration (コネクタ設定)\]**​ 項目の横にある ​**\[+\]**​ をクリックしてグローバル要素を追加します。
5. デフォルトを受け入れます。
6. **\[Path (パス)\]**​ 項目を ​`/`​ に設定します。
    
    ![http-properties](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-http-props.png)

### [](#transform-message-コンポーネントを追加してメタデータを添付する)Transform Message コンポーネントを追加してメタデータを添付する

1. \[Mule Palette (Mule パレット)\] ビューで、​**「Transform Message」**​を検索します。
    
    ![select-transform](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-select-transform.png)
2. **Transform Message**​ コンポーネントをキャンバスの ​**Listener**​ コンポーネントの右にドラッグします。
3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。
    
    ```dataweave
    {
    	delaySeconds: 0,
    	body: "Hello World",
    	messageAttributes: {
    		"AccountId": {
    			"stringValue" : "000123456",
    			"dataType" : "String.AccountId"
    		} as Object {
    			class: "org.mule.extension.sqs.api.model.MessageAttributeValue"
    		},
    		"NumberId": {
    			"stringValue" : "230.000000000000000001",
    			"dataType" : "Number"
    		} as Object {
    			class : "org.mule.extension.sqs.api.model.MessageAttributeValue"
    		}
    	} as Object {
    		class: "java.util.HashMap"
    	}
    } as Object {
    	class: "org.mule.extension.sqs.api.model.Message"
    }
    ```
    
    次のスクリーンショットは、Studio の ​**\[Output (出力)\]**​ セクションに表示される XML を示しています。
    
    ![transform-message](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-transform-message.png)

### [](#sqs-send-message-操作を追加および設定する)SQS Send Message 操作を追加および設定する

1. \[Mule Palette (Mule パレット)\] ビューで​**「SQS」**​を検索し、​**Send message**​ 操作を選択します。
    
    ![select-send-message](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-select-send.png)
2. **Send message**​ 操作をキャンバスの ​**Transform Message**​ コンポーネントの右にドラッグします。
3. **Send message**​ 設定で、​**\[Connector configuration (コネクタ設定)\]**​ 項目の横にある ​**\[+\]**​ をクリックしてグローバル要素を追加します。
4. 次のようにグローバル要素を設定します。
    
    <table class="tableblock frame-all grid-all fit-content spread">
<colgroup>
<col>
<col>
</colgroup>
<thead>
<tr>
<th class="tableblock halign-left valign-top">項目</th>
<th class="tableblock halign-left valign-top">値</th>
</tr>
</thead>
<tbody>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Name (名前)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">設定の参照に使用される名前。</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Session Token (セッショントークン)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">一時的なセキュリティログイン情報を検証するために使用するセッショントークン。</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Access Key (アクセスキー)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">アカウントを所有するユーザーを一意に識別する英数字のテキスト文字列</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Secret Key (シークレットキー)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">パスワードの役割を果たすキー。</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Region Endpoint (リージョンエンドポイント)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">キューリージョン</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Default Global Queue URL (デフォルトのグローバルキュー URL)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">デフォルトの Amazon SQS キュー URL ログイン情報。</p></td>
</tr>
</tbody>
</table>
    
    次に例を示します。
    
    ![send-global-config](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-studio-global-config-new.png)
5. **\[Configuration XML (設定 XML)\]**​ タブを選択して、対応する XML を表示します。
    
    ```dataweave
    <sqs:config name="Amazon_SQS_Configuration"
      doc:name="Amazon SQS Configuration"
    	defaultQueueUrl="${sqs.queueUrl}">
    	<sqs:basic-connection accessKey="${sqs.accessKey}"
    	secretKey="${sqs.secretKey}"
    	region="us-east-1"
    	sessionToken="${sqs.sessionToken}"/>
    </sqs:config>
    ```
6. プロパティウィンドウで次の各項目を設定します。
    
    <table class="tableblock frame-all grid-all fit-content spread">
<colgroup>
<col>
<col>
</colgroup>
<thead>
<tr>
<th class="tableblock halign-left valign-top">項目</th>
<th class="tableblock halign-left valign-top">値</th>
</tr>
</thead>
<tbody>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Display Name (表示名)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">コネクタ操作の名前</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Connector Configuration (コネクタ設定)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">作成したばかりのグローバル設定</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Message (メッセージ)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock"><code>payload</code></p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Queue url (キュー URL)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">Amazon SQS キュー URL。</p>
<p class="tableblock">指定した場合、この項目の値は ​<strong>[Global Configuration Elements (グローバル設定要素)]</strong>​ ウィンドウの ​<strong>[Default Global Queue URL (デフォルトのグローバルキュー URL)]</strong>​ 項目の値よりも優先されます。</p></td>
</tr>
</tbody>
</table>
    
    次に例を示します。
    
    ![send-message](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-send-message.png)

### [](#mule-コンソールに応答を出力するロガーを追加する)Mule コンソールに応答を出力するロガーを追加する

1. \[Mule Palette (Mule パレット)\] ビューで、​**「Logger」**​を検索します。
2. コンポーネントをキャンバスの ​**\[Send Message\]**​ コンポーネントの右にドラッグします。
3. 次の項目を設定します。
    
    <table class="tableblock frame-all grid-all fit-content spread">
<colgroup>
<col>
<col>
</colgroup>
<thead>
<tr>
<th class="tableblock halign-left valign-top">項目</th>
<th class="tableblock halign-left valign-top">値</th>
</tr>
</thead>
<tbody>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Display Name (表示名)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">ロガーの名前 (​<code>Log Response</code>​ など)</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Message (メッセージ)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock"><code>Sent Message: `​#[payload]​`</code></p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Level (レベル)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">INFO (Default) (INFO (デフォルト))</p></td>
</tr>
</tbody>
</table>
    
    次に例を示します。
    
    ![Logger](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-logger.png)

### [](#キュー内のメッセージ数を取得する)キュー内のメッセージ数を取得する

1. \[Mule Palette (Mule パレット)\] ビューで、​**「Amazon SQS」**​を検索します。
2. **\[Get approximate number of messages\]**​ 操作を選択し、キャンバスの ​**\[Logger\]**​ コンポーネントの右にドラッグします。
3. プロパティウィンドウで次の各項目を設定します。
    
    <table class="tableblock frame-all grid-all fit-content spread">
<colgroup>
<col>
<col>
</colgroup>
<thead>
<tr>
<th class="tableblock halign-left valign-top">項目</th>
<th class="tableblock halign-left valign-top">値</th>
</tr>
</thead>
<tbody>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Queue url (キュー URL)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">Amazon SQS キュー URL</p></td>
</tr>
</tbody>
</table>
    
    次に例を示します。
    
    ![get-message-count](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-get-message-count.png)

### [](#mule-コンソールに数を出力するロガーを追加する)Mule コンソールに数を出力するロガーを追加する

1. \[Mule Palette (Mule パレット)\] ビューで、​**「Logger」**​を検索します。
2. コンポーネントをキャンバスの ​**\[Get approximate number of messages\]**​ コンポーネントの右にドラッグします。
3. 次の項目を設定します。
    
    <table class="tableblock frame-all grid-all fit-content spread">
<colgroup>
<col>
<col>
</colgroup>
<thead>
<tr>
<th class="tableblock halign-left valign-top">項目</th>
<th class="tableblock halign-left valign-top">値</th>
</tr>
</thead>
<tbody>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Display Name (表示名)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">ロガーの名前 (​<code>Log Count</code>​ など)</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Message (メッセージ)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock"><code>Approx. messages in queue: `​#[payload]​`</code></p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Level (レベル)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">INFO (Default) (INFO (デフォルト))</p></td>
</tr>
</tbody>
</table>
    
    次に例を示します。
    
    ![log-message-count](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-logger2.png)

## [](#メッセージを受信するフローを作成する)メッセージを受信するフローを作成する

最後に、メッセージを受信して記録し、キューから削除する別のフローを作成します。

1. \[Mule Palette (Mule パレット)\] ビューで​**「SQS」**​を検索し、​**\[Receive messages\]**​ 操作を選択します。
    
    ![select-receive-messages](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-select-receive.png)
2. **\[Receive messages\]**​ 操作をキャンバスにドラッグします。
3. プロパティウィンドウで次の各項目を設定します。
    
    <table class="tableblock frame-all grid-all fit-content spread">
<colgroup>
<col>
<col>
</colgroup>
<thead>
<tr>
<th class="tableblock halign-left valign-top">項目</th>
<th class="tableblock halign-left valign-top">値</th>
</tr>
</thead>
<tbody>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Display Name (表示名)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">コネクタ操作の名前</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Connector Configuration (コネクタ設定)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">Amazon SQS 用 Anypoint Connector (Amazon SQS Connector) で以前に作成したグローバル設定</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Number of Messages (メッセージ数)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">10</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Queue url (キュー URL)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">Amazon SQS キュー URL。</p>
<p class="tableblock">指定した場合、この項目の値は ​<strong>[Global Configuration Elements (グローバル設定要素)]</strong>​ ウィンドウの ​<strong>[Default Global Queue URL (デフォルトのグローバルキュー URL)]</strong>​ 項目の値よりも優先されます。</p></td>
</tr>
</tbody>
</table>
    
    次に例を示します。
    
    ![receive-message](/mulesoft/current/ja-jp/amazon-sqs-connector/5.7/_images/amazon-sqs-receive-message.png)
4. Mule コンソールにメッセージを表示するロガーを追加します。
5. 次の項目値を使用してロガーを設定します。
    
    <table class="tableblock frame-all grid-all fit-content spread">
<colgroup>
<col>
<col>
</colgroup>
<thead>
<tr>
<th class="tableblock halign-left valign-top">項目</th>
<th class="tableblock halign-left valign-top">値</th>
</tr>
</thead>
<tbody>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Display Name (表示名)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">任意の名前</p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Message (メッセージ)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock"><code>`​#[payload]​`</code></p></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock">Level (レベル)</p></td>
<td class="tableblock halign-left valign-top"><p class="tableblock">INFO (Default) (INFO (デフォルト))</p></td>
</tr>
</tbody>
</table>

## [](#mule-アプリケーション-xml-コードの例)Mule アプリケーション XML コードの例

このユースケース例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを XML エディターに貼り付けます。必要に応じて、環境に合わせて値を変更します。

```xml
<mule xmlns:sqs="http://www.mulesoft.org/schema/mule/sqs" xmlns:ee="http://www.mulesoft.org/schema/mule/ee/core"
	xmlns:http="http://www.mulesoft.org/schema/mule/http"
	xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
  http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
  http://www.mulesoft.org/schema/mule/ee/core
  http://www.mulesoft.org/schema/mule/ee/core/current/mule-ee.xsd
  http://www.mulesoft.org/schema/mule/sqs
	http://www.mulesoft.org/schema/mule/sqs/current/mule-sqs.xsd">
	<http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config" >
		<http:listener-connection host="0.0.0.0" port="8081" />
	</http:listener-config>
	<sqs:config name="Amazon_SQS_Configuration" doc:name="Amazon SQS Configuration"
	defaultQueueUrl="${sqs.queueUrl}" >
		<sqs:basic-connection accessKey="${sqs.accessKey}" secretKey="$sqs.secretKey}" region="us-east-1" />
	</sqs:config>
	<flow name="sqs-send-messageFlow" >
		<http:listener doc:name="Listener"
		config-ref="HTTP_Listener_config"
		path="/"/>
		<ee:transform doc:name="Transform Message" >
			<ee:message >
				<ee:set-payload ><![CDATA[%dw 2.0
output application/java
---
{
	delaySeconds: 0,
	body: "Hello World",
	messageAttributes: {
		"AccountId": {
			"stringValue" : "000123456",
			"dataType" : "String.AccountId"
		} as Object {
			class: "org.mule.extension.sqs.api.model.MessageAttributeValue"
		},
		"NumberId": {
			"stringValue" : "230.000000000000000001",
			"dataType" : "Number"
		} as Object {
			class : "org.mule.extension.sqs.api.model.MessageAttributeValue"
		}
	} as Object {
		class: "java.util.HashMap"
	}
} as Object {
	class: "org.mule.extension.sqs.api.model.Message"
}]]></ee:set-payload>
			</ee:message>
		</ee:transform>
		<sqs:send-message doc:name="Send message" configref="Amazon_SQS_Configuration"/>
		<logger level="INFO"
		doc:name="Log Response"
		message="payload"/>
		<sqs:get-approximate-number-of-messages
		doc:name="Get approximate number of messages"
		config-ref="Amazon_SQS_Configuration"
		queueUrl="${sqs.queueUrl}"/>
		<logger level="INFO" doc:name="Log Count"
		message="Sent Message: `#[payload]`"/>
	</flow>
	<flow name="sqs-receive-message-flow" >
		<sqs:receivemessages doc:name="Receive messages"
		config-ref="Amazon_SQS_Configuration"/>
		<logger level="INFO" doc:name="Log Receipt" />
	</flow>
</mule>
```

## [](#関連情報)関連情報

- [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors)
- [MuleSoft ヘルプセンター](https://help.mulesoft.com)