Usa Python con Managed Service per Apache Flink - Servizio gestito per Apache Flink

Amazon Managed Service for Apache Flink (Amazon MSF) era precedentemente noto come Amazon Kinesis Data Analytics for Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Usa Python con Managed Service per Apache Flink

Nota

Se stai sviluppando un'applicazione Python Flink su un nuovo Mac con chip Apple Silicon, potresti riscontrare alcuni problemi noti con le dipendenze Python della versione 1.15. PyFlink In questo caso consigliamo di eseguire l'interprete Python in Docker. Per step-by-step istruzioni, consulta lo sviluppo della versione PyFlink 1.15 su Apple Silicon Mac.

La versione 1.20 di Apache Flink include il supporto per la creazione di applicazioni utilizzando la versione 3.11 di Python. Per ulteriori informazioni, consulta Flink Python Docs. È possibile creare un'applicazione del servizio gestito per Apache Flink con Python seguendo la procedura descritta di seguito:

  • Crea il codice dell'applicazione Python come file di testo con un metodo main.

  • Raggruppa il file di codice dell'applicazione e tutte le dipendenze Python o Java in un file zip e caricalo in un bucket Amazon S3.

  • Crea la tua applicazione del servizio gestito per Apache Flink, specificando la posizione del codice Amazon S3, le proprietà dell'applicazione e le sue impostazioni.

Ad alto livello, l'API Python Table è un wrapper per l'API Java Table. Per informazioni sull'API Python Table, consulta il Table API Tutorial nella documentazione di Apache Flink.