Crea ed esegui l'applicazione (console)

1. Apri la console Managed Service for Apache Flink all'indirizzo /flink https://console.aws.amazon.com

2. Nella dashboard del servizio gestito per Apache Flink, scegli Crea un'applicazione di analisi.

3. Nella pagina Servizio gestito per Apache Flink: crea applicazione, fornisci i dettagli dell'applicazione nel modo seguente:

   • Per Nome applicazione, immetti MyApplication.

   • Per Descrizione, inserisci My scala test app.

   • Per Runtime, scegli Apache Flink.

   • Mantieni la versione di Apache Flink 1.19.1.

4. Per Autorizzazioni di accesso, scegli Crea/aggiorna kinesis-analytics-MyApplication-us-west-2 per il ruolo IAM.

5. Scegli Crea applicazione.

Per configurare l'applicazione

1. Nella MyApplicationpagina, scegli Configura.

2. Nella pagina Configura applicazione, fornisci la Posizione del codice:

   • Per Bucket Amazon S3, inserisci ka-app-code-<username>.

   • Per Percorso dell'oggetto Amazon S3, inserisci getting-started-scala-1.0.jar.

3. In Accesso alle risorse dell'applicazione, per Autorizzazioni di accesso, scegli Crea/aggiorna kinesis-analytics-MyApplication-us-west-2 per il ruolo IAM.

4. In Proprietà, scegli Aggiungi gruppo.

5. Immetti i seguenti dati:

   ID gruppo	Chiave	Valore
   ConsumerConfigProperties	input.stream.name	ExampleInputStream
   ConsumerConfigProperties	aws.region	us-west-2
   ConsumerConfigProperties	flink.stream.initpos	LATEST

   Seleziona Salva.

6. In Proprietà, scegli di nuovo Aggiungi gruppo.

7. Immetti i seguenti dati:

   ID gruppo	Chiave	Valore
   ProducerConfigProperties	output.stream.name	ExampleOutputStream
   ProducerConfigProperties	aws.region	us-west-2

8. In Monitoraggio, accertati che il Monitoraggio del livello dei parametri sia impostato su Applicazione.

9. Per la CloudWatch registrazione, seleziona la casella di controllo Abilita.

10. Scegli Aggiorna.

Modifica della policy IAM per aggiungere le autorizzazioni per i bucket S3

1. Aprire la console IAM all'indirizzo https://console.aws.amazon.com/iam/.

2. Seleziona Policy. Scegli la policy kinesis-analytics-service-MyApplication-us-west-2 creata dalla console nella sezione precedente.

3. Nella pagina Riepilogo, scegli Modifica policy. Scegli la scheda JSON.

4. Aggiungi alla policy la sezione evidenziata del seguente esempio di policy. Sostituisci l'account di esempio IDs (012345678901) con l'ID del tuo account.

   {
       "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"
           }
       ]
   }