Nozioni di base su Servizio gestito da HAQM per Apache Flink
Perché dovrei scegliere Servizio gestito per Apache Flink?
Con il servizio gestito da HAQM per Apache Flink puoi trasformare e analizzare i dati di streaming in tempo reale utilizzando Apache Flink. Il servizio gestito da HAQM per Apache Flink semplifica la costruzione e la gestione dei carichi di lavoro di Apache Flink e ti permette di integrare facilmente le applicazioni con altri servizi AWS.
Crea applicazioni di streaming con Apache Flink e Apache Beam
1
Fase 1: scarica le librerie open source nel tuo ambiente IDE preferito
Puoi iniziare scaricando le librerie open source che includono gli SDK AWS, Apache Flink e i connettori per i servizi AWS.
2
Fase 2: crea un'applicazione campione utilizzando Apache Flink e Apache Beam
Scrivi il codice della tua applicazione Apache Flink utilizzando flussi di dati e operatori di flussi. I flussi di dati dell'applicazione sono la struttura dei dati rispetto ai quali esegui l'elaborazione utilizzando il codice dell'applicazione. I dati fluiscono continuamente dalle origini nei flussi di dati dell'applicazione. Per definire l'elaborazione sui flussi di dati dell'applicazione vengono utilizzati uno o più operatori di flussi.
3
Fase 3: carica il codice sul servizio gestito da HAQM per Apache Flink
Una volta creato, carica il codice nel servizio gestito da HAQM per Apache Flink. Questo servizio si occupa di tutte le operazioni necessarie per eseguire le applicazioni in tempo reale in modo continuo, ricalibrando automaticamente le risorse in base al volume e alla velocità di trasmissione effettiva dei dati in entrata.
Usa in modo intuitivo il servizio gestito da HAQM per Apache Flink Studio
1
Fase 1: crea un'applicazione del servizio gestito da HAQM per Apache Flink Studio
Inizia dalla console del Servizio gestito da HAQM per Apache Flink, di HAQM MSK o del flusso di dati HAQM Kinesis. Puoi anche usare connettori personalizzati e connetterti a qualsiasi altra origine dati.
2
Fase 2: scrivi codice nel notebook serverless in SQL, Python e Scala e sviluppa applicazioni Apache Flink
Esegui singoli paragrafi nel notebook, visualizza i risultati nel contesto e utilizza la visualizzazione integrata di Apache Zeppelin per accelerare lo sviluppo. Puoi anche usare funzioni definite dall'utente nel codice.
3
Fase 3: crea e implementa la soluzione come applicazione di streaming del servizio gestito da HAQM per Apache Flink
Implementa il codice come applicazione di elaborazione di flussi in esecuzione continua con pochi clic. L'applicazione implementata sarà un'applicazione del servizio gestito da HAQM per Apache Flink con stato durevole e dimensionamento automatico. Prima di mettere in produzione il codice, puoi cambiare le origini, le destinazioni, la registrazione e i livelli di monitoraggio.