Procédure
- Pour lire des données d'un flux Kinesis, ajoutez un composant tKinesisInput et connectez le composant tRowGenerator à celui-ci à l'aide d'un lien InParallel.
- Dans la vue Basic settings du composant tKinesisInput, fournissez vos informations d'authentification à Amazon.
- Saisissez le nom de votre flux Kinesis et l'URL de l'endpoint correspondant.
- Sélectionnez l'option Explicitly set authentication parameters et saisissez votre Région, comme mentionné dans Points de terminaison de service AWS.
-
Ajoutez un composant tReplicate et connectez-le au tKinesisInput.
L'objectif du composant tReplicate est d'avoir un composant de traitement dans le Job. Sinon, l'exécution du Job échoue. Le tReplicate permet au Job de compiler sans modifier les données.
-
Ajoutez un composant tExtractDelimitedFields et reliez-le au composant tReplicate.
Le tExtractDelimitedFields extrait les données du message sérialisé généré par le composant tKinesisInput.
- Ajoutez un tLogRow pour afficher la sortie dans la console et, dans sa vue Basic settings, sélectionnez Table (print values in cells of a table) pour afficher les données sous forme de table.