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 le autorizzazioni di accesso, scegli Crea/aggiorna ruolo. IAM kinesis-analytics-MyApplication-us-west-2

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 IAM ruolo kinesis-analytics-MyApplication-us-west-2.

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.

Per modificare la IAM policy per aggiungere le autorizzazioni del bucket S3

1. Apri la console all'IAMindirizzo. 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 JSONscheda.

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