Amazon Kinesis Producer Library(KPL)를 사용하여 Kinesis 데이터 스트림에 레코드를 삽입하고자 합니다. 

아래 단계를 완료하기 전에 다음을 확인하십시오.

  • Amazon Elastic Compute Cloud(Amazon EC2) Linux 인스턴스가 실행 중입니다.
  • AWS Identity and Access Management(IAM) 역할이 인스턴스에 연결되어 있습니다.
  • KinesisFullAccess 정책이 인스턴스의 IAM 역할에 연결되어 있습니다.

1.    EC2 인스턴스에 연결합니다.

2.    최신 버전의 OpenJDK 8 개발자 패키지를 설치합니다.

sudo yum install java-1.8.0-openjdk-devel

3.    Java가 설치되었는지 확인합니다.

java -version

다음과 같이 출력되어야 합니다. 

java version "1.7.0_181"
OpenJDK Runtime Environment (amzn-2.6.14.8.80.amzn1-x86_64 u181-b00)
OpenJDK 64-Bit Server VM (build 24.181-b00, mixed mode)

4.    다음 명령을 실행하여 Java 1.8을 기본 javajavac 제공자로 설정합니다.

sudo /usr/sbin/alternatives --config java 
sudo /usr/sbin/alternatives --config javac

5.    Apache Maven 패키지로 리포지토리를 추가합니다.

sudo wget http://repos.fedorapeople.org/repos/dchen/apache-maven/epel-apache-maven.repo -O /etc/yum.repos.d/epel-apache-maven.repo

6.    Maven 패키지에 대한 버전 번호를 설정합니다.

sudo sed -i s/\$releasever/6/g /etc/yum.repos.d/epel-apache-maven.repo

7.    yum을 실행하여 Maven을 설치합니다.

sudo yum install -y apache-maven

8.    Maven이 올바르게 설치되었는지 확인합니다.

mvn -version

다음과 같이 출력되어야 합니다. 

Apache Maven 3.5.2 (138edd61fd100ec658bfa2d307c43b76940a5d7d; 2017-10-18T07:58:13Z)
Maven home: /usr/share/apache-maven
Java version: 1.7.0_181, vendor: Oracle Corporation
Java home: /usr/lib/jvm/java-1.7.0-openjdk-1.7.0.181.x86_64/jre
Default locale: en_US, platform encoding: UTF-8
OS name: "linux", version: "4.14.33-51.37.amzn1.x86_64", arch: "amd64", family: "unix"

9.    git를 설치한 다음 AWS 실습에서 KPL을 다운로드합니다.

sudo yum install git
git clone https://github.com/awslabs/amazon-kinesis-producer

10.    amazon-kinesis-producer/java/amazon-kinesis-producer-sample/ 디렉토리를 연 다음 파일을 나열합니다.

cd amazon-kinesis-producer/java/amazon-kinesis-producer-sample/
ls
default_config.properties  pom.xml  README.md  src  target

11.    다음과 유사한 명령을 실행하여 Kinesis 데이터 스트림을 생성합니다. 얼마나 많은 샤드가 필요한지 확실하지 않은 경우에는 샤드에 대한 추가 정보를 참조하십시오.

aws kinesis create-stream --stream-name kinesis-kpl-demo --shard-count 2

12.    list-streams를 실행하여 스트림이 생성되었는지 확인합니다.

aws kinesis list-streams

13.    SampleProducer.java 파일을 열고 다음 필드를 수정합니다.
[public static final String STREAM_NAME]에 11단계에서 생성한 스트림의 이름을 입력합니다.
[public static final String REGION]에 사용 중인 지역을 입력합니다.

cd src/com/amazonaws/services/kinesis/producer/sample
vi SampleProducer.java

public static final String STREAM_NAME = "kinesis-kpl-demo";
public static final String REGION = "us-east-1";

14.    Maven이 모든 의존성을 다운로드할 수 있도록 amazon-kinesis-producer-sample 디렉토리에서 다음 명령을 실행합니다.

mvn clean package

15.    amazon-kinesis-producer-sample 디렉토리에서 다음 명령을 수행하여 생산자를 실행하고 데이터를 스트림에 삽입합니다.

mvn exec:java -Dexec.mainClass="com.amazonaws.services.kinesis.producer.sample.SampleProducer"

16.    얼마나 많은 레코드가 스트림에 삽입되었는지 보려면 Kinesis 콘솔의 [Monitoring] 탭에 있는 [Incoming Data (Count)] 그래프를 확인합니다.
참고: 레코드 수가 데이터 스트림에 사용자가 삽입한 레코드 수보다 더 적을 수 있습니다. 이는 KPL이 집계 기능을 사용하기 때문입니다.


페이지 내용이 도움이 되었습니까? | 아니요

AWS 지원 지식 센터로 돌아가기

도움이 필요하십니까? AWS 지원 센터를 방문하십시오

게시 날짜: 2019년 2월 11일