Création et exécution de l'application (console)

1. Ouvrez le service géré pour la console Apache Flink à https://console.aws.amazon.com l'adresse /flink

2. Dans le tableau de bord du service géré pour Apache Flink, choisissez Créer une application d’analyse.

3. Sur la page Service géré pour Apache Flink - Créer une application, fournissez les détails de l’application comme suit :

   • Pour Nom de l’application, saisissez MyApplication.

   • Pour Description, saisissez My scala test app.

   • Pour Exécution, choisissez Apache Flink.

   • Conservez la version 1.19.1 d'Apache Flink.

4. Pour les autorisations d'accès, choisissez Create/update IAM role kinesis-analytics-MyApplication-us-west-2.

5. Choisissez Créer une application.

Pour configurer l’application

1. Sur la MyApplicationpage, choisissez Configurer.

2. Sur la page Configurer l’application, indiquez l’emplacement du code:

   • Pour le compartiment Amazon S3, saisissez ka-app-code-<username>.

   • Pour le chemin de l'objet Amazon S3, saisissez getting-started-scala-1.0.jar..

3. Sous Accès aux ressources de l'application, pour les autorisations d'accès, choisissez Create/update IAM role kinesis-analytics-MyApplication-us-west-2.

4. Sous Propriétés, sélectionnez Ajouter un groupe.

5. Saisissez :

   ID du groupe	Clé	Valeur
   ConsumerConfigProperties	input.stream.name	ExampleInputStream
   ConsumerConfigProperties	aws.region	us-west-2
   ConsumerConfigProperties	flink.stream.initpos	LATEST

   Choisissez Enregistrer.

6. Sous Propriétés, sélectionnez à nouveau Ajouter un groupe.

7. Saisissez :

   ID du groupe	Clé	Valeur
   ProducerConfigProperties	output.stream.name	ExampleOutputStream
   ProducerConfigProperties	aws.region	us-west-2

8. Sous Surveillance, assurez-vous que Surveillance du niveau des métriques est défini sur Application.

9. Pour la CloudWatch journalisation, cochez la case Activer.

10. Choisissez Mettre à jour.

Pour modifier la IAM politique afin d'ajouter des autorisations au compartiment S3

1. Ouvrez la IAM console à l'adresse https://console.aws.amazon.com/iam/.

2. Choisissez Stratégies. Choisissez la politique kinesis-analytics-service-MyApplication-us-west-2 créée pour vous par la console dans la section précédente.

3. Sur la page Récapitulatif, choisissez Modifier la politique. Choisissez l'JSONonglet.

4. Ajoutez la section mise en surbrillance dans l’exemple de stratégie suivant à la politique. Remplacez le compte d'exemple IDs (012345678901) avec votre identifiant de compte.

   {
       "Version": "2012-10-17",
       "Statement": [
           {
               "Sid": "ReadCode",
               "Effect": "Allow",
               "Action": [
                   "s3:GetObject",
                   "s3:GetObjectVersion"
               ],
               "Resource": [
                   "arn:aws:s3:::ka-app-code-username/getting-started-scala-1.0.jar"
               ]
           },
           {
               "Sid": "DescribeLogGroups",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogGroups"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:*"
               ]
           },
           {
               "Sid": "DescribeLogStreams",
               "Effect": "Allow",
               "Action": [
                   "logs:DescribeLogStreams"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:*"
               ]
           },
           {
               "Sid": "PutLogEvents",
               "Effect": "Allow",
               "Action": [
                   "logs:PutLogEvents"
               ],
               "Resource": [
                   "arn:aws:logs:us-west-2:012345678901:log-group:/aws/kinesis-analytics/MyApplication:log-stream:kinesis-analytics-log-stream"
               ]
           },
           {
               "Sid": "ReadInputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleInputStream"
           },
           {
               "Sid": "WriteOutputStream",
               "Effect": "Allow",
               "Action": "kinesis:*",
               "Resource": "arn:aws:kinesis:us-west-2:012345678901:stream/ExampleOutputStream"
           }
       ]
   }