Étape 3 : Configurer la sortie de l'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 : Configurer la sortie de l'application

À ce stade de l’exemple pour les points chauds, vous avez un code d’application Amazon Kinesis Data Analytics qui identifie des points chauds significatifs d’une source de streaming et qui attribue un score de chaleur à chacun.

Vous pouvez maintenant envoyer les résultats de l’application depuis le flux intégré à l’application vers une destination externe, qui est un autre flux de données Kinesis (ExampleOutputStream). Vous pouvez ensuite analyser les scores de points chauds et déterminer un seuil approprié pour la chaleur des points chauds. Vous pouvez étendre encore cette application pour générer des alertes.

Pour configurer la sortie de l'application

  1. Ouvrez la console Kinesis Data Analytics à l’adresse https://console.aws.amazon.com/kinesisanalytics.

  2. Dans l'éditeur SQL, choisissez Destination ou Add a destination dans le tableau de bord d'application.

  3. Sur la page Add a destination (Ajouter une destination), choisissez Select from your streams (Choisissez parmi vos flux). Choisissez ensuite le flux ExampleOutputStream que vous avez créé dans la section précédente.

    Maintenant, vous disposez d’une destination externe où Amazon Kinesis Data Analytics conserve tous les enregistrements que votre application écrit dans le flux intégré à l’application DESTINATION_SQL_STREAM.

  4. Vous pouvez configurer AWS Lambda le cas échéant pour surveiller le flux ExampleOutputStream et vous envoyer des alertes. Pour de plus amples informations, veuillez consulter Utilisation d'une fonction Lambda en tant que sortie. Vous pouvez également vérifier les enregistrements écrits par Kinesis Data Analytics dans la destination externe, qui est le flux Kinesis ExampleOutputStream, comme décrit dans Étape 4 : Vérifier la sortie de l'application.

Étape suivante

Étape 4 : Vérifier la sortie de l'application