Skip to content

Commit 48ddddf

Browse files
committed
Update integration test to use SqsSource
1 parent 8d4f21e commit 48ddddf

File tree

11 files changed

+683
-517
lines changed

11 files changed

+683
-517
lines changed

packages/@aws-cdk/aws-pipes-targets-alpha/README.md

+18-1
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,24 @@ const streamTarget = new targets.KinesisTarget(targetStream, {
220220
});
221221

222222
const pipe = new pipes.Pipe(this, 'Pipe', {
223-
source: new SomeSource(sourceQueue),
223+
source: new SqsSource(sourceQueue),
224+
target: streamTarget,
225+
});
226+
```
227+
228+
The input to the target data stream can be transformed:
229+
230+
```ts
231+
declare const sourceQueue: sqs.Queue;
232+
declare const targetStream: kinesis.Stream;
233+
234+
const streamTarget = new targets.KinesisTarget(targetStream, {
235+
partitionKey: 'pk',
236+
inputTransformation: pipes.InputTransformation.fromObject({ body: "👀" }),
237+
});
238+
239+
const pipe = new pipes.Pipe(this, 'Pipe', {
240+
source: new SqsSource(sourceQueue),
224241
target: streamTarget,
225242
});
226243
```
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-targets-kinesis.assets.json

+3-3
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-targets-kinesis.template.json

+1-5
Original file line numberDiff line numberDiff line change
@@ -104,11 +104,7 @@
104104
"Arn"
105105
]
106106
},
107-
"SourceParameters": {
108-
"SqsQueueParameters": {
109-
"BatchSize": 1
110-
}
111-
},
107+
"SourceParameters": {},
112108
"Target": {
113109
"Fn::GetAtt": [
114110
"TargetStream3B4B2880",

packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/cdk.out

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/integ.json

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/integtestpipetargetkinesisDefaultTestDeployAssertA9FA1AAE.assets.json

+6-6
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/integtestpipetargetkinesisDefaultTestDeployAssertA9FA1AAE.template.json

+17-2
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/manifest.json

+5-3
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)