자습서: REST API를 Amazon Kinesis 프록시로 생성

AWS 서비스 프록시 실행 역할을 생성하려면

1. AWS Management Console에 로그인하여 https://console.aws.amazon.com/iam/ 에서 IAM 콘솔을 엽니다.

2. Roles를 선택합니다.

3. 역할 생성을 선택합니다.

4. 신뢰할 수 있는 유형의 엔터티 선택에서 AWS 서비스를 선택한 다음 API Gateway를 선택하고 API Gateway가 로그를 CloudWatch Logs로 푸시하도록 허용을 선택합니다.

5. 다음을 선택한 후 다시 다음을 선택합니다.

6. 역할 이름에 APIGatewayKinesisProxyPolicy를 입력한 다음 역할 생성을 선택합니다.

7. 역할 목록에서 방금 생성한 역할을 선택합니다. 스크롤하거나 검색 창을 사용하여 역할을 찾을 수 있습니다.

8. 선택한 역할에 대해 권한 추가 탭을 선택합니다.

9. 드롭다운 목록에서 정책 연결을 선택합니다.

10. 검색 창에 AmazonKinesisFullAccess를 입력하고 권한 추가를 선택합니다.

    참고

    이 자습서에서는 단순화를 위해 관리형 정책을 사용합니다. 가장 좋은 방법은 필요한 최소 권한을 부여하는 자체 IAM 정책을 생성하는 것입니다.

11. 새로 생성된 역할 ARN은 나중에 사용할 수 있도록 기록해 둡니다.

API를 Kinesis에 대한 AWS 서비스 프록시로 생성

1. https://console.aws.amazon.com/apigateway에서 API Gateway 콘솔에 로그인합니다.

2. API Gateway를 처음 사용하는 경우, 서비스의 기능을 소개하는 페이지가 나타납니다. REST API에서 빌드를 선택합니다. 예제 API 생성 팝업이 나타나면 확인을 선택합니다.

   API Gateway를 처음 사용하는 것이 아닌 경우 API 생성을 선택합니다. REST API에서 빌드를 선택합니다.

3. 새 API(New API)를 선택합니다.

4. API 이름에 KinesisProxy를 입력합니다. 다른 모든 필드에 대한 기본값을 그대로 유지합니다.

5. (선택 사항) 설명에 설명을 입력합니다.

6. API 생성(Create API)을 선택합니다.

API Gateway 콘솔을 사용하여 Kinesis 스트림을 나열하려면

1. / 리소스를 선택한 다음 리소스 생성을 선택합니다.

2. 리소스 이름에 streams을 입력합니다.

3. 오리진 간 리소스 공유(CORS)를 꺼진 상태로 둡니다.

4. 리소스 생성을 선택합니다.

5. /streams 리소스를 선택한 후 메서드 생성을 선택하고 다음을 수행합니다.

   1. 메서드 유형에서 GET을 선택합니다.

      참고

      클라이언트에 의해 호출된 메서드에 대한 HTTP 동사는 백엔드에서 요구하는 통합에 대한 HTTP 동사와 다를 수 있습니다. 여기에서는 GET을 선택했는데, 목록 스트림이 본질적으로 읽기(READ) 작업이기 때문입니다.

   2. 통합 유형에서 AWS 서비스를 선택합니다.

   3. AWS 리전에서 Kinesis 스트림을 생성한 AWS 리전을 선택합니다.

   4. AWS 서비스에서 Kinesis를 선택합니다.

   5. AWS 하위 도메인은 비워 둡니다.

   6. HTTP 메서드(HTTP method)에 대해 POST를 선택합니다.

      참고

      여기에서는 POST를 선택했는데, Kinesis의 경우 ListStreams 작업이 POST로 호출되기 때문입니다.

   7. 작업 유형에서 사용자 작업 이름을 선택합니다.

   8. 함수 이름에 ListStreams를 입력합니다.

   9. 실행 역할에 실행 역할의 ARN을 입력합니다.

   10. 콘텐츠 처리에서 패스스루의 기본값을 유지합니다.

   11. 메서드 생성을 선택합니다.

