Skip to content

Commit 65f9c35

Browse files
committed
feat(lambda): lambda esm features
1 parent f2a384b commit 65f9c35

35 files changed

+5185
-5
lines changed

packages/@aws-cdk-testing/framework-integ/test/aws-lambda-event-sources/test/integ.kafka-dlq.js.snapshot/LambdaEventSourceKafkaDlqTestDefaultTestDeployAssert0E9E64FD.assets.json

Lines changed: 20 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk-testing/framework-integ/test/aws-lambda-event-sources/test/integ.kafka-dlq.js.snapshot/LambdaEventSourceKafkaDlqTestDefaultTestDeployAssert0E9E64FD.template.json

Lines changed: 36 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk-testing/framework-integ/test/aws-lambda-event-sources/test/integ.kafka-dlq.js.snapshot/cdk.out

Lines changed: 1 addition & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk-testing/framework-integ/test/aws-lambda-event-sources/test/integ.kafka-dlq.js.snapshot/integ.json

Lines changed: 13 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk-testing/framework-integ/test/aws-lambda-event-sources/test/integ.kafka-dlq.js.snapshot/lambda-event-source-self-managed-kafka-dlq.assets.json

Lines changed: 20 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,184 @@
1+
{
2+
"Resources": {
3+
"SelfManagedKafkaFunctionServiceRole8B4CD784": {
4+
"Type": "AWS::IAM::Role",
5+
"Properties": {
6+
"AssumeRolePolicyDocument": {
7+
"Statement": [
8+
{
9+
"Action": "sts:AssumeRole",
10+
"Effect": "Allow",
11+
"Principal": {
12+
"Service": "lambda.amazonaws.com"
13+
}
14+
}
15+
],
16+
"Version": "2012-10-17"
17+
},
18+
"ManagedPolicyArns": [
19+
{
20+
"Fn::Join": [
21+
"",
22+
[
23+
"arn:",
24+
{
25+
"Ref": "AWS::Partition"
26+
},
27+
":iam::aws:policy/service-role/AWSLambdaBasicExecutionRole"
28+
]
29+
]
30+
}
31+
]
32+
}
33+
},
34+
"SelfManagedKafkaFunctionServiceRoleDefaultPolicy93A35EC6": {
35+
"Type": "AWS::IAM::Policy",
36+
"Properties": {
37+
"PolicyDocument": {
38+
"Statement": [
39+
{
40+
"Action": [
41+
"secretsmanager:DescribeSecret",
42+
"secretsmanager:GetSecretValue"
43+
],
44+
"Effect": "Allow",
45+
"Resource": [
46+
{
47+
"Ref": "ClientCertSecret84224011"
48+
},
49+
{
50+
"Ref": "RootCASecret21632BB9"
51+
}
52+
]
53+
}
54+
],
55+
"Version": "2012-10-17"
56+
},
57+
"PolicyName": "SelfManagedKafkaFunctionServiceRoleDefaultPolicy93A35EC6",
58+
"Roles": [
59+
{
60+
"Ref": "SelfManagedKafkaFunctionServiceRole8B4CD784"
61+
}
62+
]
63+
}
64+
},
65+
"SelfManagedKafkaFunction79CF5C6C": {
66+
"Type": "AWS::Lambda::Function",
67+
"Properties": {
68+
"Code": {
69+
"ZipFile": "exports.handler = async function handler(event) {\n console.log('event:', JSON.stringify(event, undefined, 2));\n return { event };\n}"
70+
},
71+
"Handler": "index.handler",
72+
"Role": {
73+
"Fn::GetAtt": [
74+
"SelfManagedKafkaFunctionServiceRole8B4CD784",
75+
"Arn"
76+
]
77+
},
78+
"Runtime": "nodejs18.x"
79+
},
80+
"DependsOn": [
81+
"SelfManagedKafkaFunctionServiceRoleDefaultPolicy93A35EC6",
82+
"SelfManagedKafkaFunctionServiceRole8B4CD784"
83+
]
84+
},
85+
"SelfManagedKafkaFunctionKafkaEventSource99e655d80fe5967cadc6359fb2218a33selfmanagedtesttopic9AE37B25": {
86+
"Type": "AWS::Lambda::EventSourceMapping",
87+
"Properties": {
88+
"BatchSize": 100,
89+
"DestinationConfig": {
90+
"OnFailure": {
91+
"Destination": "kafka://self-managed-kafka-failure-topic"
92+
}
93+
},
94+
"FunctionName": {
95+
"Ref": "SelfManagedKafkaFunction79CF5C6C"
96+
},
97+
"ProvisionedPollerConfig": {
98+
"MaximumPollers": 1,
99+
"MinimumPollers": 1
100+
},
101+
"SelfManagedEventSource": {
102+
"Endpoints": {
103+
"KafkaBootstrapServers": [
104+
"self-managed-kafka-broker-1:9092",
105+
"self-managed-kafka-broker-2:9092",
106+
"self-managed-kafka-broker-3:9092"
107+
]
108+
}
109+
},
110+
"SelfManagedKafkaEventSourceConfig": {
111+
"ConsumerGroupId": "self-managed-test-consumer-group"
112+
},
113+
"SourceAccessConfigurations": [
114+
{
115+
"Type": "CLIENT_CERTIFICATE_TLS_AUTH",
116+
"URI": {
117+
"Ref": "ClientCertSecret84224011"
118+
}
119+
},
120+
{
121+
"Type": "SERVER_ROOT_CA_CERTIFICATE",
122+
"URI": {
123+
"Ref": "RootCASecret21632BB9"
124+
}
125+
}
126+
],
127+
"StartingPosition": "TRIM_HORIZON",
128+
"Topics": [
129+
"self-managed-test-topic"
130+
]
131+
}
132+
},
133+
"RootCASecret21632BB9": {
134+
"Type": "AWS::SecretsManager::Secret",
135+
"Properties": {
136+
"SecretString": "{\"certificate\":\"-----BEGIN CERTIFICATE-----\\nMIIE5DCCAsygAwIBAgIRAPJdwaFaNRrytHBto0j5BA0wDQYJKoZIhvcNAQELBQAw\\ncmUuaAii9R0=\\n-----END CERTIFICATE-----\\n-----BEGIN CERTIFICATE-----\\nMIIFgjCCA2qgAwIBAgIQdjNZd6uFf9hbNC5RdfmHrzANBgkqhkiG9w0BAQsFADBb\\nc8PH3PSoAaRwMMgOSA2ALJvbRz8mpg==\\n-----END CERTIFICATE-----\"}"
137+
},
138+
"UpdateReplacePolicy": "Delete",
139+
"DeletionPolicy": "Delete"
140+
},
141+
"ClientCertSecret84224011": {
142+
"Type": "AWS::SecretsManager::Secret",
143+
"Properties": {
144+
"SecretString": "{\"certificate\":\"-----BEGIN CERTIFICATE-----\\nMIIE5DCCAsygAwIBAgIRAPJdwaFaNRrytHBto0j5BA0wDQYJKoZIhvcNAQELBQAw\\ncmUuaAii9R0=\\n-----END CERTIFICATE-----\\n-----BEGIN CERTIFICATE-----\\nMIIFgjCCA2qgAwIBAgIQdjNZd6uFf9hbNC5RdfmHrzANBgkqhkiG9w0BAQsFADBb\\nc8PH3PSoAaRwMMgOSA2ALJvbRz8mpg==\\n-----END CERTIFICATE-----\",\"privateKey\":\"-----BEGIN ENCRYPTED PRIVATE KEY-----\\nzp2mwJn2NYB7AZ7+imp0azDZb+8YG2aUCiyqb6PnnA==\\n-----END ENCRYPTED PRIVATE KEY-----\"}"
145+
},
146+
"UpdateReplacePolicy": "Delete",
147+
"DeletionPolicy": "Delete"
148+
}
149+
},
150+
"Parameters": {
151+
"BootstrapVersion": {
152+
"Type": "AWS::SSM::Parameter::Value<String>",
153+
"Default": "/cdk-bootstrap/hnb659fds/version",
154+
"Description": "Version of the CDK Bootstrap resources in this environment, automatically retrieved from SSM Parameter Store. [cdk:skip]"
155+
}
156+
},
157+
"Rules": {
158+
"CheckBootstrapVersion": {
159+
"Assertions": [
160+
{
161+
"Assert": {
162+
"Fn::Not": [
163+
{
164+
"Fn::Contains": [
165+
[
166+
"1",
167+
"2",
168+
"3",
169+
"4",
170+
"5"
171+
],
172+
{
173+
"Ref": "BootstrapVersion"
174+
}
175+
]
176+
}
177+
]
178+
},
179+
"AssertDescription": "CDK bootstrap stack version 6 required. Please run 'cdk bootstrap' with a recent version of the CDK CLI."
180+
}
181+
]
182+
}
183+
}
184+
}

0 commit comments

Comments
 (0)