Managed Service for Apache Flink와 함께 Python 사용 - Managed Service for Apache Flink

Amazon Managed Service for Apache Flink(Amazon MSF)는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려져 있었습니다.

Managed Service for Apache Flink와 함께 Python 사용

참고

애플 실리콘 칩이 장착된 새로운 Mac에서 Python Flink 애플리케이션을 개발하는 경우, PyFlink 1.15의 Python 종속성과 관련된 몇 가지 알려진 문제가 발생할 수 있습니다. 이 경우 Docker에서 Python 인터프리터를 실행하는 것이 좋습니다. 단계별 지침은 Apple Silicon Mac에서의 PyFlink 1.15 개발을 참조하세요.

Apache Flink 버전 1.20에는 Python 버전 3.11을 사용하여 애플리케이션을 만들 수 있는 지원이 포함되어 있습니다. 자세한 내용은 Flink Python 설명서를 참조하세요. 다음을 통해 Python을 사용하여 Managed Service for Apache Flink 애플리케이션을 생성합니다.

  • main 메서드를 사용하여 Python 애플리케이션 코드를 텍스트 파일로 만듭니다.

  • 애플리케이션 코드 파일과 Python 또는 Java 종속성을 zip 파일로 번들링한 다음 Amazon S3 버킷에 업로드합니다.

  • Amazon S3 코드 위치, 애플리케이션 속성 및 애플리케이션 설정을 지정하여 Managed Service for Apache Flink 애플리케이션을 생성합니다.

상위 수준에서 보면, Python 표 API는 자바 표 API에 대한 래퍼입니다. Python Table API에 관한 자세한 내용은 Apache Flink 설명서의 Table API 자습서를 참조하세요.