6. 통합 요청 탭의 통합 요청 설정에서 편집을 선택합니다.

7. 요청 본문 패스스루에서 정의된 템플릿이 없는 경우(권장)를 선택합니다.

8. URL 요청 헤더 파라미터를 선택하고 다음을 수행합니다.

   1. 요청 헤더 파라미터 추가를 선택합니다.

   2. 이름에 Content-Type을 입력합니다.

   3. 다음에서 매핑됨에 'application/x-amz-json-1.1'을 입력합니다.

   Content-Type 헤더를 'application/x-amz-json-1.1'의 정적 값으로 설정하는 요청 파라미터 매핑을 사용하여 입력이 특정 버전의 JSON임을 Kinesis에 알립니다.

9. 매핑 템플릿을 선택한 다음 매핑 템플릿 추가를 선택하고 다음을 수행합니다.

   1. 콘텐츠 유형에 application/json을 입력합니다.

   2. 템플릿 본문에 {}를 입력합니다.

   3. Save(저장)를 선택합니다.

   ListStreams 요청은 아래 JSON 형식의 페이로드를 취합니다.

   
   {
       "ExclusiveStartStreamName": "string",
       "Limit": number
   }
                       

   하지만 속성은 선택 사항입니다. 여기에서는 기본값을 사용하기 위해 비어 있는 JSON 페이로드를 선택했습니다.

10. Kinesis에서 ListStreams 작업을 호출하는 GET 메서드를 /streams 리소스에서 테스트합니다.

    테스트 탭을 선택합니다. 탭을 표시하려면 오른쪽 화살표 버튼을 선택해야 할 수도 있습니다.

    테스트를 선택하여 메서드를 테스트합니다.

    Kinesis에서 이미 두 개의 스트림("myStream" 및 "yourStream")을 생성했다면, 테스트가 다음의 페이로드가 포함된 200 OK 응답을 반환할 것입니다.

    
    {
         "HasMoreStreams": false,
         "StreamNames": [
             "myStream",
             "yourStream"
         ]
    }            
                        

{stream-name} 리소스를 생성하려면

1. /streams 리소스를 선택한 다음 리소스 생성을 선택합니다.

2. 프록시 리소스는 꺼진 상태로 둡니다.

3. 리소스 경로에서 /streams를 선택합니다.

4. 리소스 이름에 {stream-name}을 입력합니다.

5. 오리진 간 리소스 공유(CORS)를 꺼진 상태로 둡니다.

6. 리소스 생성을 선택합니다.

스트림 리소스에서 GET 메서드를 구성하고 테스트하는 방법

1. /{stream-name} 리소스를 선택한 다음 메서드 생성을 선택합니다.

2. 메서드 유형에서 GET을 선택합니다.

3. 통합 유형에서 AWS 서비스를 선택합니다.

4. AWS 리전에서 Kinesis 스트림을 생성한 AWS 리전을 선택합니다.

5. AWS 서비스에서 Kinesis를 선택합니다.

6. AWS 하위 도메인은 비워 둡니다.

7. HTTP 메서드에 대해 POST를 선택합니다.

8. 작업 유형에서 사용자 작업 이름을 선택합니다.

9. 함수 이름에 DescribeStream를 입력합니다.

10. 실행 역할에 실행 역할의 ARN을 입력합니다.

11. 콘텐츠 처리에서 패스스루의 기본값을 유지합니다.

12. 메서드 생성을 선택합니다.

13. 통합 요청 섹션에서 다음 URL 요청 헤더 파라미터를 추가합니다.

    Content-Type: 'x-amz-json-1.1'

    작업 절차는 GET /streams 메서드에 대한 요청 파라미터 매핑을 설정하는 절차와 같습니다.

14. 다음의 본문 매핑 템플릿을 추가하여 데이터를 GET /streams/{stream-name} 메서드 요청에서 POST /?Action=DescribeStream 통합 요청으로 매핑합니다.

    {
        "StreamName": "$input.params('stream-name')"
    }

    이 매핑 템플릿은 메서드 요청의 DescribeStream 경로 파라미터 값으로부터 Kinesis의 stream-name 작업에 대한 필수 통합 요청 페이로드를 생성합니다.

