Update integration test to use SqsSource

aws · Sep 29, 2024 · 48ddddf · 48ddddf
1 parent 8d4f21e
commit 48ddddf
Show file tree

Hide file tree

Showing 11 changed files with 683 additions and 517 deletions.
diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/README.md b/packages/@aws-cdk/aws-pipes-targets-alpha/README.md
@@ -220,7 +220,24 @@ const streamTarget = new targets.KinesisTarget(targetStream, {
 });
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
-    source: new SomeSource(sourceQueue),
+    source: new SqsSource(sourceQueue),
+    target: streamTarget,
+});
+```
+
+The input to the target data stream can be transformed:
+
+```ts
+declare const sourceQueue: sqs.Queue;
+declare const targetStream: kinesis.Stream;
+
+const streamTarget = new targets.KinesisTarget(targetStream, {
+    partitionKey: 'pk',
+    inputTransformation: pipes.InputTransformation.fromObject({ body: "👀" }),
+});
+
+const pipe = new pipes.Pipe(this, 'Pipe', {
+    source: new SqsSource(sourceQueue),
     target: streamTarget,
 });
 ```
diff --git a/...db52eec8e467ce2a69454a41a.bundle/index.js → ...38002598930d6d34e5711985b.bundle/index.js b/...db52eec8e467ce2a69454a41a.bundle/index.js → ...38002598930d6d34e5711985b.bundle/index.js
diff --git a/...es-targets-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-targets-kinesis.assets.json b/...es-targets-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-targets-kinesis.assets.json
diff --git a/...-targets-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-targets-kinesis.template.json b/...-targets-alpha/test/integ.kinesis.js.snapshot/aws-cdk-pipes-targets-kinesis.template.json
@@ -104,11 +104,7 @@
       "Arn"
      ]
     },
-    "SourceParameters": {
-     "SqsQueueParameters": {
-      "BatchSize": 1
-     }
-    },
+    "SourceParameters": {},
     "Target": {
      "Fn::GetAtt": [
       "TargetStream3B4B2880",

diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/cdk.out b/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/cdk.out
diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/integ.json b/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/integ.json
diff --git a/...kinesis.js.snapshot/integtestpipetargetkinesisDefaultTestDeployAssertA9FA1AAE.assets.json b/...kinesis.js.snapshot/integtestpipetargetkinesisDefaultTestDeployAssertA9FA1AAE.assets.json
diff --git a/...nesis.js.snapshot/integtestpipetargetkinesisDefaultTestDeployAssertA9FA1AAE.template.json b/...nesis.js.snapshot/integtestpipetargetkinesisDefaultTestDeployAssertA9FA1AAE.template.json
diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/manifest.json b/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.kinesis.js.snapshot/manifest.json