Skip to content

Commit b795af4

Browse files
author
AWS
committed
Amazon EventBridge Pipes Update: AWS introduces new Amazon EventBridge Pipes which allow you to connect sources (SQS, Kinesis, DDB, Kafka, MQ) to Targets (14+ EventBridge Targets) without any code, with filtering, batching, input transformation, and an optional Enrichment stage (Lambda, StepFunctions, ApiGateway, ApiDestinations)
1 parent 44bfd50 commit b795af4

File tree

6 files changed

+3487
-0
lines changed

6 files changed

+3487
-0
lines changed

‎.changes/next-release/feature-AmazonEventBridgePipes-b7175bf.json

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
{
2+
"type": "feature",
3+
"category": "Amazon EventBridge Pipes",
4+
"contributor": "",
5+
"description": "AWS introduces new Amazon EventBridge Pipes which allow you to connect sources (SQS, Kinesis, DDB, Kafka, MQ) to Targets (14+ EventBridge Targets) without any code, with filtering, batching, input transformation, and an optional Enrichment stage (Lambda, StepFunctions, ApiGateway, ApiDestinations)"
6+
}

‎services/pipes/pom.xml

Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
<?xml version="1.0"?>
2+
<!--
3+
~ Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
4+
~
5+
~ Licensed under the Apache License, Version 2.0 (the "License").
6+
~ You may not use this file except in compliance with the License.
7+
~ A copy of the License is located at
8+
~
9+
~ http://aws.amazon.com/apache2.0
10+
~
11+
~ or in the "license" file accompanying this file. This file is distributed
12+
~ on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
13+
~ express or implied. See the License for the specific language governing
14+
~ permissions and limitations under the License.
15+
-->
16+
17+
<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
18+
xmlns="http://maven.apache.org/POM/4.0.0"
19+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
20+
<modelVersion>4.0.0</modelVersion>
21+
<parent>
22+
<groupId>software.amazon.awssdk</groupId>
23+
<artifactId>services</artifactId>
24+
<version>2.18.29-SNAPSHOT</version>
25+
</parent>
26+
<artifactId>pipes</artifactId>
27+
<name>AWS Java SDK :: Services :: Pipes</name>
28+
<description>The AWS Java SDK for Pipes module holds the client classes that are used for
29+
communicating with Pipes.
30+
</description>
31+
<url>https://aws.amazon.com/sdkforjava</url>
32+
<build>
33+
<plugins>
34+
<plugin>
35+
<groupId>org.apache.maven.plugins</groupId>
36+
<artifactId>maven-jar-plugin</artifactId>
37+
<configuration>
38+
<archive>
39+
<manifestEntries>
40+
<Automatic-Module-Name>software.amazon.awssdk.services.pipes</Automatic-Module-Name>
41+
</manifestEntries>
42+
</archive>
43+
</configuration>
44+
</plugin>
45+
</plugins>
46+
</build>
47+
48+
<dependencies>
49+
<dependency>
50+
<groupId>software.amazon.awssdk</groupId>
51+
<artifactId>protocol-core</artifactId>
52+
<version>${awsjavasdk.version}</version>
53+
</dependency>
54+
<dependency>
55+
<groupId>software.amazon.awssdk</groupId>
56+
<artifactId>aws-json-protocol</artifactId>
57+
<version>${awsjavasdk.version}</version>
58+
</dependency>
59+
</dependencies>
60+
</project>

‎services/pipes/src/main/resources/codegen-resources/endpoint-rule-set.json

