Amazon Managed Service for Apache Flink는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려졌습니다.
기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
아파치 플링크용 아마존 매니지드 서비스란 무엇입니까?
Apache Flink용 Amazon 매니지드 서비스를 사용하면 Java, Scala, Python을 사용하거나 스트리밍 데이터를 처리하고 SQL 분석할 수 있습니다. 이 서비스를 사용하면 스트리밍 소스 및 정적 소스를 대상으로 코드를 작성하고 실행하여 시계열 분석을 수행하고 실시간 대시보드 및 지표를 제공할 수 있습니다.
Apache Flink 기반 오픈 소스 라이브러리를 사용하여 Apache Flink용 관리 서비스에서 원하는 언어로 애플리케이션을 빌드할 수 있습니다.
Managed Service for Apache Flink는 Apache Flink 애플리케이션을 위한 기본 인프라를 제공합니다. 컴퓨팅 리소스 프로비저닝, AZ 페일오버 복원력, 병렬 계산, 자동 확장, 애플리케이션 백업 (체크포인트 및 스냅샷으로 구현) 과 같은 핵심 기능을 처리합니다. Flink 인프라를 직접 호스팅할 때 사용하는 것과 동일한 방식으로 고급 Flink 프로그래밍 기능(예: 연산자, 함수, 소스, 싱크)을 사용할 수 있습니다.
Apache Flink용 관리형 서비스와 Apache Flink Studio용 관리형 서비스 중 하나를 사용할지 결정하십시오.
Apache Flink용 아마존 매니지드 서비스를 사용하여 Flink 작업을 실행할 수 있는 두 가지 옵션이 있습니다. Apache Flink용 관리형 서비스를 사용하면 선택한 애플리케이션과 Apache Flink 데이터스트림 또는 테이블을 사용하여 Java, Scala 또는 Python (및 임베디드SQL) 으로 IDE Flink 애플리케이션을 빌드할 수 있습니다. APIs Apache Flink Studio용 관리형 서비스를 사용하면 실시간으로 대화형 방식으로 데이터 스트림을 쿼리하고 표준, SQL Python 및 Scala를 사용하여 스트림 처리 애플리케이션을 쉽게 빌드하고 실행할 수 있습니다.
사용 사례에 가장 적합한 방법을 선택할 수 있습니다. 확실하지 않은 경우 이 섹션에서 자세한 지침을 확인할 수 있습니다.
Apache Flink용 Amazon Managed Service를 사용할지 아니면 Apache Flink Studio용 Amazon Managed Service를 사용할지 결정하기 전에 사용 사례를 고려해야 합니다.
스트리밍 ETL 또는 연속 애플리케이션과 같은 워크로드를 처리하는 장기 실행 애플리케이션을 운영하려는 경우 Apache Flink용 관리형 서비스를 사용하는 것을 고려해야 합니다. 선택한 애플리케이션에서 APIs 직접 Flink를 사용하여 Flink 애플리케이션을 만들 수 있기 때문입니다. IDE IDE또한 로컬에서 개발하면 Git의 코드 버전 관리, CI/CD 자동화 또는 단위 테스트와 같은 소프트웨어 개발 수명 주기 (SDLC) 공통 프로세스 및 도구를 활용할 수 있습니다.
임시 데이터 탐색에 관심이 있거나, 스트리밍 데이터를 대화형 방식으로 쿼리하거나, 비공개 실시간 대시보드를 생성하려는 경우, Apache Flink Studio의 Managed Service for Apache Flink Studio를 사용하면 클릭 몇 번으로 이러한 목표를 달성할 수 있습니다. 익숙한 사용자는 장기간 실행되는 애플리케이션을 Studio에서 직접 배포하는 방안을 고려해 볼 SQL 수 있습니다.
참고
Studio 노트북을 장기 실행 애플리케이션으로 승격할 수 있습니다. 그러나 Git의 코드 버전 관리 및 CI/CD 자동화와 같은 SDLC 도구 또는 단위 테스트와 같은 기술과 통합하려는 경우 선택한 방법을 사용하는 Apache Flink용 관리 서비스를 사용하는 것이 좋습니다. IDE
Apache Flink용 관리 서비스에서 사용할 Apache Flink를 선택하십시오. APIs
원하는 Apache Flink를 사용하여 Apache Flink용 관리 서비스에서 Java, Python 및 Scala를 사용하여 애플리케이션을 빌드할 수 있습니다. APIs IDE 설명서에서 Flink 데이터스트림 및 테이블을 사용하여 애플리케이션을 빌드하는 방법에 대한 지침을 찾을 수 있습니다. API Flink 애플리케이션을 만들 때 사용할 언어와 애플리케이션 및 운영의 요구 사항을 가장 잘 충족하는 데 사용할 언어를 선택할 수 있습니다. APIs 확실하지 않은 경우 이 섹션에서 자세한 지침을 확인할 수 있습니다.
플링크를 선택하세요 API
Apache APIs Flink는 추상화 수준이 다르므로 애플리케이션 구축 결정에 영향을 미칠 수 있습니다. 표현력이 뛰어나고 유연하며 함께 사용하여 애플리케이션을 빌드할 수 있습니다. APIFlink를 하나만 사용할 필요는 없습니다. 플링크에 대한 자세한 내용은 Apache
Flink는 플링크SQL, 테이블, 프로세스 함수의 네 가지 API 추상화 수준을 제공하며 API DataStream API, 이 추상화는 와 함께 사용됩니다. DataStream API 이는 모두 Apache Flink용 아마존 매니지드 서비스에서 지원됩니다. 가능하면 더 높은 수준의 추상화로 시작하는 것이 좋지만 일부 Flink 기능은 Java, Python 또는 Scala로 애플리케이션을 만들 수 API 있는 Datastream에서만 사용할 수 있습니다. 다음과 같은 경우 데이터스트림 사용을 고려해야 합니다. API
상태를 세밀하게 제어해야 합니다.
외부 데이터베이스 또는 엔드포인트를 비동기적으로 호출하는 기능을 활용하려는 경우 (예: 추론)
사용자 지정 타이머를 사용하려는 경우 (예: 사용자 지정 윈도우 설정 또는 지연 이벤트 처리 구현)
-
상태를 재설정하지 않고도 애플리케이션의 흐름을 수정할 수 있기를 원합니다.
참고
다음을 사용하여 언어 선택: DataStream API
SQL선택한 프로그래밍 언어에 관계없이 모든 Flink 애플리케이션에 내장할 수 있습니다.
를 사용할 계획이라면 Python에서 모든 커넥터가 지원되는 것은 아닙니다. DataStream API
낮은 레이턴시/높은 처리량이 필요한 경우에는 어떤 상황에서도 Java/Scala를 고려해야 합니다. API
프로세스 함수에서 비동기 IO를 사용하려면 Java를 사용해야 합니다. API
또한 의 선택은 상태를 재설정하지 않고도 애플리케이션 로직을 발전시키는 능력에 영향을 미칠 API 수 있습니다. 이는 Java와 Python에서만 사용할 수 있는 특정 기능인 연산자에 설정하는 UID 기능에 따라 달라집니다. DataStream API 자세한 내용은 Apache Flink UUIDs설명서의 모든 연산자에 대한 설정을
스트리밍 데이터 애플리케이션으로 시작하세요.
스트리밍 데이터를 지속적으로 읽고 처리하는 Managed Service for Apache Flink 애플리케이션을 생성하는 것부터 시작할 수 있습니다. 그런 다음 원하는 코드를 사용하여 코드를 작성하고 라이브 스트리밍 데이터로 테스트하세요IDE. Managed Service for Apache Flink가 결과를 전송하려는 대상을 구성할 수도 있습니다.
시작하려면 다음 섹션을 읽어보는 것이 좋습니다.
또는 실시간으로 대화식으로 데이터 스트림을 쿼리하고 표준, SQL Python 및 Scala를 사용하여 스트림 처리 애플리케이션을 쉽게 빌드하고 실행할 수 있는 Apache Flink Studio용 관리형 서비스 노트북을 만드는 것부터 시작할 수 있습니다. 에서 몇 번만 클릭하면 서버리스 노트북을 실행하여 AWS Management Console데이터 스트림을 쿼리하고 몇 초 만에 결과를 얻을 수 있습니다. 시작하려면 다음 섹션을 읽어보는 것이 좋습니다.