15. Kinesis에서 DescribeStream 작업을 간접적으로 호출하는 GET /stream/{stream-name} 메서드를 테스트하려면 테스트 탭을 선택합니다.

16. 경로의 stream-name에 기존 Kinesis 스트림의 이름을 입력합니다.

17. 테스트를 선택합니다. 테스트가 성공하면 다음과 비슷한 페이로드와 함께 200 OK 응답이 반환됩니다.

    {
      "StreamDescription": {
        "HasMoreShards": false,
        "RetentionPeriodHours": 24,
        "Shards": [
          {
            "HashKeyRange": {
              "EndingHashKey": "68056473384187692692674921486353642290",
              "StartingHashKey": "0"
            },
            "SequenceNumberRange": {
              "StartingSequenceNumber": "49559266461454070523309915164834022007924120923395850242"
            },
            "ShardId": "shardId-000000000000"
          },
          ...
          {
            "HashKeyRange": {
              "EndingHashKey": "340282366920938463463374607431768211455",
              "StartingHashKey": "272225893536750770770699685945414569164"
            },
            "SequenceNumberRange": {
              "StartingSequenceNumber": "49559266461543273504104037657400164881014714369419771970"
            },
            "ShardId": "shardId-000000000004"
          }
        ],
        "StreamARN": "arn:aws:kinesis:us-east-1:12345678901:stream/myStream",
        "StreamName": "myStream",
        "StreamStatus": "ACTIVE"
      }
    }

    API를 배포한 후에 이 API 메서드에 대해 REST 요청을 할 수 있습니다.

    
    GET https://your-api-id.execute-api.region.amazonaws.com/stage/streams/myStream HTTP/1.1
    Host: your-api-id.execute-api.region.amazonaws.com
    Content-Type: application/json
    Authorization: ...
    X-Amz-Date: 20160323T194451Z
    
                        

스트림 리소스에서 POST 메서드를 구성하고 테스트하는 방법

1. /{stream-name} 리소스를 선택한 다음 메서드 생성을 선택합니다.

2. 메서드 유형에서 POST를 선택합니다.

3. 통합 유형에서 AWS 서비스를 선택합니다.

4. AWS 리전에서 Kinesis 스트림을 생성한 AWS 리전을 선택합니다.

5. AWS 서비스에서 Kinesis를 선택합니다.

6. AWS 하위 도메인은 비워 둡니다.

7. HTTP 메서드에 대해 POST를 선택합니다.

8. 작업 유형에서 사용자 작업 이름을 선택합니다.

9. 함수 이름에 CreateStream를 입력합니다.

10. 실행 역할에 실행 역할의 ARN을 입력합니다.

11. 콘텐츠 처리에서 패스스루의 기본값을 유지합니다.

12. 메서드 생성을 선택합니다.

13. 통합 요청 섹션에서 다음 URL 요청 헤더 파라미터를 추가합니다.

    Content-Type: 'x-amz-json-1.1'

    작업 절차는 GET /streams 메서드에 대한 요청 파라미터 매핑을 설정하는 절차와 같습니다.

14. 다음의 본문 매핑 템플릿을 추가하여 데이터를 POST /streams/{stream-name} 메서드 요청에서 POST /?Action=CreateStream 통합 요청으로 매핑합니다.

    {
        "ShardCount": #if($input.path('$.ShardCount') == '') 5 #else $input.path('$.ShardCount') #end,
        "StreamName": "$input.params('stream-name')"
    }

    앞서 다룬 매핑 템플릿에서, 클라이언트가 메서드 요청 페이로드에서 값을 지정하지 않은 경우 ShardCount를 고정값 5로 설정합니다.

15. Kinesis에서 CreateStream 작업을 간접적으로 호출하는 POST /stream/{stream-name} 메서드를 테스트하려면 테스트 탭을 선택합니다.

16. 경로의 stream-name에 새 Kinesis 스트림의 이름을 입력합니다.

