

Amazon Timestream for LiveAnalytics와 유사한 기능을 원하는 경우 Amazon Timestream for InfluxDB를 고려해 보세요. 간소화된 데이터 수집과 실시간 분석을 위한 10밀리초 미만의 쿼리 응답 시간을 제공합니다. [여기](https://docs.aws.amazon.com//timestream/latest/developerguide/timestream-for-influxdb.html)에서 자세히 알아보세요.

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

# Amazon Managed Service for Apache Flink
<a name="ApacheFlink"></a>

Apache Flink를 사용하여 Amazon Managed Service for Apache Flink, Amazon MSK, Apache Kafka 및 기타 스트리밍 기술에서 Amazon Timestream for LiveAnalytics로 직접 시계열 데이터를 전송할 수 있습니다. Timestream용 Apache Flink 샘플 데이터 커넥터를 생성했습니다. 또한 데이터가 Kinesis에서 Managed Service for Apache Flink로, 마지막으로 Amazon Timestream으로 흐를 수 있도록 Amazon Kinesis로 데이터를 전송하기 위한 샘플 애플리케이션을 만들었습니다. 이러한 모든 아티팩트는 GitHub에서 사용할 수 있습니다. 이 [동영상 자습서](https://youtu.be/64DSlBvN5lg)에서는 설정에 대해 설명합니다.

**참고**  
 Java 11은 Managed Service for Apache Flink 애플리케이션을 사용하기 위한 권장 버전입니다. 여러 Java 버전이 있는 경우 Java 11을 JAVA\$1HOME 환경 변수로 내보내야 합니다.

**Topics**
+ [샘플 애플리케이션](#ApacheFlink.sample-app)
+ [동영상 자습서](#ApacheFlink.video-tutorial)

## 샘플 애플리케이션
<a name="ApacheFlink.sample-app"></a>

시작하려면 다음 절차를 따르세요.

1. [데이터베이스 생성](console_timestream.md#console_timestream.db.using-console)에 설명된 지침에 따라 Timestream에 이름이 `kdaflink`인 데이터베이스를 생성합니다.

1. [테이블 생성](console_timestream.md#console_timestream.table.using-console)에 설명된 지침에 따라 Timestream에 이름이 `kinesisdata1`인 테이브을 생성합니다.

1. [스트림 생성](https://docs.aws.amazon.com/streams/latest/dev/amazon-kinesis-streams.html#how-do-i-create-a-stream)에 설명된 지침에 따라 이름이 `TimestreamTestStream`인 Amazon Kinesis Data Stream을 생성합니다.

1. [GitHub](https://docs.github.com/en/free-pro-team@latest/github/creating-cloning-and-archiving-repositories/cloning-a-repository)의 지침에 따라 [Timestream용 Apache Flink 데이터 커넥터](https://github.com/awslabs/amazon-timestream-tools/blob/master/integrations/flink_connector)의 GitHub 리포지토리를 복제합니다.

1.  샘플 애플리케이션을 컴파일, 실행 및 사용하려면 [Apache Flink 샘플 데이터 커넥터 README](https://github.com/awslabs/amazon-timestream-tools/blob/master/integrations/flink_connector/README.md)의 지침을 따릅니다.

1. [애플리케이션 코드 컴파일](https://docs.aws.amazon.com/managed-flink/latest/java/get-started-exercise.html#get-started-exercise-5.5) 지침에 따라 Managed Service for Apache Flink 애플리케이션을 컴파일합니다.

1. [Apache Flink 스트리밍 코드 업로드](https://docs.aws.amazon.com/managed-flink/latest/java/get-started-exercise.html#get-started-exercise-6) 지침에 따라 Managed Service for Apache Flink 애플리케이션 바이너리를 업로드합니다.

   1. 애플리케이션 생성을 클릭한 후 애플리케이션의 IAM 역할 링크를 클릭합니다.

   1. **AmazonKinesisReadOnlyAccess** 및 **AmazonTimestreamFullAccess**에 대한 IAM 정책을 연결합니다.
**참고**  
위의 IAM 정책은 특정 리소스로 제한되지 않으며 프로덕션 용도로 적합하지 않습니다. 프로덕션 시스템의 경우 특정 리소스에 대한 액세스를 제한하는 정책을 사용하는 것이 좋습니다.

1. [GitHub](https://docs.github.com/en/free-pro-team@latest/github/creating-cloning-and-archiving-repositories/cloning-a-repository)의 지침에 따라 [Kinesis에 데이터를 쓰는 샘플 애플리케이션](https://github.com/awslabs/amazon-timestream-tools/tree/mainline/tools/python/kinesis_ingestor)의 GitHub 리포지토리를 복제합니다.

1. [README](https://github.com/awslabs/amazon-timestream-tools/blob/mainline/tools/python/kinesis_ingestor/README.md)의 지침에 따라 Kinesis에 데이터를 쓰기 위한 샘플 애플리케이션을 실행합니다.

1. Timestream에서 하나 이상의 쿼리를 실행하여 [테이블 생성](console_timestream.md#console_timestream.table.using-console)에 대한 지침에 따라 데이터가 Kinesis에서 Managed Service for Apache Flink로 Timestream으로 전송되는지 확인합니다.

## 동영상 자습서
<a name="ApacheFlink.video-tutorial"></a>

이 [동영상](https://youtu.be/64DSlBvN5lg)에서는 Managed Service for Apache Flink와 함께 Timestream을 사용하는 방법을 설명합니다.