Crie e execute o aplicativo (console)

1. Faça login no Console de gerenciamento da AWS e abra o console do Amazon MSF em https://console.aws.amazon.com/flink.

2. No painel do Managed Service for Apache Flink, selecione Criar aplicativo de analytics.

3. Na página Managed Service for Apache Flink - Criar aplicativo, forneça os detalhes do aplicativo da seguinte forma:

   • Em Nome do aplicativo, insira MyApplication.

   • Em Descrição, insira My scala test app.

   • Em Runtime, selecione Apache Flink.

   • Deixe a versão como Apache Flink versão 1.19.1.

4. Em Permissões de acesso, selecione Criar/atualizar o perfil do IAM kinesis-analytics-MyApplication-us-west-2.

5. Selecione Create application (Criar aplicativo).

Configurar o aplicativo

1. Na página MyApplication, selecione Configure (Configurar).

2. Na página Configurar aplicativo, forneça o Local do código:

   • Em Bucket do Amazon S3, insira ka-app-code-<username>.

   • Em Caminho do objeto do Amazon S3, insira getting-started-scala-1.0.jar..

3. Na seção Acesso aos recursos do aplicativo, em Permissões de acesso, selecione Criar/atualizar o perfil do IAM kinesis-analytics-MyApplication-us-west-2.

4. Em Propriedades, selecione Adicionar grupo.

5. Insira o seguinte:

   ID do grupo	Chave	Valor
   ConsumerConfigProperties	input.stream.name	ExampleInputStream
   ConsumerConfigProperties	aws.region	us-west-2
   ConsumerConfigProperties	flink.stream.initpos	LATEST

   Selecione Save (Salvar).

6. Em Propriedades, selecione Adicionar grupo novamente.

7. Insira o seguinte:

   ID do grupo	Chave	Valor
   ProducerConfigProperties	output.stream.name	ExampleOutputStream
   ProducerConfigProperties	aws.region	us-west-2

8. Em Monitoramento, confirme se Nível de monitoramento de métricas está definido como Aplicativo.

9. Em CloudWatch logging, marque a caixa de seleção Habilitar.

10. Selecione Atualizar.

Editar a política do IAM para adicionar permissões do bucket do S3

1. Abra o console do IAM em https://console.aws.amazon.com/iam/.

2. Selecione Políticas. Selecione a política kinesis-analytics-service-MyApplication-us-west-2 que o console criou na seção anterior.

3. Na página Resumo, selecione Editar política. Selecione a guia JSON.

4. Adicione a seção destacada do exemplo de política a seguir à política. Substitua os exemplos de IDs de conta (012345678901) pelo ID da conta.

   JSON

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