17. 테스트를 선택합니다. 테스트가 성공하면 아무 데이터 없이 200 OK 응답이 반환됩니다.

    API를 배포한 후에 스트림 리소스 상에서 POST 메서드에 대한 REST API 요청을 만들어 Kinesis에서 CreateStream 작업을 호출할 수도 있습니다.

    
    POST https://your-api-id.execute-api.region.amazonaws.com/stage/streams/yourStream HTTP/1.1
    Host: your-api-id.execute-api.region.amazonaws.com
    Content-Type: application/json
    Authorization: ...
    X-Amz-Date: 20160323T194451Z
    
    { 
        "ShardCount": 5
    }
                        

스트림 리소스에서 DELETE 메서드를 구성하고 테스트하는 방법

1. /{stream-name} 리소스를 선택한 다음 메서드 생성을 선택합니다.

2. 메서드 유형에서 DELETE를 선택합니다.

3. 통합 유형에서 AWS 서비스를 선택합니다.

4. AWS 리전에서 Kinesis 스트림을 생성한 AWS 리전을 선택합니다.

5. AWS 서비스에서 Kinesis를 선택합니다.

6. AWS 하위 도메인은 비워 둡니다.

7. HTTP 메서드에 대해 POST를 선택합니다.

8. 작업 유형에서 사용자 작업 이름을 선택합니다.

9. 함수 이름에 DeleteStream를 입력합니다.

10. 실행 역할에 실행 역할의 ARN을 입력합니다.

11. 콘텐츠 처리에서 패스스루의 기본값을 유지합니다.

12. 메서드 생성을 선택합니다.

13. 통합 요청 섹션에서 다음 URL 요청 헤더 파라미터를 추가합니다.

    Content-Type: 'x-amz-json-1.1'

    작업 절차는 GET /streams 메서드에 대한 요청 파라미터 매핑을 설정하는 절차와 같습니다.

14. 다음의 본문 매핑 템플릿을 추가하여 데이터를 DELETE /streams/{stream-name} 메서드 요청에서 POST /?Action=DeleteStream의 해당 통합 요청으로 매핑합니다.

    {
        "StreamName": "$input.params('stream-name')"
    }

    이 매핑 템플릿은 클라이언트에서 제공한 DELETE /streams/{stream-name}의 URL 경로 이름으로부터 stream-name 작업에 대한 필수 입력을 생성합니다.

15. Kinesis에서 DeleteStream 작업을 간접적으로 호출하는 DELETE /stream/{stream-name} 메서드를 테스트하려면 테스트 탭을 선택합니다.

16. 경로의 stream-name에 기존 Kinesis 스트림의 이름을 입력합니다.

17. 테스트를 선택합니다. 테스트가 성공하면 아무 데이터 없이 200 OK 응답이 반환됩니다.

    API를 배포한 후에 스트림 리소스 상에서 다음과 같은 DELETE 메서드에 대한 REST API 요청을 만들어 Kinesis에서 DeleteStream 작업을 호출할 수도 있습니다.

    
    DELETE https://your-api-id.execute-api.region.amazonaws.com/stage/streams/yourStream HTTP/1.1
    Host: your-api-id.execute-api.region.amazonaws.com
    Content-Type: application/json
    Authorization: ...
    X-Amz-Date: 20160323T194451Z
    
    {}
                        

/record, /records 및 /sharditerator 리소스를 생성하려면

1. /{stream-name} 리소스를 선택한 다음 리소스 생성을 선택합니다.

2. 프록시 리소스는 꺼진 상태로 둡니다.

3. 리소스 경로에서 /{stream-name}를 선택합니다.

4. 리소스 이름에 record을 입력합니다.

5. 오리진 간 리소스 공유(CORS)를 꺼진 상태로 둡니다.

6. 리소스 생성을 선택합니다.

7. 이전 단계를 반복하여 /records와 /sharditerator 리소스를 생성합니다. 최종 API는 다음과 같아야 합니다.

   

Kinesis에서 PutRecord를 호출할 수 있도록 PUT /streams/{stream-name}/record 메서드를 설정하고 테스트하려면:

