Étape 3.4 : (Facultatif) Mise à jour du code d'application - Guide du développeur d'Amazon Kinesis Data Analytics SQL pour applications

Après mûre réflexion, nous avons décidé de mettre fin à Amazon Kinesis Data Analytics SQL pour les applications en deux étapes :

1. À compter du 15 octobre 2025, vous ne pourrez plus créer de nouveaux Kinesis Data Analytics SQL pour les applications.

2. Nous supprimerons vos candidatures à compter du 27 janvier 2026. Vous ne serez pas en mesure de démarrer ou d'utiliser votre Amazon Kinesis Data Analytics SQL pour les applications. Support ne sera plus disponible pour Amazon Kinesis Data Analytics à partir SQL de cette date. Pour de plus amples informations, veuillez consulter Arrêt d'Amazon Kinesis Data Analytics SQL pour applications.

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

É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'SQLéditeur, 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 SQL instructions suivantes au code de votre 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) Modifier le schéma et le SQL code à l'aide de la console.