でのHTTPリゾルバーの使用 AWS AppSync

マイクロサービス用のビジネスロジックを含む Lambda 関数を設定します。

次のendpoint/method/contentタイプの組み合わせRESTAPIで API Gateway を設定します。

AWS AppSync コンソールを開き、 の作成 APIを選択します。

GraphQL APIsを選択し、最初から設計 を選択します。[Next (次へ)] を選択します。

API 名前には、 と入力しますUserData。[Next (次へ)] を選択します。

[Create GraphQL resources later] を選択します。[Next (次へ)] を選択します。

入力を確認し、 の作成 APIを選択します。

AWS AppSync GraphQL のデータソースページでAPI、データソースの作成 を選択します。

HTTP_Example のようにデータソースの名前を入力します。

データソースタイプ で、HTTPエンドポイント を選択します。

チュートリアルの冒頭で作成された API Gateway エンドポイントにエンドポイントを設定します。Lambda コンソールに移動し、[アプリケーション] でアプリケーションを見つけると、スタックで生成されたエンドポイントを見つけることができます。アプリケーションの設定内には、 のAPIエンドポイントとなるエンドポイントが表示されます AWS AppSync。エンドポイントの一部にステージ名が含まれていないことを確認します。例えば、エンドポイントが https://aaabbbcccd.execute-api.us-east-1.amazonaws.com/v1 であれば、https://aaabbbcccd.execute-api.us-east-1.amazonaws.com に入力します。

AWS AppSync GraphQL でAPI、スキーマタブを選択します。

スキーマエディタの右側の［リゾルバー］ペインの［クエリタイプ］で、getUserフィールドを見つけて［アタッチ］を選択します。

リゾルバータイプはUnitのままにし、ランタイムはAPPSYNC_JSにします。

データソース名 で、前に作成したHTTPエンドポイントを選択します。

[Create] (作成) を選択します。

Resolver コードエディターで、次のスニペットをリクエストハンドラーとして追加します。

import { util } from '@aws-appsync/utils'

export function request(ctx) {
	return {
		version: '2018-05-29',
		method: 'GET',
		params: {
			headers: {
				'Content-Type': 'application/json',
			},
		},
		resourcePath: `/v1/users/${ctx.args.id}`,
	}
}

次のスニペットをレスポンスハンドラーとして追加します。

export function response(ctx) {
	const { statusCode, body } = ctx.result
	// if response is 200, return the response
	if (statusCode === 200) {
		return JSON.parse(body)
	}
	// if response is not 200, append the response to error block.
	util.appendError(body, statusCode)
}

[Query (クエリ)] タブを選択して、以下のクエリを実行します。

query GetUser{
    getUser(id:1){
        id
        username
    }
}

これは以下のレスポンスを返します。

{
    "data": {
        "getUser": {
            "id": "1",
            "username": "nadia"
        }
    }
}

[Schema (スキーマ)] タブを選択します。

スキーマエディタの右側の［リゾルバー］ペインの［クエリタイプ］で、addUserフィールドを見つけて［アタッチ］を選択します。

リゾルバータイプはUnitのままにし、ランタイムはAPPSYNC_JSにします。

データソース名 で、前に作成したHTTPエンドポイントを選択します。

[Create] (作成) を選択します。

Resolver コードエディターで、次のスニペットをリクエストハンドラーとして追加します。

export function request(ctx) {
    return {
        "version": "2018-05-29",
        "method": "POST",
        "resourcePath": "/v1/users",
        "params":{
            "headers":{
                "Content-Type": "application/json"
            },
        "body": ctx.args.userInput
        }
    }
}

次のスニペットをレスポンスハンドラーとして追加します。

export function response(ctx) {
    if(ctx.error) {
        return util.error(ctx.error.message, ctx.error.type)
    }
    if (ctx.result.statusCode == 200) {
        return ctx.result.body
    } else {
        return util.appendError(ctx.result.body, "ctx.result.statusCode")
    }
}

[Query (クエリ)] タブを選択して、以下のクエリを実行します。

mutation addUser{
    addUser(userInput:{
        id:"2",
        username:"shaggy"
    }){
        id
        username
    }
}

getUser クエリを再実行すると、次のレスポンスが返されるはずです。

{
    "data": {
        "getUser": {
        "id": "2",
        "username": "shaggy"
        }
    }
}