Lines changed: 309 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,309 @@
1+
{
2+
"version": "1.0",
3+
"parameters": {
4+
"Region": {
5+
"builtIn": "AWS::Region",
6+
"required": true,
7+
"documentation": "The AWS region used to dispatch the request.",
8+
"type": "String"
9+
},
10+
"UseDualStack": {
11+
"builtIn": "AWS::UseDualStack",
12+
"required": true,
13+
"default": false,
14+
"documentation": "When true, use the dual-stack endpoint. If the configured endpoint does not support dual-stack, dispatching the request MAY return an error.",
15+
"type": "Boolean"
16+
},
17+
"UseFIPS": {
18+
"builtIn": "AWS::UseFIPS",
19+
"required": true,
20+
"default": false,
21+
"documentation": "When true, send this request to the FIPS-compliant regional endpoint. If the configured endpoint does not have a FIPS compliant endpoint, dispatching the request will return an error.",
22+
"type": "Boolean"
23+
},
24+
"Endpoint": {
25+
"builtIn": "SDK::Endpoint",
26+
"required": false,
27+
"documentation": "Override the endpoint used to send this request",
28+
"type": "String"
29+
}
30+
},
31+
"rules": [
32+
{
33+
"conditions": [
34+
{
35+
"fn": "aws.partition",
36+
"argv": [
37+
{
38+
"ref": "Region"
39+
}
40+
],
41+
"assign": "PartitionResult"
42+
}
43+
],
44+
"type": "tree",
45+
"rules": [
46+
{
47+
"conditions": [
48+
{
49+
"fn": "isSet",
50+
"argv": [
51+
{
52+
"ref": "Endpoint"
53+
}
54+
]
55+
},
56+
{
57+
"fn": "parseURL",
58+
"argv": [
59+
{
60+
"ref": "Endpoint"
61+
}
62+
],
63+
"assign": "url"
64+
}
65+
],
66+
"type": "tree",
67+
"rules": [
68+
{
69+
"conditions": [
70+
{
71+
"fn": "booleanEquals",
72+
"argv": [
73+
{
74+
"ref": "UseFIPS"
75+
},
76+
true
77+
]
78+
}
79+
],
80+
"error": "Invalid Configuration: FIPS and custom endpoint are not supported",
81+
"type": "error"
82+
},
83+
{
84+
"conditions": [],
85+
"type": "tree",
86+
"rules": [
87+
{
88+
"conditions": [
89+
{
90+
"fn": "booleanEquals",
91+
"argv": [
92+
{
93+
"ref": "UseDualStack"
94+
},
95+
true
96+
]
97+
}
98+
],
99+
"error": "Invalid Configuration: Dualstack and custom endpoint are not supported",
100+
"type": "error"
101+
},
102+
{
103+
"conditions": [],
104+
"endpoint": {
105+
"url": {
106+
"ref": "Endpoint"
107+
},
108+
"properties": {},
109+
"headers": {}
110+
},
111+
"type": "endpoint"
112+
}
113+
]
114+
}
115+
]
116+
},
117+
{
118+
"conditions": [
119+
{
120+
"fn": "booleanEquals",
121+
"argv": [
122+
{
123+
"ref": "UseFIPS"
124+
},
125+
true
126+
]
127+
},
128+
{
129+
"fn": "booleanEquals",
130+
"argv": [
131+
{
132+
"ref": "UseDualStack"
133+
},
134+
true
135+
]
136+
}
137+
],
138+
"type": "tree",
139+
"rules": [
140+
{
141+
"conditions": [
142+
{
143+
"fn": "booleanEquals",
144+
"argv": [
145+
true,
146+
{
147+
"fn": "getAttr",
148+
"argv": [
149+
{
150+
"ref": "PartitionResult"
151+
},
152+
"supportsFIPS"
153+
]
154+
}
155+
]
156+
},
157+
{
158+
"fn": "booleanEquals",
159+
"argv": [
160+
true,
161+
{
162+
"fn": "getAttr",
163+
"argv": [
164+
{
165+
"ref": "PartitionResult"
166+
},
167+
"supportsDualStack"
168+
]
169+
}
170+
]
171+
}
172+
],
173+
"type": "tree",
174+
"rules": [
175+
{
176+
"conditions": [],
177+
"endpoint": {
178+
"url": "https://pipes-fips.{Region}.{PartitionResult#dualStackDnsSuffix}",
179+
"properties": {},
180+
"headers": {}
181+
},
182+
"type": "endpoint"
183+
}
184+
]
185+
},
186+
{
187+
"conditions": [],
188+
"error": "FIPS and DualStack are enabled, but this partition does not support one or both",
189+
"type": "error"
190+
}
191+
]
192+
},
193+
{
194+
"conditions": [
195+
{
196+
"fn": "booleanEquals",
197+
"argv": [
198+
{
199+
"ref": "UseFIPS"
200+
},
201+
true
202+
]
203+
}
204+
],
205+
"type": "tree",
206+
"rules": [
207+
{
208+
"conditions": [
209+
{
210+
"fn": "booleanEquals",
211+
"argv": [
212+
true,
213+
{
214+
"fn": "getAttr",
215+
"argv": [
216+
{
217+
"ref": "PartitionResult"
218+
},
219+
"supportsFIPS"
220+
]
221+
}
222+
]
223+
}
224+
],
225+
"type": "tree",
226+
"rules": [
227+
{
228+
"conditions": [],
229+
"endpoint": {
230+
"url": "https://pipes-fips.{Region}.{PartitionResult#dnsSuffix}",
231+
"properties": {},
232+
"headers": {}
233+
},
234+
"type": "endpoint"
235+
}
236+
]
237+
},
238+
{
239+
"conditions": [],
240+
"error": "FIPS is enabled but this partition does not support FIPS",
241+
"type": "error"
242+
}
243+
]
244+
},
245+
{
246+
"conditions": [
247+
{
248+
"fn": "booleanEquals",
249+
"argv": [
250+
{
251+
"ref": "UseDualStack"
252+
},
253+
true
254+
]
255+
}
256+
],
257+
"type": "tree",
258+
"rules": [
259+
{
260+
"conditions": [
261+
{
262+
"fn": "booleanEquals",
263+
"argv": [
264+
true,
265+
{
266+
"fn": "getAttr",
267+
"argv": [
268+
{
269+
"ref": "PartitionResult"
270+
},
271+
"supportsDualStack"
272+
]
273+
}
274+
]
275+
}
276+
],
277+
"type": "tree",
278+
"rules": [
279+
{
280+
"conditions": [],
281+
"endpoint": {
282+
"url": "https://pipes.{Region}.{PartitionResult#dualStackDnsSuffix}",
283+
"properties": {},
284+
"headers": {}
285+
},
286+
"type": "endpoint"
287+
}
288+
]
289+
},
290+
{
291+
"conditions": [],
292+
"error": "DualStack is enabled but this partition does not support DualStack",
293+
"type": "error"
294+
}
295+
]
296+
},
297+
{
298+
"conditions": [],
299+
"endpoint": {
300+
"url": "https://pipes.{Region}.{PartitionResult#dnsSuffix}",
301+
"properties": {},
302+
"headers": {}
303+
},
304+
"type": "endpoint"
305+
}
306+
]
307+
}
308+
]
309+
}

0 commit comments

Comments
 (0)