AWS AppSync에서 HTTP 해석기 사용

마이크로서비스에 대한 비즈니스 로직이 포함된 Lambda 함수를 설정합니다.

다음 엔드포인트/메서드/콘텐츠 유형 조합으로 API Gateway REST API를 설정합니다.

AWS AppSync 콘솔을 열고 API 생성을 선택합니다.

GraphQL API를 선택한 다음 처음부터 새로 디자인을 선택합니다. Next(다음)를 선택합니다.

API에 UserData를 입력합니다. Next(다음)를 선택합니다.

Create GraphQL resources later를 선택합니다. Next(다음)를 선택합니다.

입력 내용을 검토하고 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 엔드포인트를 선택합니다.

생성(Create)을 선택합니다.

해석기 코드 편집기에서 다음 코드 조각을 요청 핸들러로 추가합니다.

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 GetUser{
    getUser(id:1){
        id
        username
    }
}

그러면 다음과 같은 응답이 반환됩니다.

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

스키마 탭을 선택합니다.

스키마 편집기의 오른쪽에 있는 해석기 창의 쿼리 유형 아래에서 addUser 필드를 찾아 연결을 선택합니다.

해석기 유형을 Unit으로 유지하고 런타임을 APPSYNC_JS로 유지합니다.

데이터 소스 이름에서 이전에 만든 HTTP 엔드포인트를 선택합니다.

생성(Create)을 선택합니다.

해석기 코드 편집기에서 다음 코드 조각을 요청 핸들러로 추가합니다.

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

쿼리 탭을 선택한 후, 다음 쿼리를 실행합니다.

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

getUser 쿼리를 다시 실행하면 다음과 같은 응답이 반환되어야 합니다.

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