cfn-pipe.yaml

cfn-pipe.yaml

  Pipe:
    Type: AWS::Pipes::Pipe
    Properties:
      Name: kinesis-to-eventbridge
      Description: 'Pipe to connect Kinesis stream to EventBridge event bus'
      RoleArn: !GetAtt PipeRole.Arn
      Source: !Sub arn:aws:kinesis:us-west-2:${AWS::AccountId}:stream/my-org-app-event-stream-${Environment}
      SourceParameters:
        FilterCriteria:
          Filters:
            - Pattern: '{"data":{"event_type":["SignUpEvent"]}}'
            - Pattern: '{"data":{"event_type":["SignInEvent"]}}'
        KinesisStreamParameters:
          StartingPosition: LATEST
          BatchSize: 1
          DeadLetterConfig:
            Arn: !GetAtt PipeDLQueue.Arn
      Target: !Sub 'arn:aws:events:us-west-2:${AWS::AccountId}:event-bus/my-org-events-${Environment}'
      Enrichment: !GetAtt TransformerLambda.Arn
      EnrichmentParameters:
        InputTemplate: '{ "data": <$.data> }'