Managed Service for Apache Flink 애플리케이션 생성 - Managed Service for Apache Flink
Managed Service for Apache Flink 애플리케이션 코드 빌드Managed Service for Apache Flink 애플리케이션 생성Managed Service for Apache Flink 애플리케이션 시작Managed Service for Apache Flink 애플리케이션 확인

Amazon Managed Service for Apache Flink는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려졌습니다.

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

Managed Service for Apache Flink 애플리케이션 생성

이 주제에는 Managed Service for Apache Flink 애플리케이션 생성에 대한 정보가 포함되어 있습니다.

이 주제는 다음 섹션을 포함하고 있습니다.

Managed Service for Apache Flink 애플리케이션 코드 빌드

이 섹션에서는 Managed Service for Apache Flink 애플리케이션의 애플리케이션 코드를 빌드하는 데 사용하는 구성 요소에 대해 설명합니다.

지원되는 최신 버전의 Apache Flink를 애플리케이션 코드에 사용하는 것이 좋습니다. Managed Service for Apache Flink 애플리케이션 업그레이드에 대한 자세한 내용을 알아보려면 Apache Flink에 현재 위치 버전 업그레이드 사용 섹션을 참조하십시오.

Apache Maven을 사용하여 애플리케이션 코드를 구축합니다. Apache Maven 프로젝트는 pom.xml 파일을 사용하여 해당 프로젝트에서 사용하는 구성 요소의 버전을 지정합니다.

참고

Managed Service for Apache Flink는 최대 512MB의 JAR 파일을 지원합니다. 이보다 큰 JAR 파일을 사용하면 애플리케이션이 시작되지 않습니다.

이제 애플리케이션은 API 모든 Scala 버전의 Java를 사용할 수 있습니다. 선택한 Scala 표준 라이브러리를 Scala 애플리케이션에 번들로 지정해야 합니다.

Apache Beam을 사용하는 Managed Service for Apache Flink 애플리케이션을 만드는 방법에 대한 자세한 내용을 알아보려면 아파치 플링크 애플리케이션을 위한 매니지드 서비스와 함께 아파치 빔을 사용하세요. 섹션을 참조하십시오.

Managed Service for Apache Flink 런타임 버전 1.1.0 이상을 사용하는 경우 애플리케이션을 컴파일할 때 애플리케이션에서 사용하는 Apache Flink 버전을 지정합니다. -Dflink.version 파라미터와 함께 Apache Flink 버전을 제공합니다. 예를 들어 Apache Flink 1.19.1을 사용하는 경우 다음을 제공합니다.

mvn package -Dflink.version=1.19.1

이전 버전의 Apache Flink를 사용하여 애플리케이션을 빌드하는 방법은 섹션을 참조하세요이전 버전.

Managed Service for Apache Flink 애플리케이션 생성

애플리케이션 코드를 빌드한 후 다음을 수행하여 Managed Service for Apache Flink 애플리케이션을 생성합니다.

  • 애플리케이션 코드 업로드: Amazon S3 버킷에 애플리케이션 코드를 업로드합니다. 애플리케이션 코드의 S3 버킷 명칭과 객체 명칭은 애플리케이션을 생성할 때 지정합니다. 애플리케이션 코드를 업로드하는 방법을 보여주는 자습서는 자습서: Managed Service for Apache Flink에서 사용 DataStream API 시작하기 자습서를 참조하세요.

  • Managed Service for Apache Flink 애플리케이션 만들기: 다음 방법 중 하나를 사용하여 Managed Service for Apache Flink 애플리케이션을 만드십시오.

    • AWS 콘솔을 사용하여 Managed Service for Apache Flink 애플리케이션을 생성합니다. 콘솔을 사용하여 애플리케이션을 생성하고 구성할 수 있습니다. AWS

      콘솔을 사용하여 애플리케이션을 생성하면 애플리케이션의 종속 리소스(예: CloudWatch 로그 스트림, IAM 역할 및 IAM 정책)가 생성됩니다.

      콘솔을 사용하여 애플리케이션을 생성할 때는 Managed Service for Apache Flink - 애플리케이션 생성 페이지의 풀다운에서 애플리케이션을 선택하여 애플리케이션에서 사용하는 Apache Flink 버전을 지정합니다.

      콘솔을 사용하여 애플리케이션을 생성하는 방법에 대한 자습서는 자습서: Managed Service for Apache Flink에서 사용 DataStream API 시작하기 자습서를 참조하세요.

    • 를 사용하여 Managed Service for Apache Flink 애플리케이션을 생성합니다 AWS CLI. 를 사용하여 애플리케이션을 생성하고 구성할 수 있습니다 AWS CLI.

      를 사용하여 애플리케이션을 생성할 때는 애플리케이션의 종속 리소스(예: CloudWatch 로그 스트림, IAM 역할 및 IAM 정책)도 수동으로 생성CLI해야 합니다.

      를 사용하여 애플리케이션을 생성할 때 CreateApplication 작업의 RuntimeEnvironment 파라미터를 사용하여 애플리케이션이 사용하는 Apache Flink 버전을 CLI지정합니다.

    참고

    기존 애플리케이션의 RuntimeEnvironment 를 변경할 수 있습니다. 자세한 방법은 Apache Flink에 현재 위치 버전 업그레이드 사용(을)를 참조하세요.

Managed Service for Apache Flink 애플리케이션 시작

애플리케이션 코드를 구축하고, S3에 업로드하고, Managed Service for Apache Flink 애플리케이션을 생성한 후 애플리케이션을 시작합니다. Managed Service for Apache Flink 애플리케이션을 시작하는 데 일반적으로 몇 분이 걸립니다.

애플리케이션을 시작하려면 다음 방법 중 하나를 사용합니다.

  • AWS 콘솔을 사용하여 Managed Service for Apache Flink 애플리케이션을 시작합니다. AWS 콘솔의 애플리케이션 페이지에서 실행을 선택하여 애플리케이션을 실행할 수 있습니다.

  • 를 사용하여 Managed Service for Apache Flink 애플리케이션을 시작합니다. 작업을 사용하여 애플리케이션을 실행할 AWS API 수 있습니다. StartApplication

Managed Service for Apache Flink 애플리케이션 확인

다음과 같은 방법으로 애플리케이션이 작동하는지 확인할 수 있습니다.

  • CloudWatch 로그 사용: CloudWatch Logs and CloudWatch Logs Insights를 사용하여 애플리케이션이 제대로 실행되고 있는지 확인할 수 있습니다. Managed Service for Apache Flink 애플리케이션에서 CloudWatch 로그를 사용하는 방법에 대한 자세한 내용은 섹션을 참조하세요아파치 플링크용 Amazon 매니지드 서비스의 로깅 및 모니터링.

  • CloudWatch 지표 사용: CloudWatch 지표를 사용하여 애플리케이션의 활동 또는 애플리케이션이 입력 또는 출력에 사용하는 리소스(예: Kinesis 스트림, Firehose 스트림 또는 Amazon S3 버킷)의 활동을 모니터링할 수 있습니다. CloudWatch 지표에 대한 자세한 내용은 Amazon CloudWatch 사용 설명서의 지표 작업을 참조하세요.

  • 출력 위치 모니터링: 애플리케이션이 특정 위치(예: Amazon S3 버킷 또는 데이터베이스)에 출력을 기록하는 경우 해당 위치에서 기록된 데이터를 모니터링할 수 있습니다.