1. /record 리소스를 선택한 다음 메서드 생성을 선택합니다.

2. 메서드 유형에서 PUT을 선택합니다.

3. 통합 유형에서 AWS 서비스를 선택합니다.

4. AWS 리전에서 Kinesis 스트림을 생성한 AWS 리전을 선택합니다.

5. AWS 서비스에서 Kinesis를 선택합니다.

6. AWS 하위 도메인은 비워 둡니다.

7. HTTP 메서드에 대해 POST를 선택합니다.

8. 작업 유형에서 사용자 작업 이름을 선택합니다.

9. 함수 이름에 PutRecord를 입력합니다.

10. 실행 역할에 실행 역할의 ARN을 입력합니다.

11. 콘텐츠 처리에서 패스스루의 기본값을 유지합니다.

12. 메서드 생성을 선택합니다.

13. 통합 요청 섹션에서 다음 URL 요청 헤더 파라미터를 추가합니다.

    Content-Type: 'x-amz-json-1.1'

    작업 절차는 GET /streams 메서드에 대한 요청 파라미터 매핑을 설정하는 절차와 같습니다.

14. 다음의 본문 매핑 템플릿을 추가하여 데이터를 PUT /streams/{stream-name}/record 메서드 요청에서 POST /?Action=PutRecord의 해당 통합 요청으로 매핑합니다.

    {
        "StreamName": "$input.params('stream-name')",
        "Data": "$util.base64Encode($input.json('$.Data'))",
        "PartitionKey": "$input.path('$.PartitionKey')"
    }

    이 매핑 템플릿에서는 메서드 요청 페이로드의 형식이 다음과 같다고 가정합니다.

    {
       "Data": "some data",
       "PartitionKey": "some key"
    }

    이 데이터는 다음의 JSON 스키마에 의해 모델링할 수 있습니다.

    {
      "$schema": "http://json-schema.org/draft-04/schema#",
      "title": "PutRecord proxy single-record payload",
      "type": "object",
      "properties": {
          "Data": { "type": "string" },
          "PartitionKey": { "type": "string" }
      }
    }

    이 스키마를 포함하는 모델을 생성한 다음 그 모델을 사용하면 매핑 템플릿을 용이하게 생성할 수 있습니다. 하지만 모델을 사용하지 않고 매핑 템플릿을 생성할 수도 있습니다.

15. PUT /streams/{stream-name}/record 메서드를 테스트하려면 stream-name 경로 변수를 기존 스트림 이름으로 설정하고, 필수 형식의 페이로드를 공급한 다음, 메서드 요청을 제출합니다. 테스트가 성공하면 다음 형식의 페이로드가 포함된 200 OK 응답이 반환됩니다.

    
    {
      "SequenceNumber": "49559409944537880850133345460169886593573102115167928386",
      "ShardId": "shardId-000000000004"
    }
                        

Kinesis에서 PUT /streams/{stream-name}/records를 호출할 수 있도록 PutRecords 메서드를 설정하고 테스트하려면

1. /record 리소스를 선택한 다음 메서드 생성을 선택합니다.

2. 메서드 유형에서 PUT을 선택합니다.

3. 통합 유형에서 AWS 서비스를 선택합니다.

4. AWS 리전에서 Kinesis 스트림을 생성한 AWS 리전을 선택합니다.

5. AWS 서비스에서 Kinesis를 선택합니다.

6. AWS 하위 도메인은 비워 둡니다.

7. HTTP 메서드에 대해 POST를 선택합니다.

8. 작업 유형에서 사용자 작업 이름을 선택합니다.

9. 함수 이름에 PutRecords를 입력합니다.

10. 실행 역할에 실행 역할의 ARN을 입력합니다.

11. 콘텐츠 처리에서 패스스루의 기본값을 유지합니다.

12. 메서드 생성을 선택합니다.

13. 통합 요청 섹션에서 다음 URL 요청 헤더 파라미터를 추가합니다.

    Content-Type: 'x-amz-json-1.1'

    작업 절차는 GET /streams 메서드에 대한 요청 파라미터 매핑을 설정하는 절차와 같습니다.

