Étape 3.3 : Ajout d'analyses en temps réel (ajout du code d'application) - Guide du développeur d'Amazon Kinesis Data Analytics SQL pour applications

Pour les nouveaux projets, nous vous recommandons d'utiliser le nouveau service géré pour Apache Flink Studio plutôt que Kinesis Data Analytics SQL for Applications. Le service géré pour Apache Flink Studio allie facilité d’utilisation et capacités analytiques avancées, ce qui vous permet de créer des applications sophistiquées de traitement des flux en quelques minutes.

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.3 : Ajout d'analyses en temps réel (ajout du code d'application)

Vous pouvez écrire vos propres SQL requêtes dans le flux intégré à l'application, mais pour l'étape suivante, vous utiliserez l'un des modèles qui fournit un exemple de code.

  1. Sur la page du hub d'applications, choisissez Accéder à l'SQLéditeur.

    Capture d'écran de l'exemple de page d'application avec le bouton Accéder à l'SQLéditeur.

  2. Dans le champ Voulez-vous commencer à courir "ExampleApp« ? dans la boîte de dialogue, choisissez Oui, démarrer l'application.

    La console envoie une demande pour démarrer l'application (voirStartApplication), puis la page de l'SQLéditeur apparaît.

  3. La console ouvre la page de l'SQLéditeur. Passez en revue la page, y compris les boutons (Ajouter SQL à partir de modèles, Enregistrer et exécuter SQL) et les différents onglets.

  4. Dans l'SQLéditeur, choisissez Ajouter SQL à partir de modèles.

  5. Dans la liste des modèles disponibles, choisissez Continuous filter. L'exemple de code lit les données d'un flux intégré à l'application (la clause WHERE filtre les lignes) et les insère dans un autre flux intégré à l'application comme suit :

    • Il crée le flux de données intégré à l'application DESTINATION_SQL_STREAM.

    • Il crée une pompe STREAM_PUMP et l'utilise pour sélectionner des lignes dans SOURCE_SQL_STREAM_001 et les insérer dans DESTINATION_SQL_STREAM.

  6. Choisissez Ajouter ceci SQL à l'éditeur.

  7. Testez le code d'application comme suit :

    N'oubliez pas que vous avez déjà lancé l'application (le statut estRUNNING). Par conséquent, Amazon Kinesis Data Analytics lit déjà en continu la source de streaming et ajoute des lignes dans le flux intégré à l’application SOURCE_SQL_STREAM_001.

    1. Dans l'SQLéditeur, choisissez Enregistrer et exécuter SQL. La console envoie d'abord la demande de mise à jour pour enregistrer le code d'application. Ensuite, le code s'exécute en continu.

    2. Vous pouvez voir les résultats dans l'onglet Real-time analytics.

      Capture d'écran de l'SQLéditeur avec les résultats affichés dans l'onglet d'analyse en temps réel.

      L'SQLéditeur comporte les onglets suivants :

      • L'onglet Source data affiche un flux d'entrée intégré à l'application qui est mappé à la source de diffusion. Choisissez le flux intégré à l'application. Vous pouvez alors voir des données entrantes. Vous remarquerez les colonnes supplémentaires dans le flux d'entrée intégré à l'application qui n'étaient pas spécifiées dans la configuration d'entrée. Celles-ci incluent les colonnes d'horodatage suivantes :

         

        • ROWTIME— Chaque ligne d'un flux intégré à l'application possède une colonne spéciale appeléeROWTIME. Cette colonne est l’horodatage du moment où Amazon Kinesis Data Analytics a inséré la ligne dans le premier flux intégré à l’application (le flux mappé à la source de streaming).

           

        • Approximate_Arrival_Time : chaque enregistrement Kinesis Data Analytics inclut une valeur appelée Approximate_Arrival_Time. Cette valeur est l'horodatage d'arrivée approximatif défini lorsque la source de streaming reçoit et stocke l'enregistrement avec succès. Quand Kinesis Data Analytics lit les enregistrements d’une source de streaming, il extrait cette colonne et l’insère dans le flux d’entrée intégré à l’application.

        Ces valeurs d'horodatage sont utiles dans les requêtes à fenêtres temporelles. Pour de plus amples informations, veuillez consulter Requêtes à fenêtres.

         

      • L'onglet Real-time analytics affiche tous les autres flux intégrés à l'application créés par votre code d'application. Il inclut également le flux d’erreurs. Kinesis Data Analytics envoie les lignes qu’il ne peut pas traiter dans le flux d’erreurs. Pour de plus amples informations, veuillez consulter Gestion des erreurs.

         

        Choisissez DESTINATION_SQL_STREAM pour afficher les lignes que votre code d'application a insérées. Vous remarquerez les colonnes supplémentaires que votre code d'application n'a pas créées. Celles-ci incluent la colonne d’horodatage ROWTIME. Kinesis Data Analytics copie simplement ces valeurs depuis la source (SOURCE_SQL_STREAM_001).

         

      • L’onglet Destination affiche la destination externe où Kinesis Data Analytics écrit les résultats de requête. Vous n'avez pas encore configuré de destination externe pour la sortie de votre application.

Étape suivante

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