Guida introduttiva (Scala)

1. Crea un file denominato stock.py con i seguenti contenuti:

   import datetime
   import json
   import random
   import boto3
   
   STREAM_NAME = "ExampleInputStream"
   
   
   def get_data():
       return {
           'event_time': datetime.datetime.now().isoformat(),
           'ticker': random.choice(['AAPL', 'AMZN', 'MSFT', 'INTC', 'TBV']),
           'price': round(random.random() * 100, 2)}
   
   
   def generate(stream_name, kinesis_client):
       while True:
           data = get_data()
           print(data)
           kinesis_client.put_record(
               StreamName=stream_name,
               Data=json.dumps(data),
               PartitionKey="partitionkey")
   
   
   if __name__ == '__main__':
       generate(STREAM_NAME, boto3.client('kinesis', region_name='us-west-2'))

2. Esegui lo script stock.py:

   $ python stock.py

   Mantieni lo script in esecuzione mentre completi il resto del tutorial.

1. Installa il client Git se non lo hai già fatto. Per ulteriori informazioni, consulta Installazione di Git.

2. Clona il repository remoto con il comando seguente:

   git clone https://github.com/aws-samples/amazon-kinesis-data-analytics-examples.git

3. Passa alla directory amazon-kinesis-data-analytics-java-examples/scala/GettingStarted.

Compilazione del codice dell'applicazione

In questa sezione, si utilizza lo strumento di SBTcompilazione per creare il codice Scala per l'applicazione. Per l'installazioneSBT, vedi Installare sbt con cs setup. È inoltre necessario installare il Java Development Kit (JDK). Consulta Prerequisiti per il completamento degli esercizi.

1. Per utilizzare il codice dell'applicazione, lo si compila e lo si impacchetta in un JAR file. Puoi compilare e impacchettare il tuo codice con: SBT

   sbt assembly

2. Se l'applicazione viene compilata correttamente, viene creato il seguente file:

   target/scala-3.2.0/getting-started-scala-1.0.jar

Caricamento del codice Scala di streaming di Apache Flink

In questa sezione, viene creato un bucket Amazon S3 e caricato il codice dell'applicazione.

1. Apri la console Amazon S3 all'indirizzo. https://console.aws.amazon.com/s3/

2. Seleziona Crea bucket.

3. Immetti ka-app-code-<username> nel campo Nome bucket. Aggiungi un suffisso al nome del bucket, ad esempio il nome utente, per renderlo globalmente univoco. Scegli Next (Successivo).

4. Nella fase Configura opzioni, non modificare le impostazioni e scegli Successivo.

5. Nella fase Imposta autorizzazioni, non modificare le impostazioni e scegli Successivo.

6. Seleziona Crea bucket.

7. Scegli il bucket ka-app-code-<username>, quindi scegli Carica.

8. Nella fase Seleziona file, scegli Aggiungi file. Individua il file getting-started-scala-1.0.jar creato nella fase precedente.

9. Non è necessario modificare alcuna delle impostazioni dell'oggetto, quindi scegli Carica.