[AWS] CodeDeploy: Lambda 롤링 배포

#AWS

람다는 여러모로 정말 편리한 서비스 중 하나다.
전반적인 관리비용이 거의 없다는 것도 그렇지만, 배포도 정말 편하긴 하다.
그냥 아래처럼 소스만 압축해서 올리면 끝이니 말이다.

게다가 이에 따른 새 버전 전환도 상당히 빠르고, 소스가 바뀐다고 서비스가 중간에 끊기지도 않는다.

하지만 이렇게 그냥 무작정 올리고 마는 것은 좀.. 아쉬운 점이 있다.
만에 하나라도 새로 올리는 소스에 문제가 있다면 어떻게 하나? 배포시에 잘 동작하는지 한번더 최종 점검을 해야 하지 않나?

그래서 필요한 것이 [롤링 배포]라는 것이다.
롤링 배포는 새 버전을 올리더라도 새 버전이 잘 동작할때까지 기다리고, 잘 동작하는게 확인되면 버전을 교체하되, 동작하지 않는다면 배포를 취소하는 기법이다.

Code Deploy를 통해 이를 적용해보도록 하겠다.

람다 버전 생성

람다는 별다른 설정을 하지 않는다면 LATEST 하나의 버전만 존재하나, 롤링 배포를 처리하려면 버전을 제대로 명시할 필요가 있다.

버전이 없는 상태라면 버전 탭에 들어가서 버전을 2개 만들어주자.

우리는 여기서 버전 1이 기존의 소스. 버전 2가 새로 배포할 버전의 소스라고 가정하겠다.

람다 별칭 생성

롤링 배포를 제대로 적용하려면 람다에 별칭을 추가해야 한다.
새로운 버전의 람다가 계속 올라오더라도 최종 엔드포인트는 하나여야 하지 않겠는가? 그걸 잡아주는 것이 별칭이다.

저기 별칭 탭에 보면 별칭 생성 버튼이 있다.

이름은 적당히 잘 지어준다.
여기서는 1 버전의 별칭으로 만들 것이다.

그리고 이 별칭을 통해 최종 배포를 하면 되는 것이다.

API GateWay로 Api 열어주고 쓰면 되는데, 주의할 점은 이럴때 그냥 함수명을 적는게 아니라 별칭의 ARN을 넣어줘야 한다는 것이다.

이렇게 말이다.

Code Deploy 앱 생성

Code Deploy에 들어가서 애플리케이션 생성을 선택, 플랫폼을 람다로 하고 생성한다.

그럼 이렇게 배포 관리 페이지가 생겨날 것이다.

그럼 이제 배포 그룹을 생성해서

저기에 서비스 역할을 만들어서 arn을 넣어주면 된다.

서비스 역할 생성

배포그룹에 사용할 역할은 다음과 같이 생성할 수 있다.
사용 사례에서 저걸 골라서

정책을 다음과 같이 2개 연결해주고

신뢰관계에 codedeploy 도메인을 넣어주면 된다.

그럼 이렇게 생성이 잘 될 것이다.

롤백 설정

만약 새로만든 람다 버전에 문제가 발생한다면 롤백을 시켜야 하지 않겠는가.
밑에 고급에서 롤백 비활성화를 해제하고 롤백을 설정해주자.

이렇게 해서 CodeDeploy 앱을 만들어주면 된다.

버킷 생성

이게 다가 아니다.
배포할때마다 버전을 어떻게 올릴지 그런걸 정의해야 하는데, 이걸 appspec 파일이라고 한다.

그걸 저장해놓을 S3 버킷을 만들어주자.

그리고 다음과 같은 형식으로 배포 설정파일을 써서 넣어주면 된다.

version: 0.0
Resources:
  - myLambdaFunction:
      Type: AWS::Lambda::Function
      Properties:
        Name: "express_test"
        Alias: "rolling"
        CurrentVersion: "7"
        TargetVersion: "8"
Hooks:
  - BeforeAllowTraffic: "code-deploy-check"

여기서 Name은 말 그대로 함수명, Alias는 아까 만든 별칭.
Current는 현재 배포되어있는 버전. TargetVersion은 배포할 버전이다.

그리고 BeforeAllowTraffic는 트래픽을 옮기기 전에 트리거를 걸어주는 것이다.
값으로 들어가는건 함수명이다.
저기서 소스의 정상작동에 대한 검증을 하면 된다.

Health Check용 훅 함수

훅 함수는 대략 다음과 같은 구조로 작성하면 된다.

'use strict';

const aws = require('aws-sdk');
const codedeploy = new aws.CodeDeploy({apiVersion: '2014-10-06'});

exports.handler = async (event, context, callback) => {
    //Read the DeploymentId from the event payload.
    var deploymentId = event.DeploymentId;

    //Read the LifecycleEventHookExecutionId from the event payload
    var lifecycleEventHookExecutionId = event.LifecycleEventHookExecutionId;

    /*
    ... 여기서 검증.
    */

    // Prepare the validation test results with the deploymentId and
    // the lifecycleEventHookExecutionId for CodeDeploy.
    var params = {
        deploymentId: deploymentId,
        lifecycleEventHookExecutionId: lifecycleEventHookExecutionId,
        status: 'Succeeded' // status can be 'Succeeded' or 'Failed'
    };

    //const bar = await codedeploy.getDe

    // Pass CodeDeploy the prepared validation test results.
    codedeploy.putLifecycleEventHookExecutionStatus(params, function(err, data) {
        if (err) {
            // 검증 실패
            callback('Validation test failed');
        } else {
            // 검증 성공
            callback(null, 'Validation test succeeded');
        }
    });
};

이건 공식문서에서 제공하는 템플릿이고, 나는 다음과 같이 사용했다.

람다의 target version을 호출해서 오류가 나면 putLifecycleEventHookExecutionStatus로 실패했다고 이벤트를 날려주고, 문제없으면 putLifecycleEventHookExecutionStatus에 성공알림을 보내는 것이다.

'use strict';

const aws = require('aws-sdk');
const codedeploy = new aws.CodeDeploy({apiVersion: '2014-10-06'});
const lambda = new aws.Lambda();

exports.handler = async (event, context, callback) => {
    // 이 값은 BeforeAllowTraffic로 걸면 자동으로 들어옴
    const deploymentId = event.DeploymentId;
    const lifecycleEventHookExecutionId = event.LifecycleEventHookExecutionId;

    // 체크용 호출
    const response = await lambda
		.invoke({
			FunctionName: 'express_test:9', //버전은 배포중인 target 버전이 들어가게 해주면 됨.
			Payload: JSON.stringify({}),
		})
		.promise()

	console.log('response: ', response)

	if(response.FunctionError !=='Unhandled') {
	    console.log('성공')
	    await codedeploy.putLifecycleEventHookExecutionStatus({
            deploymentId: deploymentId,
            lifecycleEventHookExecutionId: lifecycleEventHookExecutionId,
            status: 'Succeeded'
        }).promise();

        callback(null, 'Validation test succeeded');
	} 
	else {
	    console.log('실패')
	    await codedeploy.putLifecycleEventHookExecutionStatus({
            deploymentId: deploymentId,
            lifecycleEventHookExecutionId: lifecycleEventHookExecutionId,
            status: 'Failed' 
        }).promise();

        callback('Validation test failed');
	}
};