Crea ed esegui l'applicazione (console)

Segui questi passaggi per creare, configurare, aggiornare ed eseguire l'applicazione utilizzando la console.

Creazione dell'applicazione

1. Apri la console del servizio gestito per Apache Flink all'indirizzo https://console.aws.amazon.com/flink

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 1.19.1 di Apache Flink.

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

5. Scegli Crea applicazione.

Nota

Quando crei un'applicazione del servizio gestito per Apache Flink tramite la console, hai la possibilità di avere un ruolo e una policy IAM creati per l'applicazione. L'applicazione utilizza questo ruolo e questa policy per accedere alle sue risorse dipendenti. Queste risorse IAM sono denominate utilizzando il nome dell'applicazione e la Regione come segue:

• Policy: kinesis-analytics-service-MyApplication-us-west-2

• Ruolo: kinesisanalytics-MyApplication-us-west-2

Configura l'applicazione

Per configurare l'applicazione, utilizza la procedura seguente.

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

   Selezionare 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.

Nota

Quando scegli di abilitare la CloudWatch registrazione di Amazon, Managed Service for Apache Flink crea un gruppo di log e un flusso di log per te. I nomi di tali risorse sono i seguenti:

• Gruppo di log: /aws/kinesis-analytics/MyApplication

• Flusso di log: kinesis-analytics-log-stream

Modifica la policy IAM

Modifica la policy IAM per aggiungere le autorizzazioni per accedere al bucket Amazon S3.

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

1. Apri 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 gli ID account di esempio (012345678901) con il tuo ID 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"
           }
       ]
   }

Esecuzione dell'applicazione.

Il grafico del processo Flink può essere visualizzato eseguendo l'applicazione, aprendo il pannello di controllo di Apache Flink e scegliendo il processo Flink desiderato.

Arresta l'applicazione

Per interrompere l'applicazione, nella MyApplicationpagina, scegli Stop. Conferma l'operazione.