/
connector_sqs_to_function.yaml
82 lines (76 loc) · 2.14 KB
/
connector_sqs_to_function.yaml
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
Resources:
Queue:
Type: AWS::SQS::Queue
TriggerFunction:
Type: AWS::Serverless::Function
Properties:
Runtime: nodejs18.x
Handler: index.handler
Timeout: 10 # in case eb has delay
InlineCode: |
const AWS = require('aws-sdk');
exports.handler = async (event) => {
var params = {
QueueUrl: process.env.QUEUE_URL,
MessageBody: "test queue"
};
var sqs = new AWS.SQS();
await sqs.sendMessage(params).promise();
const data = await sqs.receiveMessage({
QueueUrl: process.env.VERIFICATION_QUEUE_URL,
WaitTimeSeconds: 5,
}).promise();
if (data.Messages.length == 0) {
throw 'No messages in the queue!';
}
};
Environment:
Variables:
QUEUE_URL: !Ref Queue
VERIFICATION_QUEUE_URL: !Ref VerificationQueue
Policies:
- SQSPollerPolicy:
QueueName: !GetAtt VerificationQueue.QueueName
- SQSSendMessagePolicy:
QueueName: !GetAtt Queue.QueueName
InvokedFunction:
Type: AWS::Serverless::Function
Properties:
Runtime: nodejs18.x
Handler: index.handler
InlineCode: |
const AWS = require('aws-sdk');
exports.handler = async (event) => {
const sqs = new AWS.SQS();
await sqs.sendMessage({
QueueUrl: process.env.VERIFICATION_QUEUE_URL,
MessageBody: "test"
}).promise();
};
Environment:
Variables:
VERIFICATION_QUEUE_URL: !Ref VerificationQueue
Policies:
- SQSSendMessagePolicy:
QueueName: !GetAtt VerificationQueue.QueueName
SQSEventSourceMapping:
Type: AWS::Lambda::EventSourceMapping
Properties:
FunctionName: !Ref InvokedFunction
EventSourceArn:
Fn::GetAtt:
- Queue
- Arn
BatchSize: 10
VerificationQueue:
Type: AWS::SQS::Queue
Connector:
Type: AWS::Serverless::Connector
Properties:
Source:
Id: Queue
Destination:
Id: InvokedFunction
Permissions:
- Read
- Write