Kinesis 스트리밍 작업에서 향상된 팬아웃 사용 - AWS Glue

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

Kinesis 스트리밍 작업에서 향상된 팬아웃 사용

향상된 팬아웃 소비자는 일반 소비자보다 더 높은 전용 처리량으로 Kinesis 스트림에서 레코드를 수신할 수 있습니다. 이는 Kinesis 소비자에게 데이터(예: 작업)를 제공하는 데 사용되는 전송 프로토콜을 최적화하는 방식으로 지원됩니다. Kinesis의 향상된 팬아웃에 대한 자세한 내용은 Kinesis 설명서를 참조하세요.

향상된 팬아웃 모드에서는 maxRecordPerRead 및 idleTimeBetweenReadsInMs 연결 옵션이 더 이상 적용되지 않습니다. 향상된 팬아웃을 사용할 때 해당 파라미터는 구성할 수 없기 때문입니다. 재시도를 위한 구성 옵션은 설명한 대로 수행됩니다.

다음 절차를 사용하여 스트리밍 작업에 대한 향상된 팬아웃을 활성화 및 비활성화합니다. 스트림에서 데이터를 소비하는 각 작업에 대해 스트림 소비자를 등록해야 합니다.

작업에서 향상된 팬아웃 소비를 활성화하려면:

  1. Kinesis API를 사용하여 작업에 대한 스트림 소비자를 등록합니다. Kinesis 설명서의 register a consumer with enhanced fan-out using the Kinesis Data Streams API에 대한 지침을 따릅니다. 첫 번째 단계인 RegisterStreamConsumer를 직접적으로 호출합니다. 요청은 ARN, consumerARN을 반환해야 합니다.

  2. 연결 메서드 인수에서 fanoutConsumerARN 연결 옵션을 consumerARN으로 설정합니다.

  3. 작업을 다시 시작합니다.

작업에서 향상된 팬아웃 소비를 비활성화하려면:

  1. 메서드 직접 호출에서 fanoutConsumerARN 연결 옵션을 제거합니다.

  2. 작업을 다시 시작합니다.

  3. Kinesis 설명서의 deregister a consumer에 대한 지침을 따릅니다. 이 지침은 콘솔에도 적용되지만 Kinesis API를 통해서도 수행할 수 있습니다. Kinesis API를 통한 스트림 소비자 등록 취소에 대한 자세한 내용은 Kinesis 설명서의 DeregisterStreamConsumer를 참조하세요.