Étape 3.4 : (Facultatif) Mise à jour du code d'application

Dans cette étape, vous découvrez comment mettre à jour le code d'application.

Pour mettre à jour votre code d'application

1. Créez un autre flux intégré à l'application comme suit :

   • Créez un autre flux intégré à l'application appelé DESTINATION_SQL_STREAM_2.

   • Créez une pompe, puis utilisez-la pour insérer des lignes dans le flux nouvellement créé en sélectionnant des lignes dans le flux DESTINATION_SQL_STREAM.

   Dans l'éditeur SQL, ajoutez le code suivant au code d'application existant :

   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM_2" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "STREAM_PUMP_2" AS 
      INSERT INTO "DESTINATION_SQL_STREAM_2"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "DESTINATION_SQL_STREAM";

   Enregistrez et exécutez le code. Des flux intégrés à l'application supplémentaires apparaissent dans l'onglet Real-time analytics.

2. Créez deux flux intégrés à l'application. Filtrez les lignes dans SOURCE_SQL_STREAM_001 en fonction du symbole boursier, puis insérez-les dans ces flux distincts.

   Ajoutez les instructions SQL suivantes à votre code d'application :

   CREATE OR REPLACE STREAM "AMZN_STREAM" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "AMZN_PUMP" AS 
      INSERT INTO "AMZN_STREAM"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  ticker_symbol SIMILAR TO '%AMZN%';
   
   CREATE OR REPLACE STREAM "TGT_STREAM" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "TGT_PUMP" AS 
      INSERT INTO "TGT_STREAM"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  ticker_symbol SIMILAR TO '%TGT%';

   Enregistrez et exécutez le code. Vous remarquerez des flux intégrés à l'application supplémentaires dans l'onglet Real-time analytics.

Vous disposez maintenant de votre première application Amazon Kinesis Data Analytics opérationnelle. Dans cet exercice, vous avez effectué les opérations suivantes :

• Création de votre première application Kinesis Data Analytics.

   

• Vous avez configuré l’entrée d’application qui identifiait le flux de démonstration comme source de diffusion et vous l’avez mappée à un flux intégré à l’application (SOURCE_SQL_STREAM_001) qui a été créé. Kinesis Data Analytics lit en continu le flux de démonstration et insère des enregistrements dans le flux intégré à l’application.

   

• Votre code d'application a interrogé le flux SOURCE_SQL_STREAM_001 et a écrit la sortie dans un autre flux intégré à l'application, appelé DESTINATION_SQL_STREAM.

Vous pouvez maintenant configurer le cas échéant la sortie d'application pour écrire celle-ci dans une destination externe. En d'autres termes, vous pouvez configurer la sortie de l'application pour qu'elle écrive des enregistrements du flux DESTINATION_SQL_STREAM dans une destination externe. Pour cet exercice, cette étape est facultative. Pour apprendre à configurer la destination, allez à l'étape suivante.

Étape suivante

Étape 4 (facultatif) Modification du schéma et du code SQL à l'aide de la console.