Anteriormente, o Amazon Managed Service for Apache Flink era conhecido como Amazon Kinesis Data Analytics for Apache Flink.
As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.
Crie e execute o aplicativo (console)
Siga estas etapas para criar, configurar, atualizar e executar o aplicativo usando o console.
Criar o aplicativo
Abra o console do Managed Service for Apache Flink em /flink https://console.aws.amazon.com
-
No painel do Managed Service for Apache Flink, selecione Criar aplicativo de análise.
-
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.
-
Mantenha a versão como Apache Flink versão 1.19.1.
-
-
Para permissões de acesso, escolha Criar/atualizar IAM função
kinesis-analytics-MyApplication-us-west-2
. -
Selecione Create application (Criar aplicativo).
nota
Ao criar um serviço gerenciado para o aplicativo Apache Flink usando o console, você tem a opção de criar uma IAM função e uma política para seu aplicativo. O aplicativo usa essa função e política para acessar os recursos dependentes. Esses IAM recursos são nomeados usando o nome do aplicativo e a região da seguinte forma:
-
Política:
kinesis-analytics-service-
MyApplication
-us-west-2
-
Função:
kinesisanalytics-
MyApplication
-us-west-2
Configurar o aplicativo
Siga o procedimento a seguir para configurar o aplicativo.
Configurar o aplicativo
-
Na MyApplicationpágina, escolha Configurar.
-
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.
.
-
-
Em Acesso aos recursos do aplicativo, para permissões de acesso, escolha Criar/atualizar IAM função
kinesis-analytics-MyApplication-us-west-2
. -
Em Propriedades, selecione Adicionar grupo.
-
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).
Em Propriedades, selecione Adicionar grupo novamente.
Insira o seguinte:
ID do grupo Chave Valor ProducerConfigProperties
output.stream.name
ExampleOutputStream
ProducerConfigProperties
aws.region
us-west-2
-
Em Monitoramento, confirme se Nível de monitoramento de métricas está definido como Aplicativo.
-
Para CloudWatch registrar, escolha a caixa de seleção Ativar.
-
Selecione Atualizar.
nota
Quando você opta por ativar o CloudWatch registro na Amazon, o Managed Service for Apache Flink cria um grupo de logs e um stream de logs para você. Os nomes desses recursos são os seguintes:
-
Grupo de logs:
/aws/kinesis-analytics/MyApplication
-
Fluxo de logs:
kinesis-analytics-log-stream
Edite a IAM política
Edite a IAM política para adicionar permissões para acessar o bucket do Amazon S3.
Para editar a IAM política para adicionar permissões de bucket do S3
Abra o IAM console em https://console.aws.amazon.com/iam/
. -
Selecione Policies (Políticas). Selecione a política
kinesis-analytics-service-MyApplication-us-west-2
que o console criou para você na seção anterior. -
Na página Summary (Resumo), selecione Edit policy (Editar política). Escolha a JSONguia.
-
Adicione a seção destacada do exemplo de política a seguir à política. Substitua a conta de amostra IDs (
012345678901
) com o ID da sua conta.{ "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" } ] }
Execute o aplicativo
O gráfico de tarefas do Flink pode ser visualizado executando o aplicativo, abrindo o painel do Apache Flink e selecionando a tarefa desejada do Flink.
Pare o aplicativo
Para interromper o aplicativo, na MyApplicationpágina, escolha Parar. Confirme a ação.