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.
Flux et pompes intégrés à l'application
Lorsque vous configurez l'entrée d'application, vous mappez une source de diffusion à un flux intégré à l'application, qui est créé. Les données arrivent en continu depuis la source de diffusion vers le flux intégré à l'application. Un flux intégré à l'application fonctionne comme une table que vous pouvez interroger à l'aide d'instructions SQL, mais on l'appelle « flux », car il s'agit d'un flux de données en continu.
Note
Ne confondez pas les flux intégrés à l'application avec les flux de données Amazon Kinesis et les flux de diffusion Firehose. Les flux intégrés à l’application n’existent que dans le contexte d’une application Amazon Kinesis Data Analytics. Les flux de données Kinesis et les flux de diffusion Firehose existent indépendamment de votre application. Vous pouvez les configurer comme source de diffusion dans votre configuration d'entrée d'application ou comme destination dans la configuration de sortie.
Vous pouvez également créer autant de flux intégrés à l'application supplémentaires que nécessaire pour stocker des résultats de requête intermédiaires. La création d'un flux intégré à l'application est un processus en deux étapes. D'abord, vous créez un flux intégré à l'application, puis vous pompez des données dans celui-ci. Par exemple, supposons que la configuration d'entrée de votre application crée un flux intégré à l'application appelé INPUTSTREAM. Dans l'exemple suivant, vous créez un autre flux (TEMPSTREAM), puis vous pompez des données depuis INPUTSTREAM dans ce flux.
-
Créez un flux intégré à l'application (
TEMPSTREAM) avec trois colonnes, comme illustré ci-après :CREATE OR REPLACE STREAM "TEMPSTREAM" ( "column1" BIGINT NOT NULL, "column2" INTEGER, "column3" VARCHAR(64));Les noms de colonne sont spécifiés entre guillemets, ce qui les rend sensibles à la casse. Pour plus d’informations, consultez Identificateurs dans le manuel Référence SQL Amazon Kinesis Data Analytics.
-
Insérez des données dans le flux à l'aide d'une pompe. Une pompe est une requête d'insertion s'exécutant en continu qui insère des données d'un flux intégré à l'application vers un autre flux intégré à l'application. L'instruction suivante crée une pompe (
SAMPLEPUMP) et insère des données dans le fluxTEMPSTREAMen sélectionnant des enregistrements d'un autre flux (INPUTSTREAM).CREATE OR REPLACE PUMP "SAMPLEPUMP" AS INSERT INTO "TEMPSTREAM" ("column1", "column2", "column3") SELECT STREAM inputcolumn1, inputcolumn2, inputcolumn3 FROM "INPUTSTREAM";
Plusieurs enregistreurs peuvent effectuer des insertions dans un flux intégré à l'application et plusieurs lecteurs peuvent être sélectionnés depuis le flux. Vous pouvez considérer un flux intégré à l'application comme l'implémentation d'un paradigme de messagerie de publication/abonnement. Dans ce paradigme, la ligne de données, y compris l'heure de création et l'heure de réception, peut être traitée, interprétée et transmise par une cascade d'instructions SQL de diffusion, sans devoir être stockée dans un SGBDR traditionnel.
Après avoir créé un flux intégré à l'application, vous pouvez exécuter des requêtes SQL normales.
Note
Lors de l'interrogation de flux, la plupart des instructions SQL sont bornées à l'aide d'une fenêtre basée sur des lignes ou d'une fenêtre temporelle. Pour de plus amples informations, veuillez consulter Requêtes à fenêtres.
Vous pouvez également joindre des flux. Pour obtenir des exemples de jointure de flux, consultez Opérations de diffusion de données : Jointures de flux.
