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

Suivez ces étapes pour créer, configurer, mettre à jour et exécuter l’application à l’aide de la console.

Pour créer l’application

1. Ouvrez la console du service géré pour Apache Flink à l’adresse https://console.aws.amazon.com/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 Autorisations d’accès, choisissez Créer/mettre à jour un rôle IAM) kinesis-analytics-MyApplication-us-west-2.

5. Choisissez Créer une application.

Note

Lorsque vous créez une application de service géré pour Apache Flink à l’aide de la console, vous avez la possibilité de créer un rôle et une politique IAM pour votre application. Votre application utilise ce rôle et cette politique pour accéder à ses ressources dépendantes. Ces ressources IAM sont nommées en utilisant le nom de votre application et la région, comme suit :

• Stratégie : kinesis-analytics-service-MyApplication-us-west-2

• Rôle : kinesisanalytics-MyApplication-us-west-2

Configuration de l'application

Procédez comme suit pour configurer l’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éder aux ressources de l’application, pour Autorisations d’accès, choisissez Créer/mettre à jour un rôle IAM 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.

Note

Lorsque vous choisissez d'activer la CloudWatch journalisation Amazon, Managed Service for Apache Flink crée un groupe de journaux et un flux de journaux pour vous. Les noms de ces ressources sont les suivants :

• Groupe de journaux : /aws/kinesis-analytics/MyApplication

• Flux de journaux : kinesis-analytics-log-stream

Modifier la politique IAM

Modifiez la politique IAM pour ajouter des autorisations afin d’accéder au compartiment Amazon S3.

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

1. Ouvrez la console IAM à 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. Sélectionnez l’onglet JSON.

4. Ajoutez la section mise en surbrillance dans l’exemple de stratégie suivant à la politique. Remplacez l’exemple d’ID de compte (012345678901) par votre ID 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"
           }
       ]
   }

Exécutez l'application

Le graphique des tâches Flink peut être visualisé en exécutant l’application, en ouvrant le tableau de bord Apache Flink et en choisissant la tâche Flink souhaitée.

Arrêtez l'application

Pour arrêter l'application, sur la MyApplicationpage, choisissez Arrêter. Confirmez l’action.