Use Python com serviço gerenciado para Apache Flink - Managed Service for Apache Flink

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

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Use Python com serviço gerenciado para Apache Flink

nota

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

A versão 1.18.1 do Apache Flink inclui suporte para criar aplicativos usando a versão 3.10 do Python. 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 tabela Python API é um invólucro em torno da tabela Java. API Para obter informações sobre a tabela PythonAPI, consulte o APItutorial da tabela na documentação do Apache Flink.