Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per 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à.
Esempi in Python per Managed Service for Apache Flink
I seguenti esempi mostrano come creare applicazioni scritte in Python.
Nota
La maggior parte degli esempi è progettata per essere eseguita sia localmente, sulla tua macchina di sviluppo e sul tuo IDE preferito, sia su Amazon Managed Service for Apache Flink. Dimostrano il semplice meccanismo che è possibile utilizzare per passare i parametri dell'applicazione e come impostare correttamente la dipendenza per eseguire l'applicazione in entrambi gli ambienti senza modifiche.
Dipendenze del progetto
La maggior parte PyFlink degli esempi richiede una o più dipendenze come file JAR, ad esempio per i connettori Flink. Queste dipendenze devono quindi essere impacchettate con l'applicazione quando vengono distribuite su Amazon Managed Service for Apache Flink.
Gli esempi seguenti includono già gli strumenti che consentono di eseguire l'applicazione localmente per lo sviluppo e il test e di impacchettare correttamente le dipendenze richieste. Questo strumento richiede l'utilizzo di Java JDK11 e Apache Maven. Fate riferimento al README contenuto in ogni esempio per le istruzioni specifiche.
Examples (Esempi)
Questo esempio dimostra la struttura di base di un' PyFlink applicazione che utilizza SQL incorporato nel codice Python. Questo progetto fornisce anche uno scheletro per qualsiasi PyFlink applicazione che includa dipendenze JAR come i connettori. La sezione README fornisce una guida dettagliata su come eseguire l'applicazione Python localmente per lo sviluppo. L'esempio mostra anche come includere una singola dipendenza JAR, il connettore Kinesis SQL in questo esempio, nell' PyFlinkapplicazione.
Esempio di codice: GettingStarted
Questo esempio mostra come aggiungere dipendenze Python all' PyFlink applicazione nel modo più generale. Questo metodo funziona per dipendenze semplici, come Boto3, o dipendenze complesse contenenti librerie C come. PyArrow
Esempio di codice: PythonDependencies
Questo esempio dimostra quattro tipi di aggregazione di finestre in SQL incorporati in un'applicazione Python.
-
Sliding Window in base al tempo di elaborazione
-
Finestra scorrevole basata sull'ora dell'evento
-
Tumbling Window basata sul tempo di elaborazione
-
Tumbling Window basata sull'ora dell'evento
Questo esempio mostra come scrivere l'output su Amazon S3 come file JSON, utilizzando SQL incorporato in un'applicazione Python. È necessario abilitare il checkpoint per il sink S3 per scrivere e ruotare i file su Amazon S3.
Esempio di
Questo esempio dimostra come definire una funzione definita dall'utente, implementarla in Python e utilizzarla nel codice SQL eseguito in un'applicazione Python.
Questo esempio dimostra come inviare dati ad Amazon Data Firehose utilizzando SQL.
Esempio di codice: FirehoseSink