14. 다음의 매핑 템플릿을 추가하여 데이터를 PUT /streams/{stream-name}/records 메서드 요청에서 POST /?Action=PutRecords의 해당 통합 요청으로 매핑합니다.

    {
        "StreamName": "$input.params('stream-name')",
        "Records": [
           #foreach($elem in $input.path('$.records'))
              {
                "Data": "$util.base64Encode($elem.data)",
                "PartitionKey": "$elem.partition-key"
              }#if($foreach.hasNext),#end
            #end
        ]
    }

    이 매핑 템플릿에서는 메서드 요청 페이로드를 다음의 JSON 스키마에 의해 모델링할 수 있다고 가정합니다.

    {
      "$schema": "http://json-schema.org/draft-04/schema#",
      "title": "PutRecords proxy payload data",
      "type": "object",
      "properties": {
        "records": {
          "type": "array",
          "items": {
            "type": "object",
            "properties": {
              "data": { "type": "string" },
              "partition-key": { "type": "string" }
            }
          }
        }
      }
    }

    이 스키마를 포함하는 모델을 생성한 다음 그 모델을 사용하면 매핑 템플릿을 용이하게 생성할 수 있습니다. 하지만 모델을 사용하지 않고 매핑 템플릿을 생성할 수도 있습니다.

    이 자습서에서는 약간 다른 두 가지 페이로드 형식을 사용하여 API 개발자가 백엔드 데이터 형식을 클라이언트에 표시하거나 클라이언트로부터 숨길 수 있음을 보여 줬습니다. 형식 하나는 PUT /streams/{stream-name}/records 메서드(위)에 사용되고, 다른 형식은 PUT /streams/{stream-name}/record 메서드(이전 절차)에 사용됩니다. 프로덕션 환경에서는 두 형식의 일관성을 유지해야 합니다.

15. PUT /streams/{stream-name}/records 메서드를 테스트하려면 stream-name 경로 변수를 기존 스트림으로 설정하고, 다음의 페이로드를 공급한 다음, 메서드 요청을 제출합니다.

    
    {
        "records": [
            {
                "data": "some data",
                "partition-key": "some key"
            },
            {
                "data": "some other data",
                "partition-key": "some key"
            }
        ]
    }
                            

    테스트가 성공하면 다음과 출력과 비슷한 페이로드를 포함하는 200 OK 응답이 반환됩니다.

    {
      "FailedRecordCount": 0,
      "Records": [
        {
          "SequenceNumber": "49559409944537880850133345460167468741933742152373764162",
          "ShardId": "shardId-000000000004"
        },
        {
          "SequenceNumber": "49559409944537880850133345460168677667753356781548470338",
          "ShardId": "shardId-000000000004"
        }
      ]
    }

Kinesis에서 GET /streams/{stream-name}/sharditerator를 호출할 수 있도록 GetShardIterator 메서드를 설정하고 테스트하려면

GET /streams/{stream-name}/sharditerator 메서드는 GET /streams/{stream-name}/records 메서드를 호출하기 전에 필수 샤드 반복자를 취득하는 헬퍼 반복자입니다.

1. /sharditerator 리소스를 선택한 다음 메서드 생성을 선택합니다.

2. 메서드 유형에서 GET을 선택합니다.

3. 통합 유형에서 AWS 서비스를 선택합니다.

4. AWS 리전에서 Kinesis 스트림을 생성한 AWS 리전을 선택합니다.

5. AWS 서비스에서 Kinesis를 선택합니다.

6. AWS 하위 도메인은 비워 둡니다.

7. HTTP 메서드에 대해 POST를 선택합니다.

8. 작업 유형에서 사용자 작업 이름을 선택합니다.

9. 함수 이름에 GetShardIterator를 입력합니다.

10. 실행 역할에 실행 역할의 ARN을 입력합니다.

11. 콘텐츠 처리에서 패스스루의 기본값을 유지합니다.

