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

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

以下のエンドポイント/メソッド/コンテンツタイプを組み合わせて、API Gateway REST API をセットアップします。

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

[GraphQL API] を選択し、[最初から設計] を選択します。[次へ ]を選択します。

API 名として「UserData」と入力します。[次へ] を選択します。

Create GraphQL resources later を選択してください。[次へ] を選択します。

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

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

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

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

チュートリアルの最初に作成された API ゲートウェイエンドポイントに、エンドポイントを設定します。Lambda コンソールに移動し、[アプリケーション] でアプリケーションを見つけると、スタックで生成されたエンドポイントを見つけることができます。アプリケーションの設定の中に、AWS AppSync のエンドポイントとなる API エンドポイントが表示されます。エンドポイントの一部にステージ名が含まれていないことを確認します。例えば、エンドポイントが 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 エンドポイントを選択します。

[作成] を選択します。

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 エンドポイントを選択します。

[作成] を選択します。

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"
        }
    }
}