Lambdaが異常終了した際にアラート通知させる仕組みをAWS SAMのテンプレートで一括デプロイ

$ sam --version
SAM CLI, version 0.4.0
$ sam init --runtime python3.6

$ tree -L 2
.
├── deploy.sh
├── hello_world
│   ├── app.py
│   ├── __init__.py
│   └── __pycache__
├── output.yaml
├── README.md
├── requirements.txt
├── template.yaml
└── tests
    └── unit

AWSTemplateFormatVersion: '2010-09-09'
Transform: AWS::Serverless-2016-10-31
Description: >
  sam-cwl-alarms

  Sample SAM Template for sam-cwl-alarms

# More info about Globals: https://github.com/awslabs/serverless-application-model/blob/master/docs/globals.rst
Globals:
  Function:
    Timeout: 10
    MemorySize: 128


Resources:

  HelloWorldFunction:
    Type: AWS::Serverless::Function # More info about Function Resource: https://github.com/awslabs/serverless-application-model/blob/master/versions/2016-10-31.md#awsserverlessfunction
    Properties:
      CodeUri: hello_world
      Handler: app.lambda_handler
      Runtime: python3.6
      Environment: # More info about Env Vars: https://github.com/awslabs/serverless-application-model/blob/master/versions/2016-10-31.md#environment-object
        Variables:
          PARAM1: VALUE
      Events:
        HelloWorldFunction:
          Type: Api # More info about API Event Source: https://github.com/awslabs/serverless-application-model/blob/master/versions/2016-10-31.md#api
          Properties:
            Path: /hello
            Method: get
      ReservedConcurrentExecutions: 1 #同時実行数の上限エラーを検知したいので1に設定

# Lambdaの標準メトリクスErrorsを監視するCloudWatch Alarms
  HelloWorldErrorAlarm:
    Type: AWS::CloudWatch::Alarm
    Properties:
      AlarmDescription: "Lambda関数のErrorメトリクスを監視して、60秒間のデータポイントの合計値が1以上の場合にSNSをトリガーするアラーム"
      AlarmActions:
        - Ref: HelloWorldSNSTopic
      MetricName: Errors
      Namespace: AWS/Lambda
      Statistic: Sum
      Period: '60'
      EvaluationPeriods: '1'
      Threshold: 1
      ComparisonOperator: GreaterThanOrEqualToThreshold
      TreatMissingData: notBreaching
      Dimensions:
      - Name: FunctionName
        Value: !Ref HelloWorldFunction

# Lambdaの標準メトリクスThrottlesを監視するCloudWatch Alarms
  HelloWorldThrottlesAlarm:
    Type: AWS::CloudWatch::Alarm
    Properties:
      AlarmDescription: "Lambda関数のThrottlesメトリクスを監視して、60秒間のデータポイントの合計値が1以上の場合にSNSをトリガーするアラーム"
      AlarmActions:
        - Ref: HelloWorldSNSTopic
      MetricName: Throttles
      Namespace: AWS/Lambda
      Statistic: Sum
      Period: '60'
      EvaluationPeriods: '1'
      Threshold: 1
      ComparisonOperator: GreaterThanOrEqualToThreshold
      TreatMissingData: notBreaching
      Dimensions:
      - Name: FunctionName
        Value: !Ref HelloWorldFunction

# CloudWatch AlarmsからトリガーされるSNS
  HelloWorldSNSTopic:
    Type: AWS::SNS::Topic
    Properties:
      Subscription:
      - Endpoint: your_mail_address@mail.com
        Protocol: email
      TopicName: HelloWorldAlertSNS

Outputs:

  HelloWorldFunctionApi:
    Description: "API Gateway endpoint URL for Prod stage for Hello World function"
    Value: !Sub "https://${ServerlessRestApi}.execute-api.${AWS::Region}.amazonaws.com/Prod/hello/"

  HelloWorldFunction:
    Description: "Hello World Lambda Function ARN"
    Value: !GetAtt HelloWorldFunction.Arn

  HelloWorldFunctionIamRole:
    Description: "Implicit IAM Role created for Hello World function"
    Value: !GetAtt HelloWorldFunctionRole.Arn

from time import sleep
import json
import logging
import boto3

logger = logging.getLogger()
logger.setLevel(logging.INFO)


def lambda_handler(event, context):
    try:

        # 権限エラーを意図的に引き起こす処理
        if(event['queryStringParameters']['permissionDeny']):
            logger.info('権限エラーになる処理')
            client = boto3.client('dynamodb')
            ddb_response = client.list_tables()
            logger.info(ddb_response)

        # タイムアウトを意図的に引き起こす処理
        if(event['queryStringParameters']['timeOut']):
            logger.info('タイムアウトになる処理')
            sleep(30)

        # メモリ超過を意図的に引き起こす処理
        if(event['queryStringParameters']['memoryExceed']):
            logger.info('メモリ超過になる処理')
            some_str = ' '
            some_str *= 128000000
            logger.info(some_str)

        return {
            "statusCode": 200,
            "body": json.dumps({'message': 'hello world'})
        }

    except Exception as e:
        # キーが存在しない場合などの、例外処理
        logger.error(e)
        raise e

aws s3 mb s3://

aws cloudformation package --template-file template.yaml --output-template-file output.yaml --s3-bucket

aws cloudformation deploy --template-file output.yaml --stack-name --capabilities CAPABILITY_IAM

$ curl "https://<domain>/Prod/hello?permissionDeny=&timeOut=&memoryExceed="
{"message": "hello world"}

$ curl "https://<domain>/Prod/hello"
{"message": "Internal server error"}

$ curl "https://<domain>/Prod/hello?permissionDeny=true&timeOut=&memoryExceed="
{"message": "Internal server error"}

$ curl "https://<domain>/Prod/hello?permissionDeny=&timeOut=true&memoryExceed="
{"message": "Internal server error"}

$ curl "https://<domain>/Prod/hello?permissionDeny=&timeOut=&memoryExceed=true"
{"message": "Internal server error"}

$ curl "https://<domain>/Prod/hello?permissionDeny=&timeOut=&memoryExceed=" & curl "https://<domain>/Prod/hello?permissionDeny=&timeOut=&memoryExceed="
{"message": "Internal server error"}