do not pass the full event to step function

ebisbe · Jul 12, 2024 · 33ed590 · 33ed590
1 parent ff947e1
commit 33ed590
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/resources/streamPipes.ts b/src/resources/streamPipes.ts
@@ -115,7 +115,7 @@ export const streamPipesResource: ServerlessExtended["resources"] = {
       },
     },
 
-    SyncNextPhotoStreamLogRule: {
+    StreamItemRule: {
       Type: "AWS::Events::Rule",
       Properties: {
         EventBusName: getRef("EventBus"),
@@ -136,6 +136,16 @@ export const streamPipesResource: ServerlessExtended["resources"] = {
             Id: `invoke-${nameHelper(ItemStream)}`,
             Arn: getAttribute(idHelper(ItemStream), "Arn"),
             RoleArn: getAttribute("TargetStreamIAMrole", "Arn"),
+            InputTransformer: {
+              InputPathsMap: {
+                eventName: "$.detail.eventName",
+                dynamodb: "$.detail.dynamodb",
+              },
+              InputTemplate: JSON.stringify({
+                eventName: "<eventName>",
+                dynamodb: "<dynamodb>",
+              }),
+            },
           },
         ],
       },