Comenzar (Scala)

1. Cree un archivo denominado stock.py con el siguiente contenido:

   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. Ejecute el script stock.py:

   $ python stock.py

   Mantenga el script en ejecución mientras completa el resto del tutorial.

1. Si aún no lo ha hecho, instale el cliente Git. Para obtener más información, consulte Installing Git.

2. Clone el repositorio remoto con el siguiente comando:

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

3. Vaya al directorio amazon-kinesis-data-analytics-java-examples/scala/GettingStarted.

Compilación del código de la aplicación

En esta sección, utilizará la herramienta de SBTcompilación para crear el código Scala para la aplicación. Para instalarloSBT, consulte Instalar sbt con cs setup. También necesita instalar el kit de desarrollo de Java (JDK). Consulte Prerequisites for Completing the Exercises.

1. Para usar el código de la aplicación, debe compilarlo y empaquetarlo en un JAR archivo. Puede compilar y empaquetar el código conSBT:

   sbt assembly

2. Si la aplicación se compila correctamente, se crea el siguiente archivo:

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

Carga del código de Scala de streaming de Apache Flink

En esta sección, creará un bucket de Amazon S3 y cargará el código de la aplicación.

1. Abra la consola Amazon S3 en https://console.aws.amazon.com/s3/.

2. Elija Crear bucket

3. Escriba ka-app-code-<username> en el campo Nombre del bucket. Añada un sufijo al nombre del bucket, como su nombre de usuario, para que sea único a nivel global. Elija Siguiente.

4. En el paso Configurar opciones, deje los ajustes tal y como están y elija Siguiente.

5. En el paso Establecer permisos, deje los ajustes tal y como están y elija Siguiente.

6. Elija Crear bucket.

7. Abra el bucket ka-app-code-<username> y elija Cargar.

8. En el paso Seleccionar archivos, elija Añadir archivos. Vaya al archivo getting-started-scala-1.0.jar que creó en el paso anterior.

9. No es necesario cambiar ninguno de los ajustes del objeto, por lo tanto, elija Cargar.