Tutorial: Analisi dei flussi di negoziazioni in tempo reale tramite il servizio gestito per Apache Flink per applicazioni Flink

Lo scenario per questo tutorial richiede l'importazione del flusso di negoziazioni in un flusso di dati e la scrittura di una semplice applicazione del Servizio gestito da Amazon per Apache Flink che esegua calcoli sul flusso. Verranno fornite informazioni su come inviare un flusso di record al flusso di dati Kinesis e su come implementare un'applicazione che consuma ed elabora i record quasi in tempo reale.

Con il servizio gestito per Apache Flink per applicazioni Flink, puoi usare Java o Scala per elaborare e analizzare i dati in streaming. Il servizio consente di creare ed eseguire codice Java su sorgenti di streaming per eseguire analisi delle serie temporali, generare pannelli di controllo e creare parametri in tempo reale.

È possibile creare applicazioni Flink nel servizio gestito per Apache Flink utilizzando le librerie open source basate su Apache Flink. Apache Flink è un celebre framework e motore per l’elaborazione di flussi di dati.

Importante

Dopo aver creato due flussi di dati e un'applicazione, all'account vengono addebitati costi nominali per l'utilizzo di Kinesis Data Streams e Managed Service for Apache Flink perché non sono idonei per il piano gratuito. AWS Quando hai finito con questa applicazione, elimina le tue risorse per evitare di incorrere in addebiti. AWS

Il codice non accede ai dati del mercato azionario, ma simula il flusso delle negoziazioni. A tale scopo, utilizza un generatore di negoziazioni casuale. Se disponi dell'accesso a un flusso di negoziazioni in tempo reale, potresti essere interessato a derivare statistiche utili e tempestive da quel flusso. Ad esempio, potresti eseguire un'analisi basata su finestra scorrevole per determinare i titoli più acquistati negli ultimi 5 minuti. Oppure potresti ricevere una notifica ogni volta che viene effettuato un ordine di vendita troppo grande (ossia, che include un numero eccessivo di titoli). Puoi estendere il codice in questa serie per fornire tale funzionalità.

Gli esempi mostrati utilizzano la regione Stati Uniti occidentali (Oregon), ma si applicano a qualunque Regione AWS che supporta il servizio gestito per Apache Flink.

Attività

• Prerequisiti per il completamento degli esercizi
• Passaggio 1: configurare un AWS account e creare un utente amministratore
• Fase 2: Configurare il AWS Command Line Interface (AWS CLI)
• Fase 3: Creazione ed esecuzione di un servizio gestito per Apache Flink per applicazioni Flink

Prerequisiti per il completamento degli esercizi

Per completare le fasi in questa guida, è richiesto quanto segue:

• Java Development Kit (JDK) versione 8. Imposta la variabile di ambiente JAVA_HOME in modo che punti alla posizione di installazione di JDK.

• Ti consigliamo di utilizzare un ambiente di sviluppo (ad esempio Eclipse Java Neon o IntelliJ IDEA) per sviluppare e compilare l'applicazione.

• Client Git. Installa il client Git se non lo hai già fatto.

• Apache Maven Compiler Plugin. Maven deve trovarsi nel percorso di lavoro. Per testare l'installazione Apache Maven, immetti quanto segue:

  $ mvn -version

Per iniziare, vai alla pagina Passaggio 1: configurare un AWS account e creare un utente amministratore.