serverless.yml

service: kinesis-stream-fanout

provider:
  name: aws
  runtime: nodejs6.10

functions:
  processPositive:
    handler: lambda/handler.processPositive
    timeout: 10
    events:
      - stream:
          type: kinesis
          batchSize: 100
          startingPosition: TRIM_HORIZON
          enabled: true
          arn:
            Fn::GetAtt:
              - PositiveTransactionsStream
              - Arn
  processNegative:
    handler: lambda/handler.processNegative
    timeout: 10
    events:
      - stream:
          type: kinesis
          batchSize: 100
          startingPosition: TRIM_HORIZON
          enabled: true
          arn:
            Fn::GetAtt:
              - NegativeTransactionsStream
              - Arn

resources:
  Resources:
    TransactionsStream:
      Type: AWS::Kinesis::Stream
      Properties:
        Name: Transactions
        ShardCount: 1
    PositiveTransactionsStream:
      Type: AWS::Kinesis::Stream
      Properties:
        Name: PositiveTransactions
        ShardCount: 1
    NegativeTransactionsStream:
      Type: AWS::Kinesis::Stream
      Properties:
        Name: NegativeTransactions
        ShardCount: 1
    KinesisAnalyticsIAMRole:
      Type: AWS::IAM::Role
      Properties:
        AssumeRolePolicyDocument:
          Version: '2012-10-17'
          Statement:
            - Sid: 'KinesisAnalyticsAssumeRole'
              Effect: Allow
              Principal:
                Service: kinesisanalytics.amazonaws.com
              Action: 'sts:AssumeRole'
        Policies:
          - PolicyName: kinesis-stream-fanout-kinesis-analytics
            PolicyDocument:
              Version: '2012-10-17'
              Statement:
                - Effect: "Allow"
                  Action:
                    - "kinesis:DescribeStream"
                    - "kinesis:GetShardIterator"
                    - "kinesis:GetRecords"
                  Resource:
                    'Fn::GetAtt':
                      - TransactionsStream
                      - Arn
                - Effect: "Allow"
                  Action:
                    - "kinesis:DescribeStream"
                    - "kinesis:PutRecord"
                    - "kinesis:PutRecords"
                  Resource:
                    'Fn::GetAtt':
                      - PositiveTransactionsStream
                      - Arn
                - Effect: "Allow"
                  Action:
                    - "kinesis:DescribeStream"
                    - "kinesis:PutRecord"
                    - "kinesis:PutRecords"
                  Resource:
                    'Fn::GetAtt':
                      - NegativeTransactionsStream
                      - Arn
  Outputs:
    TransactionsStreamARN:
      Description: Transactions Kinesis Stream ARN
      Value:
        'Fn::GetAtt':
          - TransactionsStream
          - Arn
    PositiveTransactionsStreamARN:
      Description: Positive Transactions Kinesis Stream ARN
      Value:
        'Fn::GetAtt':
          - PositiveTransactionsStream
          - Arn
    NegativeTransactionsStreamARN:
      Description: Negative Transactions Kinesis Stream ARN
      Value:
        'Fn::GetAtt':
          - NegativeTransactionsStream
          - Arn
    KinesisAnalyticsIAMRoleARN:
      Description: IAM Role ARN for Kinesis Analytics
      Value:
        'Fn::GetAtt':
          - KinesisAnalyticsIAMRole
          - Arn