[typescript] AWS SDK를 사용하여 타입스크립트로 Kinesis 데이터 스트림 처리하기

26 Dec 2023

typescript

Amazon Kinesis는 대규모 데이터 스트림을 실시간으로 처리하기 위한 플랫폼으로, 신속하고 확장 가능한 데이터 수집 및 분석을 지원합니다. 타입스크립트와 AWS SDK를 사용하여 Kinesis 데이터 스트림을 처리하는 방법을 알아보겠습니다.

AWS SDK 및 환경 설정

첫째로, 프로젝트 디렉터리에서 다음 명령어로 AWS SDK를 설치합니다.

npm install aws-sdk

그리고 AWS 계정에 액세스할 수 있는 Amazon 자격 증명 공급자(Credential Provider)를 설정해야 합니다.

Kinesis 데이터 스트림 생성

먼저, AWS Management Console을 사용하여 Kinesis 데이터 스트림을 생성합니다.

AWS Management Console에서 Kinesis 서비스로 이동합니다.
“Create data stream”을 클릭하여 새로운 데이터 스트림을 생성합니다.

타입스크립트로 Kinesis 데이터 스트림에 데이터 전송하기

이제 타입스크립트를 사용하여 생성한 Kinesis 데이터 스트림에 데이터를 전송해 보겠습니다.

import * as AWS from 'aws-sdk';

const kinesis = new AWS.Kinesis({ region: 'your-region' });

const params = {
  Data: 'example-data', /* 데이터 */
  PartitionKey: 'example-partition-key', /* 파티션 키 */
  StreamName: 'your-stream-name' /* 데이터 스트림 이름 */
};

kinesis.putRecord(params, function(err, data) {
  if (err) console.log(err, err.stack);
  else     console.log(data);
});

위 코드에서 region, example-data, example-partition-key, your-stream-name을 실제 값으로 대체해야 합니다.

참고 자료

위 과정을 따라하면 타입스크립트로 Kinesis 데이터 스트림을 생성하고 관리할 수 있습니다. AWS SDK 및 Kinesis의 다양한 기능을 활용하여 실시간 데이터 처리 솔루션을 빌드할 수 있습니다.