batch-process-using-sqs-sns/template.yaml at master · devbks/batch-process-using-sqs-sns · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
AWSTemplateFormatVersion: '2010-09-09'
Transform: AWS::Serverless-2016-10-31
Description: >
  wsa-microservice

  Sample SAM Template for wsa-microservice

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

Resources:
  FetchUnProcessedMatches:
    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: src/fetch-unprocessed/
      Handler: app.handler
      Runtime: nodejs18.x
      Architectures:
        - x86_64
      Events:
        ScheduledEvent:
          Type: Schedule
          Properties:
            Schedule: 'cron(0 0/5 * * ? *)'
      Environment:
        Variables:
          SNS_PUBLISH_TOPC: !Ref UnprocessedMatchesNotificationTopic
      Policies:
        - AWSLambdaBasicExecutionRole
        - Statement:
          - Effect: Allow
            Action:
              - sns:Publish
            Resource: !Ref UnprocessedMatchesNotificationTopic
    Metadata: # Manage esbuild properties
      BuildMethod: esbuild
      BuildProperties:
        Minify: true
        Target: "es2020"
        Sourcemap: true
        EntryPoints:
        - app.ts

  ProcessPayment:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: src/process-payment/
      Handler: app.handler
      Runtime: nodejs18.x
      Architectures:
        - x86_64
      Events:
        SqsEvent:
          Type: SQS
          Properties:
            Queue: !GetAtt JobQueue.Arn
      Policies:
        - SQSPollerPolicy:
            QueueName: !Ref JobQueue

    Metadata: # Manage esbuild properties
      BuildMethod: esbuild
      BuildProperties:
        Minify: true
        Target: "es2020"
        Sourcemap: true
        EntryPoints:
        - app.ts

  JobQueue:
    Type: AWS::SQS::Queue
    Properties:
      QueueName: matchJob

  #SNS
  UnprocessedMatchesNotificationTopic:
    Type: AWS::SNS::Topic
    Properties:
      DisplayName: Unprocessed Matches Notification Topic
      TopicName: UnprocessedMatchesNotificationTopic
      Subscription:
        - Protocol: sqs
          Endpoint: !GetAtt JobQueue.Arn

  # Policy allows SNS to publish to this SQS queue
  SnsToSqsPolicy:
    Type: AWS::SQS::QueuePolicy
    Properties:
      PolicyDocument:
        Version: "2012-10-17"
        Statement:
          - Sid: "Allow SNS publish to SQS"
            Effect: Allow
            Principal: "*"
            Resource: !GetAtt JobQueue.Arn
            Action: SQS:SendMessage
            Condition:
              ArnEquals:
                aws:SourceArn: !Ref UnprocessedMatchesNotificationTopic
      Queues:
        - Ref: JobQueue