Amazon API Gateway を Amazon SQS と統合して非同期 REST API を処理する

AWS アカウントにサインインします。

Amazon SQS コンソールを https://console.aws.amazon.com/sqs/ で開きます。

[キューの作成] を選択します。

キューの作成ページで、リージョン AWS リージョン のドロップダウンリストから正しいものを選択します。

[タイプ] については、デフォルト設定 ([標準]) のままにしておきます。

キュー名を入力します。

他の設定はすべてデフォルト値のままにしておきます。

[キューの作成] を選択します。

IAM コンソール (https://console.aws.amazon.com/iam/) を開きます。

ナビゲーションペインで [ロール]、[ロールの作成] の順に選択します。

信頼できるエンティティタイプ で、AWS のサービス を選択します。

[ユースケース] には、ドロップダウンリストから [API Gateway] を選択し、[次へ]、[次へ] の順に選択します。

[ロール名] には、AWSGatewayRoleForSQS とオプションの説明を入力し、[ロールの作成] を選択します。

[ロール] ペインで、AWSGatewayRoleForSQS を検索して、そのチェックボックスをオンにします。

[アクセス許可ポリシー] で、[アクセス許可を追加] と [ポリシーをアタッチ] を続けて選択します。

AmazonSQSFullAccess を検索して選択します。

[Add permissions (許可の追加)] を選択します。

AWSGatewayRoleForSQS の [概要] セクションで、Amazon リソース番号 (ARN) をコピーします。この ID は、後のステップで使用します。

API Gateway コンソール (「https://console.aws.amazon.com/apigateway」) を開きます。

[REST API] セクションで、[構築] を選択します。

[API 名] に API の名前とオプションの説明を入力し、その他はすべてデフォルト設定のままにして、[API の作成] を選択します。

API Gateway コンソールで、作成した API を選択します。

[リソース] ページの [メソッド] セクションで、[メソッドの作成] を選択します。

[メソッドタイプ] で、[POST] を選択します。 

[統合タイプ] で、AWS のサービスを選択します。

AWS リージョン については、SQS キューを作成する [リージョン] を選択します。

AWS のサービスで、[Simple Queue Service (SQS)] を選択します。

[HTTP メソッド] で、[POST] を選択します。

[アクションタイプ] で、[パス上書きの使用] を選択します。

[パスオーバーライド] に、<AWS アカウント ID>/<SQS キューの名前> を入力します。

[実行ロール] には、前に作成したロールの ARN を貼り付けます。

[メソッドの作成] を選択します。

API Gateway コンソールで、作成した REST API を選択します。

[リソース] ペインで、POST メソッドを選択します。

[テスト] タブを選択します。(タブが表示されない場合は、右矢印を使用します。）

[リクエスト本文] に以下の JSON コードを貼り付けます。

{
     "message": "lorem ipsum"
}

[テスト] を選択します。

次のようなエラーが表示されます。

<UnknownOperationException/>

API Gateway コンソールで、作成した API を選択し、POST を選択します。

[メソッドの実行] セクションには、API Gateway と Amazon SQS 間の視覚的なマッピングが表示されます。このセクションから、[統合リクエスト]、[編集] の順に選択します。

[HTTP ヘッダー] セクションを展開し、[リクエストヘッダーのパラメータを追加] を選択します。

[マッピングテンプレート] セクションを展開します。

API Gateway コンソールで、作成した REST API を選択します。

[リソース] ペインで、POST メソッドを選択します。

[テスト] タブを選択します。(タブが表示されない場合は、右矢印を使用します。）

[リクエスト本文] に以下の JSON コードを貼り付けます。

{
     "message": "lorem ipsum"
}

[テスト] を選択します。

Amazon SQS コンソールを開きます。

ナビゲーションペインで、[キュー] を選択してから、対象のキューを選択します。

[メッセージの送信と受信] を選択します。

メッセージをポーリングを選択します。

[メッセージ] を選択します。次のように表示されます。

Body { "message": "lorem ipsum" }

API Gateway コンソールで、API を選択します。

次の JSON コードを使用して、前のステップのテストを繰り返します。

{
     "message": "lorem ipsum &"
}

[テスト] を選択します。

次のようなエラーが表示されます。

{
  "Error": {
    "Code": "AccessDenied",
    "Message": "Access to the resource https://sqs.us-east-2.amazonaws.com/976166761794/Apg2 is denied.",
    "Type": "Sender"
  },
  "RequestId": "e83c9c67-bcf6-5e9a-91e9-c737094b17ab"
}

API Gateway コンソールで、作成した API を選択し、POST を選択します。

[統合リクエスト]、[編集] の順に選択します。

[コンテンツの処理] を [テキストに変換] に変更します。

[マッピングテンプレート] セクションで、以下を行います。

[テスト] タブを選択します。

[リクエスト本文] には、前述の JSON コードを入力します。

{
     " message": "lorem ipsum &" }

[テスト] を選択します。

Amazon SQS コンソールを開きます。

キューを選択し、前と同じように [メッセージを送受信]、[メッセージをポーリング]、[メッセージ] の順に選択します。

API Gateway コンソールを開きます。

API を選択します。

[API のデプロイ] を選択します。このステップの詳細については、「API Gateway ドキュメント」を参照してください。

Postman、Insomnia、cURL などのツールを開きます。

API を実行します。

Amazon SQS コンソールを開きます。

対象のキューを選択します。

メッセージをロードして新しいメッセージを表示します。