diff --git a/examples/with-pipes/main.tf b/examples/with-pipes/main.tf
index 08ded36..70dbbfd 100644
--- a/examples/with-pipes/main.tf
+++ b/examples/with-pipes/main.tf
@@ -134,6 +134,10 @@ module "eventbridge" {
         }
       }
 
+      target_parameters = {
+        input_template = "{\"data\":<$.dynamodb>}"
+      }
+
       tags = {
         Pipe = "dynamodb_stream_source_sqs_target"
       }
diff --git a/main.tf b/main.tf
index c8c98a9..d7e7624 100644
--- a/main.tf
+++ b/main.tf
@@ -698,6 +698,7 @@ resource "aws_pipes_pipe" "this" {
     for_each = try([each.value.target_parameters], [])
 
     content {
+      input_template = try(target_parameters.value.input_template, null)
       dynamic "sqs_queue_parameters" {
         for_each = try([target_parameters.value.sqs_queue_parameters], [])