Lambda로 Amazon Kinesis Data Streams 레코드 처리

함수에 Kinesis 권한을 추가

1. Lambda 콘솔의 함수 페이지를 열고 함수를 선택합니다.

2. 구성 탭을 선택한 다음 사용 권한을 선택합니다.

3. 실행 역할 창의 역할 이름에서 함수의 실행 역할 링크를 선택합니다. 이 링크를 클릭하면 IAM 콘솔에서의 해당 역할 페이지가 열립니다.

4. 권한 정책 창에서 권한 추가를 선택한 다음 정책 연결을 선택합니다.

5. 검색 필드에 AWSLambdaKinesisExecutionRole를 입력합니다.

6. 정책 옆의 확인란을 선택하고 권한 추가를 선택합니다.

함수에 Kinesis 권한을 추가

• 함수의 실행 역할에 AWSLambdaKinesisExecutionRole 정책을 연결하려면 다음 CLI 명령을 실행합니다.

  aws iam attach-role-policy \
  --role-name MyFunctionRole \
  --policy-arn arn:aws:iam::aws:policy/service-role/AWSLambdaKinesisExecutionRole

함수에 Kinesis 권한을 추가

• 함수 정의에서 다음 예제처럼 Policies 속성을 추가합니다.

  Resources:
    MyFunction:
      Type: AWS::Serverless::Function
      Properties:
        CodeUri: ./my-function/
        Handler: index.handler
        Runtime: nodejs22.x
        Policies:
          - AWSLambdaKinesisExecutionRole

Kinesis 이벤트 소스 매핑 생성

1. Lambda 콘솔의 함수 페이지를 열고 함수를 선택합니다.

2. 함수 개요 창에서 트리거 추가를 선택합니다.

3. 트리거 구성에서 소스로 Kinesis를 선택합니다.

4. 이벤트 소스 매핑을 생성할 Kinesis 스트림과 필요에 따라 스트림 소비자를 선택합니다.

5. (선택 사항)이벤트 소스 매핑에 대해 배치 크기, 시작 위치 및 배치 창을 편집합니다.

6. 추가를 선택합니다.

Kinesis 이벤트 소스 매핑 생성

• 다음 CLI 명령을 실행하여 Kinesis 이벤트 소스 매핑을 생성합니다. 사용 사례에 따라 배치 크기와 시작 위치를 직접 선택합니다.

  aws lambda create-event-source-mapping \
  --function-name MyFunction \
  --event-source-arn arn:aws:kinesis:us-east-2:123456789012:stream/lambda-stream \
  --starting-position LATEST \
  --batch-size 100

Kinesis 이벤트 소스 매핑 생성

• 함수 정의에서 다음 예제처럼 KinesisEvent 속성을 추가합니다.

  Resources:
    MyFunction:
      Type: AWS::Serverless::Function
      Properties:
        CodeUri: ./my-function/
        Handler: index.handler
        Runtime: nodejs22.x
        Policies:
          - AWSLambdaKinesisExecutionRole
        Events:
          KinesisEvent:
            Type: Kinesis
            Properties:
              Stream: !GetAtt MyKinesisStream.Arn
              StartingPosition: LATEST
              BatchSize: 100
  
    MyKinesisStream:
      Type: AWS::Kinesis::Stream
      Properties:
        ShardCount: 1