Amazon Managed Service for Apache Flink는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려졌습니다.
기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
이 섹션에서는 Apache Flink용 관리 서비스의 기본 개념과 표 및 를 사용하여 Java로 애플리케이션을 구현하는 방법을 소개합니다. API SQL 동일한 응용 프로그램 APIs 내에서 서로 다른 응용 프로그램 간에 전환하는 방법을 보여주고 응용 프로그램을 만들고 테스트하는 데 사용할 수 있는 옵션에 대해 설명합니다. 또한 이 가이드의 자습서를 완료하고 첫 번째 애플리케이션을 만드는 데 필요한 도구를 설치하는 방법에 대한 지침도 제공합니다.
주제
Apache Flink용 관리 서비스 응용 프로그램의 구성 요소를 검토하십시오.
참고
아파치 플링크용 관리형 서비스는 모든 아파치 APIs 플링크와
데이터를 처리하기 위해 Apache Flink용 관리 서비스 응용 프로그램에서는 Apache Flink 런타임을 사용하여 입력을 처리하고 출력을 생성하는 Java 응용 프로그램을 사용합니다.
일반적인 Apache Flink 응용 프로그램에는 다음과 같은 구성 요소가 있습니다.
-
런타임 속성: 코드를 수정하고 다시 게시하지 않고도 런타임 속성을 사용하여 구성 매개변수를 애플리케이션에 전달할 수 있습니다.
-
소스: 응용 프로그램은 하나 이상의 소스의 데이터를 사용합니다. 소스는 커넥터를
사용하여 Kinesis 데이터 스트림 또는 Amazon MSK 주제와 같은 외부 시스템에서 데이터를 읽습니다. 개발 또는 테스트의 경우 소스를 임의로 생성 [ly] 하여 테스트 데이터를 생성할 수도 있습니다. 자세한 내용은 Managed Service for Apache Flink에 스트리밍 데이터 소스 추가 단원을 참조하십시오. SQL또는 테이블을 API 사용하면 소스가 소스 테이블로 정의됩니다. -
변환: 애플리케이션은 데이터를 필터링, 강화 또는 집계할 수 있는 하나 이상의 변환을 통해 데이터를 처리합니다. 또는 테이블을 사용하는 경우 변환은 테이블 SQL 또는 API 뷰에 대한 쿼리로 정의됩니다.
-
싱크: 애플리케이션은 싱크를 통해 외부 시스템에 데이터를 전송합니다. 싱크는 커넥터를
사용하여 Kinesis 데이터 스트림, Amazon MSK 주제, Amazon S3 버킷 또는 관계형 데이터베이스와 같은 외부 시스템으로 데이터를 전송합니다. 또한 특수 커넥터를 사용하여 개발 목적으로만 출력을 인쇄할 수 있습니다. SQL또는 테이블을 사용하는 API 경우 싱크는 결과를 삽입할 싱크 테이블로 정의됩니다. 자세한 내용은 Managed Service for Apache Flink의 싱크를 사용하여 데이터 쓰기 단원을 참조하십시오.
응용 프로그램에는 응용 프로그램에서 사용하는 Flink 커넥터 또는 잠재적으로 Java 라이브러리와 같은 일부 외부 종속성이 필요합니다. Apache Flink용 아마존 매니지드 서비스에서 실행하려면 애플리케이션을 JARFat-에 종속성과 함께 패키징하여 Amazon S3 버킷에 업로드해야 합니다. 그런 다음 Managed Service for Apache Flink 애플리케이션을 생성합니다. 코드 패키지 위치를 다른 런타임 구성 파라미터와 함께 전달합니다. 이 자습서에서는 Apache Maven을 사용하여 응용 프로그램을 패키징하는 방법과 선택한 응용 프로그램을 로컬에서 실행하는 방법을 보여줍니다. IDE
필수 사전 요구 사항을 완료하십시오.
이 자습서를 시작하기 전에 Amazon Managed Service for Apache Flink(DataStream API) 시작하기의 첫 두 단계를 완료하세요.
시작하려면 애플리케이션 생성 섹션을 참조하세요.
다음 단계
