これから始めるAWS SQS！メッセージキューと上手に付き合うワンランク上の実装を解説😎

service: SQS-Serverless
provider:
  name: aws
  runtime: nodejs12.x
  stage: ${opt:stage,"dev"}
  region: ap-northeast-1
  profile: ragate
  iamRoleStatements:
    - Effect: 'Allow'
      Action:
        - 'sqs:*'
      Resource:
        - '*'

plugins:
  - serverless-webpack

custom:
  webpack:
    includeModules: true
    packager: 'npm'

functions: ${file(./resources/functions.yml)}

resources:
  - ${file(./resources/sqs.yml)}

package:
  individually: true

Resources:
  SQSQueue:
    Type: AWS::SQS::Queue
    Properties:
      # ContentBasedDeduplication: true # FifoQueue指定時のみ設定、先入れ先出し (FIFO) キューに対して、コンテンツに基づく重複排除を有効にするかどうかを指定
      DelaySeconds: 0 # メッセージの配信を遅延させたい場合。
      # FifoQueue: false # 指定しないと標準キューで作成される
      # KmsDataKeyReusePeriodSeconds: 300 # AWS KMS を呼び出す前にメッセージを暗号化または復号できる時間の長さ
      # KmsMasterKeyId: String KMSを利用する場合は必須な様子
      MaximumMessageSize: 262144 # メッセージのバイト数の制限(超過するとSQSが処理を拒否、最大値で262144まで設定が可能)
      MessageRetentionPeriod: 345600 # Amazon SQS がメッセージを保持する秒数(デフォルトは345,600(4日))
      QueueName: "SampleQueue" # FIFO キューを作成するには、FIFO キューの名前は .fifo サフィックスで終わる必要があります
      ReceiveMessageWaitTimeSeconds: 5 # キューが処理中の際の、ポーリング待機時間(0を指定するとショートポーリングとなる)
      RedrivePolicy:
        deadLetterTargetArn: { Fn::GetAtt: [DeadLetterSQSQueue, Arn] }
        maxReceiveCount: 2
      VisibilityTimeout: 5 # キュー受信時から、他Componentがキューを見れない秒数

  DeadLetterSQSQueue: # デッドレターキューにキューが入ったらLambdaを起動し、メール通知などを検討したい
    Type: AWS::SQS::Queue
    Properties:
      DelaySeconds: 0
      MaximumMessageSize: 262144
      MessageRetentionPeriod: 200
      QueueName: "DeadSampleQueue"
      ReceiveMessageWaitTimeSeconds: 5
      VisibilityTimeout: 10

createSQSQueue:
  handler: src/functions/createSQSQueue.handler
  environment:
    QUEUE_NAME: { Fn::GetAtt: [SQSQueue, QueueName] }
    QUEUE_ARN: { Fn::GetAtt: [SQSQueue, Arn] }
    QUEUE_END_POINT: !Ref SQSQueue

createEventSQSQueue:
  handler: src/functions/createEventSQSQueue.handler
  timeout: 4 # VisibilityTimeoutよりも低く設定する必要があるので一旦４秒に設定しておく
  events:
    - sqs:
        arn: { Fn::GetAtt: [SQSQueue, Arn] }
        batchSize: 1

const AWS = require("aws-sdk")
const SQS = new AWS.SQS({region: "ap-northeast-1"})
const QueueUrl = process.env.QUEUE_END_POINT

export async function handler(event, context) {
  try {    
    const MessageBody = JSON.stringify({
      id: event.id,
      text: event.input.text
    })
    const result = await SQS.sendMessage({MessageBody, QueueUrl}).promise()
    return {
      id: event.id,
      text: event.input.text,
      queueName: process.env.QUEUE_NAME,
      queueEndpoint: QueueUrl,
      messageId: result['MessageId']
    }
  } catch (e) {
    console.error(e)
  }
}

export async function handler(event, context) {
  throw('リトライ処理のためのThrow!');
}