View a markdown version of this page

Use o Python com Managed Service for Apache Flink - Managed Service 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 o Python com Managed Service for 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 obter instruções passo a passo, consulte Desenvolvimento da PyFlink versão 1.15 no Apple Silicon Mac.

A versão 2.2 do Apache Flink inclui suporte para criar aplicativos usando Python versão 3.12; o suporte para Python versão 3.8 foi removido. 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.