Amazon API Gateway を Amazon SQS と統合して非同期 REST APIs を処理する - AWS 規範ガイダンス
概要前提条件と制限アーキテクチャツールエピック関連リソース

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

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

Natalia Colantonio Favero と Gustavo Martim、Amazon Web Services

概要

REST APIsデプロイする場合、クライアントアプリケーションが発行できるメッセージキューを公開する必要がある場合があります。例えば、サードパーティー APIs のレイテンシーやレスポンスの遅延に問題がある場合や、データベースクエリの応答時間を回避したり、多数の同時 APIs がある場合にサーバーをスケーリングしないようにしたい場合があります。このようなシナリオでは、キューに発行するクライアントアプリケーションは、API がデータを受信したことを知るだけで済みます。データの受信後に何が起こるかを知る必要はありません。

このパターンは、Amazon API Gateway を使用して Amazon Simple Queue Service (Amazon SQS) にメッセージを送信することで REST API エンドポイントを作成します。 Amazon SQS これにより、SQS キューへの直接アクセスを回避する、2 つのサービス間のeasy-to-implement統合が作成されます。

前提条件と制限

アーキテクチャ

API Gateway を Amazon SQS と統合するためのアーキテクチャ

この図は、これらのステップを示しています。

  1. Postman、別の API、またはその他のテクノロジーなどのツールを使用して、POST REST API エンドポイントをリクエストします。

  2. API Gateway は、リクエストの本文で受信されるメッセージをキューに投稿します。

  3. Amazon SQS はメッセージを受信し、成功コードまたは失敗コードを含む回答を API Gateway に送信します。

ツール

  • 「Amazon API Gateway」は、任意のスケールで REST、HTTP、WebSocket API を作成、公開、維持、監視、保護する上で役立ちます。

  • AWS Identity and Access Management (IAM) は、誰が認証され、誰に使用を許可するかを制御することで、 AWS リソースへのアクセスを安全に管理できます。

  • 「Amazon Simple Queue Service (Amazon SQS) 」は、安全で耐久性があり、配信ソフトウェアシステムとコンポーネントを統合および分離できる利用可能なホスト型キューを提供します。  

エピック

タスク説明必要なスキル

キューを作成する。

REST API からメッセージを受信する SQS キューを作成するには：

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

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

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

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

  5. Type の場合、デフォルト設定 (標準) のままにします。

  6. キュー名を入力します。

  7. 他のすべての設定のデフォルト値を保持します。

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

アプリ開発者
タスク説明必要なスキル

IAM ロールを作成します。

この IAM ロールは、API Gateway リソースに Amazon SQS へのフルアクセスを付与します。

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

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

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

  4. ユースケースでは、ドロップダウンリストから API Gateway を選択し、次へ、次へを選択します。

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

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

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

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

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

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

アプリ開発者、AWS 管理者
タスク説明必要なスキル

REST API を作成します。

これは、HTTP リクエストが送信される REST API です。

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

  2. REST API セクションで、ビルド を選択します。

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

アプリ開発者

API Gateway を Amazon SQS に接続します。

このステップにより、HTTP リクエストの本文内から Amazon SQS にメッセージが流れるようになります。

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

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

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

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

  5. でAWS リージョン、SQS キューを作成したリージョンを選択します。

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

  7. HTTP メソッドの場合は、POST を選択します。

  8. アクションタイプ で、パスオーバーライドを使用する を選択します。

  9. パスオーバーライドには、<AWS アカウント ID>/<SQS queue> の名前を入力します。

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

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

アプリ開発者
タスク説明必要なスキル

REST API をテストします。

テストを実行して、設定が欠落していないことを確認します。

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

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

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

  4. リクエスト本文には、次の JSON コードを貼り付けます。

    {
     "message": "lorem ipsum"
}

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

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

    <UnknownOperationException/>
アプリ開発者

API 統合を変更して、リクエストを Amazon SQS に適切に転送します。

設定を完了して、統合エラーを修正します。

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

  2. メソッド実行セクションには、API Gateway と Amazon SQS 間のビジュアルマッピングが表示されます。このセクションでは、統合リクエストを選択し、編集を選択します。

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

    • Name に Content-Type を指定します。

    • マッピング元に「application/x-www-form-urlencoded」と入力します。必ず一重引用符を含めてください。

    • キャッシュチェックボックスをオンにします。

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

    • [マッピングテンプレートの追加] を選択します。

    • コンテンツタイプに application/json と入力します。

    • テンプレート本文の場合は、次のコードを貼り付けます。

      Action=SendMessage&MessageBody=$input.body

    • [保存] を選択します。

アプリ開発者

Amazon SQS でメッセージをテストおよび検証します。

テストを実行して、テストが正常に完了したことを確認します。

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

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

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

  4. リクエスト本文には、次の JSON コードを貼り付けます。

    {
     "message": "lorem ipsum"
}

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

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

  7. ナビゲーションペインで、キューを選択し、キューを選択します。

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

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

  10. [メッセージ] を選択します。以下が表示されます。

    Body { "message": "lorem ipsum" }
アプリ開発者

特殊文字を使用して API Gateway をテストします。

メッセージで受け入れられない特殊文字 (& など) を含むテストを実行します。

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

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

    {
     "message": "lorem ipsum &"
}

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

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

    {
  "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 Gateway ドキュメントを参照してください。

アプリ開発者

特殊文字をサポートするように API 設定を変更します。

メッセージで特殊文字を受け入れるように設定を調整します。

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

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

  3. コンテンツ処理を変更してテキストに変換します。

  4. 「マッピングテンプレート」セクションで、次の操作を行います。

    • コンテンツタイプに application/json と入力します。

    • テンプレート本文には、以下を指定します。

      Action=SendMessage&MessageBody=$util.urlEncode($input.body)

    • [保存] を選択します。

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

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

    {
     " message": "lorem ipsum &" }

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

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

  9. キューを選択し、メッセージの送受信、メッセージのポーリング、メッセージを選択します。

新しいメッセージには特殊文字が含まれている必要があります。

アプリ開発者
タスク説明必要なスキル

API をデプロイします。

REST API をデプロイするには：

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

  2. API を選択します。

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

アプリ開発者

外部ツールを使用してテストします。

外部ツールを使用してテストを実行し、メッセージが正常に受信されたことを確認します。

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

  2. API を実行します。

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

  4. キューを選択します。

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

アプリ開発者
タスク説明必要なスキル

API を削除します。

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

アプリ開発者

IAM ロールを削除します。

IAM コンソールのロールペインで、AWSGatewayRoleForSQS を選択し、削除を選択します。

アプリ開発者

SQS キューを削除します。

Amazon SQS コンソールのキューペインで、作成した SQS キューを選択し、削除を選択します。

アプリ開発者

関連リソース