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.
Travailler avec l'SQLéditeur
Vous trouverez ci-dessous des informations sur les sections de l'SQLéditeur et leur fonctionnement. Dans l'SQLéditeur, vous pouvez créer vous-même votre propre code ou choisir Ajouter SQL à partir de modèles. Un SQL modèle fournit un exemple de SQL code qui peut vous aider à écrire des applications Amazon Kinesis Data Analytics courantes. Les exemples d'applications de ce guide utilisent certains de ces modèles. Pour de plus amples informations, veuillez consulter Exemples de Kinesis Data Analytics pour SQL.
Onglet Source Data
L'onglet Source data identifie une source de streaming. Il identifie également le flux d'entrée intégré à l'application auquel celle-ci est mappée et fournit la configuration d'entrée de l'application.
Amazon Kinesis Data Analytics fournit les colonnes d’horodatage suivantes. Vous n’avez donc pas besoin d’indiquer un mappage explicite dans votre configuration d’entrée :
-
ROWTIME— Chaque ligne d'un flux intégré à l'application possède une colonne spéciale appelée
ROWTIME. Cette colonne est l’horodatage du moment où Kinesis Data Analytics a inséré la ligne dans le premier flux intégré à l’application. -
Approximate_Arrival_Time : les enregistrements de votre source de streaming incluent la colonne
Approximate_Arrival_Timestamp. Il s’agit de l’horodatage d’arrivée approximatif défini lorsque la source de streaming reçoit et stocke l’enregistrement associé avec succès. Kinesis Data Analytics extrait cette colonne et l’insère dans le flux d’entrée intégré à l’application en tant que valeurApproximate_Arrival_Time. Amazon Kinesis Data Analytics fournit cette colonne uniquement dans le flux d’entrée intégré à l’application qui est mappé à la source de streaming.
Ces valeurs d'horodatage sont utiles dans les requêtes à fenêtres temporelles. Pour de plus amples informations, veuillez consulter Requêtes à fenêtres.
Onglet Real-Time Analytics
L'onglet Real-time analytics affiche tous les flux intégrés à l'application créés par votre code d'application. Ce groupe de flux inclut également le flux d’erreurs (error_stream) qu’Amazon Kinesis Data Analytics fournit pour toutes les applications.
Onglet Destination
L'onglet Destination vous permet de configurer la sortie de l'application pour conserver les flux intégrés à l'application dans des destinations externes. Vous pouvez configurer la sortie pour conserver les données de n'importe quel flux intégré à l'application dans des destinations externes. Pour de plus amples informations, veuillez consulter Configuration de la sortie d'application.
