Configuration de la sortie d'application - Manuel du développeur des applications Amazon Kinesis Data Analytics pour SQL

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

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

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

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.

Configuration de la sortie d'application

Dans le code de votre application, vous écrivez la sortie d'instructions SQL dans un ou plusieurs flux intégrés à l'application. Vous pouvez éventuellement ajouter une configuration de sortie à votre application pour conserver tout ce qui est écrit dans un flux intégré à l'application vers une destination externe, telle qu'un flux de données Amazon Kinesis, un flux de diffusion Firehose ou une fonction. AWS Lambda

Le nombre de destinations externes que vous pouvez utiliser pour conserver la sortie d'une application est limité. Pour de plus amples informations, veuillez consulter Limites.

Note

Nous vous recommandons d'utiliser une destination externe pour conserver les données du flux d'erreurs intégré à l'application pour pouvoir examiner les erreurs.

Dans chacune de ces configurations de sortie, vous fournissez les éléments suivants :

  • Nom du flux intégré à l'application : flux que vous souhaitez conserver dans une destination externe.

    Kinesis Data Analytics recherche le flux intégré à l’application que vous avez spécifié dans la configuration de sortie. (Le nom du flux est sensible à la casse et doit correspondre exactement). Assurez-vous que votre code d'application crée ce flux intégré à l'application.

  • Destination externe : vous pouvez conserver les données dans un flux de données Kinesis, un flux de diffusion Firehose ou une fonction Lambda. Vous fournissez le nom Amazon Resource Name (ARN) du flux ou de la fonction. Vous pouvez également fournir un rôle IAM que Kinesis Data Analytics peut endosser pour écrire dans le flux ou la fonction en votre nom. Vous décrivez également le format d’enregistrement (JSON, CSV) que Kinesis Data Analytics doit utiliser lors de l’écriture dans la destination externe.

Si Kinesis Data Analytics ne peut pas écrire dans la destination de streaming ou Lambda, il continue d’essayer indéfiniment. Cela crée une pression de retour qui peut amener votre application à prendre du retard. Si ce problème n'est pas résolu, votre application finira par arrêter de traiter de nouvelles données. Vous pouvez surveiller les Métriques de données Kinesis Analytics et définir des alarmes d'échec. Pour plus d'informations sur les métriques et les alarmes, consultez les sections Utilisation d'Amazon CloudWatch Metrics et Création d' CloudWatchalarmes Amazon.

Vous pouvez configurer la sortie d'application à l'aide de l' AWS Management Console. La console effectue l'appel d'API pour enregistrer la configuration.

Création d'une sortie à l'aide du AWS CLI

Cette section explique comment créer la section Outputs du corps de la requête pour une opération CreateApplication ou AddApplicationOutput.

Création d’une sortie de flux Kinesis

Le fragment JSON suivant montre la section Outputs dans le corps de la requête CreateApplication qui permet de créer une destination de flux de données Amazon Kinesis.

"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisStreamsOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]

Création d'une sortie Firehose Delivery Stream

Le fragment JSON suivant montre la Outputs section du corps de la CreateApplication demande permettant de créer une destination de flux de diffusion Amazon Data Firehose.

"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisFirehoseOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]

Création d’une sortie de fonction Lambda

Le fragment JSON suivant montre la Outputs section du corps de la CreateApplication demande permettant de créer une destination de AWS Lambda fonction.

"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "LambdaOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]