/
connector_mix_destination.yaml
90 lines (82 loc) · 2.38 KB
/
connector_mix_destination.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
83
84
85
86
87
88
89
90
Resources:
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) => {
const eb = new AWS.EventBridge();
const response = await eb.putEvents({
Entries: [{
Source: process.env.EVENT_SOURCE,
Detail: "{}",
DetailType: "Test",
}]
}).promise();
const sqs = new AWS.SQS();
const data = await sqs.getQueueAttributes({
QueueUrl: process.env.QUEUE_URL,
AttributeNames: ['ApproximateNumberOfMessages']
}).promise();
if (data.Attributes.ApproximateNumberOfMessages < 2) {
throw 'Not enough messages in the queue!';
}
};
Environment:
Variables:
QUEUE_URL: !Ref VerificationQueue
EVENT_SOURCE: !Sub '${AWS::StackName}-test-event'
Policies:
- EventBridgePutEventsPolicy:
EventBusName: default
- SQSPollerPolicy:
QueueName: !GetAtt VerificationQueue.QueueName
EventRule:
Type: AWS::Events::Rule
Properties:
Description: !Sub 'EventRule-${AWS::StackName}'
EventPattern:
source:
- !Sub '${AWS::StackName}-test-event'
Targets:
- Arn: !GetAtt Function.Arn
Id: Target
- Arn: !GetAtt VerificationQueue.Arn
Id: Target2
Function:
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.QUEUE_URL,
MessageBody: "test"
}).promise();
};
Environment:
Variables:
QUEUE_URL: !Ref VerificationQueue
Policies:
- SQSSendMessagePolicy:
QueueName: !GetAtt VerificationQueue.QueueName
VerificationQueue:
Type: AWS::SQS::Queue
MyConnector:
Type: AWS::Serverless::Connector
Properties:
Source:
Id: EventRule
Destination:
- Id: Function
- Id: VerificationQueue
Permissions:
- Write
Metadata:
SamTransformTest: true