Use o Python com Managed Service for Apache Flink - Managed Service for Apache Flink

Anteriormente, o Amazon Managed Service for Apache Flink (Amazon MSF) era conhecido como Amazon Kinesis Data Analytics for Apache Flink.

Use o Python com Managed Service for Apache Flink

nota

Se você estiver desenvolvendo um aplicativo Python Flink em um novo Mac com o chip Apple Silicon, poderá encontrar alguns problemas conhecidos com as dependências do Python do PyFlink 1.15. Nesse caso, recomendamos executar o interpretador Python no Docker. Para obter as instruções do passo a passo, consulte Desenvolvimento do PyFlink 1.15 no Apple Silicon Mac.

O Apache Flink versão 1.20 inclui suporte para criar aplicativos usando o Python versão 3.11. Para obter mais informações, consulte Flink Python Docs. Você cria um serviço gerenciado para o aplicativo Apache Flink usando Python fazendo o seguinte:

  • Crie o código do seu aplicativo Python como um arquivo de texto com um main método.

  • Empacote o arquivo de código do seu aplicativo e todas as dependências do Python ou Java em um arquivo zip e faça o upload para um bucket do Amazon S3.

  • Crie seu serviço gerenciado para o aplicativo Apache Flink, especificando a localização do código do Amazon S3, as propriedades do aplicativo e as configurações do aplicativo.

Em um alto nível, a Python Table API é um invólucro em torno da API Java Table. Para obter informações sobre a API Table do Python, consulte o Tutorial da API Table na documentação do Apache Flink.