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

O Amazon Managed Service para Apache Flink (Amazon MSF) era conhecido anteriormente 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.20 do Apache Flink inclui suporte para criar aplicativos usando a versão 3.11 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 Python Table API é um invólucro em torno da API Java Table. Para obter informações sobre a API Python Table, consulte o Tutorial da API de tabela na documentação do Apache Flink.