Kinesis - AWS Serverless Application Model
구문속성예시

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Kinesis

Kinesis 이벤트 소스 유형을 설명하는 객체. 자세한 내용은 AWS Lambda 개발자 안내서의 Amazon Kinesis AWS Lambda 에서 사용을 참조하세요.

AWS SAM 는를 생성합니다. AWS::Lambda::EventSourceMapping이 이벤트 유형이 설정된 경우 리소스.

구문

AWS Serverless Application Model (AWS SAM) 템플릿에서이 개체를 선언하려면 다음 구문을 사용합니다.

속성

BatchSize

한 번의 배치에서 검색하는 최대 항목 수입니다.

유형: 정수

필수 항목 여부: 아니요

기본값: 100

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 BatchSize 속성으로 직접 전달됩니다.

최소: 1

최대: 10000

BisectBatchOnFunctionError

함수가 오류를 제시하면 비치를 2개로 분할해서 다시 시도합니다.

유형: 부울

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 BisectBatchOnFunctionError 속성으로 직접 전달됩니다.

DestinationConfig

폐기된 레코드에 대한 Amazon Simple Queue Service(AmazonSQS) 대기열 또는 Amazon Simple Notification Service(AmazonSNS) 주제 대상입니다.

유형: DestinationConfig

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 DestinationConfig 속성으로 직접 전달됩니다.

Enabled

이벤트 소스 매핑을 비활성화하여 폴링 및 간접 호출을 일시 중지합니다.

유형: 부울

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 Enabled 속성으로 직접 전달됩니다.

FilterCriteria

Lambda가 이벤트를 처리해야 하는지 결정하는 기준을 정의하는 객체입니다. 자세한 내용은 AWS Lambda 개발자 가이드의 AWS Lambda 이벤트 필터링을 참조하세요.

유형: FilterCriteria

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 FilterCriteria 속성으로 직접 전달됩니다.

FunctionResponseTypes

이벤트 소스 매핑에 현재 적용된 응답 유형의 목록입니다. 자세한 내용은 AWS Lambda Developer Guide의 Reporting batch item failures를 참조하세요.

유효한 값: ReportBatchItemFailures

유형: 목록

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 FunctionResponseTypes 속성으로 직접 전달됩니다.

KmsKeyArn

이 이벤트와 관련된 정보를 암호화하는 키의 Amazon 리소스 이름(ARN)입니다.

유형: 문자열

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 KmsKeyArn 속성으로 직접 전달됩니다.

MaximumBatchingWindowInSeconds

함수를 호출하기 전에 기록을 수집할 최대 기간(단위: 초)입니다.

유형: 정수

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 MaximumBatchingWindowInSeconds 속성으로 직접 전달됩니다.

MaximumRecordAgeInSeconds

Lambda가 처리를 위해 함수에 보내는 기록의 최대 사용 기간입니다.

유형: 정수

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 MaximumRecordAgeInSeconds 속성으로 직접 전달됩니다.

MaximumRetryAttempts

함수가 오류를 반환할 때 재시도하는 최대 횟수입니다.

유형: 정수

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 MaximumRetryAttempts 속성으로 직접 전달됩니다.

MetricsConfig

각 처리 단계를 캡처하는 이벤트 소스 매핑에 대한 향상된 지표를 가져오는 옵트인 구성입니다. 예시는 MetricsConfig 이벤트에서 확인하십시오.

유형: MetricsConfig

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 MetricsConfig 속성으로 직접 전달됩니다.

ParallelizationFactor

각 샤드에서 동시에 처리할 배치의 수입니다.

유형: 정수

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 ParallelizationFactor 속성으로 직접 전달됩니다.

StartingPosition

읽기를 시작하는 스트림 내의 위치입니다.

  • AT_TIMESTAMP - 기록 읽기를 시작할 시간을 지정합니다.

  • LATEST – 새 기록만 읽습니다.

  • TRIM_HORIZON – 사용 가능한 모든 기록을 처리합니다.

유효한 값: AT_TIMESTAMP | LATEST | TRIM_HORIZON

유형: 문자열

필수 항목 여부: 예

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 StartingPosition 속성으로 직접 전달됩니다.

StartingPositionTimestamp

읽기를 시작하는 시간(유닉스 시간 초 단위)입니다. StartingPositionTimestamp 언제 StartingPosition를 AT_TIMESTAMP으로 지정할지 정의합니다.

유형: Double

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 StartingPositionTimestamp 속성으로 직접 전달됩니다.

Stream

데이터 스트림 또는 스트림 소비자의 Amazon 리소스 이름(ARN)입니다.

유형: 문자열

필수 항목 여부: 예

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 EventSourceArn 속성으로 직접 전달됩니다.

TumblingWindowInSeconds

처리 윈도우 기간(초 단위). 유효한 범위는 1 ~ 900입니다(15분).

자세한 내용은 개발자 가이드의 AWS Lambda Tumbling windows를 참조하세요.

유형: 정수

필수 항목 여부: 아니요

AWS CloudFormation 호환성:이 속성은 AWS::Lambda::EventSourceMapping 리소스의 TumblingWindowInSeconds 속성으로 직접 전달됩니다.

예시

MetricsConfig 이벤트

다음은 MetricsConfig 속성을 사용하여 이벤트 소스 매핑의 각 처리 단계를 캡처하는 리소스의 예입니다.

Resources:
  FilteredEventsFunction:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: s3://sam-demo-bucket/metricsConfig.zip
      Handler: index.handler
      Runtime: nodejs16.x
      Events:
        KinesisStream:
          Type: Kinesis
          Properties:
            Stream: !GetAtt KinesisStream.Arn
            StartingPosition: LATEST
            MetricsConfig:
              Metrics:
              - EventCount

Kinesis 이벤트 소스

다음은 Kinesis 이벤트 소스의 예입니다.

YAML

Events:
  KinesisEvent:
    Type: Kinesis
    Properties:
      Stream: arn:aws:kinesis:us-east-1:123456789012:stream/my-stream
      StartingPosition: TRIM_HORIZON
      BatchSize: 10
      Enabled: false
      FilterCriteria: 
        Filters: 
          - Pattern: '{"key": ["val1", "val2"]}'