12. URL 쿼리 문자열 파라미터를 선택합니다.

    GetShardIterator 작업은 ShardId 값의 입력이 요구됩니다. 클라이언트에서 제공한 ShardId 값을 전달하려면 다음 단계에 나온 것처럼 shard-id 쿼리 파라미터를 메서드 요청에 추가합니다.

13. 쿼리 문자열 추가(Add query string)를 선택합니다.

14. 이름에 shard-id을 입력합니다.

15. 필수 상태로 유지하고 캐싱을 해제합니다.

16. 메서드 생성을 선택합니다.

17. 통합 요청 섹션에서, 메서드 요청의 shard-id 및 stream-name 파라미터에서 GetShardIterator 작업에 대한 필수 입력(ShardId 및 StreamName)을 생성하도록 다음과 같은 매핑 템플릿을 추가합니다. 이에 더해, 매핑 템플릿은 기본값으로 ShardIteratorType을 TRIM_HORIZON로 설정합니다.

    {
        "ShardId": "$input.params('shard-id')",
        "ShardIteratorType": "TRIM_HORIZON",
        "StreamName": "$input.params('stream-name')"
    }

18. API Gateway 콘솔에서 테스트(Test) 옵션을 사용하여 기존 스트림 이름을 stream-name 경로(Path) 변수 값으로 입력하고, shard-id 쿼리 문자열(Query string)을 기존 ShardId 값(예: shard-000000000004)으로 설정한 다음, 테스트(Test)를 선택합니다.

    올바른 응답 페이로드는 다음 출력과 유사합니다.

    {
      "ShardIterator": "AAAAAAAAAAFYVN3VlFy..."
    }

    [ShardIterator] 값을 기록해 둡니다. 스트림에서 레코드를 가져올 때 필요합니다.

Kinesis에서 GET /streams/{stream-name}/records 작업을 호출할 수 있도록 GetRecords 메서드를 구성하고 테스트하려면

1. /records 리소스를 선택한 다음 메서드 생성을 선택합니다.

2. 메서드 유형에서 GET을 선택합니다.

3. 통합 유형에서 AWS 서비스를 선택합니다.

4. AWS 리전에서 Kinesis 스트림을 생성한 AWS 리전을 선택합니다.

5. AWS 서비스에서 Kinesis를 선택합니다.

6. AWS 하위 도메인은 비워 둡니다.

7. HTTP 메서드에 대해 POST를 선택합니다.

8. 작업 유형에서 사용자 작업 이름을 선택합니다.

9. 함수 이름에 GetRecords를 입력합니다.

10. 실행 역할에 실행 역할의 ARN을 입력합니다.

11. 콘텐츠 처리에서 패스스루의 기본값을 유지합니다.

12. HTTP 요청 헤더를 선택합니다.

    GetRecords 작업은 ShardIterator 값의 입력이 요구됩니다. 클라이언트에서 제공한 ShardIterator 값을 전달하려면 Shard-Iterator 헤더 파라미터를 메서드 요청에 추가합니다.

13. 헤더 추가(Add header)를 선택합니다.

14. 이름에 Shard-Iterator을 입력합니다.

15. 필수 상태로 유지하고 캐싱을 해제합니다.

16. 메서드 생성을 선택합니다.

17. 통합 요청 섹션에서 다음의 본문 매핑 템플릿을 설정하여 Shard-Iterator 헤더 파라미터 값을 Kinesis에서의 GetRecords 작업에 대한 JSON 페이로드의 ShardIterator 속성 값에 매핑합니다.

    {
        "ShardIterator": "$input.params('Shard-Iterator')"
    }

18. API Gateway 콘솔에서 테스트 옵션을 사용하여 기존 스트림 이름을 stream-name 경로 변수 값으로 입력하고, Shard-Iterator 헤더를 GET /streams/{stream-name}/sharditerator 메서드(위)의 테스트 실행에서 얻은 ShardIterator 값으로 설정한 다음, 테스트를 선택합니다.

    올바른 응답 페이로드는 다음 출력과 유사합니다.

    {
      "MillisBehindLatest": 0,
      "NextShardIterator": "AAAAAAAAAAF...",
      "Records": [ ... ]
    }