Exemple : Exploration du flux d'erreurs intégré à l'application - Guide du développeur d'Amazon Kinesis Data Analytics SQL pour applications
Introduction d'une erreur d'analyseIntroduction d'une erreur de division par zéro

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.

Exemple : Exploration du flux d'erreurs intégré à l'application

Amazon Kinesis Data Analytics fournit un flux d’erreurs intégré à l’application pour chaque application que vous créez. Les lignes que votre application ne peut pas traiter sont envoyées à ce flux d'erreurs. Vous pouvez envisager de conserver les données du flux d'erreurs dans une destination externe pour pouvoir les examiner.

Vous effectuez les exercices suivants sur la console. Dans ces exemples, vous introduisez des erreurs dans la configuration d'entrée en modifiant le schéma qui est déduit par le processus de découverte, puis vous vérifiez les lignes envoyées au flux d'erreurs.

Introduction d'une erreur d'analyse

Dans cet exercice, vous introduisez une erreur d'analyse.

  1. Créez une application Kinesis Data Analytics comme décrit dans l’exercice de mise en route de Kinesis Data Analytics.

  2. Sur la page de détails de l'application, choisissez Connect streaming data (Connecter des données de diffusion).

  3. Si vous avez suivi l'exercice de mise en route, vous disposez d'un flux de démonstration (kinesis-analytics-demo-stream) dans votre compte. Sur la page Connect to source (Se connecter à la source), choisissez ce flux de démonstration.

  4. Kinesis Data Analytics prélève un échantillon dans le flux de démonstration pour déduire un schéma pour le flux d’entrée intégré à l’application qu’il crée. La console affiche le schéma déduit et les échantillons de données dans l'onglet Formatted stream sample.

  5. Ensuite, éditez le schéma et modifiez le type de colonne pour introduire l'erreur d'analyse. Choisissez Edit schema (Modifier le schéma).

  6. Remplacez le type de colonne TICKER_SYMBOL VARCHAR(4) par INTEGER.

    Le type de colonne du schéma intégré à l’application qui a été créé n’est pas valide, ce qui signifie que Kinesis Data Analytics ne peut pas introduire de données dans le flux intégré à l’application. Au lieu de cela, le service envoie les lignes dans le flux d'erreurs.

  7. Choisissez Save schema.

  8. Choisissez Refresh schema samples.

    Notez qu'il n'y a pas de lignes dans l'exemple Formatted stream. Toutefois, l'onglet Error stream affiche des données avec un message d'erreur. L'onglet Error stream montre les données envoyées aux flux d'erreurs intégré à l'application.

    Comme vous avez modifié le type de données de colonne, Kinesis Data Analytics n’a pas pu importer les données dans le flux d’entrée intégré à l’application. Au lieu de cela, le service envoie les données dans le flux d'erreurs.

Introduction d'une erreur de division par zéro

Dans le cadre de cet exercice, vous allez mettre à jour le code de l'application pour introduire une erreur d'exécution (division par zéro). Notez qu’Amazon Kinesis Data Analytics envoie les lignes obtenues sur le flux d’erreurs intégré à l’application, et non sur le flux intégré à l’application DESTINATION_SQL_STREAM dans lequel les résultats doivent logiquement être écrits.

  1. Créez une application Kinesis Data Analytics comme décrit dans l’exercice de mise en route de Kinesis Data Analytics.

    Vérifiez les résultats dans l'onglet Real-time analytics en procédant comme suit :

    -

  2. Mettez à jour l'instruction SELECT dans le code d'application pour introduire une division par zéro, par exemple : 

    SELECT STREAM ticker_symbol, sector, change, (price / 0) as ProblemColumn
FROM "SOURCE_SQL_STREAM_001"
WHERE sector SIMILAR TO '%TECH%';

  3. Exécutez l'application.

    En raison de l’erreur d’exécution de division par zéro, au lieu d’écrire les résultats dans le flux DESTINATION_SQL_STREAM, Kinesis Data Analytics envoie les lignes dans le flux d’erreurs intégré à l’application. Dans l'onglet Real-time analytics (Analyse en temps réel), choisissez le flux d'erreurs. Vous pouvez alors voir les lignes du flux d'erreurs intégré à l'application.